public class org.apache.activemq.jms.pool.PooledConnectionFactory extends java.lang.Object implements javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory
{
private static final transient org.slf4j.Logger LOG;
protected final java.util.concurrent.atomic.AtomicBoolean stopped;
private org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool;
protected java.lang.Object connectionFactory;
private int maximumActiveSessionPerConnection;
private int idleTimeout;
private int connectionTimeout;
private boolean blockIfSessionPoolIsFull;
private long blockIfSessionPoolIsFullTimeout;
private long expiryTimeout;
private boolean createConnectionOnStartup;
private boolean useAnonymousProducers;
private boolean reconnectOnException;
private final java.util.concurrent.atomic.AtomicReference mostRecentlyCreated;
public void <init>()
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
java.util.concurrent.atomic.AtomicBoolean v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: java.util.concurrent.atomic.AtomicBoolean stopped> = v;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: int maximumActiveSessionPerConnection> = 500;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: int idleTimeout> = 30000;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: int connectionTimeout> = 30000;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean blockIfSessionPoolIsFull> = 1;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: long blockIfSessionPoolIsFullTimeout> = -1L;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: long expiryTimeout> = 0L;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean createConnectionOnStartup> = 1;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean useAnonymousProducers> = 1;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean reconnectOnException> = 1;
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(null);
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: java.util.concurrent.atomic.AtomicReference mostRecentlyCreated> = v;
return;
}
public void initConnectionsPool()
{
org.apache.commons.pool.impl.GenericKeyedObjectPool v, v, v, v, v, v, v;
org.apache.activemq.jms.pool.PooledConnectionFactory$1 v;
int v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
org.apache.commons.pool.impl.GenericKeyedObjectPoolConfig v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool>;
if v != null goto label;
v = new org.apache.commons.pool.impl.GenericKeyedObjectPoolConfig;
specialinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPoolConfig: void <init>()>();
virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPoolConfig: void setJmxEnabled(boolean)>(0);
v = new org.apache.commons.pool.impl.GenericKeyedObjectPool;
v = new org.apache.activemq.jms.pool.PooledConnectionFactory$1;
specialinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory$1: void <init>(org.apache.activemq.jms.pool.PooledConnectionFactory)>(v);
specialinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: void <init>(org.apache.commons.pool.KeyedPooledObjectFactory,org.apache.commons.pool.impl.GenericKeyedObjectPoolConfig)>(v, v);
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool> = v;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool>;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: int getConnectionTimeout()>();
virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: void setMaxWaitMillis(long)>(v);
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool>;
virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: void setMaxIdlePerKey(int)>(1);
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool>;
virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: void setLifo(boolean)>(0);
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool>;
virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: void setTestOnBorrow(boolean)>(1);
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool>;
virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: void setTestWhileIdle(boolean)>(1);
label:
return;
}
public java.lang.Object getConnectionFactory()
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
java.lang.Object v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: java.lang.Object connectionFactory>;
return v;
}
public void setConnectionFactory(java.lang.Object)
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
java.lang.Object v;
java.lang.IllegalArgumentException v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: java.lang.Object;
v = v instanceof javax.jms.ConnectionFactory;
if v == 0 goto label;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: java.lang.Object connectionFactory> = v;
goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("connectionFactory should implement javax.jms.ConnectionFactory");
throw v;
label:
return;
}
public javax.jms.QueueConnection createQueueConnection() throws javax.jms.JMSException
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
javax.jms.Connection v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: javax.jms.Connection createConnection()>();
return v;
}
public javax.jms.QueueConnection createQueueConnection(java.lang.String, java.lang.String) throws javax.jms.JMSException
{
javax.jms.Connection v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
java.lang.String v, v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: javax.jms.Connection createConnection(java.lang.String,java.lang.String)>(v, v);
return v;
}
public javax.jms.TopicConnection createTopicConnection() throws javax.jms.JMSException
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
javax.jms.Connection v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: javax.jms.Connection createConnection()>();
return v;
}
public javax.jms.TopicConnection createTopicConnection(java.lang.String, java.lang.String) throws javax.jms.JMSException
{
javax.jms.Connection v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
java.lang.String v, v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: javax.jms.Connection createConnection(java.lang.String,java.lang.String)>(v, v);
return v;
}
public javax.jms.Connection createConnection() throws javax.jms.JMSException
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
javax.jms.Connection v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: javax.jms.Connection createConnection(java.lang.String,java.lang.String)>(null, null);
return v;
}
public synchronized javax.jms.Connection createConnection(java.lang.String, java.lang.String) throws javax.jms.JMSException
{
java.util.concurrent.atomic.AtomicBoolean v;
java.util.concurrent.atomic.AtomicReference v;
int v, v;
java.lang.String v, v, v, v;
java.util.NoSuchElementException v;
boolean v, v;
javax.jms.Connection v;
org.slf4j.Logger v;
org.apache.commons.pool.impl.GenericKeyedObjectPool v, v, v;
javax.jms.JMSException v, v;
java.lang.Exception v, v;
org.apache.activemq.jms.pool.ConnectionKey v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
java.lang.Object v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: java.util.concurrent.atomic.AtomicBoolean stopped>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
v = <org.apache.activemq.jms.pool.PooledConnectionFactory: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("PooledConnectionFactory is stopped, skip create new connection.");
return null;
label:
v = new org.apache.activemq.jms.pool.ConnectionKey;
specialinvoke v.<org.apache.activemq.jms.pool.ConnectionKey: void <init>(java.lang.String,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool getConnectionsPool()>();
v = virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: int getNumIdle(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: int getMaxConnections()>();
if v >= v goto label;
label:
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool>;
virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: void addObject(java.lang.Object)>(v);
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: java.util.concurrent.atomic.AtomicReference mostRecentlyCreated>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object getAndSet(java.lang.Object)>(null);
virtualinvoke v.<org.apache.activemq.jms.pool.ConnectionPool: void incrementReferenceCount()>();
label:
goto label;
label:
v := @caughtexception;
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: javax.jms.JMSException createJmsException(java.lang.String,java.lang.Exception)>("Error while attempting to add new Connection to the pool", v);
throw v;
label:
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool>;
virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: java.lang.Object borrowObject(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
v = "Timeout waiting for idle object";
v = virtualinvoke v.<java.util.NoSuchElementException: java.lang.String getMessage()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
throw v;
label:
v := @caughtexception;
v = specialinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: javax.jms.JMSException createJmsException(java.lang.String,java.lang.Exception)>("Error while attempting to retrieve a connection from the pool", v);
throw v;
label:
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: javax.jms.Connection newPooledConnection(org.apache.activemq.jms.pool.ConnectionPool)>(v);
return v;
catch java.lang.Exception from label to label with label;
catch java.util.NoSuchElementException from label to label with label;
catch java.lang.Exception from label to label with label;
}
protected javax.jms.Connection newPooledConnection(org.apache.activemq.jms.pool.ConnectionPool)
{
org.apache.activemq.jms.pool.PooledConnection v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
org.apache.activemq.jms.pool.ConnectionPool v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: org.apache.activemq.jms.pool.ConnectionPool;
v = new org.apache.activemq.jms.pool.PooledConnection;
specialinvoke v.<org.apache.activemq.jms.pool.PooledConnection: void <init>(org.apache.activemq.jms.pool.ConnectionPool)>(v);
return v;
}
private javax.jms.JMSException createJmsException(java.lang.String, java.lang.Exception)
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
java.lang.String v;
javax.jms.JMSException v;
java.lang.Exception v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Exception;
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);
virtualinvoke v.<javax.jms.JMSException: java.lang.Throwable initCause(java.lang.Throwable)>(v);
return v;
}
protected javax.jms.Connection createConnection(org.apache.activemq.jms.pool.ConnectionKey) throws javax.jms.JMSException
{
java.lang.IllegalStateException v;
javax.jms.Connection v, v;
org.apache.activemq.jms.pool.ConnectionKey v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
java.lang.Object v, v, v;
java.lang.String v, v, v, v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: org.apache.activemq.jms.pool.ConnectionKey;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: java.lang.Object connectionFactory>;
v = v instanceof javax.jms.ConnectionFactory;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.jms.pool.ConnectionKey: java.lang.String getUserName()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.jms.pool.ConnectionKey: java.lang.String getPassword()>();
if v != null goto label;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: java.lang.Object connectionFactory>;
v = interfaceinvoke v.<javax.jms.ConnectionFactory: javax.jms.Connection createConnection()>();
return v;
label:
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: java.lang.Object connectionFactory>;
v = virtualinvoke v.<org.apache.activemq.jms.pool.ConnectionKey: java.lang.String getUserName()>();
v = virtualinvoke v.<org.apache.activemq.jms.pool.ConnectionKey: java.lang.String getPassword()>();
v = interfaceinvoke v.<javax.jms.ConnectionFactory: javax.jms.Connection createConnection(java.lang.String,java.lang.String)>(v, v);
return v;
label:
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("connectionFactory should implement javax.jms.ConnectionFactory");
throw v;
}
public void start()
{
java.lang.Throwable v;
javax.jms.Connection v;
org.slf4j.Logger v, v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
java.lang.Boolean v;
boolean v, v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = <org.apache.activemq.jms.pool.PooledConnectionFactory: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean isCreateConnectionOnStartup()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Staring the PooledConnectionFactory: create on start = {}", v);
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: java.util.concurrent.atomic.AtomicBoolean stopped>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean isCreateConnectionOnStartup()>();
if v == 0 goto label;
label:
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: javax.jms.Connection createConnection()>();
interfaceinvoke v.<javax.jms.Connection: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.jms.pool.PooledConnectionFactory: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Create pooled connection during start failed. This exception will be ignored.", v);
label:
return;
catch javax.jms.JMSException from label to label with label;
}
public void stop()
{
org.slf4j.Logger v;
org.apache.commons.pool.impl.GenericKeyedObjectPool v, v, v, v;
java.util.concurrent.atomic.AtomicBoolean v;
java.lang.Integer v;
java.lang.Exception v;
int v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: java.util.concurrent.atomic.AtomicBoolean stopped>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = <org.apache.activemq.jms.pool.PooledConnectionFactory: org.slf4j.Logger LOG>;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool>;
if v == null goto label;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool>;
v = virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: int getNumActive()>();
goto label;
label:
v = 0;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Stopping the PooledConnectionFactory, number of connections in cache: {}", v);
label:
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool>;
if v == null goto label;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool>;
virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: void close()>();
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool> = null;
label:
goto label;
label:
v := @caughtexception;
label:
return;
catch java.lang.Exception from label to label with label;
}
public void clear()
{
org.apache.commons.pool.impl.GenericKeyedObjectPool v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
java.util.concurrent.atomic.AtomicBoolean v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: java.util.concurrent.atomic.AtomicBoolean stopped>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
return;
label:
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool getConnectionsPool()>();
virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: void clear()>();
return;
}
public int getMaximumActiveSessionPerConnection()
{
int v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: int maximumActiveSessionPerConnection>;
return v;
}
public void setMaximumActiveSessionPerConnection(int)
{
int v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: int;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: int maximumActiveSessionPerConnection> = v;
return;
}
public void setBlockIfSessionPoolIsFull(boolean)
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: boolean;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean blockIfSessionPoolIsFull> = v;
return;
}
public boolean isBlockIfSessionPoolIsFull()
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean blockIfSessionPoolIsFull>;
return v;
}
public int getMaxConnections()
{
int v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
org.apache.commons.pool.impl.GenericKeyedObjectPool v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool getConnectionsPool()>();
v = virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: int getMaxIdlePerKey()>();
return v;
}
public void setMaxConnections(int)
{
org.apache.commons.pool.impl.GenericKeyedObjectPool v, v;
int v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: int;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool getConnectionsPool()>();
virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: void setMaxIdlePerKey(int)>(v);
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool getConnectionsPool()>();
virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: void setMaxTotalPerKey(int)>(v);
return;
}
public int getIdleTimeout()
{
int v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: int idleTimeout>;
return v;
}
public void setIdleTimeout(int)
{
int v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: int;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: int idleTimeout> = v;
return;
}
public int getConnectionTimeout()
{
int v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: int connectionTimeout>;
return v;
}
public void setConnectionTimeout(int)
{
int v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: int;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: int connectionTimeout> = v;
return;
}
public void setExpiryTimeout(long)
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
long v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: long;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: long expiryTimeout> = v;
return;
}
public long getExpiryTimeout()
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
long v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: long expiryTimeout>;
return v;
}
public boolean isCreateConnectionOnStartup()
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean createConnectionOnStartup>;
return v;
}
public void setCreateConnectionOnStartup(boolean)
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: boolean;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean createConnectionOnStartup> = v;
return;
}
public boolean isUseAnonymousProducers()
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean useAnonymousProducers>;
return v;
}
public void setUseAnonymousProducers(boolean)
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: boolean;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean useAnonymousProducers> = v;
return;
}
protected org.apache.commons.pool.impl.GenericKeyedObjectPool getConnectionsPool()
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
org.apache.commons.pool.impl.GenericKeyedObjectPool v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: void initConnectionsPool()>();
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool connectionsPool>;
return v;
}
public void setTimeBetweenExpirationCheckMillis(long)
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
long v;
org.apache.commons.pool.impl.GenericKeyedObjectPool v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: long;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool getConnectionsPool()>();
virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: void setTimeBetweenEvictionRunsMillis(long)>(v);
return;
}
public long getTimeBetweenExpirationCheckMillis()
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
long v;
org.apache.commons.pool.impl.GenericKeyedObjectPool v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool getConnectionsPool()>();
v = virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: long getTimeBetweenEvictionRunsMillis()>();
return v;
}
public int getNumConnections()
{
int v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
org.apache.commons.pool.impl.GenericKeyedObjectPool v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: org.apache.commons.pool.impl.GenericKeyedObjectPool getConnectionsPool()>();
v = virtualinvoke v.<org.apache.commons.pool.impl.GenericKeyedObjectPool: int getNumIdle()>();
return v;
}
protected org.apache.activemq.jms.pool.ConnectionPool createConnectionPool(javax.jms.Connection)
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
javax.jms.Connection v;
org.apache.activemq.jms.pool.ConnectionPool v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: javax.jms.Connection;
v = new org.apache.activemq.jms.pool.ConnectionPool;
specialinvoke v.<org.apache.activemq.jms.pool.ConnectionPool: void <init>(javax.jms.Connection)>(v);
return v;
}
public long getBlockIfSessionPoolIsFullTimeout()
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
long v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: long blockIfSessionPoolIsFullTimeout>;
return v;
}
public void setBlockIfSessionPoolIsFullTimeout(long)
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
long v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: long;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: long blockIfSessionPoolIsFullTimeout> = v;
return;
}
public boolean isReconnectOnException()
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v = v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean reconnectOnException>;
return v;
}
public void setReconnectOnException(boolean)
{
org.apache.activemq.jms.pool.PooledConnectionFactory v;
boolean v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: boolean;
v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean reconnectOnException> = v;
return;
}
protected void populateProperties(java.util.Properties)
{
long v, v, v;
int v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
boolean v, v, v;
java.util.Properties v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
v := @this: org.apache.activemq.jms.pool.PooledConnectionFactory;
v := @parameter: java.util.Properties;
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: int getMaximumActiveSessionPerConnection()>();
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("maximumActiveSessionPerConnection", v);
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: int getMaxConnections()>();
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("maxConnections", v);
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: int getIdleTimeout()>();
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("idleTimeout", v);
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: long getExpiryTimeout()>();
v = staticinvoke <java.lang.Long: java.lang.String toString(long)>(v);
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("expiryTimeout", v);
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: long getTimeBetweenExpirationCheckMillis()>();
v = staticinvoke <java.lang.Long: java.lang.String toString(long)>(v);
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("timeBetweenExpirationCheckMillis", v);
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean isCreateConnectionOnStartup()>();
v = staticinvoke <java.lang.Boolean: java.lang.String toString(boolean)>(v);
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("createConnectionOnStartup", v);
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean isUseAnonymousProducers()>();
v = staticinvoke <java.lang.Boolean: java.lang.String toString(boolean)>(v);
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("useAnonymousProducers", v);
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: long getBlockIfSessionPoolIsFullTimeout()>();
v = staticinvoke <java.lang.Long: java.lang.String toString(long)>(v);
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("blockIfSessionPoolIsFullTimeout", v);
v = virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: boolean isReconnectOnException()>();
v = staticinvoke <java.lang.Boolean: java.lang.String toString(boolean)>(v);
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("reconnectOnException", v);
return;
}
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/PooledConnectionFactory;");
<org.apache.activemq.jms.pool.PooledConnectionFactory: org.slf4j.Logger LOG> = v;
return;
}
}