public class org.apache.activemq.ActiveMQMessageProducer extends org.apache.activemq.ActiveMQMessageProducerSupport implements org.apache.activemq.management.StatsCapable, org.apache.activemq.Disposable
{
private static final org.slf4j.Logger LOG;
protected org.apache.activemq.command.ProducerInfo info;
protected boolean closed;
private final org.apache.activemq.management.JMSProducerStatsImpl stats;
private java.util.concurrent.atomic.AtomicLong messageSequence;
private final long startTime;
private org.apache.activemq.MessageTransformer transformer;
private org.apache.activemq.usage.MemoryUsage producerWindow;
protected void <init>(org.apache.activemq.ActiveMQSession, org.apache.activemq.command.ProducerId, org.apache.activemq.command.ActiveMQDestination, int) throws javax.jms.JMSException
{
org.apache.activemq.management.JMSProducerStatsImpl v;
java.util.Map v, v, v;
org.apache.activemq.usage.MemoryUsage v, v, v, v;
org.apache.activemq.management.JMSSessionStatsImpl v;
org.apache.activemq.MessageTransformer v;
org.apache.activemq.ActiveMQConnection v, v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.ActiveMQSession v, v, v, v;
java.lang.Throwable v;
java.util.concurrent.ThreadPoolExecutor v;
org.apache.activemq.ActiveMQMessageProducer v;
java.util.HashMap v;
long v;
int v, v, v, v, v, v, v;
java.lang.String v, v;
org.apache.activemq.ConfigurationException v;
org.slf4j.Logger v;
org.apache.activemq.command.ProducerId v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.command.ProducerInfo v, v, v, v, v, v, v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v := @parameter: org.apache.activemq.ActiveMQSession;
v := @parameter: org.apache.activemq.command.ProducerId;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v := @parameter: int;
specialinvoke v.<org.apache.activemq.ActiveMQMessageProducerSupport: void <init>(org.apache.activemq.ActiveMQSession)>(v);
v = new org.apache.activemq.command.ProducerInfo;
specialinvoke v.<org.apache.activemq.command.ProducerInfo: void <init>(org.apache.activemq.command.ProducerId)>(v);
v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info> = v;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
v = v.<org.apache.activemq.ActiveMQSession: org.apache.activemq.ActiveMQConnection connection>;
v = virtualinvoke v.<org.apache.activemq.ActiveMQConnection: int getProducerWindowSize()>();
virtualinvoke v.<org.apache.activemq.command.ProducerInfo: void setWindowSize(int)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.util.Map getOptions()>();
if v == null goto label;
v = new java.util.HashMap;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.util.Map getOptions()>();
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = staticinvoke <org.apache.activemq.util.IntrospectionSupport: java.util.Map extractProperties(java.util.Map,java.lang.String)>(v, "producer.");
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
staticinvoke <org.apache.activemq.util.IntrospectionSupport: boolean setProperties(java.lang.Object,java.util.Map)>(v, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v <= 0 goto label;
v = interfaceinvoke v.<java.util.Map: int size()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,java.util.Map)>(v, 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[])>("There are \u producer options that couldn\'t be set on the producer. Check the options are spelled correctly. Unknown parameters=[\u]. This producer cannot be started.");
v = <org.apache.activemq.ActiveMQMessageProducer: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
v = new org.apache.activemq.ConfigurationException;
specialinvoke v.<org.apache.activemq.ConfigurationException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
virtualinvoke v.<org.apache.activemq.command.ProducerInfo: void setDestination(org.apache.activemq.command.ActiveMQDestination)>(v);
v = v.<org.apache.activemq.ActiveMQSession: org.apache.activemq.ActiveMQConnection connection>;
v = virtualinvoke v.<org.apache.activemq.ActiveMQConnection: int getProtocolVersion()>();
if v < 3 goto label;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: int getWindowSize()>();
if v <= 0 goto label;
v = new org.apache.activemq.usage.MemoryUsage;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.ProducerId)>(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[])>("Producer Window: \u0001");
specialinvoke v.<org.apache.activemq.usage.MemoryUsage: void <init>(java.lang.String)>(v);
v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.usage.MemoryUsage producerWindow> = v;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.usage.MemoryUsage producerWindow>;
v = virtualinvoke v.<org.apache.activemq.ActiveMQSession: java.util.concurrent.ThreadPoolExecutor getConnectionExecutor()>();
virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: void setExecutor(java.util.concurrent.ThreadPoolExecutor)>(v);
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.usage.MemoryUsage producerWindow>;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: int getWindowSize()>();
virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: void setLimit(long)>(v);
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.usage.MemoryUsage producerWindow>;
virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: void start()>();
label:
v.<org.apache.activemq.ActiveMQMessageProducer: int defaultDeliveryMode> = 2;
v.<org.apache.activemq.ActiveMQMessageProducer: int defaultPriority> = 4;
v.<org.apache.activemq.ActiveMQMessageProducer: long defaultTimeToLive> = 0L;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v.<org.apache.activemq.ActiveMQMessageProducer: long startTime> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<org.apache.activemq.ActiveMQMessageProducer: java.util.concurrent.atomic.AtomicLong messageSequence> = v;
v = new org.apache.activemq.management.JMSProducerStatsImpl;
v = virtualinvoke v.<org.apache.activemq.ActiveMQSession: org.apache.activemq.management.JMSSessionStatsImpl getSessionStats()>();
specialinvoke v.<org.apache.activemq.management.JMSProducerStatsImpl: void <init>(org.apache.activemq.management.JMSSessionStatsImpl,javax.jms.Destination)>(v, v);
v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.management.JMSProducerStatsImpl stats> = v;
label:
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.ActiveMQSession session>;
virtualinvoke v.<org.apache.activemq.ActiveMQSession: void addProducer(org.apache.activemq.ActiveMQMessageProducer)>(v);
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.ActiveMQSession session>;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
virtualinvoke v.<org.apache.activemq.ActiveMQSession: org.apache.activemq.command.Response syncSendPacket(org.apache.activemq.command.Command)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.ActiveMQSession session>;
virtualinvoke v.<org.apache.activemq.ActiveMQSession: void removeProducer(org.apache.activemq.ActiveMQMessageProducer)>(v);
throw v;
label:
virtualinvoke v.<org.apache.activemq.ActiveMQMessageProducer: void setSendTimeout(int)>(v);
v = virtualinvoke v.<org.apache.activemq.ActiveMQSession: org.apache.activemq.MessageTransformer getTransformer()>();
virtualinvoke v.<org.apache.activemq.ActiveMQMessageProducer: void setTransformer(org.apache.activemq.MessageTransformer)>(v);
return;
catch javax.jms.JMSException from label to label with label;
}
public org.apache.activemq.management.StatsImpl getStats()
{
org.apache.activemq.ActiveMQMessageProducer v;
org.apache.activemq.management.JMSProducerStatsImpl v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.management.JMSProducerStatsImpl stats>;
return v;
}
public org.apache.activemq.management.JMSProducerStatsImpl getProducerStats()
{
org.apache.activemq.ActiveMQMessageProducer v;
org.apache.activemq.management.JMSProducerStatsImpl v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.management.JMSProducerStatsImpl stats>;
return v;
}
public javax.jms.Destination getDestination() throws javax.jms.JMSException
{
org.apache.activemq.ActiveMQMessageProducer v;
org.apache.activemq.command.ProducerInfo v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
virtualinvoke v.<org.apache.activemq.ActiveMQMessageProducer: void checkClosed()>();
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
return v;
}
public void close() throws javax.jms.JMSException
{
org.apache.activemq.command.ProducerInfo v;
org.apache.activemq.ActiveMQMessageProducer v;
org.apache.activemq.ActiveMQSession v;
org.apache.activemq.command.RemoveInfo v;
boolean v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v = v.<org.apache.activemq.ActiveMQMessageProducer: boolean closed>;
if v != 0 goto label;
virtualinvoke v.<org.apache.activemq.ActiveMQMessageProducer: void dispose()>();
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.ActiveMQSession session>;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.RemoveInfo createRemoveCommand()>();
virtualinvoke v.<org.apache.activemq.ActiveMQSession: void asyncSendPacket(org.apache.activemq.command.Command)>(v);
label:
return;
}
public void dispose()
{
org.apache.activemq.ActiveMQMessageProducer v;
org.apache.activemq.usage.MemoryUsage v, v;
org.apache.activemq.ActiveMQSession v;
boolean v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v = v.<org.apache.activemq.ActiveMQMessageProducer: boolean closed>;
if v != 0 goto label;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.ActiveMQSession session>;
virtualinvoke v.<org.apache.activemq.ActiveMQSession: void removeProducer(org.apache.activemq.ActiveMQMessageProducer)>(v);
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.usage.MemoryUsage producerWindow>;
if v == null goto label;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.usage.MemoryUsage producerWindow>;
virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: void stop()>();
label:
v.<org.apache.activemq.ActiveMQMessageProducer: boolean closed> = 1;
label:
return;
}
protected void checkClosed() throws javax.jms.IllegalStateException
{
org.apache.activemq.ActiveMQMessageProducer v;
javax.jms.IllegalStateException v;
boolean v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v = v.<org.apache.activemq.ActiveMQMessageProducer: boolean closed>;
if v == 0 goto label;
v = new javax.jms.IllegalStateException;
specialinvoke v.<javax.jms.IllegalStateException: void <init>(java.lang.String)>("The producer is closed");
throw v;
label:
return;
}
public void send(javax.jms.Destination, javax.jms.Message, int, int, long) throws javax.jms.JMSException
{
javax.jms.Destination v;
int v, v;
org.apache.activemq.ActiveMQMessageProducer v;
long v;
javax.jms.Message v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v := @parameter: javax.jms.Destination;
v := @parameter: javax.jms.Message;
v := @parameter: int;
v := @parameter: int;
v := @parameter: long;
virtualinvoke v.<org.apache.activemq.ActiveMQMessageProducer: void send(javax.jms.Destination,javax.jms.Message,int,int,long,org.apache.activemq.AsyncCallback)>(v, v, v, v, v, null);
return;
}
public void send(javax.jms.Message, org.apache.activemq.AsyncCallback) throws javax.jms.JMSException
{
javax.jms.Destination v;
int v, v;
org.apache.activemq.ActiveMQMessageProducer v;
org.apache.activemq.AsyncCallback v;
long v;
javax.jms.Message v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v := @parameter: javax.jms.Message;
v := @parameter: org.apache.activemq.AsyncCallback;
v = virtualinvoke v.<org.apache.activemq.ActiveMQMessageProducer: javax.jms.Destination getDestination()>();
v = v.<org.apache.activemq.ActiveMQMessageProducer: int defaultDeliveryMode>;
v = v.<org.apache.activemq.ActiveMQMessageProducer: int defaultPriority>;
v = v.<org.apache.activemq.ActiveMQMessageProducer: long defaultTimeToLive>;
virtualinvoke v.<org.apache.activemq.ActiveMQMessageProducer: void send(javax.jms.Destination,javax.jms.Message,int,int,long,org.apache.activemq.AsyncCallback)>(v, v, v, v, v, v);
return;
}
public void send(javax.jms.Destination, javax.jms.Message, org.apache.activemq.AsyncCallback) throws javax.jms.JMSException
{
javax.jms.Destination v;
int v, v;
org.apache.activemq.ActiveMQMessageProducer v;
org.apache.activemq.AsyncCallback v;
long v;
javax.jms.Message v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v := @parameter: javax.jms.Destination;
v := @parameter: javax.jms.Message;
v := @parameter: org.apache.activemq.AsyncCallback;
v = v.<org.apache.activemq.ActiveMQMessageProducer: int defaultDeliveryMode>;
v = v.<org.apache.activemq.ActiveMQMessageProducer: int defaultPriority>;
v = v.<org.apache.activemq.ActiveMQMessageProducer: long defaultTimeToLive>;
virtualinvoke v.<org.apache.activemq.ActiveMQMessageProducer: void send(javax.jms.Destination,javax.jms.Message,int,int,long,org.apache.activemq.AsyncCallback)>(v, v, v, v, v, v);
return;
}
public void send(javax.jms.Message, int, int, long, org.apache.activemq.AsyncCallback) throws javax.jms.JMSException
{
javax.jms.Destination v;
int v, v;
org.apache.activemq.ActiveMQMessageProducer v;
org.apache.activemq.AsyncCallback v;
long v;
javax.jms.Message v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v := @parameter: javax.jms.Message;
v := @parameter: int;
v := @parameter: int;
v := @parameter: long;
v := @parameter: org.apache.activemq.AsyncCallback;
v = virtualinvoke v.<org.apache.activemq.ActiveMQMessageProducer: javax.jms.Destination getDestination()>();
virtualinvoke v.<org.apache.activemq.ActiveMQMessageProducer: void send(javax.jms.Destination,javax.jms.Message,int,int,long,org.apache.activemq.AsyncCallback)>(v, v, v, v, v, v);
return;
}
public void send(javax.jms.Destination, javax.jms.Message, int, int, long, org.apache.activemq.AsyncCallback) throws javax.jms.JMSException
{
org.apache.activemq.management.JMSProducerStatsImpl v;
org.apache.activemq.usage.MemoryUsage v, v, v;
boolean v;
org.apache.activemq.MessageTransformer v, v;
org.apache.activemq.AsyncCallback v;
javax.jms.JMSException v, v;
org.apache.activemq.command.ActiveMQDestination v, v, v, v;
javax.jms.Destination v;
org.apache.activemq.ActiveMQSession v, v;
org.apache.activemq.ActiveMQMessageProducer v;
long v;
int v, v, v;
javax.jms.InvalidDestinationException v;
java.lang.String v, v;
javax.jms.Message v, v;
java.lang.UnsupportedOperationException v, v;
java.lang.InterruptedException v;
org.apache.activemq.command.ProducerInfo v, v, v, v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v := @parameter: javax.jms.Destination;
v := @parameter: javax.jms.Message;
v := @parameter: int;
v := @parameter: int;
v := @parameter: long;
v := @parameter: org.apache.activemq.AsyncCallback;
virtualinvoke v.<org.apache.activemq.ActiveMQMessageProducer: void checkClosed()>();
if v != null goto label;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
if v != null goto label;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("A destination must be specified.");
throw v;
label:
v = new javax.jms.InvalidDestinationException;
specialinvoke v.<javax.jms.InvalidDestinationException: void <init>(java.lang.String)>("Don\'t understand null destinations");
throw v;
label:
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
if v != null goto label;
v = staticinvoke <org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination transform(javax.jms.Destination)>(v);
goto label;
label:
v = new java.lang.UnsupportedOperationException;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("This producer can only send messages to: \u0001");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
label:
if v != null goto label;
v = new javax.jms.JMSException;
specialinvoke v.<javax.jms.JMSException: void <init>(java.lang.String)>("No destination specified");
throw v;
label:
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.MessageTransformer transformer>;
if v == null goto label;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.MessageTransformer transformer>;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.ActiveMQSession session>;
v = interfaceinvoke v.<org.apache.activemq.MessageTransformer: javax.jms.Message producerTransform(javax.jms.Session,javax.jms.MessageProducer,javax.jms.Message)>(v, v, v);
if v == null goto label;
v = v;
label:
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.usage.MemoryUsage producerWindow>;
if v == null goto label;
label:
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.usage.MemoryUsage producerWindow>;
virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: void waitForSpace()>();
label:
goto label;
label:
v := @caughtexception;
v = new javax.jms.JMSException;
specialinvoke v.<javax.jms.JMSException: void <init>(java.lang.String)>("Send aborted due to thread interrupt.");
throw v;
label:
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.ActiveMQSession session>;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.usage.MemoryUsage producerWindow>;
v = v.<org.apache.activemq.ActiveMQMessageProducer: int sendTimeout>;
virtualinvoke v.<org.apache.activemq.ActiveMQSession: void send(org.apache.activemq.ActiveMQMessageProducer,org.apache.activemq.command.ActiveMQDestination,javax.jms.Message,int,int,long,org.apache.activemq.usage.MemoryUsage,int,org.apache.activemq.AsyncCallback)>(v, v, v, v, v, v, v, v, v);
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.management.JMSProducerStatsImpl stats>;
virtualinvoke v.<org.apache.activemq.management.JMSProducerStatsImpl: void onMessage()>();
return;
catch java.lang.InterruptedException from label to label with label;
}
public org.apache.activemq.MessageTransformer getTransformer()
{
org.apache.activemq.ActiveMQMessageProducer v;
org.apache.activemq.MessageTransformer v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.MessageTransformer transformer>;
return v;
}
public void setTransformer(org.apache.activemq.MessageTransformer)
{
org.apache.activemq.ActiveMQMessageProducer v;
org.apache.activemq.MessageTransformer v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v := @parameter: org.apache.activemq.MessageTransformer;
v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.MessageTransformer transformer> = v;
return;
}
protected long getStartTime()
{
org.apache.activemq.ActiveMQMessageProducer v;
long v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v = v.<org.apache.activemq.ActiveMQMessageProducer: long startTime>;
return v;
}
protected long getMessageSequence()
{
org.apache.activemq.ActiveMQMessageProducer v;
java.util.concurrent.atomic.AtomicLong v;
long v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v = v.<org.apache.activemq.ActiveMQMessageProducer: java.util.concurrent.atomic.AtomicLong messageSequence>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long incrementAndGet()>();
return v;
}
protected void setMessageSequence(java.util.concurrent.atomic.AtomicLong)
{
org.apache.activemq.ActiveMQMessageProducer v;
java.util.concurrent.atomic.AtomicLong v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v := @parameter: java.util.concurrent.atomic.AtomicLong;
v.<org.apache.activemq.ActiveMQMessageProducer: java.util.concurrent.atomic.AtomicLong messageSequence> = v;
return;
}
protected org.apache.activemq.command.ProducerInfo getProducerInfo()
{
org.apache.activemq.ActiveMQMessageProducer v;
org.apache.activemq.command.ProducerInfo v, v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
if v == null goto label;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
goto label;
label:
v = null;
label:
return v;
}
protected void setProducerInfo(org.apache.activemq.command.ProducerInfo)
{
org.apache.activemq.ActiveMQMessageProducer v;
org.apache.activemq.command.ProducerInfo v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v := @parameter: org.apache.activemq.command.ProducerInfo;
v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info> = v;
return;
}
public java.lang.String toString()
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.command.ProducerInfo v;
org.apache.activemq.ActiveMQMessageProducer v;
java.lang.String v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ProducerId getProducerId()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.ProducerId)>(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[])>("ActiveMQMessageProducer { value=\u }");
return v;
}
public void onProducerAck(org.apache.activemq.command.ProducerAck)
{
org.apache.activemq.command.ProducerAck v;
int v;
org.apache.activemq.ActiveMQMessageProducer v;
org.apache.activemq.usage.MemoryUsage v, v;
v := @this: org.apache.activemq.ActiveMQMessageProducer;
v := @parameter: org.apache.activemq.command.ProducerAck;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.usage.MemoryUsage producerWindow>;
if v == null goto label;
v = v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.usage.MemoryUsage producerWindow>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerAck: int getSize()>();
virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: void decreaseUsage(long)>(v);
label:
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/ActiveMQMessageProducer;");
<org.apache.activemq.ActiveMQMessageProducer: org.slf4j.Logger LOG> = v;
return;
}
}