public class org.apache.activemq.network.jms.SimpleJmsQueueConnector extends org.apache.activemq.network.jms.JmsConnector
{
private static final org.slf4j.Logger LOG;
private java.lang.String outboundQueueConnectionFactoryName;
private java.lang.String localConnectionFactoryName;
private javax.jms.QueueConnectionFactory outboundQueueConnectionFactory;
private javax.jms.QueueConnectionFactory localQueueConnectionFactory;
private org.apache.activemq.network.jms.InboundQueueBridge[] inboundQueueBridges;
private org.apache.activemq.network.jms.OutboundQueueBridge[] outboundQueueBridges;
public void <init>()
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
specialinvoke v.<org.apache.activemq.network.jms.JmsConnector: void <init>()>();
return;
}
public org.apache.activemq.network.jms.InboundQueueBridge[] getInboundQueueBridges()
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
org.apache.activemq.network.jms.InboundQueueBridge[] v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.InboundQueueBridge[] inboundQueueBridges>;
return v;
}
public void setInboundQueueBridges(org.apache.activemq.network.jms.InboundQueueBridge[])
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
org.apache.activemq.network.jms.InboundQueueBridge[] v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: org.apache.activemq.network.jms.InboundQueueBridge[];
v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.InboundQueueBridge[] inboundQueueBridges> = v;
return;
}
public org.apache.activemq.network.jms.OutboundQueueBridge[] getOutboundQueueBridges()
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
org.apache.activemq.network.jms.OutboundQueueBridge[] v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.OutboundQueueBridge[] outboundQueueBridges>;
return v;
}
public void setOutboundQueueBridges(org.apache.activemq.network.jms.OutboundQueueBridge[])
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
org.apache.activemq.network.jms.OutboundQueueBridge[] v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: org.apache.activemq.network.jms.OutboundQueueBridge[];
v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.OutboundQueueBridge[] outboundQueueBridges> = v;
return;
}
public javax.jms.QueueConnectionFactory getLocalQueueConnectionFactory()
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
javax.jms.QueueConnectionFactory v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory localQueueConnectionFactory>;
return v;
}
public void setLocalQueueConnectionFactory(javax.jms.QueueConnectionFactory)
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
javax.jms.QueueConnectionFactory v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: javax.jms.QueueConnectionFactory;
v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory localQueueConnectionFactory> = v;
return;
}
public javax.jms.QueueConnectionFactory getOutboundQueueConnectionFactory()
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
javax.jms.QueueConnectionFactory v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory outboundQueueConnectionFactory>;
return v;
}
public java.lang.String getOutboundQueueConnectionFactoryName()
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
java.lang.String v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String outboundQueueConnectionFactoryName>;
return v;
}
public void setOutboundQueueConnectionFactoryName(java.lang.String)
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
java.lang.String v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: java.lang.String;
v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String outboundQueueConnectionFactoryName> = v;
return;
}
public java.lang.String getLocalConnectionFactoryName()
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
java.lang.String v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String localConnectionFactoryName>;
return v;
}
public void setLocalConnectionFactoryName(java.lang.String)
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
java.lang.String v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: java.lang.String;
v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String localConnectionFactoryName> = v;
return;
}
public javax.jms.QueueConnection getLocalQueueConnection()
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
java.lang.Object v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.util.concurrent.atomic.AtomicReference localConnection>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
return v;
}
public void setLocalQueueConnection(javax.jms.QueueConnection)
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
javax.jms.QueueConnection v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: javax.jms.QueueConnection;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.util.concurrent.atomic.AtomicReference localConnection>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
return;
}
public javax.jms.QueueConnection getOutboundQueueConnection()
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
java.lang.Object v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.util.concurrent.atomic.AtomicReference foreignConnection>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
return v;
}
public void setOutboundQueueConnection(javax.jms.QueueConnection)
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
javax.jms.QueueConnection v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: javax.jms.QueueConnection;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.util.concurrent.atomic.AtomicReference foreignConnection>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
return;
}
public void setOutboundQueueConnectionFactory(javax.jms.QueueConnectionFactory)
{
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
javax.jms.QueueConnectionFactory v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: javax.jms.QueueConnectionFactory;
v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory outboundQueueConnectionFactory> = v;
return;
}
protected void initializeForeignConnection() throws javax.naming.NamingException, javax.jms.JMSException
{
java.util.concurrent.atomic.AtomicReference v, v, v;
org.apache.activemq.network.jms.JmsMesageConvertor v;
org.apache.activemq.network.jms.SimpleJmsQueueConnector$1 v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
javax.jms.QueueConnection v;
javax.jms.JMSException v;
java.lang.Exception v;
javax.jms.QueueConnectionFactory v, v, v, v, v;
org.apache.activemq.network.jms.JndiLookupFactory v;
java.lang.Object v, v, v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v = null;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.util.concurrent.atomic.AtomicReference foreignConnection>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v != null goto label;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory outboundQueueConnectionFactory>;
if v != null goto label;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String outboundQueueConnectionFactoryName>;
if v == null goto label;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.JndiLookupFactory jndiOutboundTemplate>;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String outboundQueueConnectionFactoryName>;
v = virtualinvoke v.<org.apache.activemq.network.jms.JndiLookupFactory: java.lang.Object lookup(java.lang.String,java.lang.Class)>(v, class "Ljavax/jms/QueueConnectionFactory;");
v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory outboundQueueConnectionFactory> = v;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String outboundUsername>;
if v == null goto label;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory outboundQueueConnectionFactory>;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String outboundUsername>;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String outboundPassword>;
v = interfaceinvoke v.<javax.jms.QueueConnectionFactory: javax.jms.QueueConnection createQueueConnection(java.lang.String,java.lang.String)>(v, v);
goto label;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory outboundQueueConnectionFactory>;
v = interfaceinvoke v.<javax.jms.QueueConnectionFactory: javax.jms.QueueConnection createQueueConnection()>();
goto label;
label:
v = new javax.jms.JMSException;
specialinvoke v.<javax.jms.JMSException: void <init>(java.lang.String)>("Cannot create foreignConnection - no information");
throw v;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String outboundUsername>;
if v == null goto label;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory outboundQueueConnectionFactory>;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String outboundUsername>;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String outboundPassword>;
v = interfaceinvoke v.<javax.jms.QueueConnectionFactory: javax.jms.QueueConnection createQueueConnection(java.lang.String,java.lang.String)>(v, v);
goto label;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory outboundQueueConnectionFactory>;
v = interfaceinvoke v.<javax.jms.QueueConnectionFactory: javax.jms.QueueConnection createQueueConnection()>();
goto label;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.util.concurrent.atomic.AtomicReference foreignConnection>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object getAndSet(java.lang.Object)>(null);
label:
v = new org.apache.activemq.network.jms.SimpleJmsQueueConnector$1;
specialinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector$1: void <init>(org.apache.activemq.network.jms.SimpleJmsQueueConnector)>(v);
interfaceinvoke v.<javax.jms.QueueConnection: void setExceptionListener(javax.jms.ExceptionListener)>(v);
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String outboundClientId>;
if v == null goto label;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String outboundClientId>;
v = virtualinvoke v.<java.lang.String: int length()>();
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String getOutboundClientId()>();
interfaceinvoke v.<javax.jms.QueueConnection: void setClientID(java.lang.String)>(v);
label:
interfaceinvoke v.<javax.jms.QueueConnection: void start()>();
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.JmsMesageConvertor outboundMessageConvertor>;
interfaceinvoke v.<org.apache.activemq.network.jms.JmsMesageConvertor: void setConnection(javax.jms.Connection)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: void initializeInboundDestinationBridgesOutboundSide(javax.jms.QueueConnection)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: void initializeOutboundDestinationBridgesOutboundSide(javax.jms.QueueConnection)>(v);
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.util.concurrent.atomic.AtomicReference foreignConnection>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
protected void initializeLocalConnection() throws javax.naming.NamingException, javax.jms.JMSException
{
org.apache.activemq.network.jms.JmsMesageConvertor v;
javax.jms.JMSException v;
java.lang.Exception v;
org.apache.activemq.ActiveMQConnectionFactory v, v;
org.apache.activemq.network.jms.JndiLookupFactory v;
java.util.concurrent.atomic.AtomicReference v, v, v;
org.apache.activemq.network.jms.SimpleJmsQueueConnector$2 v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
javax.jms.QueueConnection v;
javax.jms.QueueConnectionFactory v, v, v, v, v;
java.lang.Object v, v, v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v = null;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.util.concurrent.atomic.AtomicReference localConnection>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v != null goto label;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory localQueueConnectionFactory>;
if v != null goto label;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.ActiveMQConnectionFactory embeddedConnectionFactory>;
if v != null goto label;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String localConnectionFactoryName>;
if v == null goto label;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.JndiLookupFactory jndiLocalTemplate>;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String localConnectionFactoryName>;
v = virtualinvoke v.<org.apache.activemq.network.jms.JndiLookupFactory: java.lang.Object lookup(java.lang.String,java.lang.Class)>(v, class "Ljavax/jms/QueueConnectionFactory;");
v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory localQueueConnectionFactory> = v;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String localUsername>;
if v == null goto label;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory localQueueConnectionFactory>;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String localUsername>;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String localPassword>;
v = interfaceinvoke v.<javax.jms.QueueConnectionFactory: javax.jms.QueueConnection createQueueConnection(java.lang.String,java.lang.String)>(v, v);
goto label;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory localQueueConnectionFactory>;
v = interfaceinvoke v.<javax.jms.QueueConnectionFactory: javax.jms.QueueConnection createQueueConnection()>();
goto label;
label:
v = new javax.jms.JMSException;
specialinvoke v.<javax.jms.JMSException: void <init>(java.lang.String)>("Cannot create localConnection - no information");
throw v;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.ActiveMQConnectionFactory embeddedConnectionFactory>;
v = virtualinvoke v.<org.apache.activemq.ActiveMQConnectionFactory: javax.jms.QueueConnection createQueueConnection()>();
goto label;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String localUsername>;
if v == null goto label;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory localQueueConnectionFactory>;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String localUsername>;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String localPassword>;
v = interfaceinvoke v.<javax.jms.QueueConnectionFactory: javax.jms.QueueConnection createQueueConnection(java.lang.String,java.lang.String)>(v, v);
goto label;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.QueueConnectionFactory localQueueConnectionFactory>;
v = interfaceinvoke v.<javax.jms.QueueConnectionFactory: javax.jms.QueueConnection createQueueConnection()>();
goto label;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.util.concurrent.atomic.AtomicReference localConnection>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object getAndSet(java.lang.Object)>(null);
label:
v = new org.apache.activemq.network.jms.SimpleJmsQueueConnector$2;
specialinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector$2: void <init>(org.apache.activemq.network.jms.SimpleJmsQueueConnector)>(v);
interfaceinvoke v.<javax.jms.QueueConnection: void setExceptionListener(javax.jms.ExceptionListener)>(v);
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String localClientId>;
if v == null goto label;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String localClientId>;
v = virtualinvoke v.<java.lang.String: int length()>();
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.lang.String getLocalClientId()>();
interfaceinvoke v.<javax.jms.QueueConnection: void setClientID(java.lang.String)>(v);
label:
interfaceinvoke v.<javax.jms.QueueConnection: void start()>();
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.JmsMesageConvertor inboundMessageConvertor>;
interfaceinvoke v.<org.apache.activemq.network.jms.JmsMesageConvertor: void setConnection(javax.jms.Connection)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: void initializeInboundDestinationBridgesLocalSide(javax.jms.QueueConnection)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: void initializeOutboundDestinationBridgesLocalSide(javax.jms.QueueConnection)>(v);
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.util.concurrent.atomic.AtomicReference localConnection>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
protected void initializeInboundDestinationBridgesOutboundSide(javax.jms.QueueConnection) throws javax.jms.JMSException
{
javax.jms.QueueSession v;
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
javax.jms.QueueConnection v;
org.apache.activemq.network.jms.InboundQueueBridge[] v, v;
javax.jms.Queue v;
int v, v;
org.apache.activemq.network.jms.InboundQueueBridge v;
java.lang.String v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: javax.jms.QueueConnection;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.InboundQueueBridge[] inboundQueueBridges>;
if v == null goto label;
v = interfaceinvoke v.<javax.jms.QueueConnection: javax.jms.QueueSession createQueueSession(boolean,int)>(0, 1);
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.InboundQueueBridge[] inboundQueueBridges>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: java.lang.String getInboundQueueName()>();
v = virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.Queue createForeignQueue(javax.jms.QueueSession,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setConsumer(javax.jms.MessageConsumer)>(null);
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setConsumerQueue(javax.jms.Queue)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setConsumerConnection(javax.jms.QueueConnection)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setJmsConnector(org.apache.activemq.network.jms.JmsConnector)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: void addInboundBridge(org.apache.activemq.network.jms.DestinationBridge)>(v);
v = v + 1;
goto label;
label:
interfaceinvoke v.<javax.jms.QueueSession: void close()>();
label:
return;
}
protected void initializeInboundDestinationBridgesLocalSide(javax.jms.QueueConnection) throws javax.jms.JMSException
{
javax.jms.QueueSession v;
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
javax.jms.QueueConnection v;
org.apache.activemq.network.jms.InboundQueueBridge[] v, v;
javax.jms.Queue v;
org.apache.activemq.network.jms.JmsMesageConvertor v, v;
int v, v;
org.apache.activemq.network.jms.InboundQueueBridge v;
java.lang.String v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: javax.jms.QueueConnection;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.InboundQueueBridge[] inboundQueueBridges>;
if v == null goto label;
v = interfaceinvoke v.<javax.jms.QueueConnection: javax.jms.QueueSession createQueueSession(boolean,int)>(0, 1);
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.InboundQueueBridge[] inboundQueueBridges>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: java.lang.String getLocalQueueName()>();
v = virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.Queue createActiveMQQueue(javax.jms.QueueSession,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setProducerQueue(javax.jms.Queue)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setProducerConnection(javax.jms.QueueConnection)>(v);
v = virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: org.apache.activemq.network.jms.JmsMesageConvertor getJmsMessageConvertor()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.JmsMesageConvertor getInboundMessageConvertor()>();
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setJmsMessageConvertor(org.apache.activemq.network.jms.JmsMesageConvertor)>(v);
label:
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setJmsConnector(org.apache.activemq.network.jms.JmsConnector)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: void addInboundBridge(org.apache.activemq.network.jms.DestinationBridge)>(v);
v = v + 1;
goto label;
label:
interfaceinvoke v.<javax.jms.QueueSession: void close()>();
label:
return;
}
protected void initializeOutboundDestinationBridgesOutboundSide(javax.jms.QueueConnection) throws javax.jms.JMSException
{
org.apache.activemq.network.jms.OutboundQueueBridge v;
javax.jms.QueueSession v;
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
javax.jms.QueueConnection v;
javax.jms.Queue v;
org.apache.activemq.network.jms.JmsMesageConvertor v, v;
org.apache.activemq.network.jms.OutboundQueueBridge[] v, v;
int v, v;
java.lang.String v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: javax.jms.QueueConnection;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.OutboundQueueBridge[] outboundQueueBridges>;
if v == null goto label;
v = interfaceinvoke v.<javax.jms.QueueConnection: javax.jms.QueueSession createQueueSession(boolean,int)>(0, 1);
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.OutboundQueueBridge[] outboundQueueBridges>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: java.lang.String getOutboundQueueName()>();
v = virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.Queue createForeignQueue(javax.jms.QueueSession,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setProducerQueue(javax.jms.Queue)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setProducerConnection(javax.jms.QueueConnection)>(v);
v = virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: org.apache.activemq.network.jms.JmsMesageConvertor getJmsMessageConvertor()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.JmsMesageConvertor getOutboundMessageConvertor()>();
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setJmsMessageConvertor(org.apache.activemq.network.jms.JmsMesageConvertor)>(v);
label:
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setJmsConnector(org.apache.activemq.network.jms.JmsConnector)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: void addOutboundBridge(org.apache.activemq.network.jms.DestinationBridge)>(v);
v = v + 1;
goto label;
label:
interfaceinvoke v.<javax.jms.QueueSession: void close()>();
label:
return;
}
protected void initializeOutboundDestinationBridgesLocalSide(javax.jms.QueueConnection) throws javax.jms.JMSException
{
org.apache.activemq.network.jms.OutboundQueueBridge v;
javax.jms.QueueSession v;
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
javax.jms.QueueConnection v;
javax.jms.Queue v;
org.apache.activemq.network.jms.OutboundQueueBridge[] v, v;
int v, v;
java.lang.String v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: javax.jms.QueueConnection;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.OutboundQueueBridge[] outboundQueueBridges>;
if v == null goto label;
v = interfaceinvoke v.<javax.jms.QueueConnection: javax.jms.QueueSession createQueueSession(boolean,int)>(0, 1);
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.OutboundQueueBridge[] outboundQueueBridges>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: java.lang.String getLocalQueueName()>();
v = virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: javax.jms.Queue createActiveMQQueue(javax.jms.QueueSession,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setConsumer(javax.jms.MessageConsumer)>(null);
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setConsumerQueue(javax.jms.Queue)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setConsumerConnection(javax.jms.QueueConnection)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setJmsConnector(org.apache.activemq.network.jms.JmsConnector)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: void addOutboundBridge(org.apache.activemq.network.jms.DestinationBridge)>(v);
v = v + 1;
goto label;
label:
interfaceinvoke v.<javax.jms.QueueSession: void close()>();
label:
return;
}
protected javax.jms.Destination createReplyToBridge(javax.jms.Destination, javax.jms.Connection, javax.jms.Connection)
{
java.util.concurrent.atomic.AtomicReference v;
org.apache.activemq.network.jms.SimpleJmsQueueConnector$4 v;
org.apache.activemq.network.jms.JmsMesageConvertor v, v, v, v;
org.apache.activemq.network.jms.SimpleJmsQueueConnector$3 v;
org.apache.activemq.util.LRUCache v, v, v, v;
boolean v;
javax.jms.Connection v, v;
org.slf4j.Logger v, v, v, v;
javax.jms.QueueSession v, v;
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
java.lang.Exception v, v;
javax.jms.Queue v, v;
javax.jms.Destination v;
java.lang.Object v, v, v;
javax.jms.TemporaryQueue v, v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: javax.jms.Destination;
v := @parameter: javax.jms.Connection;
v := @parameter: javax.jms.Connection;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: java.util.concurrent.atomic.AtomicReference localConnection>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.util.LRUCache replyToBridges>;
v = virtualinvoke v.<org.apache.activemq.util.LRUCache: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new org.apache.activemq.network.jms.SimpleJmsQueueConnector$3;
specialinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector$3: void <init>(org.apache.activemq.network.jms.SimpleJmsQueueConnector)>(v);
v = v;
label:
v = interfaceinvoke v.<javax.jms.QueueConnection: javax.jms.QueueSession createQueueSession(boolean,int)>(0, 1);
v = interfaceinvoke v.<javax.jms.QueueSession: javax.jms.TemporaryQueue createTemporaryQueue()>();
interfaceinvoke v.<javax.jms.QueueSession: void close()>();
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setConsumerQueue(javax.jms.Queue)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setProducerQueue(javax.jms.Queue)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setProducerConnection(javax.jms.QueueConnection)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setConsumerConnection(javax.jms.QueueConnection)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setDoHandleReplyTo(boolean)>(0);
v = virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: org.apache.activemq.network.jms.JmsMesageConvertor getJmsMessageConvertor()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.JmsMesageConvertor getInboundMessageConvertor()>();
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setJmsMessageConvertor(org.apache.activemq.network.jms.JmsMesageConvertor)>(v);
label:
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void setJmsConnector(org.apache.activemq.network.jms.JmsConnector)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: void start()>();
v = <org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Created replyTo bridge for {}", v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to create replyTo bridge for queue: {}", v, v);
return null;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.util.LRUCache replyToBridges>;
virtualinvoke v.<org.apache.activemq.util.LRUCache: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<org.apache.activemq.network.jms.InboundQueueBridge: javax.jms.Queue getConsumerQueue()>();
return v;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.util.LRUCache replyToBridges>;
v = virtualinvoke v.<org.apache.activemq.util.LRUCache: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new org.apache.activemq.network.jms.SimpleJmsQueueConnector$4;
specialinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector$4: void <init>(org.apache.activemq.network.jms.SimpleJmsQueueConnector)>(v);
v = v;
label:
v = interfaceinvoke v.<javax.jms.QueueConnection: javax.jms.QueueSession createQueueSession(boolean,int)>(0, 1);
v = interfaceinvoke v.<javax.jms.QueueSession: javax.jms.TemporaryQueue createTemporaryQueue()>();
interfaceinvoke v.<javax.jms.QueueSession: void close()>();
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setConsumerQueue(javax.jms.Queue)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setProducerQueue(javax.jms.Queue)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setProducerConnection(javax.jms.QueueConnection)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setConsumerConnection(javax.jms.QueueConnection)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setDoHandleReplyTo(boolean)>(0);
v = virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: org.apache.activemq.network.jms.JmsMesageConvertor getJmsMessageConvertor()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.JmsMesageConvertor getOutboundMessageConvertor()>();
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setJmsMessageConvertor(org.apache.activemq.network.jms.JmsMesageConvertor)>(v);
label:
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void setJmsConnector(org.apache.activemq.network.jms.JmsConnector)>(v);
virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: void start()>();
v = <org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Created replyTo bridge for {}", v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to create replyTo bridge for queue: {}", v, v);
return null;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.util.LRUCache replyToBridges>;
virtualinvoke v.<org.apache.activemq.util.LRUCache: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<org.apache.activemq.network.jms.OutboundQueueBridge: javax.jms.Queue getConsumerQueue()>();
return v;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
protected javax.jms.Queue createActiveMQQueue(javax.jms.QueueSession, java.lang.String) throws javax.jms.JMSException
{
javax.jms.Queue v;
javax.jms.QueueSession v;
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
java.lang.String v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: javax.jms.QueueSession;
v := @parameter: java.lang.String;
v = interfaceinvoke v.<javax.jms.QueueSession: javax.jms.Queue createQueue(java.lang.String)>(v);
return v;
}
protected javax.jms.Queue createForeignQueue(javax.jms.QueueSession, java.lang.String) throws javax.jms.JMSException
{
java.lang.Throwable v, v;
javax.naming.NamingException v, v;
java.lang.String v, v, v;
boolean v;
org.slf4j.Logger v, v;
javax.jms.QueueSession v;
org.apache.activemq.network.jms.SimpleJmsQueueConnector v;
javax.jms.JMSException v, v;
org.apache.activemq.network.jms.JndiLookupFactory v, v;
java.lang.Object v;
v := @this: org.apache.activemq.network.jms.SimpleJmsQueueConnector;
v := @parameter: javax.jms.QueueSession;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: boolean preferJndiDestinationLookup>;
if v == 0 goto label;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.JndiLookupFactory jndiOutboundTemplate>;
v = virtualinvoke v.<org.apache.activemq.network.jms.JndiLookupFactory: java.lang.Object lookup(java.lang.String,java.lang.Class)>(v, class "Ljavax/jms/Queue;");
label:
goto label;
label:
v := @caughtexception;
label:
v = interfaceinvoke v.<javax.jms.QueueSession: javax.jms.Queue createQueue(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to look-up or create Queue for name: \u0001");
v = <org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
v = new javax.jms.JMSException;
specialinvoke v.<javax.jms.JMSException: void <init>(java.lang.String)>(v);
virtualinvoke v.<javax.jms.JMSException: void setLinkedException(java.lang.Exception)>(v);
throw v;
label:
v = interfaceinvoke v.<javax.jms.QueueSession: javax.jms.Queue createQueue(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.apache.activemq.network.jms.JndiLookupFactory jndiOutboundTemplate>;
virtualinvoke v.<org.apache.activemq.network.jms.JndiLookupFactory: java.lang.Object lookup(java.lang.String,java.lang.Class)>(v, class "Ljavax/jms/Queue;");
label:
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to look-up Queue for name: \u0001");
v = <org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
v = new javax.jms.JMSException;
specialinvoke v.<javax.jms.JMSException: void <init>(java.lang.String)>(v);
virtualinvoke v.<javax.jms.JMSException: void setLinkedException(java.lang.Exception)>(v);
throw v;
label:
return v;
catch javax.naming.NamingException from label to label with label;
catch javax.jms.JMSException from label to label with label;
catch javax.jms.JMSException from label to label with label;
catch javax.naming.NamingException from label to label with label;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/network/jms/SimpleJmsQueueConnector;");
<org.apache.activemq.network.jms.SimpleJmsQueueConnector: org.slf4j.Logger LOG> = v;
return;
}
}