public class org.apache.activemq.ActiveMQConnectionFactory extends org.apache.activemq.jndi.JNDIBaseStorable implements javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory, org.apache.activemq.management.StatsCapable, java.lang.Cloneable { private static final org.slf4j.Logger LOG; private static final java.lang.String DEFAULT_BROKER_HOST; private static final int DEFAULT_BROKER_PORT; public static final java.lang.String DEFAULT_BROKER_BIND_URL; public static final java.lang.String DEFAULT_BROKER_URL; public static final java.lang.String DEFAULT_USER; public static final java.lang.String DEFAULT_PASSWORD; public static final int DEFAULT_PRODUCER_WINDOW_SIZE; protected java.net.URI brokerURL; protected java.lang.String userName; protected java.lang.String password; protected java.lang.String clientID; protected boolean dispatchAsync; protected boolean alwaysSessionAsync; org.apache.activemq.management.JMSStatsImpl factoryStats; private org.apache.activemq.util.IdGenerator clientIdGenerator; private java.lang.String clientIDPrefix; private org.apache.activemq.util.IdGenerator connectionIdGenerator; private java.lang.String connectionIDPrefix; private org.apache.activemq.ActiveMQPrefetchPolicy prefetchPolicy; private org.apache.activemq.broker.region.policy.RedeliveryPolicyMap redeliveryPolicyMap; private org.apache.activemq.blob.BlobTransferPolicy blobTransferPolicy; private org.apache.activemq.MessageTransformer transformer; private boolean disableTimeStampsByDefault; private boolean optimizedMessageDispatch; private long optimizeAcknowledgeTimeOut; private long optimizedAckScheduledAckInterval; private boolean copyMessageOnSend; private boolean useCompression; private boolean objectMessageSerializationDefered; private boolean useAsyncSend; private boolean optimizeAcknowledge; private int closeTimeout; private boolean useRetroactiveConsumer; private boolean exclusiveConsumer; private boolean nestedMapAndListEnabled; private boolean alwaysSyncSend; private boolean watchTopicAdvisories; private int producerWindowSize; private long warnAboutUnstartedConnectionTimeout; private int sendTimeout; private int connectResponseTimeout; private boolean sendAcksAsync; private org.apache.activemq.transport.TransportListener transportListener; private javax.jms.ExceptionListener exceptionListener; private int auditDepth; private int auditMaximumProducerNumber; private boolean useDedicatedTaskRunner; private long consumerFailoverRedeliveryWaitPeriod; private boolean checkForDuplicates; private org.apache.activemq.ClientInternalExceptionListener clientInternalExceptionListener; private boolean messagePrioritySupported; private boolean transactedIndividualAck; private boolean nonBlockingRedelivery; private int maxThreadPoolSize; private org.apache.activemq.thread.TaskRunnerFactory sessionTaskRunner; private java.util.concurrent.RejectedExecutionHandler rejectedTaskHandler; protected int xaAckMode; private boolean rmIdFromConnectionId; private boolean consumerExpiryCheckEnabled; private java.util.List trustedPackages; private boolean trustAllPackages; public void () { java.lang.String v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = ; specialinvoke v.(java.lang.String)>(v); return; } public void (java.lang.String) { java.lang.String v; java.net.URI v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.lang.String; v = staticinvoke (v); specialinvoke v.(java.net.URI)>(v); return; } public void (java.net.URI) { org.apache.activemq.broker.region.policy.RedeliveryPolicyMap v, v; org.apache.activemq.management.JMSStatsImpl v; java.lang.String[] v; org.apache.activemq.RedeliveryPolicy v; org.apache.activemq.ActiveMQConnectionFactory v; java.util.List v; org.apache.activemq.ActiveMQPrefetchPolicy v; int v, v; org.apache.activemq.blob.BlobTransferPolicy v; java.lang.String v; java.net.URI v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.net.URI; specialinvoke v.()>(); v. = 1; v. = 1; v = new org.apache.activemq.management.JMSStatsImpl; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.ActiveMQPrefetchPolicy; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.broker.region.policy.RedeliveryPolicyMap; specialinvoke v.()>(); v. = v; v = v.; v = new org.apache.activemq.RedeliveryPolicy; specialinvoke v.()>(); virtualinvoke v.(v); v = new org.apache.activemq.blob.BlobTransferPolicy; specialinvoke v.()>(); v. = v; v. = 1; v. = 300L; v. = 0L; v. = 1; v. = 15000; v. = 1; v. = 1; v. = 0; v. = 500L; v. = 0; v. = 0; v. = 1; v. = 2048; v. = 64; v. = 0L; v. = 1; v. = 0; v. = 0; v. = 0; v = ; v. = v; v. = null; v = (int) -1; v. = v; v. = 0; v. = 1; v = ; v = staticinvoke (v); v. = v; v. = 0; v = virtualinvoke v.(); virtualinvoke v.(v); return; } public void (java.lang.String, java.lang.String, java.net.URI) { org.apache.activemq.broker.region.policy.RedeliveryPolicyMap v, v; org.apache.activemq.management.JMSStatsImpl v; java.lang.String[] v; org.apache.activemq.RedeliveryPolicy v; org.apache.activemq.ActiveMQConnectionFactory v; java.util.List v; org.apache.activemq.ActiveMQPrefetchPolicy v; int v, v; org.apache.activemq.blob.BlobTransferPolicy v; java.lang.String v, v, v; java.net.URI v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.net.URI; specialinvoke v.()>(); v. = 1; v. = 1; v = new org.apache.activemq.management.JMSStatsImpl; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.ActiveMQPrefetchPolicy; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.broker.region.policy.RedeliveryPolicyMap; specialinvoke v.()>(); v. = v; v = v.; v = new org.apache.activemq.RedeliveryPolicy; specialinvoke v.()>(); virtualinvoke v.(v); v = new org.apache.activemq.blob.BlobTransferPolicy; specialinvoke v.()>(); v. = v; v. = 1; v. = 300L; v. = 0L; v. = 1; v. = 15000; v. = 1; v. = 1; v. = 0; v. = 500L; v. = 0; v. = 0; v. = 1; v. = 2048; v. = 64; v. = 0L; v. = 1; v. = 0; v. = 0; v. = 0; v = ; v. = v; v. = null; v = (int) -1; v. = v; v. = 0; v. = 1; v = ; v = staticinvoke (v); v. = v; v. = 0; virtualinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); return; } public void (java.lang.String, java.lang.String, java.lang.String) { org.apache.activemq.broker.region.policy.RedeliveryPolicyMap v, v; org.apache.activemq.management.JMSStatsImpl v; java.lang.String[] v; org.apache.activemq.RedeliveryPolicy v; org.apache.activemq.ActiveMQConnectionFactory v; java.util.List v; org.apache.activemq.ActiveMQPrefetchPolicy v; int v, v; org.apache.activemq.blob.BlobTransferPolicy v; java.lang.String v, v, v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.()>(); v. = 1; v. = 1; v = new org.apache.activemq.management.JMSStatsImpl; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.ActiveMQPrefetchPolicy; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.broker.region.policy.RedeliveryPolicyMap; specialinvoke v.()>(); v. = v; v = v.; v = new org.apache.activemq.RedeliveryPolicy; specialinvoke v.()>(); virtualinvoke v.(v); v = new org.apache.activemq.blob.BlobTransferPolicy; specialinvoke v.()>(); v. = v; v. = 1; v. = 300L; v. = 0L; v. = 1; v. = 15000; v. = 1; v. = 1; v. = 0; v. = 500L; v. = 0; v. = 0; v. = 1; v. = 2048; v. = 64; v. = 0L; v. = 1; v. = 0; v. = 0; v. = 0; v = ; v. = v; v. = null; v = (int) -1; v. = v; v. = 0; v. = 1; v = ; v = staticinvoke (v); v. = v; v. = 0; virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); return; } public org.apache.activemq.ActiveMQConnectionFactory copy() { java.lang.Object v; java.lang.RuntimeException v; java.lang.String v; java.lang.CloneNotSupportedException v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; label: v = specialinvoke v.(); label: return v; label: v := @caughtexception; v = new java.lang.RuntimeException; v = dynamicinvoke "makeConcatWithConstants" (v) ("This should never happen: \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; catch java.lang.CloneNotSupportedException from label to label with label; } private static java.net.URI createURI(java.lang.String) { java.lang.Throwable v; java.net.URISyntaxException v; java.lang.String v, v; java.net.URI v; java.lang.IllegalArgumentException v; v := @parameter: java.lang.String; label: v = new java.net.URI; specialinvoke v.(java.lang.String)>(v); label: return v; label: v := @caughtexception; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Invalid broker URI: \u0001"); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v); throw v; catch java.net.URISyntaxException from label to label with label; } public javax.jms.Connection createConnection() throws javax.jms.JMSException { org.apache.activemq.ActiveMQConnection v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = virtualinvoke v.(); return v; } public javax.jms.Connection createConnection(java.lang.String, java.lang.String) throws javax.jms.JMSException { java.lang.String v, v; org.apache.activemq.ActiveMQConnection v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = virtualinvoke v.(v, v); return v; } public javax.jms.QueueConnection createQueueConnection() throws javax.jms.JMSException { org.apache.activemq.ActiveMQConnection v, v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } public javax.jms.QueueConnection createQueueConnection(java.lang.String, java.lang.String) throws javax.jms.JMSException { java.lang.String v, v; org.apache.activemq.ActiveMQConnection v, v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = virtualinvoke v.(v, v); v = virtualinvoke v.(); return v; } public javax.jms.TopicConnection createTopicConnection() throws javax.jms.JMSException { org.apache.activemq.ActiveMQConnection v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = virtualinvoke v.(); return v; } public javax.jms.TopicConnection createTopicConnection(java.lang.String, java.lang.String) throws javax.jms.JMSException { java.lang.String v, v; org.apache.activemq.ActiveMQConnection v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = virtualinvoke v.(v, v); return v; } public org.apache.activemq.management.StatsImpl getStats() { org.apache.activemq.management.JMSStatsImpl v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } protected org.apache.activemq.ActiveMQConnection createActiveMQConnection() throws javax.jms.JMSException { java.lang.String v, v; org.apache.activemq.ActiveMQConnection v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; v = v.; v = virtualinvoke v.(v, v); return v; } protected org.apache.activemq.transport.Transport createTransport() throws javax.jms.JMSException { java.lang.String v, v, v, v, v, v, v, v, v, v, v; java.net.URI v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v; java.io.IOException v; org.apache.activemq.transport.Transport v; javax.jms.JMSException v; java.lang.Exception v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; label: v = v.; v = v.; v = virtualinvoke v.(); if v != null goto label; v = new java.io.IOException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Transport not scheme specified: [\u]"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.("auto"); if v == 0 goto label; v = new java.net.URI; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.("auto", "tcp"); specialinvoke v.(java.lang.String)>(v); v = v; goto label; label: v = virtualinvoke v.("auto+ssl"); if v == 0 goto label; v = new java.net.URI; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.("auto+ssl", "ssl"); specialinvoke v.(java.lang.String)>(v); v = v; goto label; label: v = virtualinvoke v.("auto+nio"); if v == 0 goto label; v = new java.net.URI; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.("auto+nio", "nio"); specialinvoke v.(java.lang.String)>(v); v = v; goto label; label: v = virtualinvoke v.("auto+nio+ssl"); if v == 0 goto label; v = new java.net.URI; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.("auto+nio+ssl", "nio+ssl"); specialinvoke v.(java.lang.String)>(v); v = v; label: v = staticinvoke (v); label: return v; label: v := @caughtexception; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not create Transport. Reason: \u0001"); v = staticinvoke (v, v); throw v; catch java.lang.Exception from label to label with label; } protected org.apache.activemq.ActiveMQConnection createActiveMQConnection(java.lang.String, java.lang.String) throws javax.jms.JMSException { java.lang.Throwable v; org.apache.activemq.management.JMSStatsImpl v; org.apache.activemq.transport.Transport v; org.apache.activemq.ActiveMQConnection v; javax.jms.JMSException v; java.lang.Exception v; org.apache.activemq.ActiveMQConnectionFactory v; java.lang.String v, v, v, v, v; java.net.URI v, v; org.apache.activemq.ConfigurationException v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = v.; if v != null goto label; v = new org.apache.activemq.ConfigurationException; specialinvoke v.(java.lang.String)>("brokerURL not set."); throw v; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v, v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); interfaceinvoke v.(); v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); label: return v; label: v := @caughtexception; throw v; label: v := @caughtexception; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Could not connect to broker URL: \u. Reason: \u0001"); v = staticinvoke (v, v); throw v; catch javax.jms.JMSException from label to label with label; catch java.lang.Exception from label to label with label; } protected org.apache.activemq.ActiveMQConnection createActiveMQConnection(org.apache.activemq.transport.Transport, org.apache.activemq.management.JMSStatsImpl) throws java.lang.Exception { org.apache.activemq.management.JMSStatsImpl v; org.apache.activemq.transport.Transport v; org.apache.activemq.util.IdGenerator v, v; org.apache.activemq.ActiveMQConnection v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: org.apache.activemq.transport.Transport; v := @parameter: org.apache.activemq.management.JMSStatsImpl; v = new org.apache.activemq.ActiveMQConnection; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.transport.Transport,org.apache.activemq.util.IdGenerator,org.apache.activemq.util.IdGenerator,org.apache.activemq.management.JMSStatsImpl)>(v, v, v, v); return v; } protected void configureConnection(org.apache.activemq.ActiveMQConnection) throws javax.jms.JMSException { org.apache.activemq.transport.TransportListener v, v; java.util.concurrent.RejectedExecutionHandler v; org.apache.activemq.ActiveMQPrefetchPolicy v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.policy.RedeliveryPolicyMap v; org.apache.activemq.MessageTransformer v; org.apache.activemq.ClientInternalExceptionListener v, v; org.apache.activemq.ActiveMQConnection v; org.apache.activemq.ActiveMQConnectionFactory v; java.util.List v; org.apache.activemq.thread.TaskRunnerFactory v; org.apache.activemq.blob.BlobTransferPolicy v, v; long v, v, v, v; javax.jms.ExceptionListener v, v; int v, v, v, v, v, v, v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: org.apache.activemq.ActiveMQConnection; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); label: return; } public java.lang.String getBrokerURL() { java.lang.String v; java.net.URI v, v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; if v != null goto label; v = null; goto label; label: v = v.; v = virtualinvoke v.(); label: return v; } public void setBrokerURL(java.lang.String) { org.apache.activemq.util.URISupport$CompositeData v; java.net.URISyntaxException v, v; java.util.Map v, v, v, v; int v, v; java.lang.String v, v, v, v, v; java.net.URI v, v, v, v, v, v, v; boolean v, v, v, v; java.lang.IllegalArgumentException v, v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.lang.String; v = staticinvoke (v); v. = v; v = v.; v = virtualinvoke v.(); if v == null goto label; label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v, "jms."); v = virtualinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("There are \u jms options that couldn\'t be set on the ConnectionFactory. Check the options are spelled correctly. Unknown parameters=[\u]. This connection factory cannot be started."); v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = staticinvoke (v, v); v. = v; label: goto label; label: v := @caughtexception; goto label; label: v = v.; v = staticinvoke (v); v = virtualinvoke v.(); v = staticinvoke (v, "jms."); v = virtualinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("There are \u jms options that couldn\'t be set on the ConnectionFactory. Check the options are spelled correctly. Unknown parameters=[\u]. This connection factory cannot be started."); v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); v. = v; label: goto label; label: v := @caughtexception; label: return; catch java.net.URISyntaxException from label to label with label; catch java.net.URISyntaxException from label to label with label; } public java.lang.String getClientID() { java.lang.String v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setClientID(java.lang.String) { java.lang.String v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.lang.String; v. = v; return; } public boolean isCopyMessageOnSend() { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setCopyMessageOnSend(boolean) { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: boolean; v. = v; return; } public boolean isDisableTimeStampsByDefault() { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setDisableTimeStampsByDefault(boolean) { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: boolean; v. = v; return; } public boolean isOptimizedMessageDispatch() { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setOptimizedMessageDispatch(boolean) { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: boolean; v. = v; return; } public java.lang.String getPassword() { java.lang.String v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setPassword(java.lang.String) { java.lang.String v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.lang.String; v. = v; return; } public org.apache.activemq.ActiveMQPrefetchPolicy getPrefetchPolicy() { org.apache.activemq.ActiveMQPrefetchPolicy v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setPrefetchPolicy(org.apache.activemq.ActiveMQPrefetchPolicy) { org.apache.activemq.ActiveMQPrefetchPolicy v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: org.apache.activemq.ActiveMQPrefetchPolicy; v. = v; return; } public boolean isUseAsyncSend() { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public org.apache.activemq.blob.BlobTransferPolicy getBlobTransferPolicy() { org.apache.activemq.blob.BlobTransferPolicy v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setBlobTransferPolicy(org.apache.activemq.blob.BlobTransferPolicy) { org.apache.activemq.blob.BlobTransferPolicy v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: org.apache.activemq.blob.BlobTransferPolicy; v. = v; return; } public void setUseAsyncSend(boolean) { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: boolean; v. = v; return; } public synchronized boolean isWatchTopicAdvisories() { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public synchronized void setWatchTopicAdvisories(boolean) { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: boolean; v. = v; return; } public boolean isAlwaysSyncSend() { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setAlwaysSyncSend(boolean) { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: boolean; v. = v; return; } public java.lang.String getUserName() { java.lang.String v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setUserName(java.lang.String) { java.lang.String v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.lang.String; v. = v; return; } public boolean isUseRetroactiveConsumer() { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setUseRetroactiveConsumer(boolean) { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: boolean; v. = v; return; } public boolean isExclusiveConsumer() { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setExclusiveConsumer(boolean) { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: boolean; v. = v; return; } public org.apache.activemq.RedeliveryPolicy getRedeliveryPolicy() { org.apache.activemq.RedeliveryPolicy v; org.apache.activemq.broker.region.policy.RedeliveryPolicyMap v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; v = virtualinvoke v.(); return v; } public void setRedeliveryPolicy(org.apache.activemq.RedeliveryPolicy) { org.apache.activemq.RedeliveryPolicy v; org.apache.activemq.broker.region.policy.RedeliveryPolicyMap v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: org.apache.activemq.RedeliveryPolicy; v = v.; virtualinvoke v.(v); return; } public org.apache.activemq.broker.region.policy.RedeliveryPolicyMap getRedeliveryPolicyMap() { org.apache.activemq.broker.region.policy.RedeliveryPolicyMap v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setRedeliveryPolicyMap(org.apache.activemq.broker.region.policy.RedeliveryPolicyMap) { org.apache.activemq.broker.region.policy.RedeliveryPolicyMap v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: org.apache.activemq.broker.region.policy.RedeliveryPolicyMap; v. = v; return; } public org.apache.activemq.MessageTransformer getTransformer() { org.apache.activemq.MessageTransformer v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public int getSendTimeout() { int v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setSendTimeout(int) { int v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: int; v. = v; return; } public boolean isSendAcksAsync() { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setSendAcksAsync(boolean) { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: boolean; v. = v; return; } public boolean isMessagePrioritySupported() { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v = v.; return v; } public void setMessagePrioritySupported(boolean) { boolean v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: boolean; v. = v; return; } public void setTransformer(org.apache.activemq.MessageTransformer) { org.apache.activemq.MessageTransformer v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: org.apache.activemq.MessageTransformer; v. = v; return; } public void buildFromProperties(java.util.Properties) { java.util.Properties v, v; int v, v; java.util.HashMap v; java.lang.String v; org.apache.activemq.ActiveMQConnectionFactory v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.util.Properties; if v != null goto label; v = new java.util.Properties; specialinvoke v.()>(); v = v; label: v = virtualinvoke v.("java.naming.provider.url"); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; label: v = virtualinvoke v.("brokerURL"); label: if v == null goto label; v = virtualinvoke v.(); if v <= 0 goto label; virtualinvoke v.(v); label: v = new java.util.HashMap; specialinvoke v.(java.util.Map)>(v); virtualinvoke v.(v); return; } public boolean buildFromMap(java.util.Map) { org.apache.activemq.RedeliveryPolicy v; org.apache.activemq.ActiveMQConnectionFactory v; org.apache.activemq.ActiveMQPrefetchPolicy v; java.util.Map v; org.apache.activemq.blob.BlobTransferPolicy v; boolean v, v, v, v, v, v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.util.Map; v = 0; v = new org.apache.activemq.ActiveMQPrefetchPolicy; specialinvoke v.()>(); v = staticinvoke (v, v, "prefetchPolicy."); if v == 0 goto label; virtualinvoke v.(v); v = 1; label: v = new org.apache.activemq.RedeliveryPolicy; specialinvoke v.()>(); v = staticinvoke (v, v, "redeliveryPolicy."); if v == 0 goto label; virtualinvoke v.(v); v = 1; label: v = new org.apache.activemq.blob.BlobTransferPolicy; specialinvoke v.()>(); v = staticinvoke (v, v, "blobTransferPolicy."); if v == 0 goto label; virtualinvoke v.(v); v = 1; label: v = staticinvoke (v, v); v = v | v; return v; } public void populateProperties(java.util.Properties) { org.apache.activemq.ActiveMQPrefetchPolicy v; org.apache.activemq.ActiveMQConnectionFactory v; org.apache.activemq.blob.BlobTransferPolicy v; long v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Properties v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.RedeliveryPolicy v; int v, v, v, v, v, v, v; v := @this: org.apache.activemq.ActiveMQConnectionFactory; v := @parameter: java.util.Properties; v = virtualinvoke v.