public class org.springframework.messaging.simp.config.StompBrokerRelayRegistration extends org.springframework.messaging.simp.config.AbstractBrokerRegistration
{
private java.lang.String relayHost;
private int relayPort;
private java.lang.String clientLogin;
private java.lang.String clientPasscode;
private java.lang.String systemLogin;
private java.lang.String systemPasscode;
private java.lang.Long systemHeartbeatSendInterval;
private java.lang.Long systemHeartbeatReceiveInterval;
private java.lang.String virtualHost;
private org.springframework.messaging.tcp.TcpOperations tcpClient;
private boolean autoStartup;
private java.lang.String userDestinationBroadcast;
private java.lang.String userRegistryBroadcast;
public void <init>(org.springframework.messaging.SubscribableChannel, org.springframework.messaging.MessageChannel, java.lang.String[])
{
int v;
org.springframework.messaging.SubscribableChannel v;
java.lang.String[] v;
org.springframework.messaging.MessageChannel v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: org.springframework.messaging.SubscribableChannel;
v := @parameter: org.springframework.messaging.MessageChannel;
v := @parameter: java.lang.String[];
specialinvoke v.<org.springframework.messaging.simp.config.AbstractBrokerRegistration: void <init>(org.springframework.messaging.SubscribableChannel,org.springframework.messaging.MessageChannel,java.lang.String[])>(v, v, v);
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String relayHost> = "127.0.0.1";
v = (int) 61613;
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: int relayPort> = v;
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String clientLogin> = "guest";
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String clientPasscode> = "guest";
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String systemLogin> = "guest";
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String systemPasscode> = "guest";
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: boolean autoStartup> = 1;
return;
}
public org.springframework.messaging.simp.config.StompBrokerRelayRegistration setRelayHost(java.lang.String)
{
java.lang.String v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: java.lang.String;
staticinvoke <org.springframework.util.Assert: void hasText(java.lang.String,java.lang.String)>(v, "relayHost must not be empty");
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String relayHost> = v;
return v;
}
public org.springframework.messaging.simp.config.StompBrokerRelayRegistration setRelayPort(int)
{
int v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: int;
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: int relayPort> = v;
return v;
}
public org.springframework.messaging.simp.config.StompBrokerRelayRegistration setClientLogin(java.lang.String)
{
java.lang.String v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: java.lang.String;
staticinvoke <org.springframework.util.Assert: void hasText(java.lang.String,java.lang.String)>(v, "clientLogin must not be empty");
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String clientLogin> = v;
return v;
}
public org.springframework.messaging.simp.config.StompBrokerRelayRegistration setClientPasscode(java.lang.String)
{
java.lang.String v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: java.lang.String;
staticinvoke <org.springframework.util.Assert: void hasText(java.lang.String,java.lang.String)>(v, "clientPasscode must not be empty");
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String clientPasscode> = v;
return v;
}
public org.springframework.messaging.simp.config.StompBrokerRelayRegistration setSystemLogin(java.lang.String)
{
java.lang.String v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: java.lang.String;
staticinvoke <org.springframework.util.Assert: void hasText(java.lang.String,java.lang.String)>(v, "systemLogin must not be empty");
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String systemLogin> = v;
return v;
}
public org.springframework.messaging.simp.config.StompBrokerRelayRegistration setSystemPasscode(java.lang.String)
{
java.lang.String v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: java.lang.String;
staticinvoke <org.springframework.util.Assert: void hasText(java.lang.String,java.lang.String)>(v, "systemPasscode must not be empty");
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String systemPasscode> = v;
return v;
}
public org.springframework.messaging.simp.config.StompBrokerRelayRegistration setSystemHeartbeatSendInterval(long)
{
long v;
java.lang.Long v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: long;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.Long systemHeartbeatSendInterval> = v;
return v;
}
public org.springframework.messaging.simp.config.StompBrokerRelayRegistration setSystemHeartbeatReceiveInterval(long)
{
long v;
java.lang.Long v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: long;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.Long systemHeartbeatReceiveInterval> = v;
return v;
}
public org.springframework.messaging.simp.config.StompBrokerRelayRegistration setVirtualHost(java.lang.String)
{
java.lang.String v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: java.lang.String;
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String virtualHost> = v;
return v;
}
public void setTcpClient(org.springframework.messaging.tcp.TcpOperations)
{
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
org.springframework.messaging.tcp.TcpOperations v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: org.springframework.messaging.tcp.TcpOperations;
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: org.springframework.messaging.tcp.TcpOperations tcpClient> = v;
return;
}
public org.springframework.messaging.simp.config.StompBrokerRelayRegistration setAutoStartup(boolean)
{
boolean v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: boolean;
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: boolean autoStartup> = v;
return v;
}
public org.springframework.messaging.simp.config.StompBrokerRelayRegistration setUserDestinationBroadcast(java.lang.String)
{
java.lang.String v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: java.lang.String;
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String userDestinationBroadcast> = v;
return v;
}
protected java.lang.String getUserDestinationBroadcast()
{
java.lang.String v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String userDestinationBroadcast>;
return v;
}
public org.springframework.messaging.simp.config.StompBrokerRelayRegistration setUserRegistryBroadcast(java.lang.String)
{
java.lang.String v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: java.lang.String;
v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String userRegistryBroadcast> = v;
return v;
}
protected java.lang.String getUserRegistryBroadcast()
{
java.lang.String v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String userRegistryBroadcast>;
return v;
}
protected org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler getMessageHandler(org.springframework.messaging.SubscribableChannel)
{
org.springframework.messaging.SubscribableChannel v, v;
long v, v;
org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler v;
org.springframework.messaging.tcp.TcpOperations v, v;
java.lang.Long v, v, v, v;
int v;
java.lang.String v, v, v, v, v, v, v;
boolean v;
java.util.Collection v;
org.springframework.messaging.MessageChannel v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
v := @this: org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v := @parameter: org.springframework.messaging.SubscribableChannel;
v = new org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler;
v = virtualinvoke v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: org.springframework.messaging.SubscribableChannel getClientInboundChannel()>();
v = virtualinvoke v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: org.springframework.messaging.MessageChannel getClientOutboundChannel()>();
v = virtualinvoke v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.util.Collection getDestinationPrefixes()>();
specialinvoke v.<org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler: void <init>(org.springframework.messaging.SubscribableChannel,org.springframework.messaging.MessageChannel,org.springframework.messaging.SubscribableChannel,java.util.Collection)>(v, v, v, v);
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String relayHost>;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler: void setRelayHost(java.lang.String)>(v);
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: int relayPort>;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler: void setRelayPort(int)>(v);
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String clientLogin>;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler: void setClientLogin(java.lang.String)>(v);
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String clientPasscode>;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler: void setClientPasscode(java.lang.String)>(v);
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String systemLogin>;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler: void setSystemLogin(java.lang.String)>(v);
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String systemPasscode>;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler: void setSystemPasscode(java.lang.String)>(v);
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.Long systemHeartbeatSendInterval>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.Long systemHeartbeatSendInterval>;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler: void setSystemHeartbeatSendInterval(long)>(v);
label:
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.Long systemHeartbeatReceiveInterval>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.Long systemHeartbeatReceiveInterval>;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler: void setSystemHeartbeatReceiveInterval(long)>(v);
label:
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String virtualHost>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String virtualHost>;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler: void setVirtualHost(java.lang.String)>(v);
label:
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: org.springframework.messaging.tcp.TcpOperations tcpClient>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: org.springframework.messaging.tcp.TcpOperations tcpClient>;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler: void setTcpClient(org.springframework.messaging.tcp.TcpOperations)>(v);
label:
v = v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: boolean autoStartup>;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler: void setAutoStartup(boolean)>(v);
return v;
}
}