public class org.apache.activemq.osgi.cf.ConnectionFactoryProvider extends java.lang.Object
{
private static final java.lang.String OSGI_JNDI_SERVICE_NAME;
private org.osgi.framework.ServiceRegistration reg;
public void <init>()
{
org.apache.activemq.osgi.cf.ConnectionFactoryProvider v;
v := @this: org.apache.activemq.osgi.cf.ConnectionFactoryProvider;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void create(org.osgi.service.component.ComponentContext)
{
org.osgi.service.component.ComponentContext v;
long v;
java.lang.Integer v, v;
org.apache.activemq.osgi.cf.ConnectionFactoryProvider v;
java.lang.Long v;
int v, v;
java.lang.String v, v, v, v, v, v, v;
java.util.Hashtable v;
org.osgi.framework.ServiceRegistration v;
org.osgi.framework.BundleContext v;
org.apache.activemq.ActiveMQConnectionFactory v;
org.apache.activemq.jms.pool.PooledConnectionFactory v;
java.util.Dictionary v;
v := @this: org.apache.activemq.osgi.cf.ConnectionFactoryProvider;
v := @parameter: org.osgi.service.component.ComponentContext;
v = interfaceinvoke v.<org.osgi.service.component.ComponentContext: org.osgi.framework.BundleContext getBundleContext()>();
v = interfaceinvoke v.<org.osgi.service.component.ComponentContext: java.util.Dictionary getProperties()>();
v = specialinvoke v.<org.apache.activemq.osgi.cf.ConnectionFactoryProvider: java.lang.String getString(java.util.Dictionary,java.lang.String,java.lang.String)>(v, "url", "tcp://localhost:61616");
v = specialinvoke v.<org.apache.activemq.osgi.cf.ConnectionFactoryProvider: java.lang.String getString(java.util.Dictionary,java.lang.String,java.lang.String)>(v, "osgi.jndi.service.name", "jms/local");
v = specialinvoke v.<org.apache.activemq.osgi.cf.ConnectionFactoryProvider: java.lang.String getString(java.util.Dictionary,java.lang.String,java.lang.String)>(v, "userName", null);
v = specialinvoke v.<org.apache.activemq.osgi.cf.ConnectionFactoryProvider: java.lang.String getString(java.util.Dictionary,java.lang.String,java.lang.String)>(v, "password", null);
v = new java.lang.Long;
v = specialinvoke v.<org.apache.activemq.osgi.cf.ConnectionFactoryProvider: java.lang.String getString(java.util.Dictionary,java.lang.String,java.lang.String)>(v, "expiryTimeout", "0");
specialinvoke v.<java.lang.Long: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = new java.lang.Integer;
v = specialinvoke v.<org.apache.activemq.osgi.cf.ConnectionFactoryProvider: java.lang.String getString(java.util.Dictionary,java.lang.String,java.lang.String)>(v, "idleTimeout", "30000");
specialinvoke v.<java.lang.Integer: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = new java.lang.Integer;
v = specialinvoke v.<org.apache.activemq.osgi.cf.ConnectionFactoryProvider: java.lang.String getString(java.util.Dictionary,java.lang.String,java.lang.String)>(v, "maxConnections", "8");
specialinvoke v.<java.lang.Integer: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = new org.apache.activemq.ActiveMQConnectionFactory;
specialinvoke v.<org.apache.activemq.ActiveMQConnectionFactory: void <init>(java.lang.String)>(v);
if v == null goto label;
virtualinvoke v.<org.apache.activemq.ActiveMQConnectionFactory: void setUserName(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.ActiveMQConnectionFactory: void setPassword(java.lang.String)>(v);
label:
v = new org.apache.activemq.jms.pool.PooledConnectionFactory;
specialinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: void <init>()>();
virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: void setConnectionFactory(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: void setExpiryTimeout(long)>(v);
virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: void setIdleTimeout(int)>(v);
virtualinvoke v.<org.apache.activemq.jms.pool.PooledConnectionFactory: void setMaxConnections(int)>(v);
v = new java.util.Hashtable;
specialinvoke v.<java.util.Hashtable: void <init>()>();
virtualinvoke v.<java.util.Dictionary: java.lang.Object put(java.lang.Object,java.lang.Object)>("osgi.jndi.service.name", v);
v = interfaceinvoke v.<org.osgi.framework.BundleContext: org.osgi.framework.ServiceRegistration registerService(java.lang.Class,java.lang.Object,java.util.Dictionary)>(class "Ljavax/jms/ConnectionFactory;", v, v);
v.<org.apache.activemq.osgi.cf.ConnectionFactoryProvider: org.osgi.framework.ServiceRegistration reg> = v;
return;
}
public void deactivate()
{
org.apache.activemq.osgi.cf.ConnectionFactoryProvider v;
org.osgi.framework.ServiceRegistration v;
v := @this: org.apache.activemq.osgi.cf.ConnectionFactoryProvider;
v = v.<org.apache.activemq.osgi.cf.ConnectionFactoryProvider: org.osgi.framework.ServiceRegistration reg>;
interfaceinvoke v.<org.osgi.framework.ServiceRegistration: void unregister()>();
return;
}
private java.lang.String getString(java.util.Dictionary, java.lang.String, java.lang.String)
{
java.lang.Object v;
java.lang.String v, v, v;
java.util.Dictionary v;
org.apache.activemq.osgi.cf.ConnectionFactoryProvider v;
v := @this: org.apache.activemq.osgi.cf.ConnectionFactoryProvider;
v := @parameter: java.util.Dictionary;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<java.util.Dictionary: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
goto label;
label:
v = v;
label:
return v;
}
}