public abstract class org.springframework.messaging.simp.config.AbstractBrokerRegistration extends java.lang.Object
{
private final org.springframework.messaging.SubscribableChannel clientInboundChannel;
private final org.springframework.messaging.MessageChannel clientOutboundChannel;
private final java.util.List destinationPrefixes;
public void <init>(org.springframework.messaging.SubscribableChannel, org.springframework.messaging.MessageChannel, java.lang.String[])
{
java.util.List v;
org.springframework.messaging.SubscribableChannel v;
java.lang.String[] v;
org.springframework.messaging.MessageChannel v;
org.springframework.messaging.simp.config.AbstractBrokerRegistration v;
v := @this: org.springframework.messaging.simp.config.AbstractBrokerRegistration;
v := @parameter: org.springframework.messaging.SubscribableChannel;
v := @parameter: org.springframework.messaging.MessageChannel;
v := @parameter: java.lang.String[];
specialinvoke v.<java.lang.Object: void <init>()>();
staticinvoke <org.springframework.util.Assert: void notNull(java.lang.Object,java.lang.String)>(v, "\'clientInboundChannel\' must not be null");
staticinvoke <org.springframework.util.Assert: void notNull(java.lang.Object,java.lang.String)>(v, "\'clientOutboundChannel\' must not be null");
v.<org.springframework.messaging.simp.config.AbstractBrokerRegistration: org.springframework.messaging.SubscribableChannel clientInboundChannel> = v;
v.<org.springframework.messaging.simp.config.AbstractBrokerRegistration: org.springframework.messaging.MessageChannel clientOutboundChannel> = v;
if v == null goto label;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
goto label;
label:
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
label:
v.<org.springframework.messaging.simp.config.AbstractBrokerRegistration: java.util.List destinationPrefixes> = v;
return;
}
protected org.springframework.messaging.SubscribableChannel getClientInboundChannel()
{
org.springframework.messaging.SubscribableChannel v;
org.springframework.messaging.simp.config.AbstractBrokerRegistration v;
v := @this: org.springframework.messaging.simp.config.AbstractBrokerRegistration;
v = v.<org.springframework.messaging.simp.config.AbstractBrokerRegistration: org.springframework.messaging.SubscribableChannel clientInboundChannel>;
return v;
}
protected org.springframework.messaging.MessageChannel getClientOutboundChannel()
{
org.springframework.messaging.MessageChannel v;
org.springframework.messaging.simp.config.AbstractBrokerRegistration v;
v := @this: org.springframework.messaging.simp.config.AbstractBrokerRegistration;
v = v.<org.springframework.messaging.simp.config.AbstractBrokerRegistration: org.springframework.messaging.MessageChannel clientOutboundChannel>;
return v;
}
protected java.util.Collection getDestinationPrefixes()
{
java.util.List v;
org.springframework.messaging.simp.config.AbstractBrokerRegistration v;
v := @this: org.springframework.messaging.simp.config.AbstractBrokerRegistration;
v = v.<org.springframework.messaging.simp.config.AbstractBrokerRegistration: java.util.List destinationPrefixes>;
return v;
}
protected abstract org.springframework.messaging.simp.broker.AbstractBrokerMessageHandler getMessageHandler(org.springframework.messaging.SubscribableChannel);
}