public class org.apache.activemq.util.ProducerThread extends java.lang.Thread
{
private static final org.slf4j.Logger LOG;
int messageCount;
boolean runIndefinitely;
javax.jms.Destination destination;
protected javax.jms.Session session;
int sleep;
boolean persistent;
int messageSize;
int textMessageSize;
long msgTTL;
java.lang.String msgGroupID;
int transactionBatchSize;
int transactions;
java.util.concurrent.atomic.AtomicInteger sentCount;
java.lang.String message;
java.lang.String messageText;
java.lang.String payloadUrl;
byte[] payload;
boolean running;
java.util.concurrent.CountDownLatch finished;
java.util.concurrent.CountDownLatch paused;
public void <init>(javax.jms.Session, javax.jms.Destination)
{
java.util.concurrent.CountDownLatch v;
javax.jms.Session v;
java.util.concurrent.atomic.AtomicInteger v;
javax.jms.Destination v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: javax.jms.Session;
v := @parameter: javax.jms.Destination;
specialinvoke v.<java.lang.Thread: void <init>()>();
v.<org.apache.activemq.util.ProducerThread: int messageCount> = 1000;
v.<org.apache.activemq.util.ProducerThread: boolean runIndefinitely> = 0;
v.<org.apache.activemq.util.ProducerThread: int sleep> = 0;
v.<org.apache.activemq.util.ProducerThread: boolean persistent> = 1;
v.<org.apache.activemq.util.ProducerThread: int messageSize> = 0;
v.<org.apache.activemq.util.ProducerThread: long msgTTL> = 0L;
v.<org.apache.activemq.util.ProducerThread: java.lang.String msgGroupID> = null;
v.<org.apache.activemq.util.ProducerThread: int transactions> = 0;
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(0);
v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.atomic.AtomicInteger sentCount> = v;
v.<org.apache.activemq.util.ProducerThread: java.lang.String messageText> = null;
v.<org.apache.activemq.util.ProducerThread: java.lang.String payloadUrl> = null;
v.<org.apache.activemq.util.ProducerThread: byte[] payload> = null;
v.<org.apache.activemq.util.ProducerThread: boolean running> = 0;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(0);
v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.CountDownLatch paused> = v;
v.<org.apache.activemq.util.ProducerThread: javax.jms.Destination destination> = v;
v.<org.apache.activemq.util.ProducerThread: javax.jms.Session session> = v;
return;
}
public void run()
{
javax.jms.Session v;
byte v;
java.util.concurrent.atomic.AtomicInteger v, v, v, v;
java.lang.Thread v;
javax.jms.MessageProducer v, v;
org.apache.activemq.util.ProducerThread v;
boolean v, v, v, v;
java.lang.Exception v;
java.util.concurrent.CountDownLatch v, v, v, v, v, v, v, v;
javax.jms.Destination v;
java.lang.Throwable v, v, v;
long v, v, v, v, v, v;
int v, v, v;
java.lang.String v, v, v, v, v;
org.slf4j.Logger v, v, v, v;
v := @this: org.apache.activemq.util.ProducerThread;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = virtualinvoke v.<java.lang.Thread: java.lang.String getName()>();
label:
v = v.<org.apache.activemq.util.ProducerThread: javax.jms.Session session>;
v = v.<org.apache.activemq.util.ProducerThread: javax.jms.Destination destination>;
v = interfaceinvoke v.<javax.jms.Session: javax.jms.MessageProducer createProducer(javax.jms.Destination)>(v);
v = v;
v = v.<org.apache.activemq.util.ProducerThread: boolean persistent>;
if v == 0 goto label;
v = 2;
goto label;
label:
v = 1;
label:
interfaceinvoke v.<javax.jms.MessageProducer: void setDeliveryMode(int)>(v);
v = v.<org.apache.activemq.util.ProducerThread: long msgTTL>;
interfaceinvoke v.<javax.jms.MessageProducer: void setTimeToLive(long)>(v);
specialinvoke v.<org.apache.activemq.util.ProducerThread: void initPayLoad()>();
v.<org.apache.activemq.util.ProducerThread: boolean running> = 1;
v = <org.apache.activemq.util.ProducerThread: org.slf4j.Logger LOG>;
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[])>("\u Started to calculate elapsed time ...\n");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v.<org.apache.activemq.util.ProducerThread: boolean runIndefinitely>;
if v == 0 goto label;
label:
v = v.<org.apache.activemq.util.ProducerThread: boolean running>;
if v == 0 goto label;
entermonitor v;
label:
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.CountDownLatch paused>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
specialinvoke v.<org.apache.activemq.util.ProducerThread: void sendMessage(javax.jms.MessageProducer,java.lang.String)>(v, v);
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.atomic.AtomicInteger sentCount>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int incrementAndGet()>();
goto label;
label:
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.atomic.AtomicInteger sentCount>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: void set(int)>(0);
label:
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.atomic.AtomicInteger sentCount>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
v = v.<org.apache.activemq.util.ProducerThread: int messageCount>;
if v >= v goto label;
v = v.<org.apache.activemq.util.ProducerThread: boolean running>;
if v == 0 goto label;
entermonitor v;
label:
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.CountDownLatch paused>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
specialinvoke v.<org.apache.activemq.util.ProducerThread: void sendMessage(javax.jms.MessageProducer,java.lang.String)>(v, v);
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.atomic.AtomicInteger sentCount>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int incrementAndGet()>();
goto label;
label:
v = <org.apache.activemq.util.ProducerThread: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.activemq.util.ProducerThread: int getSentCount()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(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[])>("\u Produced: \u messages");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
v = v / 1000L;
v = <org.apache.activemq.util.ProducerThread: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,long)>(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[])>("\u Elapsed time in second : \u s");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = <org.apache.activemq.util.ProducerThread: org.slf4j.Logger LOG>;
v = v - v;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,long)>(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[])>("\u Elapsed time in milli second : \u milli seconds");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
label:
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.CountDownLatch finished>;
if v == null goto label;
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.CountDownLatch finished>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.Exception: void printStackTrace()>();
label:
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.CountDownLatch finished>;
if v == null goto label;
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.CountDownLatch finished>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.CountDownLatch finished>;
if v == null goto label;
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.CountDownLatch finished>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
label:
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private void sendMessage(javax.jms.MessageProducer, java.lang.String) throws java.lang.Exception
{
javax.jms.Session v;
java.util.concurrent.atomic.AtomicInteger v, v, v;
int v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v;
javax.jms.MessageProducer v;
javax.jms.Message v;
org.apache.activemq.util.ProducerThread v;
boolean v, v;
org.slf4j.Logger v, v, v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: javax.jms.MessageProducer;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.atomic.AtomicInteger sentCount>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
v = virtualinvoke v.<org.apache.activemq.util.ProducerThread: javax.jms.Message createMessage(int)>(v);
interfaceinvoke v.<javax.jms.MessageProducer: void send(javax.jms.Message)>(v);
v = <org.apache.activemq.util.ProducerThread: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.activemq.util.ProducerThread: org.slf4j.Logger LOG>;
v = v instanceof javax.jms.TextMessage;
if v == 0 goto label;
v = interfaceinvoke v.<javax.jms.TextMessage: java.lang.String getText()>();
goto label;
label:
v = interfaceinvoke v.<javax.jms.Message: java.lang.String getJMSMessageID()>();
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("\u Sent: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
v = v.<org.apache.activemq.util.ProducerThread: int transactionBatchSize>;
if v <= 0 goto label;
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.atomic.AtomicInteger sentCount>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
if v <= 0 goto label;
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.atomic.AtomicInteger sentCount>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
v = v.<org.apache.activemq.util.ProducerThread: int transactionBatchSize>;
v = v % v;
if v != 0 goto label;
v = <org.apache.activemq.util.ProducerThread: org.slf4j.Logger LOG>;
v = v.<org.apache.activemq.util.ProducerThread: int transactions>;
v = v + 1;
v.<org.apache.activemq.util.ProducerThread: int transactions> = v;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(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[])>("\u Committing transaction: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = v.<org.apache.activemq.util.ProducerThread: javax.jms.Session session>;
interfaceinvoke v.<javax.jms.Session: void commit()>();
label:
v = v.<org.apache.activemq.util.ProducerThread: int sleep>;
if v <= 0 goto label;
v = v.<org.apache.activemq.util.ProducerThread: int sleep>;
staticinvoke <java.lang.Thread: void sleep(long)>(v);
label:
return;
}
private void initPayLoad()
{
byte[] v, v, v;
int v, v, v, v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: int messageSize>;
if v <= 0 goto label;
v = v.<org.apache.activemq.util.ProducerThread: int messageSize>;
v = newarray (byte)[v];
v.<org.apache.activemq.util.ProducerThread: byte[] payload> = v;
v = 0;
label:
v = v.<org.apache.activemq.util.ProducerThread: byte[] payload>;
v = lengthof v;
if v >= v goto label;
v = v.<org.apache.activemq.util.ProducerThread: byte[] payload>;
v[v] = 46;
v = v + 1;
goto label;
label:
return;
}
protected javax.jms.Message createMessage(int) throws java.lang.Exception
{
byte[] v, v;
java.net.URL v;
javax.jms.Session v, v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.util.ProducerThread v;
boolean v;
java.lang.Class v;
java.lang.Object v;
java.io.InputStream v, v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: int;
v = v.<org.apache.activemq.util.ProducerThread: byte[] payload>;
if v == null goto label;
v = v.<org.apache.activemq.util.ProducerThread: javax.jms.Session session>;
v = interfaceinvoke v.<javax.jms.Session: javax.jms.BytesMessage createBytesMessage()>();
v = v.<org.apache.activemq.util.ProducerThread: byte[] payload>;
interfaceinvoke v.<javax.jms.BytesMessage: void writeBytes(byte[])>(v);
goto label;
label:
v = v.<org.apache.activemq.util.ProducerThread: int textMessageSize>;
if v <= 0 goto label;
v = v.<org.apache.activemq.util.ProducerThread: java.lang.String messageText>;
if v != null goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.io.InputStream getResourceAsStream(java.lang.String)>("demo.txt");
v = v.<org.apache.activemq.util.ProducerThread: int textMessageSize>;
v = specialinvoke v.<org.apache.activemq.util.ProducerThread: java.lang.String readInputStream(java.io.InputStream,int,int)>(v, v, v);
v.<org.apache.activemq.util.ProducerThread: java.lang.String messageText> = v;
goto label;
label:
v = v.<org.apache.activemq.util.ProducerThread: java.lang.String payloadUrl>;
if v == null goto label;
v = new java.net.URL;
v = v.<org.apache.activemq.util.ProducerThread: java.lang.String payloadUrl>;
specialinvoke v.<java.net.URL: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.net.URL: java.io.InputStream openStream()>();
v = (int) -1;
v = specialinvoke v.<org.apache.activemq.util.ProducerThread: java.lang.String readInputStream(java.io.InputStream,int,int)>(v, v, v);
v.<org.apache.activemq.util.ProducerThread: java.lang.String messageText> = v;
goto label;
label:
v = v.<org.apache.activemq.util.ProducerThread: java.lang.String message>;
if v == null goto label;
v = v.<org.apache.activemq.util.ProducerThread: java.lang.String message>;
v.<org.apache.activemq.util.ProducerThread: java.lang.String messageText> = v;
goto label;
label:
v = specialinvoke v.<org.apache.activemq.util.ProducerThread: java.lang.String createDefaultMessage(int)>(v);
v.<org.apache.activemq.util.ProducerThread: java.lang.String messageText> = v;
label:
v = v.<org.apache.activemq.util.ProducerThread: javax.jms.Session session>;
v = v.<org.apache.activemq.util.ProducerThread: java.lang.String messageText>;
v = interfaceinvoke v.<javax.jms.Session: javax.jms.TextMessage createTextMessage(java.lang.String)>(v);
label:
v = v.<org.apache.activemq.util.ProducerThread: java.lang.String msgGroupID>;
if v == null goto label;
v = v.<org.apache.activemq.util.ProducerThread: java.lang.String msgGroupID>;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
v = v.<org.apache.activemq.util.ProducerThread: java.lang.String msgGroupID>;
interfaceinvoke v.<javax.jms.Message: void setStringProperty(java.lang.String,java.lang.String)>("JMSXGroupID", v);
label:
return v;
}
private java.lang.String readInputStream(java.io.InputStream, int, int) throws java.io.IOException
{
java.lang.Throwable v;
java.io.IOException v;
java.io.InputStreamReader v;
int v, v, v, v;
char[] v;
java.lang.StringBuilder v;
java.lang.String v, v;
org.apache.activemq.util.ProducerThread v;
java.io.InputStream v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: java.io.InputStream;
v := @parameter: int;
v := @parameter: int;
v = new java.io.InputStreamReader;
specialinvoke v.<java.io.InputStreamReader: void <init>(java.io.InputStream)>(v);
label:
if v <= 0 goto label;
v = newarray (char)[v];
goto label;
label:
v = newarray (char)[1024];
label:
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
label:
v = virtualinvoke v.<java.io.InputStreamReader: int read(char[])>(v);
v = (int) -1;
if v == v goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char[],int,int)>(v, 0, v);
if v <= 0 goto label;
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
label:
virtualinvoke v.<java.io.InputStreamReader: void close()>();
return v;
label:
v := @caughtexception;
v = specialinvoke v.<org.apache.activemq.util.ProducerThread: java.lang.String createDefaultMessage(int)>(v);
label:
virtualinvoke v.<java.io.InputStreamReader: void close()>();
return v;
label:
v := @caughtexception;
virtualinvoke v.<java.io.InputStreamReader: void close()>();
throw v;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private java.lang.String createDefaultMessage(int)
{
int v;
java.lang.String v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: int;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("test message: \u0001");
return v;
}
public void setMessageCount(int)
{
int v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: int;
v.<org.apache.activemq.util.ProducerThread: int messageCount> = v;
return;
}
public int getSleep()
{
int v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: int sleep>;
return v;
}
public void setSleep(int)
{
int v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: int;
v.<org.apache.activemq.util.ProducerThread: int sleep> = v;
return;
}
public int getMessageCount()
{
int v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: int messageCount>;
return v;
}
public int getSentCount()
{
int v;
java.util.concurrent.atomic.AtomicInteger v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.atomic.AtomicInteger sentCount>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
return v;
}
public boolean isPersistent()
{
org.apache.activemq.util.ProducerThread v;
boolean v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: boolean persistent>;
return v;
}
public void setPersistent(boolean)
{
org.apache.activemq.util.ProducerThread v;
boolean v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: boolean;
v.<org.apache.activemq.util.ProducerThread: boolean persistent> = v;
return;
}
public boolean isRunning()
{
org.apache.activemq.util.ProducerThread v;
boolean v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: boolean running>;
return v;
}
public void setRunning(boolean)
{
org.apache.activemq.util.ProducerThread v;
boolean v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: boolean;
v.<org.apache.activemq.util.ProducerThread: boolean running> = v;
return;
}
public long getMsgTTL()
{
long v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: long msgTTL>;
return v;
}
public void setMsgTTL(long)
{
long v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: long;
v.<org.apache.activemq.util.ProducerThread: long msgTTL> = v;
return;
}
public int getTransactionBatchSize()
{
int v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: int transactionBatchSize>;
return v;
}
public void setTransactionBatchSize(int)
{
int v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: int;
v.<org.apache.activemq.util.ProducerThread: int transactionBatchSize> = v;
return;
}
public java.lang.String getMsgGroupID()
{
java.lang.String v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: java.lang.String msgGroupID>;
return v;
}
public void setMsgGroupID(java.lang.String)
{
java.lang.String v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: java.lang.String;
v.<org.apache.activemq.util.ProducerThread: java.lang.String msgGroupID> = v;
return;
}
public int getTextMessageSize()
{
int v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: int textMessageSize>;
return v;
}
public void setTextMessageSize(int)
{
int v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: int;
v.<org.apache.activemq.util.ProducerThread: int textMessageSize> = v;
return;
}
public int getMessageSize()
{
int v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: int messageSize>;
return v;
}
public void setMessageSize(int)
{
int v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: int;
v.<org.apache.activemq.util.ProducerThread: int messageSize> = v;
return;
}
public java.util.concurrent.CountDownLatch getFinished()
{
java.util.concurrent.CountDownLatch v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.CountDownLatch finished>;
return v;
}
public void setFinished(java.util.concurrent.CountDownLatch)
{
java.util.concurrent.CountDownLatch v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: java.util.concurrent.CountDownLatch;
v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.CountDownLatch finished> = v;
return;
}
public java.lang.String getPayloadUrl()
{
java.lang.String v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: java.lang.String payloadUrl>;
return v;
}
public void setPayloadUrl(java.lang.String)
{
java.lang.String v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: java.lang.String;
v.<org.apache.activemq.util.ProducerThread: java.lang.String payloadUrl> = v;
return;
}
public java.lang.String getMessage()
{
java.lang.String v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: java.lang.String message>;
return v;
}
public void setMessage(java.lang.String)
{
java.lang.String v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: java.lang.String;
v.<org.apache.activemq.util.ProducerThread: java.lang.String message> = v;
return;
}
public boolean isRunIndefinitely()
{
org.apache.activemq.util.ProducerThread v;
boolean v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: boolean runIndefinitely>;
return v;
}
public void setRunIndefinitely(boolean)
{
org.apache.activemq.util.ProducerThread v;
boolean v;
v := @this: org.apache.activemq.util.ProducerThread;
v := @parameter: boolean;
v.<org.apache.activemq.util.ProducerThread: boolean runIndefinitely> = v;
return;
}
public synchronized void pauseProducer()
{
java.util.concurrent.CountDownLatch v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.CountDownLatch paused> = v;
return;
}
public synchronized void resumeProducer()
{
java.util.concurrent.CountDownLatch v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.CountDownLatch paused>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
return;
}
public void resetCounters()
{
java.util.concurrent.atomic.AtomicInteger v;
org.apache.activemq.util.ProducerThread v;
v := @this: org.apache.activemq.util.ProducerThread;
v = v.<org.apache.activemq.util.ProducerThread: java.util.concurrent.atomic.AtomicInteger sentCount>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: void set(int)>(0);
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/util/ProducerThread;");
<org.apache.activemq.util.ProducerThread: org.slf4j.Logger LOG> = v;
return;
}
}