public class org.apache.activemq.ra.ManagedConnectionProxy extends java.lang.Object implements javax.jms.Connection, javax.jms.QueueConnection, javax.jms.TopicConnection, javax.jms.ExceptionListener
{
private org.apache.activemq.ra.ActiveMQManagedConnection managedConnection;
private final java.util.List sessions;
private javax.jms.ExceptionListener exceptionListener;
private org.apache.activemq.ra.ActiveMQConnectionRequestInfo info;
public void <init>(org.apache.activemq.ra.ActiveMQManagedConnection, javax.resource.spi.ConnectionRequestInfo)
{
org.apache.activemq.ra.ManagedConnectionProxy v;
org.apache.activemq.ra.ActiveMQManagedConnection v;
javax.resource.spi.ConnectionRequestInfo v;
boolean v;
java.util.ArrayList v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v := @parameter: org.apache.activemq.ra.ActiveMQManagedConnection;
v := @parameter: javax.resource.spi.ConnectionRequestInfo;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.activemq.ra.ManagedConnectionProxy: java.util.List sessions> = v;
v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ActiveMQManagedConnection managedConnection> = v;
v = v instanceof org.apache.activemq.ra.ActiveMQConnectionRequestInfo;
if v == 0 goto label;
v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ActiveMQConnectionRequestInfo info> = v;
label:
return;
}
public void close() throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
org.apache.activemq.ra.ActiveMQManagedConnection v, v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ActiveMQManagedConnection managedConnection>;
if v == null goto label;
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ActiveMQManagedConnection managedConnection>;
virtualinvoke v.<org.apache.activemq.ra.ActiveMQManagedConnection: void proxyClosedEvent(org.apache.activemq.ra.ManagedConnectionProxy)>(v);
label:
return;
}
public void cleanup()
{
java.lang.Throwable v, v;
org.apache.activemq.ra.ManagedConnectionProxy v;
java.util.Iterator v;
java.util.List v, v, v;
java.lang.Object v;
boolean v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v.<org.apache.activemq.ra.ManagedConnectionProxy: javax.jms.ExceptionListener exceptionListener> = null;
v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ActiveMQManagedConnection managedConnection> = null;
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: java.util.List sessions>;
entermonitor v;
label:
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: java.util.List sessions>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
label:
virtualinvoke v.<org.apache.activemq.ra.ManagedSessionProxy: void cleanup()>();
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: java.util.List sessions>;
interfaceinvoke v.<java.util.List: void clear()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch javax.jms.JMSException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private javax.jms.Connection getConnection() throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
javax.jms.Connection v;
org.apache.activemq.ra.ActiveMQManagedConnection v, v;
javax.jms.IllegalStateException v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ActiveMQManagedConnection managedConnection>;
if v != null goto label;
v = new javax.jms.IllegalStateException;
specialinvoke v.<javax.jms.IllegalStateException: void <init>(java.lang.String)>("The Connection is closed");
throw v;
label:
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ActiveMQManagedConnection managedConnection>;
v = virtualinvoke v.<org.apache.activemq.ra.ActiveMQManagedConnection: javax.jms.Connection getPhysicalConnection()>();
return v;
}
public javax.jms.Session createSession(boolean, int) throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
org.apache.activemq.ra.ManagedSessionProxy v;
int v;
boolean v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v := @parameter: boolean;
v := @parameter: int;
v = specialinvoke v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ManagedSessionProxy createSessionProxy(boolean,int)>(v, v);
return v;
}
private org.apache.activemq.ra.ManagedSessionProxy createSessionProxy(boolean, int) throws javax.jms.JMSException
{
java.lang.Throwable v;
javax.jms.Session v;
int v, v;
boolean v, v, v;
org.apache.activemq.TransactionContext v;
org.apache.activemq.ra.ManagedConnectionProxy v;
org.apache.activemq.ra.ManagedTransactionContext v;
javax.jms.Connection v, v;
org.apache.activemq.ra.ActiveMQManagedConnection v, v;
java.util.List v, v;
org.apache.activemq.ra.ManagedSessionProxy v;
org.apache.activemq.ra.ActiveMQConnectionRequestInfo v, v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v := @parameter: boolean;
v := @parameter: int;
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ActiveMQConnectionRequestInfo info>;
if v == null goto label;
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ActiveMQConnectionRequestInfo info>;
v = virtualinvoke v.<org.apache.activemq.ra.ActiveMQConnectionRequestInfo: boolean isUseSessionArgs()>();
if v == 0 goto label;
v = specialinvoke v.<org.apache.activemq.ra.ManagedConnectionProxy: javax.jms.Connection getConnection()>();
if v == 0 goto label;
v = 0;
goto label;
label:
v = v;
label:
v = interfaceinvoke v.<javax.jms.Connection: javax.jms.Session createSession(boolean,int)>(v, v);
goto label;
label:
v = specialinvoke v.<org.apache.activemq.ra.ManagedConnectionProxy: javax.jms.Connection getConnection()>();
interfaceinvoke v.<javax.jms.Connection: javax.jms.Session createSession(boolean,int)>(0, 1);
label:
v = new org.apache.activemq.ra.ManagedTransactionContext;
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ActiveMQManagedConnection managedConnection>;
v = virtualinvoke v.<org.apache.activemq.ra.ActiveMQManagedConnection: org.apache.activemq.TransactionContext getTransactionContext()>();
specialinvoke v.<org.apache.activemq.ra.ManagedTransactionContext: void <init>(org.apache.activemq.TransactionContext)>(v);
virtualinvoke v.<org.apache.activemq.ActiveMQSession: void setTransactionContext(org.apache.activemq.TransactionContext)>(v);
v = new org.apache.activemq.ra.ManagedSessionProxy;
specialinvoke v.<org.apache.activemq.ra.ManagedSessionProxy: void <init>(org.apache.activemq.ActiveMQSession,org.apache.activemq.ra.ManagedConnectionProxy)>(v, v);
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ActiveMQManagedConnection managedConnection>;
v = virtualinvoke v.<org.apache.activemq.ra.ActiveMQManagedConnection: boolean isInManagedTx()>();
virtualinvoke v.<org.apache.activemq.ra.ManagedSessionProxy: void setUseSharedTxContext(boolean)>(v);
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: java.util.List sessions>;
entermonitor v;
label:
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: java.util.List sessions>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return v;
catch java.lang.Throwable from label to label with label;
}
protected void sessionClosed(org.apache.activemq.ra.ManagedSessionProxy)
{
java.lang.Throwable v;
org.apache.activemq.ra.ManagedConnectionProxy v;
java.util.List v, v;
org.apache.activemq.ra.ManagedSessionProxy v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v := @parameter: org.apache.activemq.ra.ManagedSessionProxy;
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: java.util.List sessions>;
entermonitor v;
label:
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: java.util.List sessions>;
interfaceinvoke v.<java.util.List: boolean remove(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void setUseSharedTxContext(boolean) throws javax.jms.JMSException
{
java.lang.Throwable v;
org.apache.activemq.ra.ManagedConnectionProxy v;
java.util.Iterator v;
java.util.List v, v;
java.lang.Object v;
boolean v, v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v := @parameter: boolean;
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: java.util.List sessions>;
entermonitor v;
label:
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: java.util.List sessions>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.ra.ManagedSessionProxy: void setUseSharedTxContext(boolean)>(v);
goto label;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public javax.jms.QueueSession createQueueSession(boolean, int) throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
org.apache.activemq.ra.ManagedSessionProxy v;
int v;
org.apache.activemq.ActiveMQQueueSession v;
boolean v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v := @parameter: boolean;
v := @parameter: int;
v = new org.apache.activemq.ActiveMQQueueSession;
v = specialinvoke v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ManagedSessionProxy createSessionProxy(boolean,int)>(v, v);
specialinvoke v.<org.apache.activemq.ActiveMQQueueSession: void <init>(javax.jms.QueueSession)>(v);
return v;
}
public javax.jms.TopicSession createTopicSession(boolean, int) throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
org.apache.activemq.ra.ManagedSessionProxy v;
int v;
boolean v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v := @parameter: boolean;
v := @parameter: int;
v = new org.apache.activemq.ActiveMQTopicSession;
v = specialinvoke v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ManagedSessionProxy createSessionProxy(boolean,int)>(v, v);
specialinvoke v.<org.apache.activemq.ActiveMQTopicSession: void <init>(javax.jms.TopicSession)>(v);
return v;
}
public java.lang.String getClientID() throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
javax.jms.Connection v;
java.lang.String v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v = specialinvoke v.<org.apache.activemq.ra.ManagedConnectionProxy: javax.jms.Connection getConnection()>();
v = interfaceinvoke v.<javax.jms.Connection: java.lang.String getClientID()>();
return v;
}
public javax.jms.ExceptionListener getExceptionListener() throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
javax.jms.Connection v;
javax.jms.ExceptionListener v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v = specialinvoke v.<org.apache.activemq.ra.ManagedConnectionProxy: javax.jms.Connection getConnection()>();
v = interfaceinvoke v.<javax.jms.Connection: javax.jms.ExceptionListener getExceptionListener()>();
return v;
}
public javax.jms.ConnectionMetaData getMetaData() throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
javax.jms.Connection v;
javax.jms.ConnectionMetaData v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v = specialinvoke v.<org.apache.activemq.ra.ManagedConnectionProxy: javax.jms.Connection getConnection()>();
v = interfaceinvoke v.<javax.jms.Connection: javax.jms.ConnectionMetaData getMetaData()>();
return v;
}
public void setClientID(java.lang.String) throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
javax.jms.Connection v;
java.lang.String v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v := @parameter: java.lang.String;
v = specialinvoke v.<org.apache.activemq.ra.ManagedConnectionProxy: javax.jms.Connection getConnection()>();
interfaceinvoke v.<javax.jms.Connection: void setClientID(java.lang.String)>(v);
return;
}
public void setExceptionListener(javax.jms.ExceptionListener) throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
javax.jms.ExceptionListener v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v := @parameter: javax.jms.ExceptionListener;
specialinvoke v.<org.apache.activemq.ra.ManagedConnectionProxy: javax.jms.Connection getConnection()>();
v.<org.apache.activemq.ra.ManagedConnectionProxy: javax.jms.ExceptionListener exceptionListener> = v;
return;
}
public void start() throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
javax.jms.Connection v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v = specialinvoke v.<org.apache.activemq.ra.ManagedConnectionProxy: javax.jms.Connection getConnection()>();
interfaceinvoke v.<javax.jms.Connection: void start()>();
return;
}
public void stop() throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
javax.jms.Connection v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v = specialinvoke v.<org.apache.activemq.ra.ManagedConnectionProxy: javax.jms.Connection getConnection()>();
interfaceinvoke v.<javax.jms.Connection: void stop()>();
return;
}
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue, java.lang.String, javax.jms.ServerSessionPool, int) throws javax.jms.JMSException
{
javax.jms.Queue v;
org.apache.activemq.ra.ManagedConnectionProxy v;
int v;
java.lang.String v;
javax.jms.JMSException v;
javax.jms.ServerSessionPool v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v := @parameter: javax.jms.Queue;
v := @parameter: java.lang.String;
v := @parameter: javax.jms.ServerSessionPool;
v := @parameter: int;
v = new javax.jms.JMSException;
specialinvoke v.<javax.jms.JMSException: void <init>(java.lang.String)>("Not Supported.");
throw v;
}
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic, java.lang.String, javax.jms.ServerSessionPool, int) throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
int v;
javax.jms.Topic v;
java.lang.String v;
javax.jms.JMSException v;
javax.jms.ServerSessionPool v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v := @parameter: javax.jms.Topic;
v := @parameter: java.lang.String;
v := @parameter: javax.jms.ServerSessionPool;
v := @parameter: int;
v = new javax.jms.JMSException;
specialinvoke v.<javax.jms.JMSException: void <init>(java.lang.String)>("Not Supported.");
throw v;
}
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination, java.lang.String, javax.jms.ServerSessionPool, int) throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
javax.jms.Destination v;
int v;
java.lang.String v;
javax.jms.JMSException v;
javax.jms.ServerSessionPool v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v := @parameter: javax.jms.Destination;
v := @parameter: java.lang.String;
v := @parameter: javax.jms.ServerSessionPool;
v := @parameter: int;
v = new javax.jms.JMSException;
specialinvoke v.<javax.jms.JMSException: void <init>(java.lang.String)>("Not Supported.");
throw v;
}
public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic, java.lang.String, java.lang.String, javax.jms.ServerSessionPool, int) throws javax.jms.JMSException
{
org.apache.activemq.ra.ManagedConnectionProxy v;
int v;
javax.jms.Topic v;
java.lang.String v, v;
javax.jms.JMSException v;
javax.jms.ServerSessionPool v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v := @parameter: javax.jms.Topic;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: javax.jms.ServerSessionPool;
v := @parameter: int;
v = new javax.jms.JMSException;
specialinvoke v.<javax.jms.JMSException: void <init>(java.lang.String)>("Not Supported.");
throw v;
}
public org.apache.activemq.ra.ActiveMQManagedConnection getManagedConnection()
{
org.apache.activemq.ra.ManagedConnectionProxy v;
org.apache.activemq.ra.ActiveMQManagedConnection v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ActiveMQManagedConnection managedConnection>;
return v;
}
public void onException(javax.jms.JMSException)
{
java.lang.Throwable v;
org.apache.activemq.ra.ManagedConnectionProxy v;
org.apache.activemq.ra.ActiveMQManagedConnection v;
javax.jms.JMSException v;
javax.jms.ExceptionListener v, v;
v := @this: org.apache.activemq.ra.ManagedConnectionProxy;
v := @parameter: javax.jms.JMSException;
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: javax.jms.ExceptionListener exceptionListener>;
if v == null goto label;
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: org.apache.activemq.ra.ActiveMQManagedConnection managedConnection>;
if v == null goto label;
label:
v = v.<org.apache.activemq.ra.ManagedConnectionProxy: javax.jms.ExceptionListener exceptionListener>;
interfaceinvoke v.<javax.jms.ExceptionListener: void onException(javax.jms.JMSException)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
return;
catch java.lang.Throwable from label to label with label;
}
}