public class org.apache.activemq.jms.pool.PooledSession extends java.lang.Object implements javax.jms.Session, javax.jms.TopicSession, javax.jms.QueueSession, javax.jms.XASession
{
private static final transient org.slf4j.Logger LOG;
private final org.apache.activemq.jms.pool.SessionKey key;
private final org.apache.commons.pool.KeyedObjectPool sessionPool;
private final java.util.concurrent.CopyOnWriteArrayList consumers;
private final java.util.concurrent.CopyOnWriteArrayList browsers;
private final java.util.concurrent.CopyOnWriteArrayList sessionEventListeners;
private final java.util.concurrent.atomic.AtomicBoolean closed;
private org.apache.activemq.jms.pool.SessionHolder sessionHolder;
private boolean transactional;
private boolean ignoreClose;
private boolean isXa;
private boolean useAnonymousProducers;
public void <init>(org.apache.activemq.jms.pool.SessionKey, org.apache.activemq.jms.pool.SessionHolder, org.apache.commons.pool.KeyedObjectPool, boolean, boolean)
{
org.apache.activemq.jms.pool.SessionKey v;
org.apache.activemq.jms.pool.SessionHolder v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.activemq.jms.pool.PooledSession v;
org.apache.commons.pool.KeyedObjectPool v;
boolean v, v;
java.util.concurrent.CopyOnWriteArrayList v, v, v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: org.apache.activemq.jms.pool.SessionKey;
v := @parameter: org.apache.activemq.jms.pool.SessionHolder;
v := @parameter: org.apache.commons.pool.KeyedObjectPool;
v := @parameter: boolean;
v := @parameter: boolean;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.CopyOnWriteArrayList;
specialinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void <init>()>();
v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList consumers> = v;
v = new java.util.concurrent.CopyOnWriteArrayList;
specialinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void <init>()>();
v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList browsers> = v;
v = new java.util.concurrent.CopyOnWriteArrayList;
specialinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void <init>()>();
v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList sessionEventListeners> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>()>();
v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.atomic.AtomicBoolean closed> = v;
v.<org.apache.activemq.jms.pool.PooledSession: boolean transactional> = 1;
v.<org.apache.activemq.jms.pool.PooledSession: boolean useAnonymousProducers> = 1;
v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionKey key> = v;
v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionHolder sessionHolder> = v;
v.<org.apache.activemq.jms.pool.PooledSession: org.apache.commons.pool.KeyedObjectPool sessionPool> = v;
v.<org.apache.activemq.jms.pool.PooledSession: boolean transactional> = v;
v.<org.apache.activemq.jms.pool.PooledSession: boolean useAnonymousProducers> = v;
return;
}
public void addSessionEventListener(org.apache.activemq.jms.pool.PooledSessionEventListener)
{
org.apache.activemq.jms.pool.PooledSessionEventListener v;
org.apache.activemq.jms.pool.PooledSession v;
boolean v;
java.util.concurrent.CopyOnWriteArrayList v, v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: org.apache.activemq.jms.pool.PooledSessionEventListener;
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList sessionEventListeners>;
v = virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList sessionEventListeners>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: boolean add(java.lang.Object)>(v);
label:
return;
}
protected boolean isIgnoreClose()
{
org.apache.activemq.jms.pool.PooledSession v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = v.<org.apache.activemq.jms.pool.PooledSession: boolean ignoreClose>;
return v;
}
protected void setIgnoreClose(boolean)
{
org.apache.activemq.jms.pool.PooledSession v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: boolean;
v.<org.apache.activemq.jms.pool.PooledSession: boolean ignoreClose> = v;
return;
}
public void close() throws javax.jms.JMSException
{
javax.jms.Session v, v;
boolean v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.jms.pool.SessionHolder v, v, v, v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.IllegalStateException v;
java.lang.Exception v, v;
java.util.concurrent.CopyOnWriteArrayList v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Throwable v, v, v, v;
org.apache.activemq.jms.pool.SessionKey v, v;
java.util.concurrent.atomic.AtomicBoolean v;
java.lang.String v, v, v, v, v;
org.slf4j.Logger v, v, v, v;
java.util.Iterator v, v, v, v, v;
org.apache.commons.pool.KeyedObjectPool v, v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = v.<org.apache.activemq.jms.pool.PooledSession: boolean ignoreClose>;
if v == 0 goto label;
return;
label:
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.atomic.AtomicBoolean closed>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = 0;
label:
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
interfaceinvoke v.<javax.jms.Session: void setMessageListener(javax.jms.MessageListener)>(null);
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList consumers>;
v = virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: 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()>();
interfaceinvoke v.<javax.jms.MessageConsumer: void close()>();
goto label;
label:
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList browsers>;
v = virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: 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()>();
interfaceinvoke v.<javax.jms.QueueBrowser: void close()>();
goto label;
label:
v = v.<org.apache.activemq.jms.pool.PooledSession: boolean transactional>;
if v == 0 goto label;
v = v.<org.apache.activemq.jms.pool.PooledSession: boolean isXa>;
if v != 0 goto label;
label:
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
interfaceinvoke v.<javax.jms.Session: void rollback()>();
label:
goto label;
label:
v := @caughtexception;
v = 1;
v = <org.apache.activemq.jms.pool.PooledSession: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Throwable)>(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[])>("Caught exception trying rollback() when putting session back into the pool, will invalidate. \u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>(v, v);
label:
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList consumers>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void clear()>();
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList browsers>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void clear()>();
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList sessionEventListeners>;
v = virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: 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()>();
interfaceinvoke v.<org.apache.activemq.jms.pool.PooledSessionEventListener: void onSessionClosed(org.apache.activemq.jms.pool.PooledSession)>(v);
goto label;
label:
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList sessionEventListeners>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void clear()>();
goto label;
label:
v := @caughtexception;
v = 1;
v = <org.apache.activemq.jms.pool.PooledSession: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Throwable)>(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[])>("Caught exception trying close() when putting session back into the pool, will invalidate. \u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>(v, v);
label:
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList consumers>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void clear()>();
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList browsers>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void clear()>();
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList sessionEventListeners>;
v = virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: 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()>();
interfaceinvoke v.<org.apache.activemq.jms.pool.PooledSessionEventListener: void onSessionClosed(org.apache.activemq.jms.pool.PooledSession)>(v);
goto label;
label:
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList sessionEventListeners>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void clear()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList consumers>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void clear()>();
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList browsers>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void clear()>();
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList sessionEventListeners>;
v = virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: 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()>();
interfaceinvoke v.<org.apache.activemq.jms.pool.PooledSessionEventListener: void onSessionClosed(org.apache.activemq.jms.pool.PooledSession)>(v);
goto label;
label:
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList sessionEventListeners>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void clear()>();
throw v;
label:
if v == 0 goto label;
v = v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionHolder sessionHolder>;
if v == null goto label;
label:
v = v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionHolder sessionHolder>;
virtualinvoke v.<org.apache.activemq.jms.pool.SessionHolder: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.jms.pool.PooledSession: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Throwable)>(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[])>("Ignoring exception on close as discarding session: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Throwable)>(v, v);
label:
v = v.<org.apache.activemq.jms.pool.PooledSession: org.apache.commons.pool.KeyedObjectPool sessionPool>;
v = v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionKey key>;
v = v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionHolder sessionHolder>;
interfaceinvoke v.<org.apache.commons.pool.KeyedObjectPool: void invalidateObject(java.lang.Object,java.lang.Object)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.jms.pool.PooledSession: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Exception)>(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[])>("Ignoring exception on invalidateObject as discarding session: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Throwable)>(v, v);
goto label;
label:
v = v.<org.apache.activemq.jms.pool.PooledSession: org.apache.commons.pool.KeyedObjectPool sessionPool>;
v = v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionKey key>;
v = v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionHolder sessionHolder>;
interfaceinvoke v.<org.apache.commons.pool.KeyedObjectPool: void returnObject(java.lang.Object,java.lang.Object)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new javax.jms.IllegalStateException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String toString()>();
specialinvoke v.<javax.jms.IllegalStateException: void <init>(java.lang.String)>(v);
virtualinvoke v.<javax.jms.IllegalStateException: java.lang.Throwable initCause(java.lang.Throwable)>(v);
throw v;
label:
v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionHolder sessionHolder> = null;
label:
return;
catch javax.jms.JMSException from label to label with label;
catch javax.jms.JMSException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch javax.jms.JMSException from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
public void commit() throws javax.jms.JMSException
{
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
interfaceinvoke v.<javax.jms.Session: void commit()>();
return;
}
public javax.jms.BytesMessage createBytesMessage() throws javax.jms.JMSException
{
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.BytesMessage v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.BytesMessage createBytesMessage()>();
return v;
}
public javax.jms.MapMessage createMapMessage() throws javax.jms.JMSException
{
javax.jms.MapMessage v;
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.MapMessage createMapMessage()>();
return v;
}
public javax.jms.Message createMessage() throws javax.jms.JMSException
{
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.Message v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.Message createMessage()>();
return v;
}
public javax.jms.ObjectMessage createObjectMessage() throws javax.jms.JMSException
{
javax.jms.ObjectMessage v;
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.ObjectMessage createObjectMessage()>();
return v;
}
public javax.jms.ObjectMessage createObjectMessage(java.io.Serializable) throws javax.jms.JMSException
{
javax.jms.Session v;
javax.jms.ObjectMessage v;
org.apache.activemq.jms.pool.PooledSession v;
java.io.Serializable v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: java.io.Serializable;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.ObjectMessage createObjectMessage(java.io.Serializable)>(v);
return v;
}
public javax.jms.Queue createQueue(java.lang.String) throws javax.jms.JMSException
{
javax.jms.Queue v;
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
java.lang.String v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.Queue createQueue(java.lang.String)>(v);
return v;
}
public javax.jms.StreamMessage createStreamMessage() throws javax.jms.JMSException
{
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.StreamMessage v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.StreamMessage createStreamMessage()>();
return v;
}
public javax.jms.TemporaryQueue createTemporaryQueue() throws javax.jms.JMSException
{
javax.jms.Session v;
java.util.Iterator v;
java.lang.Object v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.TemporaryQueue v;
boolean v;
java.util.concurrent.CopyOnWriteArrayList v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.TemporaryQueue createTemporaryQueue()>();
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList sessionEventListeners>;
v = virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: 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()>();
interfaceinvoke v.<org.apache.activemq.jms.pool.PooledSessionEventListener: void onTemporaryQueueCreate(javax.jms.TemporaryQueue)>(v);
goto label;
label:
return v;
}
public javax.jms.TemporaryTopic createTemporaryTopic() throws javax.jms.JMSException
{
javax.jms.Session v;
java.util.Iterator v;
javax.jms.TemporaryTopic v;
java.lang.Object v;
org.apache.activemq.jms.pool.PooledSession v;
boolean v;
java.util.concurrent.CopyOnWriteArrayList v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.TemporaryTopic createTemporaryTopic()>();
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList sessionEventListeners>;
v = virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: 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()>();
interfaceinvoke v.<org.apache.activemq.jms.pool.PooledSessionEventListener: void onTemporaryTopicCreate(javax.jms.TemporaryTopic)>(v);
goto label;
label:
return v;
}
public void unsubscribe(java.lang.String) throws javax.jms.JMSException
{
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
java.lang.String v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
interfaceinvoke v.<javax.jms.Session: void unsubscribe(java.lang.String)>(v);
return;
}
public javax.jms.TextMessage createTextMessage() throws javax.jms.JMSException
{
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.TextMessage v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.TextMessage createTextMessage()>();
return v;
}
public javax.jms.TextMessage createTextMessage(java.lang.String) throws javax.jms.JMSException
{
javax.jms.Session v;
javax.jms.TextMessage v;
org.apache.activemq.jms.pool.PooledSession v;
java.lang.String v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.TextMessage createTextMessage(java.lang.String)>(v);
return v;
}
public javax.jms.Topic createTopic(java.lang.String) throws javax.jms.JMSException
{
javax.jms.Session v;
javax.jms.Topic v;
org.apache.activemq.jms.pool.PooledSession v;
java.lang.String v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.Topic createTopic(java.lang.String)>(v);
return v;
}
public int getAcknowledgeMode() throws javax.jms.JMSException
{
int v;
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: int getAcknowledgeMode()>();
return v;
}
public boolean getTransacted() throws javax.jms.JMSException
{
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: boolean getTransacted()>();
return v;
}
public void recover() throws javax.jms.JMSException
{
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
interfaceinvoke v.<javax.jms.Session: void recover()>();
return;
}
public void rollback() throws javax.jms.JMSException
{
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
interfaceinvoke v.<javax.jms.Session: void rollback()>();
return;
}
public javax.transaction.xa.XAResource getXAResource()
{
javax.transaction.xa.XAResource v;
javax.jms.Session v, v;
org.apache.activemq.jms.pool.SessionHolder v;
org.apache.activemq.jms.pool.PooledSession v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionHolder safeGetSessionHolder()>();
v = virtualinvoke v.<org.apache.activemq.jms.pool.SessionHolder: javax.jms.Session getSession()>();
v = v instanceof javax.jms.XASession;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.jms.pool.SessionHolder: javax.jms.Session getSession()>();
v = interfaceinvoke v.<javax.jms.XASession: javax.transaction.xa.XAResource getXAResource()>();
return v;
label:
return null;
}
public javax.jms.Session getSession()
{
org.apache.activemq.jms.pool.PooledSession v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
return v;
}
public void run()
{
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
org.apache.activemq.jms.pool.SessionHolder v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionHolder safeGetSessionHolder()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.jms.pool.SessionHolder: javax.jms.Session getSession()>();
interfaceinvoke v.<javax.jms.Session: void run()>();
label:
return;
}
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue) throws javax.jms.JMSException
{
javax.jms.Queue v;
javax.jms.QueueBrowser v, v;
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Queue;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.QueueBrowser createBrowser(javax.jms.Queue)>(v);
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.QueueBrowser addQueueBrowser(javax.jms.QueueBrowser)>(v);
return v;
}
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue, java.lang.String) throws javax.jms.JMSException
{
javax.jms.Queue v;
javax.jms.QueueBrowser v, v;
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
java.lang.String v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Queue;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.QueueBrowser createBrowser(javax.jms.Queue,java.lang.String)>(v, v);
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.QueueBrowser addQueueBrowser(javax.jms.QueueBrowser)>(v);
return v;
}
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Session v;
javax.jms.MessageConsumer v, v;
javax.jms.Destination v;
org.apache.activemq.jms.pool.PooledSession v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Destination;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.MessageConsumer createConsumer(javax.jms.Destination)>(v);
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.MessageConsumer addConsumer(javax.jms.MessageConsumer)>(v);
return v;
}
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination, java.lang.String) throws javax.jms.JMSException
{
javax.jms.Session v;
javax.jms.MessageConsumer v, v;
javax.jms.Destination v;
org.apache.activemq.jms.pool.PooledSession v;
java.lang.String v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Destination;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.MessageConsumer createConsumer(javax.jms.Destination,java.lang.String)>(v, v);
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.MessageConsumer addConsumer(javax.jms.MessageConsumer)>(v);
return v;
}
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination, java.lang.String, boolean) throws javax.jms.JMSException
{
javax.jms.Session v;
javax.jms.MessageConsumer v, v;
javax.jms.Destination v;
org.apache.activemq.jms.pool.PooledSession v;
java.lang.String v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Destination;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.MessageConsumer createConsumer(javax.jms.Destination,java.lang.String,boolean)>(v, v, v);
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.MessageConsumer addConsumer(javax.jms.MessageConsumer)>(v);
return v;
}
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic, java.lang.String) throws javax.jms.JMSException
{
javax.jms.Session v;
javax.jms.Topic v;
org.apache.activemq.jms.pool.PooledSession v;
java.lang.String v;
javax.jms.TopicSubscriber v, v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Topic;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic,java.lang.String)>(v, v);
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.TopicSubscriber addTopicSubscriber(javax.jms.TopicSubscriber)>(v);
return v;
}
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic, java.lang.String, java.lang.String, boolean) throws javax.jms.JMSException
{
javax.jms.Topic v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.Session v;
java.lang.String v, v;
javax.jms.TopicSubscriber v, v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Topic;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic,java.lang.String,java.lang.String,boolean)>(v, v, v, v);
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.TopicSubscriber addTopicSubscriber(javax.jms.TopicSubscriber)>(v);
return v;
}
public javax.jms.MessageListener getMessageListener() throws javax.jms.JMSException
{
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.MessageListener v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.MessageListener getMessageListener()>();
return v;
}
public void setMessageListener(javax.jms.MessageListener) throws javax.jms.JMSException
{
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.MessageListener v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.MessageListener;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
interfaceinvoke v.<javax.jms.Session: void setMessageListener(javax.jms.MessageListener)>(v);
return;
}
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic) throws javax.jms.JMSException
{
javax.jms.Session v;
javax.jms.Topic v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.TopicSubscriber v, v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Topic;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic)>(v);
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.TopicSubscriber addTopicSubscriber(javax.jms.TopicSubscriber)>(v);
return v;
}
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic, java.lang.String, boolean) throws javax.jms.JMSException
{
javax.jms.Session v;
javax.jms.Topic v;
org.apache.activemq.jms.pool.PooledSession v;
java.lang.String v;
javax.jms.TopicSubscriber v, v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Topic;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic,java.lang.String,boolean)>(v, v, v);
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.TopicSubscriber addTopicSubscriber(javax.jms.TopicSubscriber)>(v);
return v;
}
public javax.jms.QueueReceiver createReceiver(javax.jms.Queue) throws javax.jms.JMSException
{
javax.jms.Queue v;
javax.jms.Session v;
javax.jms.QueueReceiver v, v;
org.apache.activemq.jms.pool.PooledSession v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Queue;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.QueueSession: javax.jms.QueueReceiver createReceiver(javax.jms.Queue)>(v);
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.QueueReceiver addQueueReceiver(javax.jms.QueueReceiver)>(v);
return v;
}
public javax.jms.QueueReceiver createReceiver(javax.jms.Queue, java.lang.String) throws javax.jms.JMSException
{
javax.jms.Queue v;
javax.jms.Session v;
javax.jms.QueueReceiver v, v;
org.apache.activemq.jms.pool.PooledSession v;
java.lang.String v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Queue;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.QueueSession: javax.jms.QueueReceiver createReceiver(javax.jms.Queue,java.lang.String)>(v, v);
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.QueueReceiver addQueueReceiver(javax.jms.QueueReceiver)>(v);
return v;
}
public javax.jms.MessageProducer createProducer(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
org.apache.activemq.jms.pool.PooledProducer v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.MessageProducer v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Destination;
v = new org.apache.activemq.jms.pool.PooledProducer;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.MessageProducer getMessageProducer(javax.jms.Destination)>(v);
specialinvoke v.<org.apache.activemq.jms.pool.PooledProducer: void <init>(javax.jms.MessageProducer,javax.jms.Destination)>(v, v);
return v;
}
public javax.jms.QueueSender createSender(javax.jms.Queue) throws javax.jms.JMSException
{
javax.jms.Queue v;
org.apache.activemq.jms.pool.PooledQueueSender v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.QueueSender v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Queue;
v = new org.apache.activemq.jms.pool.PooledQueueSender;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.QueueSender getQueueSender(javax.jms.Queue)>(v);
specialinvoke v.<org.apache.activemq.jms.pool.PooledQueueSender: void <init>(javax.jms.QueueSender,javax.jms.Destination)>(v, v);
return v;
}
public javax.jms.TopicPublisher createPublisher(javax.jms.Topic) throws javax.jms.JMSException
{
org.apache.activemq.jms.pool.PooledTopicPublisher v;
javax.jms.Topic v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.TopicPublisher v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Topic;
v = new org.apache.activemq.jms.pool.PooledTopicPublisher;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.TopicPublisher getTopicPublisher(javax.jms.Topic)>(v);
specialinvoke v.<org.apache.activemq.jms.pool.PooledTopicPublisher: void <init>(javax.jms.TopicPublisher,javax.jms.Destination)>(v, v);
return v;
}
public javax.jms.Session getInternalSession() throws java.lang.IllegalStateException
{
javax.jms.Session v;
org.apache.activemq.jms.pool.PooledSession v;
org.apache.activemq.jms.pool.SessionHolder v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionHolder safeGetSessionHolder()>();
v = virtualinvoke v.<org.apache.activemq.jms.pool.SessionHolder: javax.jms.Session getSession()>();
return v;
}
public javax.jms.MessageProducer getMessageProducer() throws javax.jms.JMSException
{
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.MessageProducer v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.MessageProducer getMessageProducer(javax.jms.Destination)>(null);
return v;
}
public javax.jms.MessageProducer getMessageProducer(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Session v;
javax.jms.Destination v;
org.apache.activemq.jms.pool.SessionHolder v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.MessageProducer v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Destination;
v = v.<org.apache.activemq.jms.pool.PooledSession: boolean useAnonymousProducers>;
if v == 0 goto label;
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionHolder safeGetSessionHolder()>();
v = virtualinvoke v.<org.apache.activemq.jms.pool.SessionHolder: javax.jms.MessageProducer getOrCreateProducer()>();
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.MessageProducer createProducer(javax.jms.Destination)>(v);
label:
return v;
}
public javax.jms.QueueSender getQueueSender() throws javax.jms.JMSException
{
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.QueueSender v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.QueueSender getQueueSender(javax.jms.Queue)>(null);
return v;
}
public javax.jms.QueueSender getQueueSender(javax.jms.Queue) throws javax.jms.JMSException
{
javax.jms.Queue v;
javax.jms.Session v;
org.apache.activemq.jms.pool.SessionHolder v;
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.QueueSender v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Queue;
v = v.<org.apache.activemq.jms.pool.PooledSession: boolean useAnonymousProducers>;
if v == 0 goto label;
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionHolder safeGetSessionHolder()>();
v = virtualinvoke v.<org.apache.activemq.jms.pool.SessionHolder: javax.jms.QueueSender getOrCreateSender()>();
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.QueueSession: javax.jms.QueueSender createSender(javax.jms.Queue)>(v);
label:
return v;
}
public javax.jms.TopicPublisher getTopicPublisher() throws javax.jms.JMSException
{
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.TopicPublisher v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.TopicPublisher getTopicPublisher(javax.jms.Topic)>(null);
return v;
}
public javax.jms.TopicPublisher getTopicPublisher(javax.jms.Topic) throws javax.jms.JMSException
{
javax.jms.Session v;
org.apache.activemq.jms.pool.SessionHolder v;
javax.jms.Topic v;
org.apache.activemq.jms.pool.PooledSession v;
boolean v;
javax.jms.TopicPublisher v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.Topic;
v = v.<org.apache.activemq.jms.pool.PooledSession: boolean useAnonymousProducers>;
if v == 0 goto label;
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionHolder safeGetSessionHolder()>();
v = virtualinvoke v.<org.apache.activemq.jms.pool.SessionHolder: javax.jms.TopicPublisher getOrCreatePublisher()>();
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledSession: javax.jms.Session getInternalSession()>();
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.TopicPublisher createPublisher(javax.jms.Topic)>(v);
label:
return v;
}
private javax.jms.QueueBrowser addQueueBrowser(javax.jms.QueueBrowser)
{
javax.jms.QueueBrowser v;
org.apache.activemq.jms.pool.PooledSession v;
java.util.concurrent.CopyOnWriteArrayList v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.QueueBrowser;
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList browsers>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: boolean add(java.lang.Object)>(v);
return v;
}
private javax.jms.MessageConsumer addConsumer(javax.jms.MessageConsumer)
{
org.apache.activemq.jms.pool.PooledMessageConsumer v;
javax.jms.MessageConsumer v;
org.apache.activemq.jms.pool.PooledSession v;
java.util.concurrent.CopyOnWriteArrayList v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.MessageConsumer;
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList consumers>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: boolean add(java.lang.Object)>(v);
v = new org.apache.activemq.jms.pool.PooledMessageConsumer;
specialinvoke v.<org.apache.activemq.jms.pool.PooledMessageConsumer: void <init>(org.apache.activemq.jms.pool.PooledSession,javax.jms.MessageConsumer)>(v, v);
return v;
}
private javax.jms.TopicSubscriber addTopicSubscriber(javax.jms.TopicSubscriber)
{
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.TopicSubscriber v;
java.util.concurrent.CopyOnWriteArrayList v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.TopicSubscriber;
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList consumers>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: boolean add(java.lang.Object)>(v);
return v;
}
private javax.jms.QueueReceiver addQueueReceiver(javax.jms.QueueReceiver)
{
javax.jms.QueueReceiver v;
org.apache.activemq.jms.pool.PooledSession v;
java.util.concurrent.CopyOnWriteArrayList v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.QueueReceiver;
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList consumers>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: boolean add(java.lang.Object)>(v);
return v;
}
public void setIsXa(boolean)
{
org.apache.activemq.jms.pool.PooledSession v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: boolean;
v.<org.apache.activemq.jms.pool.PooledSession: boolean isXa> = v;
return;
}
public java.lang.String toString()
{
org.apache.activemq.jms.pool.PooledSession v;
java.lang.String v;
org.apache.activemq.jms.pool.SessionHolder v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionHolder safeGetSessionHolder()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.jms.pool.SessionHolder)>(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[])>("PooledSession { \u }");
return v;
}
protected void onConsumerClose(javax.jms.MessageConsumer)
{
org.apache.activemq.jms.pool.PooledSession v;
javax.jms.MessageConsumer v;
java.util.concurrent.CopyOnWriteArrayList v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v := @parameter: javax.jms.MessageConsumer;
v = v.<org.apache.activemq.jms.pool.PooledSession: java.util.concurrent.CopyOnWriteArrayList consumers>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: boolean remove(java.lang.Object)>(v);
return;
}
private org.apache.activemq.jms.pool.SessionHolder safeGetSessionHolder()
{
java.lang.IllegalStateException v;
org.apache.activemq.jms.pool.PooledSession v;
org.apache.activemq.jms.pool.SessionHolder v;
v := @this: org.apache.activemq.jms.pool.PooledSession;
v = v.<org.apache.activemq.jms.pool.PooledSession: org.apache.activemq.jms.pool.SessionHolder sessionHolder>;
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("The session has already been closed");
throw v;
label:
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/jms/pool/PooledSession;");
<org.apache.activemq.jms.pool.PooledSession: org.slf4j.Logger LOG> = v;
return;
}
}