public class org.springframework.messaging.simp.config.SimpleBrokerRegistration extends org.springframework.messaging.simp.config.AbstractBrokerRegistration
{
private org.springframework.scheduling.TaskScheduler taskScheduler;
private long[] heartbeat;
private java.lang.String selectorHeaderName;
public void <init>(org.springframework.messaging.SubscribableChannel, org.springframework.messaging.MessageChannel, java.lang.String[])
{
org.springframework.messaging.simp.config.SimpleBrokerRegistration v;
org.springframework.messaging.SubscribableChannel v;
java.lang.String[] v;
org.springframework.messaging.MessageChannel v;
v := @this: org.springframework.messaging.simp.config.SimpleBrokerRegistration;
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.SimpleBrokerRegistration: java.lang.String selectorHeaderName> = "selector";
return;
}
public org.springframework.messaging.simp.config.SimpleBrokerRegistration setTaskScheduler(org.springframework.scheduling.TaskScheduler)
{
org.springframework.scheduling.TaskScheduler v;
org.springframework.messaging.simp.config.SimpleBrokerRegistration v;
v := @this: org.springframework.messaging.simp.config.SimpleBrokerRegistration;
v := @parameter: org.springframework.scheduling.TaskScheduler;
v.<org.springframework.messaging.simp.config.SimpleBrokerRegistration: org.springframework.scheduling.TaskScheduler taskScheduler> = v;
return v;
}
public org.springframework.messaging.simp.config.SimpleBrokerRegistration setHeartbeatValue(long[])
{
long[] v;
org.springframework.messaging.simp.config.SimpleBrokerRegistration v;
v := @this: org.springframework.messaging.simp.config.SimpleBrokerRegistration;
v := @parameter: long[];
v.<org.springframework.messaging.simp.config.SimpleBrokerRegistration: long[] heartbeat> = v;
return v;
}
public void setSelectorHeaderName(java.lang.String)
{
java.lang.String v;
org.springframework.messaging.simp.config.SimpleBrokerRegistration v;
v := @this: org.springframework.messaging.simp.config.SimpleBrokerRegistration;
v := @parameter: java.lang.String;
v.<org.springframework.messaging.simp.config.SimpleBrokerRegistration: java.lang.String selectorHeaderName> = v;
return;
}
protected org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler getMessageHandler(org.springframework.messaging.SubscribableChannel)
{
java.util.Collection v;
org.springframework.messaging.SubscribableChannel v, v;
org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler v;
org.springframework.scheduling.TaskScheduler v, v;
org.springframework.messaging.MessageChannel v;
long[] v, v;
org.springframework.messaging.simp.config.SimpleBrokerRegistration v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.config.SimpleBrokerRegistration;
v := @parameter: org.springframework.messaging.SubscribableChannel;
v = new org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler;
v = virtualinvoke v.<org.springframework.messaging.simp.config.SimpleBrokerRegistration: org.springframework.messaging.SubscribableChannel getClientInboundChannel()>();
v = virtualinvoke v.<org.springframework.messaging.simp.config.SimpleBrokerRegistration: org.springframework.messaging.MessageChannel getClientOutboundChannel()>();
v = virtualinvoke v.<org.springframework.messaging.simp.config.SimpleBrokerRegistration: java.util.Collection getDestinationPrefixes()>();
specialinvoke v.<org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler: 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.SimpleBrokerRegistration: org.springframework.scheduling.TaskScheduler taskScheduler>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.SimpleBrokerRegistration: org.springframework.scheduling.TaskScheduler taskScheduler>;
virtualinvoke v.<org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler: void setTaskScheduler(org.springframework.scheduling.TaskScheduler)>(v);
label:
v = v.<org.springframework.messaging.simp.config.SimpleBrokerRegistration: long[] heartbeat>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.SimpleBrokerRegistration: long[] heartbeat>;
virtualinvoke v.<org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler: void setHeartbeatValue(long[])>(v);
label:
v = v.<org.springframework.messaging.simp.config.SimpleBrokerRegistration: java.lang.String selectorHeaderName>;
virtualinvoke v.<org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler: void setSelectorHeaderName(java.lang.String)>(v);
return v;
}
}