public class org.springframework.messaging.simp.config.MessageBrokerRegistry extends java.lang.Object
{
private final org.springframework.messaging.SubscribableChannel clientInboundChannel;
private final org.springframework.messaging.MessageChannel clientOutboundChannel;
private org.springframework.messaging.simp.config.SimpleBrokerRegistration simpleBrokerRegistration;
private org.springframework.messaging.simp.config.StompBrokerRelayRegistration brokerRelayRegistration;
private final org.springframework.messaging.simp.config.ChannelRegistration brokerChannelRegistration;
private java.lang.String[] applicationDestinationPrefixes;
private java.lang.String userDestinationPrefix;
private org.springframework.util.PathMatcher pathMatcher;
private java.lang.Integer cacheLimit;
public void <init>(org.springframework.messaging.SubscribableChannel, org.springframework.messaging.MessageChannel)
{
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
org.springframework.messaging.simp.config.ChannelRegistration v;
org.springframework.messaging.SubscribableChannel v;
org.springframework.messaging.MessageChannel v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v := @parameter: org.springframework.messaging.SubscribableChannel;
v := @parameter: org.springframework.messaging.MessageChannel;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.springframework.messaging.simp.config.ChannelRegistration;
specialinvoke v.<org.springframework.messaging.simp.config.ChannelRegistration: void <init>()>();
v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.ChannelRegistration brokerChannelRegistration> = v;
staticinvoke <org.springframework.util.Assert: void notNull(java.lang.Object,java.lang.String)>(v, "Inbound channel must not be null");
staticinvoke <org.springframework.util.Assert: void notNull(java.lang.Object,java.lang.String)>(v, "Outbound channel must not be null");
v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.SubscribableChannel clientInboundChannel> = v;
v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.MessageChannel clientOutboundChannel> = v;
return;
}
public transient org.springframework.messaging.simp.config.SimpleBrokerRegistration enableSimpleBroker(java.lang.String[])
{
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
org.springframework.messaging.simp.config.SimpleBrokerRegistration v, v;
org.springframework.messaging.SubscribableChannel v;
java.lang.String[] v;
org.springframework.messaging.MessageChannel v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v := @parameter: java.lang.String[];
v = new org.springframework.messaging.simp.config.SimpleBrokerRegistration;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.SubscribableChannel clientInboundChannel>;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.MessageChannel clientOutboundChannel>;
specialinvoke v.<org.springframework.messaging.simp.config.SimpleBrokerRegistration: void <init>(org.springframework.messaging.SubscribableChannel,org.springframework.messaging.MessageChannel,java.lang.String[])>(v, v, v);
v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.SimpleBrokerRegistration simpleBrokerRegistration> = v;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.SimpleBrokerRegistration simpleBrokerRegistration>;
return v;
}
public transient org.springframework.messaging.simp.config.StompBrokerRelayRegistration enableStompBrokerRelay(java.lang.String[])
{
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
org.springframework.messaging.SubscribableChannel v;
java.lang.String[] v;
org.springframework.messaging.MessageChannel v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v, v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v := @parameter: java.lang.String[];
v = new org.springframework.messaging.simp.config.StompBrokerRelayRegistration;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.SubscribableChannel clientInboundChannel>;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.MessageChannel clientOutboundChannel>;
specialinvoke v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: void <init>(org.springframework.messaging.SubscribableChannel,org.springframework.messaging.MessageChannel,java.lang.String[])>(v, v, v);
v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.StompBrokerRelayRegistration brokerRelayRegistration> = v;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.StompBrokerRelayRegistration brokerRelayRegistration>;
return v;
}
public org.springframework.messaging.simp.config.ChannelRegistration configureBrokerChannel()
{
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
org.springframework.messaging.simp.config.ChannelRegistration v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.ChannelRegistration brokerChannelRegistration>;
return v;
}
protected org.springframework.messaging.simp.config.ChannelRegistration getBrokerChannelRegistration()
{
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
org.springframework.messaging.simp.config.ChannelRegistration v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.ChannelRegistration brokerChannelRegistration>;
return v;
}
protected java.lang.String getUserDestinationBroadcast()
{
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
java.lang.String v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v, v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.StompBrokerRelayRegistration brokerRelayRegistration>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.StompBrokerRelayRegistration brokerRelayRegistration>;
v = virtualinvoke v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String getUserDestinationBroadcast()>();
goto label;
label:
v = null;
label:
return v;
}
protected java.lang.String getUserRegistryBroadcast()
{
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
java.lang.String v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v, v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.StompBrokerRelayRegistration brokerRelayRegistration>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.StompBrokerRelayRegistration brokerRelayRegistration>;
v = virtualinvoke v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: java.lang.String getUserRegistryBroadcast()>();
goto label;
label:
v = null;
label:
return v;
}
public transient org.springframework.messaging.simp.config.MessageBrokerRegistry setApplicationDestinationPrefixes(java.lang.String[])
{
java.lang.String[] v;
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v := @parameter: java.lang.String[];
v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: java.lang.String[] applicationDestinationPrefixes> = v;
return v;
}
protected java.util.Collection getApplicationDestinationPrefixes()
{
java.util.List v;
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
java.lang.String[] v, v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: java.lang.String[] applicationDestinationPrefixes>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: java.lang.String[] applicationDestinationPrefixes>;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
goto label;
label:
v = null;
label:
return v;
}
public org.springframework.messaging.simp.config.MessageBrokerRegistry setUserDestinationPrefix(java.lang.String)
{
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v := @parameter: java.lang.String;
v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: java.lang.String userDestinationPrefix> = v;
return v;
}
protected java.lang.String getUserDestinationPrefix()
{
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: java.lang.String userDestinationPrefix>;
return v;
}
public org.springframework.messaging.simp.config.MessageBrokerRegistry setPathMatcher(org.springframework.util.PathMatcher)
{
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
org.springframework.util.PathMatcher v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v := @parameter: org.springframework.util.PathMatcher;
v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.util.PathMatcher pathMatcher> = v;
return v;
}
protected org.springframework.util.PathMatcher getPathMatcher()
{
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
org.springframework.util.PathMatcher v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.util.PathMatcher pathMatcher>;
return v;
}
public org.springframework.messaging.simp.config.MessageBrokerRegistry setCacheLimit(int)
{
int v;
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
java.lang.Integer v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v := @parameter: int;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: java.lang.Integer cacheLimit> = v;
return v;
}
protected org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler getSimpleBroker(org.springframework.messaging.SubscribableChannel)
{
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
org.springframework.util.PathMatcher v;
org.springframework.messaging.SubscribableChannel v;
org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler v;
java.lang.String[] v;
java.lang.Integer v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v;
org.springframework.messaging.simp.config.SimpleBrokerRegistration v, v, v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v := @parameter: org.springframework.messaging.SubscribableChannel;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.SimpleBrokerRegistration simpleBrokerRegistration>;
if v != null goto label;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.StompBrokerRelayRegistration brokerRelayRegistration>;
if v != null goto label;
v = newarray (java.lang.String)[0];
virtualinvoke v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.SimpleBrokerRegistration enableSimpleBroker(java.lang.String[])>(v);
label:
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.SimpleBrokerRegistration simpleBrokerRegistration>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.SimpleBrokerRegistration simpleBrokerRegistration>;
v = virtualinvoke v.<org.springframework.messaging.simp.config.SimpleBrokerRegistration: org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler getMessageHandler(org.springframework.messaging.SubscribableChannel)>(v);
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.util.PathMatcher pathMatcher>;
virtualinvoke v.<org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler: void setPathMatcher(org.springframework.util.PathMatcher)>(v);
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: java.lang.Integer cacheLimit>;
virtualinvoke v.<org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler: void setCacheLimit(java.lang.Integer)>(v);
return v;
label:
return null;
}
protected org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler getStompBrokerRelay(org.springframework.messaging.SubscribableChannel)
{
org.springframework.messaging.simp.config.MessageBrokerRegistry v;
org.springframework.messaging.SubscribableChannel v;
org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler v;
org.springframework.messaging.simp.config.StompBrokerRelayRegistration v, v;
v := @this: org.springframework.messaging.simp.config.MessageBrokerRegistry;
v := @parameter: org.springframework.messaging.SubscribableChannel;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.StompBrokerRelayRegistration brokerRelayRegistration>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.MessageBrokerRegistry: org.springframework.messaging.simp.config.StompBrokerRelayRegistration brokerRelayRegistration>;
v = virtualinvoke v.<org.springframework.messaging.simp.config.StompBrokerRelayRegistration: org.springframework.messaging.simp.stomp.StompBrokerRelayMessageHandler getMessageHandler(org.springframework.messaging.SubscribableChannel)>(v);
return v;
label:
return null;
}
}