public class glassfish.mq.examples.jms.AckEquivExample extends java.lang.Object
{
final java.lang.String CONTROL_QUEUE;
java.lang.String queueName;
java.lang.String topicName;
int exitResult;
public void <init>()
{
glassfish.mq.examples.jms.AckEquivExample v;
v := @this: glassfish.mq.examples.jms.AckEquivExample;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<AckEquivExample: java.lang.String CONTROL_QUEUE> = "controlQueue";
v.<AckEquivExample: java.lang.String queueName> = null;
v.<AckEquivExample: java.lang.String topicName> = null;
v.<AckEquivExample: int exitResult> = 0;
return;
}
public void run_threads()
{
AckEquivExample$SynchProducer v;
glassfish.mq.examples.jms.AckEquivExample v;
java.lang.InterruptedException v, v;
AckEquivExample$AsynchSubscriber v;
AckEquivExample$MultiplePublisher v;
AckEquivExample$SynchConsumer v;
v := @this: glassfish.mq.examples.jms.AckEquivExample;
v = new AckEquivExample$SynchProducer;
specialinvoke v.<AckEquivExample$SynchProducer: void <init>(AckEquivExample)>(v);
v = new AckEquivExample$SynchConsumer;
specialinvoke v.<AckEquivExample$SynchConsumer: void <init>(AckEquivExample)>(v);
v = new AckEquivExample$AsynchSubscriber;
specialinvoke v.<AckEquivExample$AsynchSubscriber: void <init>(AckEquivExample)>(v);
v = new AckEquivExample$MultiplePublisher;
specialinvoke v.<AckEquivExample$MultiplePublisher: void <init>(AckEquivExample)>(v);
virtualinvoke v.<AckEquivExample$SynchProducer: void start()>();
virtualinvoke v.<AckEquivExample$SynchConsumer: void start()>();
label:
virtualinvoke v.<AckEquivExample$SynchProducer: void join()>();
virtualinvoke v.<AckEquivExample$SynchConsumer: void join()>();
label:
goto label;
label:
v := @caughtexception;
label:
virtualinvoke v.<AckEquivExample$AsynchSubscriber: void start()>();
virtualinvoke v.<AckEquivExample$MultiplePublisher: void start()>();
label:
virtualinvoke v.<AckEquivExample$AsynchSubscriber: void join()>();
virtualinvoke v.<AckEquivExample$MultiplePublisher: void join()>();
label:
goto label;
label:
v := @caughtexception;
label:
return;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
}
public static void main(java.lang.String[])
{
AckEquivExample v;
java.io.PrintStream v, v, v;
java.lang.String[] v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v;
v := @parameter: java.lang.String[];
v = new AckEquivExample;
specialinvoke v.<AckEquivExample: void <init>()>();
v = lengthof v;
if v == 2 goto label;
v = <java.lang.System: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>("Usage: java AckEquivExample <queue_name> <topic_name>");
staticinvoke <java.lang.System: void exit(int)>(1);
label:
v = new java.lang.String;
v = v[0];
specialinvoke v.<java.lang.String: void <init>(java.lang.String)>(v);
v.<AckEquivExample: java.lang.String queueName> = v;
v = new java.lang.String;
v = v[1];
specialinvoke v.<java.lang.String: void <init>(java.lang.String)>(v);
v.<AckEquivExample: java.lang.String topicName> = v;
v = <java.lang.System: java.io.PrintStream out>;
v = v.<AckEquivExample: java.lang.String queueName>;
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[])>("Queue name is \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = <java.lang.System: java.io.PrintStream out>;
v = v.<AckEquivExample: java.lang.String topicName>;
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[])>("Topic name is \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
virtualinvoke v.<AckEquivExample: void run_threads()>();
v = v.<AckEquivExample: int exitResult>;
staticinvoke <SampleUtilities: void exit(int)>(v);
return;
}
}