public class glassfish.mq.examples.jms.SampleUtilities extends java.lang.Object
{
public static final boolean USE_JNDI;
public static final java.lang.String jndiNamePrefix;
public static final java.lang.String CONFAC;
public static final java.lang.String QUEUECONFAC;
public static final java.lang.String TOPICCONFAC;
private static javax.naming.Context jndiContext;
public void <init>()
{
glassfish.mq.examples.jms.SampleUtilities v;
v := @this: glassfish.mq.examples.jms.SampleUtilities;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static jakarta.jms.ConnectionFactory getConnectionFactory() throws java.lang.Exception
{
java.lang.Object v;
com.sun.messaging.ConnectionFactory v;
boolean v;
v = <SampleUtilities: boolean USE_JNDI>;
if v == 0 goto label;
v = staticinvoke <SampleUtilities: java.lang.Object jndiLookup(java.lang.String)>("ConnectionFactory");
return v;
label:
v = new com.sun.messaging.ConnectionFactory;
specialinvoke v.<com.sun.messaging.ConnectionFactory: void <init>()>();
return v;
}
public static jakarta.jms.QueueConnectionFactory getQueueConnectionFactory() throws java.lang.Exception
{
java.lang.Object v;
com.sun.messaging.QueueConnectionFactory v;
boolean v;
v = <SampleUtilities: boolean USE_JNDI>;
if v == 0 goto label;
v = staticinvoke <SampleUtilities: java.lang.Object jndiLookup(java.lang.String)>("QueueConnectionFactory");
return v;
label:
v = new com.sun.messaging.QueueConnectionFactory;
specialinvoke v.<com.sun.messaging.QueueConnectionFactory: void <init>()>();
return v;
}
public static jakarta.jms.TopicConnectionFactory getTopicConnectionFactory() throws java.lang.Exception
{
com.sun.messaging.TopicConnectionFactory v;
java.lang.Object v;
boolean v;
v = <SampleUtilities: boolean USE_JNDI>;
if v == 0 goto label;
v = staticinvoke <SampleUtilities: java.lang.Object jndiLookup(java.lang.String)>("TopicConnectionFactory");
return v;
label:
v = new com.sun.messaging.TopicConnectionFactory;
specialinvoke v.<com.sun.messaging.TopicConnectionFactory: void <init>()>();
return v;
}
public static jakarta.jms.Queue getQueue(java.lang.String, jakarta.jms.Session) throws java.lang.Exception
{
java.lang.Object v;
java.lang.String v;
jakarta.jms.Queue v;
jakarta.jms.Session v;
boolean v;
v := @parameter: java.lang.String;
v := @parameter: jakarta.jms.Session;
v = <SampleUtilities: boolean USE_JNDI>;
if v == 0 goto label;
v = staticinvoke <SampleUtilities: java.lang.Object jndiLookup(java.lang.String)>(v);
return v;
label:
v = interfaceinvoke v.<jakarta.jms.Session: jakarta.jms.Queue createQueue(java.lang.String)>(v);
return v;
}
public static jakarta.jms.Topic getTopic(java.lang.String, jakarta.jms.Session) throws java.lang.Exception
{
jakarta.jms.Topic v;
java.lang.Object v;
java.lang.String v;
jakarta.jms.Session v;
boolean v;
v := @parameter: java.lang.String;
v := @parameter: jakarta.jms.Session;
v = <SampleUtilities: boolean USE_JNDI>;
if v == 0 goto label;
v = staticinvoke <SampleUtilities: java.lang.Object jndiLookup(java.lang.String)>(v);
return v;
label:
v = interfaceinvoke v.<jakarta.jms.Session: jakarta.jms.Topic createTopic(java.lang.String)>(v);
return v;
}
public static java.lang.Object jndiLookup(java.lang.String) throws javax.naming.NamingException
{
java.io.PrintStream v, v;
javax.naming.InitialContext v;
javax.naming.NamingException v, v;
java.lang.Object v;
java.lang.String v, v, v, v, v, v;
javax.naming.Context v, v;
v := @parameter: java.lang.String;
v = <SampleUtilities: javax.naming.Context jndiContext>;
if v != null goto label;
label:
v = new javax.naming.InitialContext;
specialinvoke v.<javax.naming.InitialContext: void <init>()>();
<SampleUtilities: javax.naming.Context jndiContext> = v;
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<javax.naming.NamingException: java.lang.String toString()>();
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[])>("Could not create JNDI context: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
throw v;
label:
v = <SampleUtilities: javax.naming.Context jndiContext>;
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[])>("cn=\u0001");
v = interfaceinvoke v.<javax.naming.Context: java.lang.Object lookup(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<javax.naming.NamingException: java.lang.String toString()>();
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[])>("JNDI lookup failed for:\u0001: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
throw v;
label:
return v;
catch javax.naming.NamingException from label to label with label;
catch javax.naming.NamingException from label to label with label;
}
public static void exit(int)
{
int v;
v := @parameter: int;
staticinvoke <java.lang.System: void exit(int)>(v);
return;
}
public static void receiveSynchronizeMessages(java.lang.String, java.lang.String, int) throws java.lang.Exception
{
java.lang.Throwable v, v;
jakarta.jms.QueueConnection v;
jakarta.jms.QueueSession v;
jakarta.jms.Queue v;
jakarta.jms.QueueReceiver v;
int v;
java.lang.String v, v, v, v, v, v, v, v;
java.io.PrintStream v, v, v, v;
java.lang.Exception v;
jakarta.jms.QueueConnectionFactory v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: int;
label:
v = staticinvoke <SampleUtilities: jakarta.jms.QueueConnectionFactory getQueueConnectionFactory()>();
v = interfaceinvoke v.<jakarta.jms.QueueConnectionFactory: jakarta.jms.QueueConnection createQueueConnection()>();
v = interfaceinvoke v.<jakarta.jms.QueueConnection: jakarta.jms.QueueSession createQueueSession(boolean,int)>(0, 1);
v = staticinvoke <SampleUtilities: jakarta.jms.Queue getQueue(java.lang.String,jakarta.jms.Session)>(v, v);
interfaceinvoke v.<jakarta.jms.QueueConnection: void start()>();
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<java.lang.Exception: java.lang.String toString()>();
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[])>("Connection problem: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
throw v;
label:
v = <java.lang.System: java.io.PrintStream out>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,int)>(v, 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[])>("\u0001Receiving synchronize messages from \u; count = \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = interfaceinvoke v.<jakarta.jms.QueueSession: jakarta.jms.QueueReceiver createReceiver(jakarta.jms.Queue)>(v);
label:
if v <= 0 goto label;
interfaceinvoke v.<jakarta.jms.QueueReceiver: jakarta.jms.Message receive()>();
v = v - 1;
v = <java.lang.System: java.io.PrintStream out>;
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[])>("\u0001Received synchronize message; expect \u more");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
goto label;
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<jakarta.jms.JMSException: java.lang.String toString()>();
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[])>("Exception occurred: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
throw v;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
catch jakarta.jms.JMSException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public static void sendSynchronizeMessage(java.lang.String, java.lang.String) throws java.lang.Exception
{
java.lang.Throwable v, v;
jakarta.jms.QueueConnection v;
jakarta.jms.QueueSender v;
jakarta.jms.QueueSession v;
jakarta.jms.Queue v;
java.lang.String v, v, v, v, v, v, v;
java.io.PrintStream v, v, v;
java.lang.Exception v;
jakarta.jms.TextMessage v;
jakarta.jms.QueueConnectionFactory v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
label:
v = staticinvoke <SampleUtilities: jakarta.jms.QueueConnectionFactory getQueueConnectionFactory()>();
v = interfaceinvoke v.<jakarta.jms.QueueConnectionFactory: jakarta.jms.QueueConnection createQueueConnection()>();
v = interfaceinvoke v.<jakarta.jms.QueueConnection: jakarta.jms.QueueSession createQueueSession(boolean,int)>(0, 1);
v = staticinvoke <SampleUtilities: jakarta.jms.Queue getQueue(java.lang.String,jakarta.jms.Session)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<java.lang.Exception: java.lang.String toString()>();
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[])>("Connection problem: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<jakarta.jms.QueueSession: jakarta.jms.QueueSender createSender(jakarta.jms.Queue)>(v);
v = interfaceinvoke v.<jakarta.jms.QueueSession: jakarta.jms.TextMessage createTextMessage()>();
interfaceinvoke v.<jakarta.jms.TextMessage: void setText(java.lang.String)>("synchronize");
v = <java.lang.System: java.io.PrintStream out>;
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[])>("\u0001Sending synchronize message to \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
interfaceinvoke v.<jakarta.jms.QueueSender: void send(jakarta.jms.Message)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<jakarta.jms.JMSException: java.lang.String toString()>();
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[])>("Exception occurred: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
throw v;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
catch jakarta.jms.JMSException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
static void <clinit>()
{
boolean v;
v = staticinvoke <java.lang.Boolean: boolean getBoolean(java.lang.String)>("USE_JNDI");
<SampleUtilities: boolean USE_JNDI> = v;
<SampleUtilities: javax.naming.Context jndiContext> = null;
return;
}
}