public class glassfish.mq.examples.applications.uclient.UniversalClient extends java.lang.Object implements UniversalClientConstants, jakarta.jms.ExceptionListener
{
static final java.lang.String ADDRESSLIST_PROP;
private jakarta.jms.ConnectionFactory myConnFactory;
private jakarta.jms.Connection myConn;
private jakarta.jms.Session myProducerSession;
private jakarta.jms.Session myConsumerSession;
private jakarta.jms.MessageProducer myProducer;
private jakarta.jms.MessageConsumer myConsumer;
private jakarta.jms.Destination myDestination;
private boolean connected;
private java.util.HashMap mySessionMap;
private java.util.HashMap myProducerMap;
private java.lang.String userName;
private java.lang.String password;
private java.lang.String brokerAddress;
private java.lang.String clientID;
private javax.swing.JFrame frame;
private javax.swing.JMenuBar menuBar;
private javax.swing.JMenuItem connectItem;
private javax.swing.JMenuItem disconnectItem;
private javax.swing.JMenuItem clearItem;
private javax.swing.JMenuItem exitItem;
private javax.swing.JMenuItem sendMsgItem;
private javax.swing.JMenuItem sendMsgStopItem;
private javax.swing.JMenuItem rcvMsgItem;
private javax.swing.JMenuItem rcvMsgStopItem;
private ConnectionDialogBox connDialogB;
private javax.swing.JButton connectB;
private javax.swing.JButton connCancelB;
private SendMessageDialogBox sendMsgDialogB;
private javax.swing.JButton sendMsgB;
private javax.swing.JButton sendMsgCancelB;
private javax.swing.JPanel footerPanel;
private javax.swing.JLabel footerLabel;
private boolean footerInUse;
private javax.swing.JTable msgTable;
private javax.swing.JScrollPane msgTableScrollPane;
private boolean scrollingON;
private double msgProductionRate;
private javax.swing.JPanel topPanel;
private javax.swing.JLabel msgProductionRateLabel;
private javax.swing.JLabel hostPortLabel;
private javax.swing.JLabel clientIDLabel;
private javax.swing.JProgressBar sendMsgProgressBar;
private javax.swing.JFrame detailsFrame;
private PropertyPanel msgDetailsHeaderPanel;
private PropertyPanel msgDetailsPropertyPanel;
private PropertyPanel msgDetailsBodyPanel;
private ReceiveMessageDialogBox receiveMsgDialogB;
private javax.swing.JButton receiveMsgB;
private javax.swing.JButton receiveMsgCancelB;
StatusArea statusArea;
private boolean msgSenderStopped;
private boolean msgReceiverStopped;
public void <init>()
{
java.util.HashMap v, v;
UniversalClient$StatusReportingThread v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v, v;
javax.swing.JProgressBar v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<UniversalClient: boolean connected> = 0;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<UniversalClient: java.util.HashMap mySessionMap> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<UniversalClient: java.util.HashMap myProducerMap> = v;
v.<UniversalClient: java.lang.String brokerAddress> = "localhost:7676";
v = new javax.swing.JProgressBar;
specialinvoke v.<javax.swing.JProgressBar: void <init>()>();
v.<UniversalClient: javax.swing.JProgressBar sendMsgProgressBar> = v;
v.<UniversalClient: java.lang.String userName> = "guest";
v.<UniversalClient: java.lang.String password> = "guest";
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("universalclient.cid", null);
v.<UniversalClient: java.lang.String clientID> = v;
v = v.<UniversalClient: java.lang.String clientID>;
if v != null goto label;
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("user.name", "UClient-ID");
v.<UniversalClient: java.lang.String clientID> = v;
label:
specialinvoke v.<UniversalClient: void createAndShowGUI()>();
v = new UniversalClient$StatusReportingThread;
specialinvoke v.<UniversalClient$StatusReportingThread: void <init>(UniversalClient)>(v);
virtualinvoke v.<java.lang.Thread: void setPriority(int)>(1);
virtualinvoke v.<java.lang.Thread: void setDaemon(boolean)>(1);
virtualinvoke v.<java.lang.Thread: void start()>();
return;
}
private void createAndShowGUI()
{
javax.swing.JSplitPane v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.awt.Container v, v, v;
java.lang.String v;
java.awt.BorderLayout v;
javax.swing.JFrame v, v, v, v, v, v, v;
javax.swing.JMenuBar v, v;
StatusArea v, v, v;
java.lang.Exception v;
javax.swing.JPanel v, v, v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
label:
v = staticinvoke <javax.swing.UIManager: java.lang.String getCrossPlatformLookAndFeelClassName()>();
staticinvoke <javax.swing.UIManager: void setLookAndFeel(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.Exception: void printStackTrace()>();
label:
v = new javax.swing.JFrame;
specialinvoke v.<javax.swing.JFrame: void <init>(java.lang.String)>("Oracle GlassFish(tm) Server Message Queue Universal Client");
v.<UniversalClient: javax.swing.JFrame frame> = v;
v = v.<UniversalClient: javax.swing.JFrame frame>;
virtualinvoke v.<javax.swing.JFrame: void setDefaultCloseOperation(int)>(3);
v = v.<UniversalClient: javax.swing.JFrame frame>;
v = virtualinvoke v.<javax.swing.JFrame: java.awt.Container getContentPane()>();
v = new java.awt.BorderLayout;
specialinvoke v.<java.awt.BorderLayout: void <init>()>();
virtualinvoke v.<java.awt.Container: void setLayout(java.awt.LayoutManager)>(v);
v = specialinvoke v.<UniversalClient: javax.swing.JMenuBar createMenuBar()>();
v.<UniversalClient: javax.swing.JMenuBar menuBar> = v;
v = v.<UniversalClient: javax.swing.JFrame frame>;
v = v.<UniversalClient: javax.swing.JMenuBar menuBar>;
virtualinvoke v.<javax.swing.JFrame: void setJMenuBar(javax.swing.JMenuBar)>(v);
v = specialinvoke v.<UniversalClient: javax.swing.JPanel createTopPanel()>();
v.<UniversalClient: javax.swing.JPanel topPanel> = v;
v = v.<UniversalClient: javax.swing.JFrame frame>;
v = virtualinvoke v.<javax.swing.JFrame: java.awt.Container getContentPane()>();
v = v.<UniversalClient: javax.swing.JPanel topPanel>;
virtualinvoke v.<java.awt.Container: void add(java.awt.Component,java.lang.Object)>(v, "North");
v = specialinvoke v.<UniversalClient: javax.swing.JPanel createTablePanel()>();
specialinvoke v.<UniversalClient: javax.swing.JPanel createFooterPanel()>();
v = v.<UniversalClient: javax.swing.JPanel footerPanel>;
virtualinvoke v.<javax.swing.JPanel: void add(java.awt.Component,java.lang.Object)>(v, "South");
v = new StatusArea;
specialinvoke v.<StatusArea: void <init>()>();
v.<UniversalClient: StatusArea statusArea> = v;
v = v.<UniversalClient: StatusArea statusArea>;
virtualinvoke v.<StatusArea: void appendText(java.lang.String)>("# Message Queue Client Runtime Connection Notification And Connection related log");
v = new javax.swing.JSplitPane;
specialinvoke v.<javax.swing.JSplitPane: void <init>(int)>(0);
virtualinvoke v.<javax.swing.JSplitPane: void setOneTouchExpandable(boolean)>(1);
virtualinvoke v.<javax.swing.JSplitPane: void setTopComponent(java.awt.Component)>(v);
v = v.<UniversalClient: StatusArea statusArea>;
virtualinvoke v.<javax.swing.JSplitPane: void setBottomComponent(java.awt.Component)>(v);
virtualinvoke v.<javax.swing.JSplitPane: void setResizeWeight(double)>(0.9);
v = v.<UniversalClient: javax.swing.JFrame frame>;
v = virtualinvoke v.<javax.swing.JFrame: java.awt.Container getContentPane()>();
virtualinvoke v.<java.awt.Container: void add(java.awt.Component,java.lang.Object)>(v, "Center");
specialinvoke v.<UniversalClient: void setSize()>();
v = v.<UniversalClient: javax.swing.JFrame frame>;
virtualinvoke v.<javax.swing.JFrame: void setVisible(boolean)>(1);
return;
catch java.lang.Exception from label to label with label;
}
private void setSize()
{
byte v;
int v, v, v, v, v, v, v, v, v, v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v;
javax.swing.JFrame v, v, v;
java.awt.Dimension v;
java.awt.Toolkit v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = 10;
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("os.name", "");
v = virtualinvoke v.<java.lang.String: int indexOf(java.lang.String)>("Windows");
if v < 0 goto label;
v = 12;
label:
v = v.<UniversalClient: javax.swing.JFrame frame>;
v = virtualinvoke v.<javax.swing.JFrame: java.awt.Toolkit getToolkit()>();
v = virtualinvoke v.<java.awt.Toolkit: java.awt.Dimension getScreenSize()>();
v = v.<UniversalClient: javax.swing.JFrame frame>;
v = v.<java.awt.Dimension: int width>;
v = v * v;
v = v / 15;
v = v.<java.awt.Dimension: int height>;
v = v * v;
v = v / 15;
virtualinvoke v.<javax.swing.JFrame: void setSize(int,int)>(v, v);
v = v.<UniversalClient: javax.swing.JFrame frame>;
v = v.<java.awt.Dimension: int width>;
v = v / 8;
v = v.<java.awt.Dimension: int height>;
v = v / 16;
virtualinvoke v.<javax.swing.JFrame: void setLocation(int,int)>(v, v);
return;
}
private javax.swing.JMenuBar createMenuBar()
{
UniversalClient$ConnectionPopUpListener v;
UniversalClient$ReceiveMessagePopUpListener v;
UniversalClient$DisConnectionListener v;
javax.swing.JMenuBar v;
javax.swing.KeyStroke v;
UniversalClient$ExitListener v;
UniversalClient$SendMessagePopUpListener v;
javax.swing.JMenu v, v, v, v;
javax.swing.JSeparator v, v, v;
javax.swing.JMenuItem 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;
glassfish.mq.examples.applications.uclient.UniversalClient v;
UniversalClient$ClearMessageListener v;
UniversalClient$1 v;
UniversalClient$2 v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = new javax.swing.JMenuBar;
specialinvoke v.<javax.swing.JMenuBar: void <init>()>();
v = new javax.swing.JMenu;
specialinvoke v.<javax.swing.JMenu: void <init>(java.lang.String)>("Universal Client");
v = virtualinvoke v.<javax.swing.JMenuBar: javax.swing.JMenu add(javax.swing.JMenu)>(v);
virtualinvoke v.<javax.swing.JMenu: void setMnemonic(char)>(67);
v = new javax.swing.JMenu;
specialinvoke v.<javax.swing.JMenu: void <init>(java.lang.String)>("Actions");
v = virtualinvoke v.<javax.swing.JMenuBar: javax.swing.JMenu add(javax.swing.JMenu)>(v);
virtualinvoke v.<javax.swing.JMenu: void setMnemonic(char)>(65);
v = specialinvoke v.<UniversalClient: javax.swing.JMenuItem addMenuItem(javax.swing.JMenu,java.lang.String)>(v, "Connect ...");
v.<UniversalClient: javax.swing.JMenuItem connectItem> = v;
v = v.<UniversalClient: javax.swing.JMenuItem connectItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setMnemonic(char)>(67);
v = specialinvoke v.<UniversalClient: javax.swing.JMenuItem addMenuItem(javax.swing.JMenu,java.lang.String)>(v, "Disconnect");
v.<UniversalClient: javax.swing.JMenuItem disconnectItem> = v;
v = v.<UniversalClient: javax.swing.JMenuItem disconnectItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setMnemonic(char)>(68);
v = new javax.swing.JSeparator;
specialinvoke v.<javax.swing.JSeparator: void <init>()>();
virtualinvoke v.<javax.swing.JMenu: java.awt.Component add(java.awt.Component)>(v);
v = specialinvoke v.<UniversalClient: javax.swing.JMenuItem addMenuItem(javax.swing.JMenu,java.lang.String)>(v, "Send Message ...");
v.<UniversalClient: javax.swing.JMenuItem sendMsgItem> = v;
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setMnemonic(char)>(77);
v = specialinvoke v.<UniversalClient: javax.swing.JMenuItem addMenuItem(javax.swing.JMenu,java.lang.String)>(v, "Stop Msg Sender");
v.<UniversalClient: javax.swing.JMenuItem sendMsgStopItem> = v;
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgStopItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setMnemonic(char)>(83);
v = new javax.swing.JSeparator;
specialinvoke v.<javax.swing.JSeparator: void <init>()>();
virtualinvoke v.<javax.swing.JMenu: java.awt.Component add(java.awt.Component)>(v);
v = specialinvoke v.<UniversalClient: javax.swing.JMenuItem addMenuItem(javax.swing.JMenu,java.lang.String)>(v, "Receive Message ...");
v.<UniversalClient: javax.swing.JMenuItem rcvMsgItem> = v;
v = v.<UniversalClient: javax.swing.JMenuItem rcvMsgItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setMnemonic(char)>(82);
v = specialinvoke v.<UniversalClient: javax.swing.JMenuItem addMenuItem(javax.swing.JMenu,java.lang.String)>(v, "Stop Msg Receiver");
v.<UniversalClient: javax.swing.JMenuItem rcvMsgStopItem> = v;
v = v.<UniversalClient: javax.swing.JMenuItem rcvMsgStopItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setMnemonic(char)>(116);
v = new javax.swing.JSeparator;
specialinvoke v.<javax.swing.JSeparator: void <init>()>();
virtualinvoke v.<javax.swing.JMenu: java.awt.Component add(java.awt.Component)>(v);
v = specialinvoke v.<UniversalClient: javax.swing.JMenuItem addMenuItem(javax.swing.JMenu,java.lang.String)>(v, "Clear Messages");
v.<UniversalClient: javax.swing.JMenuItem clearItem> = v;
v = v.<UniversalClient: javax.swing.JMenuItem clearItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setMnemonic(char)>(101);
v = specialinvoke v.<UniversalClient: javax.swing.JMenuItem addMenuItem(javax.swing.JMenu,java.lang.String)>(v, "Exit");
v.<UniversalClient: javax.swing.JMenuItem exitItem> = v;
v = v.<UniversalClient: javax.swing.JMenuItem exitItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setMnemonic(char)>(120);
v = v.<UniversalClient: javax.swing.JMenuItem exitItem>;
v = staticinvoke <javax.swing.KeyStroke: javax.swing.KeyStroke getKeyStroke(int,int)>(81, 2);
virtualinvoke v.<javax.swing.JMenuItem: void setAccelerator(javax.swing.KeyStroke)>(v);
v = v.<UniversalClient: javax.swing.JMenuItem disconnectItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
v = v.<UniversalClient: javax.swing.JMenuItem connectItem>;
v = new UniversalClient$ConnectionPopUpListener;
specialinvoke v.<UniversalClient$ConnectionPopUpListener: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JMenuItem: void addActionListener(java.awt.event.ActionListener)>(v);
v = v.<UniversalClient: javax.swing.JMenuItem disconnectItem>;
v = new UniversalClient$DisConnectionListener;
specialinvoke v.<UniversalClient$DisConnectionListener: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JMenuItem: void addActionListener(java.awt.event.ActionListener)>(v);
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgItem>;
v = new UniversalClient$SendMessagePopUpListener;
specialinvoke v.<UniversalClient$SendMessagePopUpListener: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JMenuItem: void addActionListener(java.awt.event.ActionListener)>(v);
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgStopItem>;
v = new UniversalClient$1;
specialinvoke v.<UniversalClient$1: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JMenuItem: void addActionListener(java.awt.event.ActionListener)>(v);
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgStopItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
v = v.<UniversalClient: javax.swing.JMenuItem rcvMsgItem>;
v = new UniversalClient$ReceiveMessagePopUpListener;
specialinvoke v.<UniversalClient$ReceiveMessagePopUpListener: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JMenuItem: void addActionListener(java.awt.event.ActionListener)>(v);
v = v.<UniversalClient: javax.swing.JMenuItem rcvMsgItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
v = v.<UniversalClient: javax.swing.JMenuItem rcvMsgStopItem>;
v = new UniversalClient$2;
specialinvoke v.<UniversalClient$2: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JMenuItem: void addActionListener(java.awt.event.ActionListener)>(v);
v = v.<UniversalClient: javax.swing.JMenuItem rcvMsgStopItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
v = v.<UniversalClient: javax.swing.JMenuItem clearItem>;
v = new UniversalClient$ClearMessageListener;
specialinvoke v.<UniversalClient$ClearMessageListener: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JMenuItem: void addActionListener(java.awt.event.ActionListener)>(v);
v = v.<UniversalClient: javax.swing.JMenuItem exitItem>;
v = new UniversalClient$ExitListener;
specialinvoke v.<UniversalClient$ExitListener: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JMenuItem: void addActionListener(java.awt.event.ActionListener)>(v);
return v;
}
private javax.swing.JMenuItem addMenuItem(javax.swing.JMenu, java.lang.String)
{
javax.swing.JMenuItem v, v;
javax.swing.JMenu v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: javax.swing.JMenu;
v := @parameter: java.lang.String;
v = specialinvoke v.<UniversalClient: javax.swing.JMenuItem newJMenuItem(java.lang.String)>(v);
v = virtualinvoke v.<javax.swing.JMenu: javax.swing.JMenuItem add(javax.swing.JMenuItem)>(v);
return v;
}
private javax.swing.JMenuItem newJMenuItem(java.lang.String)
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v;
javax.swing.JMenuItem v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: java.lang.String;
v = new javax.swing.JMenuItem;
specialinvoke v.<javax.swing.JMenuItem: void <init>(java.lang.String)>(v);
return v;
}
private javax.swing.JPanel createTablePanel()
{
javax.swing.border.Border v;
UniversalClient$TableMouseListener v;
java.awt.BorderLayout v;
javax.swing.JTable v, v, v, v, v, v, v, v, v;
javax.swing.JPanel v;
javax.swing.table.TableColumnModel v, v, v, v, v, v;
MsgTable v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
javax.swing.table.TableColumn v, v, v, v, v, v;
UniversalClient$3 v;
javax.swing.JScrollPane v, v, v, v, v;
javax.swing.JLabel v;
javax.swing.JScrollBar v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = new javax.swing.JPanel;
specialinvoke v.<javax.swing.JPanel: void <init>()>();
v = new java.awt.BorderLayout;
specialinvoke v.<java.awt.BorderLayout: void <init>()>();
virtualinvoke v.<javax.swing.JPanel: void setLayout(java.awt.LayoutManager)>(v);
v = new javax.swing.JTable;
v = new MsgTable;
specialinvoke v.<MsgTable: void <init>()>();
specialinvoke v.<javax.swing.JTable: void <init>(javax.swing.table.TableModel)>(v);
v.<UniversalClient: javax.swing.JTable msgTable> = v;
v = v.<UniversalClient: javax.swing.JTable msgTable>;
v = new UniversalClient$TableMouseListener;
specialinvoke v.<UniversalClient$TableMouseListener: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JTable: void addMouseListener(java.awt.event.MouseListener)>(v);
v = v.<UniversalClient: javax.swing.JTable msgTable>;
v = virtualinvoke v.<javax.swing.JTable: javax.swing.table.TableColumnModel getColumnModel()>();
v = interfaceinvoke v.<javax.swing.table.TableColumnModel: javax.swing.table.TableColumn getColumn(int)>(1);
virtualinvoke v.<javax.swing.table.TableColumn: void setPreferredWidth(int)>(125);
v = v.<UniversalClient: javax.swing.JTable msgTable>;
v = virtualinvoke v.<javax.swing.JTable: javax.swing.table.TableColumnModel getColumnModel()>();
v = interfaceinvoke v.<javax.swing.table.TableColumnModel: javax.swing.table.TableColumn getColumn(int)>(2);
virtualinvoke v.<javax.swing.table.TableColumn: void setPreferredWidth(int)>(85);
v = v.<UniversalClient: javax.swing.JTable msgTable>;
v = virtualinvoke v.<javax.swing.JTable: javax.swing.table.TableColumnModel getColumnModel()>();
v = interfaceinvoke v.<javax.swing.table.TableColumnModel: javax.swing.table.TableColumn getColumn(int)>(3);
virtualinvoke v.<javax.swing.table.TableColumn: void setPreferredWidth(int)>(95);
v = v.<UniversalClient: javax.swing.JTable msgTable>;
v = virtualinvoke v.<javax.swing.JTable: javax.swing.table.TableColumnModel getColumnModel()>();
v = interfaceinvoke v.<javax.swing.table.TableColumnModel: javax.swing.table.TableColumn getColumn(int)>(4);
virtualinvoke v.<javax.swing.table.TableColumn: void setPreferredWidth(int)>(15);
v = v.<UniversalClient: javax.swing.JTable msgTable>;
v = virtualinvoke v.<javax.swing.JTable: javax.swing.table.TableColumnModel getColumnModel()>();
v = interfaceinvoke v.<javax.swing.table.TableColumnModel: javax.swing.table.TableColumn getColumn(int)>(5);
virtualinvoke v.<javax.swing.table.TableColumn: void setPreferredWidth(int)>(15);
v = v.<UniversalClient: javax.swing.JTable msgTable>;
v = virtualinvoke v.<javax.swing.JTable: javax.swing.table.TableColumnModel getColumnModel()>();
v = interfaceinvoke v.<javax.swing.table.TableColumnModel: javax.swing.table.TableColumn getColumn(int)>(6);
virtualinvoke v.<javax.swing.table.TableColumn: void setPreferredWidth(int)>(40);
v = new javax.swing.JScrollPane;
v = v.<UniversalClient: javax.swing.JTable msgTable>;
specialinvoke v.<javax.swing.JScrollPane: void <init>(java.awt.Component)>(v);
v.<UniversalClient: javax.swing.JScrollPane msgTableScrollPane> = v;
v = v.<UniversalClient: javax.swing.JScrollPane msgTableScrollPane>;
virtualinvoke v.<javax.swing.JScrollPane: void setAutoscrolls(boolean)>(1);
v = new UniversalClient$3;
specialinvoke v.<UniversalClient$3: void <init>(UniversalClient)>(v);
v = v.<UniversalClient: javax.swing.JScrollPane msgTableScrollPane>;
v = virtualinvoke v.<javax.swing.JScrollPane: javax.swing.JScrollBar getVerticalScrollBar()>();
virtualinvoke v.<javax.swing.JScrollBar: void addMouseMotionListener(java.awt.event.MouseMotionListener)>(v);
v = v.<UniversalClient: javax.swing.JScrollPane msgTableScrollPane>;
v = virtualinvoke v.<javax.swing.JScrollPane: javax.swing.JScrollBar getVerticalScrollBar()>();
virtualinvoke v.<javax.swing.JScrollBar: void setToolTipText(java.lang.String)>("Drag to Bottom to Start auto scroll, to Stop autoscroll Drag else where");
v = new javax.swing.JLabel;
specialinvoke v.<javax.swing.JLabel: void <init>(java.lang.String,int)>("Received Message Table", 0);
virtualinvoke v.<javax.swing.JPanel: void add(java.awt.Component,java.lang.Object)>(v, "North");
v = v.<UniversalClient: javax.swing.JScrollPane msgTableScrollPane>;
virtualinvoke v.<javax.swing.JPanel: void add(java.awt.Component,java.lang.Object)>(v, "Center");
v = staticinvoke <javax.swing.BorderFactory: javax.swing.border.Border createEtchedBorder(int)>(0);
virtualinvoke v.<javax.swing.JPanel: void setBorder(javax.swing.border.Border)>(v);
return v;
}
private javax.swing.JPanel createTopPanel()
{
javax.swing.border.Border v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.awt.BorderLayout v, v, v;
javax.swing.JProgressBar v;
java.awt.Dimension v;
javax.swing.JLabel v, v, v, v, v, v, v;
javax.swing.JPanel v, v, v, v, v, v, v, v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v.<UniversalClient: double msgProductionRate> = #NaN;
v = new javax.swing.JPanel;
v = new java.awt.BorderLayout;
specialinvoke v.<java.awt.BorderLayout: void <init>()>();
specialinvoke v.<javax.swing.JPanel: void <init>(java.awt.LayoutManager)>(v);
v.<UniversalClient: javax.swing.JPanel topPanel> = v;
v = v.<UniversalClient: javax.swing.JPanel topPanel>;
v = staticinvoke <javax.swing.BorderFactory: javax.swing.border.Border createEtchedBorder(int)>(0);
virtualinvoke v.<javax.swing.JPanel: void setBorder(javax.swing.border.Border)>(v);
v = new javax.swing.JLabel;
specialinvoke v.<javax.swing.JLabel: void <init>(java.lang.String,int)>("Connection & Message Production", 0);
v = staticinvoke <javax.swing.BorderFactory: javax.swing.border.Border createEtchedBorder(int)>(1);
virtualinvoke v.<javax.swing.JLabel: void setBorder(javax.swing.border.Border)>(v);
v = v.<UniversalClient: javax.swing.JPanel topPanel>;
virtualinvoke v.<javax.swing.JPanel: java.awt.Component add(java.lang.String,java.awt.Component)>("North", v);
v = new javax.swing.JPanel;
v = new java.awt.BorderLayout;
specialinvoke v.<java.awt.BorderLayout: void <init>()>();
specialinvoke v.<javax.swing.JPanel: void <init>(java.awt.LayoutManager)>(v);
v = new javax.swing.JLabel;
specialinvoke v.<javax.swing.JLabel: void <init>()>();
v.<UniversalClient: javax.swing.JLabel clientIDLabel> = v;
v = new javax.swing.JLabel;
specialinvoke v.<javax.swing.JLabel: void <init>()>();
v.<UniversalClient: javax.swing.JLabel msgProductionRateLabel> = v;
v = new javax.swing.JLabel;
specialinvoke v.<javax.swing.JLabel: void <init>()>();
v.<UniversalClient: javax.swing.JLabel hostPortLabel> = v;
v = v.<UniversalClient: javax.swing.JLabel clientIDLabel>;
virtualinvoke v.<javax.swing.JPanel: java.awt.Component add(java.lang.String,java.awt.Component)>("North", v);
v = v.<UniversalClient: javax.swing.JLabel hostPortLabel>;
virtualinvoke v.<javax.swing.JPanel: java.awt.Component add(java.lang.String,java.awt.Component)>("Center", v);
v = v.<UniversalClient: javax.swing.JLabel msgProductionRateLabel>;
virtualinvoke v.<javax.swing.JPanel: java.awt.Component add(java.lang.String,java.awt.Component)>("South", v);
v = v.<UniversalClient: javax.swing.JPanel topPanel>;
virtualinvoke v.<javax.swing.JPanel: java.awt.Component add(java.lang.String,java.awt.Component)>("West", v);
specialinvoke v.<UniversalClient: void setClientID()>();
specialinvoke v.<UniversalClient: void setMsgProductionRate(java.lang.Object)>("Not Available");
specialinvoke v.<UniversalClient: void setHostPortLabelText(java.lang.String)>("Client Not Connected");
v = new javax.swing.JPanel;
v = new java.awt.BorderLayout;
specialinvoke v.<java.awt.BorderLayout: void <init>()>();
specialinvoke v.<javax.swing.JPanel: void <init>(java.awt.LayoutManager)>(v);
specialinvoke v.<UniversalClient: void setSendMsgProgressBar(int,java.lang.String)>(0, "");
v = v.<UniversalClient: javax.swing.JProgressBar sendMsgProgressBar>;
virtualinvoke v.<javax.swing.JPanel: java.awt.Component add(java.lang.String,java.awt.Component)>("Center", v);
v = v.<UniversalClient: javax.swing.JPanel topPanel>;
virtualinvoke v.<javax.swing.JPanel: java.awt.Component add(java.lang.String,java.awt.Component)>("South", v);
v = v.<UniversalClient: javax.swing.JPanel topPanel>;
v = new java.awt.Dimension;
specialinvoke v.<java.awt.Dimension: void <init>(int,int)>(0, 95);
virtualinvoke v.<javax.swing.JPanel: void setPreferredSize(java.awt.Dimension)>(v);
v = v.<UniversalClient: javax.swing.JPanel topPanel>;
return v;
}
public static void main(java.lang.String[])
{
java.lang.String[] v;
UniversalClient$4 v;
v := @parameter: java.lang.String[];
v = new UniversalClient$4;
specialinvoke v.<UniversalClient$4: void <init>()>();
staticinvoke <javax.swing.SwingUtilities: void invokeLater(java.lang.Runnable)>(v);
return;
}
private void popUpConnDialogBox()
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v, v;
javax.swing.JFrame v;
javax.swing.JButton v, v, v, v;
ConnectionDialogBox v, v, v, v, v, v, v, v;
UniversalClient$5 v;
UniversalClient$ConnectionListener v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
if v != null goto label;
v = new ConnectionDialogBox;
v = v.<UniversalClient: javax.swing.JFrame frame>;
specialinvoke v.<ConnectionDialogBox: void <init>(javax.swing.JFrame)>(v);
v.<UniversalClient: ConnectionDialogBox connDialogB> = v;
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
v = virtualinvoke v.<ConnectionDialogBox: javax.swing.JButton getConnectButton()>();
v.<UniversalClient: javax.swing.JButton connectB> = v;
v = v.<UniversalClient: javax.swing.JButton connectB>;
v = new UniversalClient$ConnectionListener;
specialinvoke v.<UniversalClient$ConnectionListener: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JButton: void addActionListener(java.awt.event.ActionListener)>(v);
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
v = virtualinvoke v.<ConnectionDialogBox: javax.swing.JButton getCancelButton()>();
v.<UniversalClient: javax.swing.JButton connCancelB> = v;
v = v.<UniversalClient: javax.swing.JButton connCancelB>;
v = new UniversalClient$5;
specialinvoke v.<UniversalClient$5: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JButton: void addActionListener(java.awt.event.ActionListener)>(v);
label:
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
v = v.<UniversalClient: java.lang.String userName>;
virtualinvoke v.<ConnectionDialogBox: void setUserName(java.lang.String)>(v);
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
v = v.<UniversalClient: java.lang.String password>;
virtualinvoke v.<ConnectionDialogBox: void setPassword(java.lang.String)>(v);
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
v = v.<UniversalClient: java.lang.String clientID>;
virtualinvoke v.<ConnectionDialogBox: void setClientID(java.lang.String)>(v);
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
virtualinvoke v.<ConnectionDialogBox: void setVisible(boolean)>(1);
return;
}
private void popUpSendMessageDialogBox()
{
UniversalClient$6 v;
javax.swing.JButton v, v, v, v;
UniversalClient$SendMessageListener v;
SendMessageDialogBox v, v, v, v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
javax.swing.JFrame v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
if v != null goto label;
v = new SendMessageDialogBox;
v = v.<UniversalClient: javax.swing.JFrame frame>;
specialinvoke v.<SendMessageDialogBox: void <init>(java.awt.Frame)>(v);
v.<UniversalClient: SendMessageDialogBox sendMsgDialogB> = v;
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
v = virtualinvoke v.<SendMessageDialogBox: javax.swing.JButton getSendButton()>();
v.<UniversalClient: javax.swing.JButton sendMsgB> = v;
v = v.<UniversalClient: javax.swing.JButton sendMsgB>;
v = new UniversalClient$SendMessageListener;
specialinvoke v.<UniversalClient$SendMessageListener: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JButton: void addActionListener(java.awt.event.ActionListener)>(v);
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
v = virtualinvoke v.<SendMessageDialogBox: javax.swing.JButton getCancelButton()>();
v.<UniversalClient: javax.swing.JButton sendMsgCancelB> = v;
v = v.<UniversalClient: javax.swing.JButton sendMsgCancelB>;
v = new UniversalClient$6;
specialinvoke v.<UniversalClient$6: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JButton: void addActionListener(java.awt.event.ActionListener)>(v);
label:
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
virtualinvoke v.<SendMessageDialogBox: void setVisible(boolean)>(1);
return;
}
private void popUpReceiveMessageDialogBox()
{
UniversalClient$7 v;
javax.swing.JButton v, v, v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
ReceiveMessageDialogBox v, v, v, v, v;
javax.swing.JFrame v;
UniversalClient$ReceiveMessageListener v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: ReceiveMessageDialogBox receiveMsgDialogB>;
if v != null goto label;
v = new ReceiveMessageDialogBox;
v = v.<UniversalClient: javax.swing.JFrame frame>;
specialinvoke v.<ReceiveMessageDialogBox: void <init>(java.awt.Frame)>(v);
v.<UniversalClient: ReceiveMessageDialogBox receiveMsgDialogB> = v;
v = v.<UniversalClient: ReceiveMessageDialogBox receiveMsgDialogB>;
v = virtualinvoke v.<ReceiveMessageDialogBox: javax.swing.JButton getReceiveButton()>();
v.<UniversalClient: javax.swing.JButton receiveMsgB> = v;
v = v.<UniversalClient: javax.swing.JButton receiveMsgB>;
v = new UniversalClient$ReceiveMessageListener;
specialinvoke v.<UniversalClient$ReceiveMessageListener: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JButton: void addActionListener(java.awt.event.ActionListener)>(v);
v = v.<UniversalClient: ReceiveMessageDialogBox receiveMsgDialogB>;
v = virtualinvoke v.<ReceiveMessageDialogBox: javax.swing.JButton getCancelButton()>();
v.<UniversalClient: javax.swing.JButton receiveMsgCancelB> = v;
v = v.<UniversalClient: javax.swing.JButton receiveMsgCancelB>;
v = new UniversalClient$7;
specialinvoke v.<UniversalClient$7: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JButton: void addActionListener(java.awt.event.ActionListener)>(v);
label:
v = v.<UniversalClient: ReceiveMessageDialogBox receiveMsgDialogB>;
virtualinvoke v.<ReceiveMessageDialogBox: void setVisible(boolean)>(1);
return;
}
private void doConnect()
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v;
boolean v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = specialinvoke v.<UniversalClient: boolean connected()>();
if v == 0 goto label;
return;
label:
v = specialinvoke v.<UniversalClient: boolean createConnection()>();
if v != 0 goto label;
specialinvoke v.<UniversalClient: void errorMessage(java.lang.String)>("Unable to create A session.  Please verify a broker is running");
return;
label:
specialinvoke v.<UniversalClient: void setUpUIAfterConnection()>();
v = virtualinvoke v.<UniversalClient: java.lang.String getBrokerAddress()>();
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[])>("Successfully Connected to \u0001");
virtualinvoke v.<UniversalClient: void printToStatusArea(java.lang.String)>(v);
return;
}
private void setUpUIAfterConnection()
{
ConnectionDialogBox v;
javax.swing.JMenuItem v, v, v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
specialinvoke v.<UniversalClient: void setConnected(boolean)>(1);
v = v.<UniversalClient: javax.swing.JMenuItem connectItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
v = v.<UniversalClient: javax.swing.JMenuItem disconnectItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(1);
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(1);
v = v.<UniversalClient: javax.swing.JMenuItem rcvMsgItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(1);
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
virtualinvoke v.<ConnectionDialogBox: void setVisible(boolean)>(0);
specialinvoke v.<UniversalClient: void setClientID()>();
v = virtualinvoke v.<UniversalClient: java.lang.String getBrokerAddress()>();
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[])>("Connected to \u0001");
specialinvoke v.<UniversalClient: void setFooter(java.lang.String)>(v);
v = virtualinvoke v.<UniversalClient: java.lang.String getBrokerAddress()>();
specialinvoke v.<UniversalClient: void setHostPortLabelText(java.lang.String)>(v);
return;
}
private boolean createConnection()
{
int v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
jakarta.jms.ConnectionFactory v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
jakarta.jms.Connection v, v, v, v, v, v;
boolean v;
UniversalClient$ConnectionEventListener v;
java.util.Properties v;
ConnectionDialogBox v, v;
java.lang.Exception v;
com.sun.messaging.ConnectionFactory v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
label:
v = virtualinvoke v.<UniversalClient: java.util.Properties getConnFactoryConfig()>();
v = virtualinvoke v.<java.util.Properties: java.lang.String getProperty(java.lang.String)>("imqAddressList");
if v == null goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("");
if v == 0 goto label;
virtualinvoke v.<java.util.Properties: java.lang.Object remove(java.lang.Object)>("imqAddressList");
v = null;
label:
v = null;
v = null;
if v != null goto label;
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
v = virtualinvoke v.<ConnectionDialogBox: java.lang.String getHost()>();
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
v = virtualinvoke v.<ConnectionDialogBox: int getPort()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
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[])>("\u0001:\u0001");
virtualinvoke v.<UniversalClient: void setBrokerAddress(java.lang.String)>(v);
goto label;
label:
virtualinvoke v.<UniversalClient: void setBrokerAddress(java.lang.String)>(v);
label:
v = v.<UniversalClient: jakarta.jms.Connection myConn>;
if v == null goto label;
v = v.<UniversalClient: jakarta.jms.Connection myConn>;
interfaceinvoke v.<jakarta.jms.Connection: void close()>();
label:
v = new com.sun.messaging.ConnectionFactory;
specialinvoke v.<com.sun.messaging.ConnectionFactory: void <init>()>();
v.<UniversalClient: jakarta.jms.ConnectionFactory myConnFactory> = v;
staticinvoke <UniversalClientUtility: void setConnFactoryProperties(com.sun.messaging.AdministeredObject,java.util.Properties)>(v, v);
if v != null goto label;
v = v.<UniversalClient: jakarta.jms.ConnectionFactory myConnFactory>;
virtualinvoke v.<com.sun.messaging.ConnectionFactory: java.lang.String setProperty(java.lang.String,java.lang.String)>("imqBrokerHostName", v);
v = v.<UniversalClient: jakarta.jms.ConnectionFactory myConnFactory>;
virtualinvoke v.<com.sun.messaging.ConnectionFactory: java.lang.String setProperty(java.lang.String,java.lang.String)>("imqBrokerHostPort", v);
label:
v = v.<UniversalClient: jakarta.jms.ConnectionFactory myConnFactory>;
v = virtualinvoke v.<UniversalClient: java.lang.String getClientID()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
virtualinvoke v.<com.sun.messaging.ConnectionFactory: java.lang.String setProperty(java.lang.String,java.lang.String)>("imqConfiguredClientID", v);
v = v.<UniversalClient: jakarta.jms.ConnectionFactory myConnFactory>;
v = virtualinvoke v.<UniversalClient: java.lang.String getUserName()>();
v = virtualinvoke v.<UniversalClient: java.lang.String getPassword()>();
v = interfaceinvoke v.<jakarta.jms.ConnectionFactory: jakarta.jms.Connection createConnection(java.lang.String,java.lang.String)>(v, v);
v.<UniversalClient: jakarta.jms.Connection myConn> = v;
v = new UniversalClient$ConnectionEventListener;
specialinvoke v.<UniversalClient$ConnectionEventListener: void <init>(UniversalClient)>(v);
v = v.<UniversalClient: jakarta.jms.Connection myConn>;
interfaceinvoke v.<com.sun.messaging.jms.Connection: void setEventListener(com.sun.messaging.jms.notification.EventListener)>(v);
v = v.<UniversalClient: jakarta.jms.Connection myConn>;
interfaceinvoke v.<jakarta.jms.Connection: void setExceptionListener(jakarta.jms.ExceptionListener)>(v);
v = v.<UniversalClient: jakarta.jms.Connection myConn>;
interfaceinvoke v.<jakarta.jms.Connection: void start()>();
label:
return 1;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.Exception: void printStackTrace()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Exception)>(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[])>("Caught Exception: \u0001");
specialinvoke v.<UniversalClient: void errorMessage(java.lang.String)>(v);
specialinvoke v.<UniversalClient: void showErrorDialog(java.lang.Exception,java.lang.String)>(v, "Connection Error");
return 0;
catch java.lang.Exception from label to label with label;
}
private void doSendMessage()
{
jakarta.jms.MessageProducer v, v;
jakarta.jms.Session v, v;
UniversalClient$MessageSenderThread v;
jakarta.jms.Destination v, v;
int v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v, v;
boolean v, v;
java.lang.Exception v;
SendMessageDialogBox v, v, v, v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = specialinvoke v.<UniversalClient: boolean connected()>();
if v != 0 goto label;
specialinvoke v.<UniversalClient: void errorMessage(java.lang.String)>("Unable to send Message.  Please verify a broker is running");
return;
label:
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
virtualinvoke v.<SendMessageDialogBox: void setVisible(boolean)>(0);
label:
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
v = virtualinvoke v.<SendMessageDialogBox: boolean isTransacted()>();
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
v = virtualinvoke v.<SendMessageDialogBox: int getDestinationType()>();
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
v = virtualinvoke v.<SendMessageDialogBox: java.lang.String getDestinationName()>();
v = specialinvoke v.<UniversalClient: jakarta.jms.Session getProducerSession(boolean)>(v);
v.<UniversalClient: jakarta.jms.Session myProducerSession> = v;
v = v.<UniversalClient: jakarta.jms.Session myProducerSession>;
v = specialinvoke v.<UniversalClient: jakarta.jms.Destination createDestination(int,java.lang.String,jakarta.jms.Session)>(v, v, v);
v.<UniversalClient: jakarta.jms.Destination myDestination> = v;
v = v.<UniversalClient: jakarta.jms.Destination myDestination>;
v = specialinvoke v.<UniversalClient: jakarta.jms.MessageProducer getProducer(jakarta.jms.Destination,boolean)>(v, v);
v.<UniversalClient: jakarta.jms.MessageProducer myProducer> = v;
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
v = virtualinvoke v.<SendMessageDialogBox: int getDeliveryMode()>();
if v != 1 goto label;
v = v.<UniversalClient: jakarta.jms.MessageProducer myProducer>;
interfaceinvoke v.<jakarta.jms.MessageProducer: void setDeliveryMode(int)>(1);
label:
v = new UniversalClient$MessageSenderThread;
specialinvoke v.<UniversalClient$MessageSenderThread: void <init>(UniversalClient)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
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[])>("Unable to send message:\u0001");
specialinvoke v.<UniversalClient: void errorMessage(java.lang.String)>(v);
specialinvoke v.<UniversalClient: void showErrorDialog(java.lang.Exception,java.lang.String)>(v, "Create Destination Error");
specialinvoke v.<UniversalClient: void doDisconnect()>();
label:
return;
catch java.lang.Exception from label to label with label;
}
private jakarta.jms.MessageConsumer getConsumer(jakarta.jms.Destination, int, boolean, jakarta.jms.Session, java.lang.String) throws jakarta.jms.JMSException
{
jakarta.jms.Session v;
jakarta.jms.Destination v;
int v;
java.lang.Object v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v;
jakarta.jms.Connection v, v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: jakarta.jms.Destination;
v := @parameter: int;
v := @parameter: boolean;
v := @parameter: jakarta.jms.Session;
v := @parameter: java.lang.String;
if v != 2 goto label;
v = v.<UniversalClient: jakarta.jms.Connection myConn>;
interfaceinvoke v.<jakarta.jms.Connection: void stop()>();
v = virtualinvoke v.<UniversalClient: java.lang.String getClientID()>();
v = interfaceinvoke v.<jakarta.jms.Session: jakarta.jms.TopicSubscriber createDurableSubscriber(jakarta.jms.Topic,java.lang.String,java.lang.String,boolean)>(v, v, v, 0);
v = v.<UniversalClient: jakarta.jms.Connection myConn>;
interfaceinvoke v.<jakarta.jms.Connection: void start()>();
goto label;
label:
v = interfaceinvoke v.<jakarta.jms.Session: jakarta.jms.MessageConsumer createConsumer(jakarta.jms.Destination,java.lang.String)>(v, v);
label:
return v;
}
private jakarta.jms.MessageProducer getProducer(jakarta.jms.Destination, boolean) throws jakarta.jms.JMSException
{
java.util.HashMap v, v;
jakarta.jms.Session v;
jakarta.jms.Destination v;
java.lang.Object v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: jakarta.jms.Destination;
v := @parameter: boolean;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,boolean)>(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[])>("\u0001\u0001");
v = v.<UniversalClient: java.util.HashMap myProducerMap>;
v = virtualinvoke v.<java.util.HashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = v.<UniversalClient: jakarta.jms.Session myProducerSession>;
v = interfaceinvoke v.<jakarta.jms.Session: jakarta.jms.MessageProducer createProducer(jakarta.jms.Destination)>(v);
v = v.<UniversalClient: java.util.HashMap myProducerMap>;
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
return v;
}
private jakarta.jms.Session getProducerSession(boolean) throws jakarta.jms.JMSException
{
java.util.HashMap v, v;
java.lang.Object v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v, v;
jakarta.jms.Connection v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: boolean;
v = new java.lang.String;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (boolean)>(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[])>("session\u0001");
specialinvoke v.<java.lang.String: void <init>(java.lang.String)>(v);
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[])>("\u0001Producer");
v = v.<UniversalClient: java.util.HashMap mySessionMap>;
v = virtualinvoke v.<java.util.HashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = v.<UniversalClient: jakarta.jms.Connection myConn>;
v = interfaceinvoke v.<jakarta.jms.Connection: jakarta.jms.Session createSession(boolean,int)>(v, 1);
v = v.<UniversalClient: java.util.HashMap mySessionMap>;
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
return v;
}
private jakarta.jms.Session getConsumerSession(boolean, int) throws jakarta.jms.JMSException
{
java.util.HashMap v, v;
int v;
java.lang.Object v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v, v;
jakarta.jms.Connection v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: boolean;
v := @parameter: int;
v = new java.lang.String;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (boolean)>(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[])>("session\u0001");
specialinvoke v.<java.lang.String: void <init>(java.lang.String)>(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[])>("\u0001Consumer\u0001");
v = v.<UniversalClient: java.util.HashMap mySessionMap>;
v = virtualinvoke v.<java.util.HashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
if v != 0 goto label;
v = 1;
goto label;
label:
if v != 1 goto label;
v = 2;
goto label;
label:
if v != 2 goto label;
v = 3;
label:
v = v.<UniversalClient: jakarta.jms.Connection myConn>;
v = interfaceinvoke v.<jakarta.jms.Connection: jakarta.jms.Session createSession(boolean,int)>(v, v);
v = v.<UniversalClient: java.util.HashMap mySessionMap>;
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
return v;
}
private void sendMessage()
{
jakarta.jms.Session v, v;
boolean v, v, v, v, v;
jakarta.jms.Message v;
java.lang.Exception v;
SendMessageDialogBox v, v, v;
java.lang.Throwable v, v, v;
jakarta.jms.MessageProducer v;
java.lang.Double v;
long v, v, v;
javax.swing.JMenuItem v, v, v, v, v, v;
int v, v, v, v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v, v;
javax.swing.JProgressBar v;
double v, v, v;
java.lang.InterruptedException v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
v = virtualinvoke v.<SendMessageDialogBox: boolean isTransacted()>();
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
v = virtualinvoke v.<SendMessageDialogBox: int getNumOfMsg()>();
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
v = virtualinvoke v.<SendMessageDialogBox: int getDelayBetweenMsg()>();
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgStopItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(1);
virtualinvoke v.<UniversalClient: void setMsgSenderStopped(boolean)>(0);
v = v.<UniversalClient: javax.swing.JProgressBar sendMsgProgressBar>;
virtualinvoke v.<javax.swing.JProgressBar: void setMaximum(int)>(v);
v = null;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = 0;
label:
if v >= v goto label;
v = null;
v = virtualinvoke v.<UniversalClient: boolean isMsgSenderStopped()>();
if v != 0 goto label;
label:
v = v + 1;
v = virtualinvoke v.<UniversalClient: jakarta.jms.Message createMessage(int,int)>(v, v);
v = v.<UniversalClient: jakarta.jms.MessageProducer myProducer>;
interfaceinvoke v.<jakarta.jms.MessageProducer: void send(jakarta.jms.Message)>(v);
if v == 0 goto label;
v = v.<UniversalClient: jakarta.jms.Session myProducerSession>;
interfaceinvoke v.<jakarta.jms.Session: void commit()>();
label:
goto label;
label:
v := @caughtexception;
v = v - 1;
goto label;
label:
v := @caughtexception;
if v == 0 goto label;
v = v.<UniversalClient: jakarta.jms.Session myProducerSession>;
interfaceinvoke v.<jakarta.jms.Session: void rollback()>();
v = v - 1;
label:
goto label;
label:
v := @caughtexception;
specialinvoke v.<UniversalClient: void showErrorDialog(java.lang.Exception,java.lang.String)>(v, "Send Message Error");
virtualinvoke v.<java.lang.Exception: void printStackTrace()>();
v = specialinvoke v.<UniversalClient: boolean isValidConnection()>();
if v == 0 goto label;
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(1);
label:
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgStopItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
virtualinvoke v.<UniversalClient: void setMsgSenderStopped(boolean)>(0);
specialinvoke v.<UniversalClient: void setSendMsgProgressBar(int,java.lang.String)>(0, "");
return;
label:
v = v + 1;
v = staticinvoke <UniversalClientUtility: java.lang.String getDestination(jakarta.jms.Message)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int,java.lang.String)>(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[])>("Sending Message \u of \u  To  \u0001");
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<jakarta.jms.JMSException: void printStackTrace()>();
label:
specialinvoke v.<UniversalClient: void setSendMsgProgressBar(int,java.lang.String)>(v, v);
if v == 0 goto label;
label:
staticinvoke <java.lang.Thread: void sleep(long)>(v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.InterruptedException: void printStackTrace()>();
label:
v = v + 1;
goto label;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v * 1000.0;
v = v - v;
v = v / v;
v.<UniversalClient: double msgProductionRate> = v;
v = new java.lang.Double;
v = v.<UniversalClient: double msgProductionRate>;
specialinvoke v.<java.lang.Double: void <init>(double)>(v);
specialinvoke v.<UniversalClient: void setMsgProductionRate(java.lang.Object)>(v);
v = virtualinvoke v.<UniversalClient: boolean isMsgSenderStopped()>();
if v == 0 goto label;
specialinvoke v.<UniversalClient: void setSendMsgProgressBar(int,java.lang.String)>(v, "Sending Message Stopped ....");
goto label;
label:
specialinvoke v.<UniversalClient: void setSendMsgProgressBar(int,java.lang.String)>(v, "Sending Message Completed ....");
label:
v = specialinvoke v.<UniversalClient: boolean connected()>();
if v == 0 goto label;
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(1);
goto label;
label:
v = new java.lang.String;
specialinvoke v.<java.lang.String: void <init>(java.lang.String)>("N/A");
specialinvoke v.<UniversalClient: void setMsgProductionRate(java.lang.Object)>(v);
label:
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgStopItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
virtualinvoke v.<UniversalClient: void setMsgSenderStopped(boolean)>(0);
label:
staticinvoke <java.lang.Thread: void sleep(long)>(2000L);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.InterruptedException: void printStackTrace()>();
label:
specialinvoke v.<UniversalClient: void setSendMsgProgressBar(int,java.lang.String)>(0, "");
return;
catch jakarta.jms.TransactionRolledBackException from label to label with label;
catch jakarta.jms.JMSException from label to label with label;
catch java.lang.Exception from label to label with label;
catch jakarta.jms.JMSException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
}
public jakarta.jms.Message createMessage(int, int) throws java.lang.Exception
{
byte[] v;
jakarta.jms.Session v, v, v, v, v;
int v, v, v, v, v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v, v, v;
boolean v, v;
SendMessageDialogBox v, v, v, v;
java.lang.Object v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: int;
v := @parameter: int;
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
v = virtualinvoke v.<SendMessageDialogBox: int getMsgTTL()>();
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
v = virtualinvoke v.<SendMessageDialogBox: int getMsgType()>();
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
v = virtualinvoke v.<SendMessageDialogBox: int getMsgSize()>();
v = v.<UniversalClient: SendMessageDialogBox sendMsgDialogB>;
v = virtualinvoke v.<SendMessageDialogBox: int getCompression()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = null;
v = newarray (byte)[v];
staticinvoke <java.util.Arrays: void fill(byte[],byte)>(v, 115);
tableswitch(v)
{
case 0: goto label;
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
default: goto label;
};
label:
v = v.<UniversalClient: jakarta.jms.Session myProducerSession>;
v = interfaceinvoke v.<jakarta.jms.Session: jakarta.jms.TextMessage createTextMessage()>();
v = new java.lang.String;
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
interfaceinvoke v.<jakarta.jms.TextMessage: void setText(java.lang.String)>(v);
goto label;
label:
v = v.<UniversalClient: jakarta.jms.Session myProducerSession>;
v = interfaceinvoke v.<jakarta.jms.Session: jakarta.jms.ObjectMessage createObjectMessage()>();
v = new java.lang.String;
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
interfaceinvoke v.<jakarta.jms.ObjectMessage: void setObject(java.io.Serializable)>(v);
goto label;
label:
v = v.<UniversalClient: jakarta.jms.Session myProducerSession>;
v = interfaceinvoke v.<jakarta.jms.Session: jakarta.jms.MapMessage createMapMessage()>();
v = new java.lang.String;
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
interfaceinvoke v.<jakarta.jms.MapMessage: void setString(java.lang.String,java.lang.String)>("hello", v);
goto label;
label:
v = v.<UniversalClient: jakarta.jms.Session myProducerSession>;
v = interfaceinvoke v.<jakarta.jms.Session: jakarta.jms.BytesMessage createBytesMessage()>();
interfaceinvoke v.<jakarta.jms.BytesMessage: void writeBytes(byte[])>(v);
goto label;
label:
v = v.<UniversalClient: jakarta.jms.Session myProducerSession>;
v = interfaceinvoke v.<jakarta.jms.Session: jakarta.jms.StreamMessage createStreamMessage()>();
interfaceinvoke v.<jakarta.jms.StreamMessage: void writeBytes(byte[])>(v);
label:
interfaceinvoke v.<jakarta.jms.Message: void setJMSExpiration(long)>(v);
interfaceinvoke v.<jakarta.jms.Message: void setJMSType(java.lang.String)>("Universal Client");
interfaceinvoke v.<jakarta.jms.Message: void setIntProperty(java.lang.String,int)>("totalNumMsgs", v);
interfaceinvoke v.<jakarta.jms.Message: void setIntProperty(java.lang.String,int)>("msgNum", v);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
interfaceinvoke v.<jakarta.jms.Message: void setStringProperty(java.lang.String,java.lang.String)>("msgNumStr", v);
interfaceinvoke v.<jakarta.jms.Message: void setStringProperty(java.lang.String,java.lang.String)>("msgSource", "I am coming from universal client");
interfaceinvoke v.<jakarta.jms.Message: void setBooleanProperty(java.lang.String,boolean)>("JMS_SUN_COMPRESS", v);
return v;
}
private jakarta.jms.Destination createDestination(int, java.lang.String, jakarta.jms.Session) throws jakarta.jms.JMSException
{
int v;
java.lang.Object v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v;
jakarta.jms.Session v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: int;
v := @parameter: java.lang.String;
v := @parameter: jakarta.jms.Session;
if v != 0 goto label;
v = interfaceinvoke v.<jakarta.jms.Session: jakarta.jms.Queue createQueue(java.lang.String)>(v);
goto label;
label:
v = interfaceinvoke v.<jakarta.jms.Session: jakarta.jms.Topic createTopic(java.lang.String)>(v);
label:
return v;
}
public java.lang.String getPassword()
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v;
ConnectionDialogBox v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
v = virtualinvoke v.<ConnectionDialogBox: java.lang.String getPassword()>();
return v;
}
public java.util.Properties getConnFactoryConfig()
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.util.Properties v;
ConnectionDialogBox v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
v = virtualinvoke v.<ConnectionDialogBox: java.util.Properties getConfiguration()>();
return v;
}
public java.lang.String getUserName()
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v;
ConnectionDialogBox v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
v = virtualinvoke v.<ConnectionDialogBox: java.lang.String getUserName()>();
return v;
}
public java.lang.String getBrokerAddress()
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: java.lang.String brokerAddress>;
return v;
}
public void setBrokerAddress(java.lang.String)
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: java.lang.String;
v.<UniversalClient: java.lang.String brokerAddress> = v;
return;
}
public java.lang.String getClientID()
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v;
ConnectionDialogBox v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
if v != null goto label;
v = v.<UniversalClient: java.lang.String clientID>;
return v;
label:
v = v.<UniversalClient: ConnectionDialogBox connDialogB>;
v = virtualinvoke v.<ConnectionDialogBox: java.lang.String getClientID()>();
return v;
}
private void doReceiveMessage()
{
java.lang.Throwable v;
jakarta.jms.Session v, v, v;
jakarta.jms.MessageConsumer v;
jakarta.jms.Destination v, v;
int v, v;
UniversalClient$MessageReceiverThread v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v;
ReceiveMessageDialogBox v, v, v, v, v, v;
boolean v, v;
java.lang.Exception v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = specialinvoke v.<UniversalClient: boolean connected()>();
if v != 0 goto label;
specialinvoke v.<UniversalClient: void errorMessage(java.lang.String)>("Unable to send Message.  Please verify a broker is running");
return;
label:
v = v.<UniversalClient: ReceiveMessageDialogBox receiveMsgDialogB>;
virtualinvoke v.<ReceiveMessageDialogBox: void setVisible(boolean)>(0);
label:
v = v.<UniversalClient: ReceiveMessageDialogBox receiveMsgDialogB>;
v = virtualinvoke v.<ReceiveMessageDialogBox: boolean isTransacted()>();
v = v.<UniversalClient: ReceiveMessageDialogBox receiveMsgDialogB>;
v = virtualinvoke v.<ReceiveMessageDialogBox: java.lang.String getDestinationName()>();
v = v.<UniversalClient: ReceiveMessageDialogBox receiveMsgDialogB>;
v = virtualinvoke v.<ReceiveMessageDialogBox: int getDestinationType()>();
v = v.<UniversalClient: ReceiveMessageDialogBox receiveMsgDialogB>;
v = virtualinvoke v.<ReceiveMessageDialogBox: java.lang.String getSelector()>();
v = v.<UniversalClient: ReceiveMessageDialogBox receiveMsgDialogB>;
v = virtualinvoke v.<ReceiveMessageDialogBox: int getAcknowledgeMode()>();
v = specialinvoke v.<UniversalClient: jakarta.jms.Session getConsumerSession(boolean,int)>(v, v);
v.<UniversalClient: jakarta.jms.Session myConsumerSession> = v;
v = v.<UniversalClient: jakarta.jms.Session myConsumerSession>;
v = specialinvoke v.<UniversalClient: jakarta.jms.Destination createDestination(int,java.lang.String,jakarta.jms.Session)>(v, v, v);
v.<UniversalClient: jakarta.jms.Destination myDestination> = v;
v = v.<UniversalClient: jakarta.jms.Destination myDestination>;
v = v.<UniversalClient: jakarta.jms.Session myConsumerSession>;
v = specialinvoke v.<UniversalClient: jakarta.jms.MessageConsumer getConsumer(jakarta.jms.Destination,int,boolean,jakarta.jms.Session,java.lang.String)>(v, v, v, v, v);
v.<UniversalClient: jakarta.jms.MessageConsumer myConsumer> = v;
v = new UniversalClient$MessageReceiverThread;
specialinvoke v.<UniversalClient$MessageReceiverThread: void <init>(UniversalClient)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
label:
goto label;
label:
v := @caughtexception;
specialinvoke v.<UniversalClient: void showErrorDialog(java.lang.Exception,java.lang.String)>(v, "Receive Message Error");
goto label;
label:
v := @caughtexception;
specialinvoke v.<UniversalClient: void showErrorDialog(java.lang.Exception,java.lang.String)>(v, "Receive Message Error");
specialinvoke v.<UniversalClient: void doDisconnect()>();
label:
return;
catch jakarta.jms.ResourceAllocationException from label to label with label;
catch java.lang.Exception from label to label with label;
}
private boolean isValidConnection()
{
java.lang.Throwable v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
jakarta.jms.Connection v, v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = 0;
v = v.<UniversalClient: jakarta.jms.Connection myConn>;
if v != null goto label;
return 0;
label:
v = v.<UniversalClient: jakarta.jms.Connection myConn>;
interfaceinvoke v.<jakarta.jms.Connection: void start()>();
v = 1;
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<jakarta.jms.JMSException: void printStackTrace()>();
label:
return v;
catch jakarta.jms.JMSException from label to label with label;
}
private void receiveMessage()
{
java.lang.Integer v;
jakarta.jms.Session v, v;
ReceiveMessageDialogBox v, v, v;
boolean v, v, v, v, v;
jakarta.jms.Message v;
java.lang.Exception v;
java.lang.Throwable v, v, v;
jakarta.jms.MessageConsumer v, v;
javax.swing.JMenuItem v, v, v, v;
int v, v, v, v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v, v, v;
java.lang.InterruptedException v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = 0;
v = v.<UniversalClient: ReceiveMessageDialogBox receiveMsgDialogB>;
v = virtualinvoke v.<ReceiveMessageDialogBox: boolean isTransacted()>();
v = v.<UniversalClient: ReceiveMessageDialogBox receiveMsgDialogB>;
v = virtualinvoke v.<ReceiveMessageDialogBox: int getAcknowledgeMode()>();
v = v.<UniversalClient: ReceiveMessageDialogBox receiveMsgDialogB>;
v = virtualinvoke v.<ReceiveMessageDialogBox: int getDelayBetweenMsg()>();
v = v.<UniversalClient: javax.swing.JMenuItem rcvMsgItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
v = v.<UniversalClient: javax.swing.JMenuItem rcvMsgStopItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(1);
virtualinvoke v.<UniversalClient: void setFooterInUse(boolean)>(1);
specialinvoke v.<UniversalClient: void setFooter(java.lang.String)>("Waiting on a message Receive() call");
label:
v = v.<UniversalClient: jakarta.jms.MessageConsumer myConsumer>;
v = interfaceinvoke v.<jakarta.jms.MessageConsumer: jakarta.jms.Message receive()>();
if v != null goto label;
virtualinvoke v.<UniversalClient: void setMsgReceiverStopped(boolean)>(0);
label:
goto label;
label:
if v == 0 goto label;
v = v.<UniversalClient: jakarta.jms.Session myConsumerSession>;
interfaceinvoke v.<jakarta.jms.Session: void commit()>();
goto label;
label:
if v != 1 goto label;
interfaceinvoke v.<jakarta.jms.Message: void acknowledge()>();
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<UniversalClient: boolean isMsgReceiverStopped()>();
if v == 0 goto label;
virtualinvoke v.<UniversalClient: void setMsgReceiverStopped(boolean)>(0);
goto label;
label:
v = specialinvoke v.<UniversalClient: boolean isValidConnection()>();
if v != 0 goto label;
goto label;
label:
v := @caughtexception;
if v == 0 goto label;
v = v.<UniversalClient: jakarta.jms.Session myConsumerSession>;
interfaceinvoke v.<jakarta.jms.Session: void rollback()>();
label:
v = virtualinvoke v.<UniversalClient: boolean isMsgReceiverStopped()>();
if v == 0 goto label;
virtualinvoke v.<UniversalClient: void setMsgReceiverStopped(boolean)>(0);
goto label;
label:
v = specialinvoke v.<UniversalClient: boolean isValidConnection()>();
if v != 0 goto label;
goto label;
label:
v = v + 1;
virtualinvoke v.<UniversalClient: void addMessageToTable(jakarta.jms.Message)>(v);
label:
v = interfaceinvoke v.<jakarta.jms.Message: int getIntProperty(java.lang.String)>("msgNum");
v = interfaceinvoke v.<jakarta.jms.Message: int getIntProperty(java.lang.String)>("totalNumMsgs");
v = staticinvoke <UniversalClientUtility: java.lang.String getDestination(jakarta.jms.Message)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int,java.lang.String)>(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[])>("Last Received Message # \u0001/\u  From  \u0001");
specialinvoke v.<UniversalClient: void setFooter(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<jakarta.jms.JMSException: void printStackTrace()>();
label:
if v == 0 goto label;
label:
staticinvoke <java.lang.Thread: void sleep(long)>(v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.InterruptedException: void printStackTrace()>();
goto label;
label:
v = v.<UniversalClient: jakarta.jms.MessageConsumer myConsumer>;
interfaceinvoke v.<jakarta.jms.MessageConsumer: void close()>();
label:
goto label;
label:
v := @caughtexception;
specialinvoke v.<UniversalClient: void showErrorDialog(java.lang.Exception,java.lang.String)>(v, "Receive Message Error");
virtualinvoke v.<UniversalClient: void setFooterInUse(boolean)>(0);
return;
label:
v = v.<UniversalClient: javax.swing.JMenuItem rcvMsgItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(1);
v = v.<UniversalClient: javax.swing.JMenuItem rcvMsgStopItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
if v != 0 goto label;
v = "NONE";
goto label;
label:
v = new java.lang.Integer;
specialinvoke v.<java.lang.Integer: void <init>(int)>(v);
v = virtualinvoke v.<java.lang.Integer: java.lang.String toString()>();
label:
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[])>("Received messages for this transaction: \u0001");
specialinvoke v.<UniversalClient: void setFooter(java.lang.String)>(v);
label:
staticinvoke <java.lang.Thread: void sleep(long)>(1000L);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.InterruptedException: void printStackTrace()>();
label:
virtualinvoke v.<UniversalClient: void setFooterInUse(boolean)>(0);
return;
catch jakarta.jms.TransactionRolledBackException from label to label with label;
catch jakarta.jms.TransactionRolledBackException from label to label with label;
catch jakarta.jms.JMSException from label to label with label;
catch jakarta.jms.JMSException from label to label with label;
catch jakarta.jms.JMSException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.InterruptedException from label to label with label;
}
public void showCurrentStatus()
{
int v;
javax.swing.JTable v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v;
javax.swing.JFrame v;
boolean v, v;
javax.swing.table.TableModel v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: javax.swing.JTable msgTable>;
v = virtualinvoke v.<javax.swing.JTable: javax.swing.table.TableModel getModel()>();
v = virtualinvoke v.<MsgTable: int getRowCount()>();
v = virtualinvoke v.<UniversalClient: boolean isFooterInUse()>();
if v == 0 goto label;
v = v.<UniversalClient: javax.swing.JFrame frame>;
virtualinvoke v.<javax.swing.JFrame: void repaint()>();
label:
if v == 0 goto label;
v = virtualinvoke v.<UniversalClient: boolean isFooterInUse()>();
if v != 0 goto label;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
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[])>("Message Table Current Size : \u0001");
specialinvoke v.<UniversalClient: void setFooter(java.lang.String)>(v);
label:
return;
}
public void scrollToLastRowOfTable()
{
java.awt.Rectangle v;
int v, v;
javax.swing.JTable v, v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: javax.swing.JTable msgTable>;
v = v.<UniversalClient: javax.swing.JTable msgTable>;
v = virtualinvoke v.<javax.swing.JTable: int getRowCount()>();
v = v - 1;
v = staticinvoke <UniversalClientUtility: java.awt.Rectangle getRowBounds(javax.swing.JTable,int)>(v, v);
v = v.<UniversalClient: javax.swing.JTable msgTable>;
virtualinvoke v.<javax.swing.JTable: void scrollRectToVisible(java.awt.Rectangle)>(v);
return;
}
public void addMessageToTable(jakarta.jms.Message)
{
jakarta.jms.Message v;
java.lang.ArrayIndexOutOfBoundsException v;
java.lang.Exception v;
int v;
javax.swing.JTable v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
boolean v;
javax.swing.table.TableModel v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: jakarta.jms.Message;
v = v.<UniversalClient: javax.swing.JTable msgTable>;
v = virtualinvoke v.<javax.swing.JTable: javax.swing.table.TableModel getModel()>();
label:
v = virtualinvoke v.<MsgTable: int addMessage(jakarta.jms.Message)>(v);
if v <= 30000 goto label;
v = new java.lang.ArrayIndexOutOfBoundsException;
specialinvoke v.<java.lang.ArrayIndexOutOfBoundsException: void <init>()>();
throw v;
label:
v = virtualinvoke v.<UniversalClient: boolean isScrollingON()>();
if v == 0 goto label;
virtualinvoke v.<UniversalClient: void scrollToLastRowOfTable()>();
label:
virtualinvoke v.<MsgTable: void updateUI()>();
label:
goto label;
label:
v := @caughtexception;
specialinvoke v.<UniversalClient: void showErrorDialog(java.lang.String,java.lang.String)>("Exceeded MAX Table Capacity: All Messages will be deleted", "Message Loading Error");
virtualinvoke v.<MsgTable: void clearData()>();
label:
return;
catch java.lang.Exception from label to label with label;
}
private void doDisconnect()
{
javax.swing.JMenuItem v, v, v, v, v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = specialinvoke v.<UniversalClient: boolean connected()>();
if v != 0 goto label;
return;
label:
specialinvoke v.<UniversalClient: void destroyCurrentSession()>();
specialinvoke v.<UniversalClient: void setConnected(boolean)>(0);
v = v.<UniversalClient: javax.swing.JMenuItem connectItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(1);
v = v.<UniversalClient: javax.swing.JMenuItem disconnectItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
v = v.<UniversalClient: javax.swing.JMenuItem sendMsgStopItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
v = v.<UniversalClient: javax.swing.JMenuItem rcvMsgItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
v = v.<UniversalClient: javax.swing.JMenuItem rcvMsgStopItem>;
virtualinvoke v.<javax.swing.JMenuItem: void setEnabled(boolean)>(0);
specialinvoke v.<UniversalClient: void setFooter(java.lang.String)>("Not Connected");
specialinvoke v.<UniversalClient: void setClientID()>();
specialinvoke v.<UniversalClient: void setHostPortLabelText(java.lang.String)>("Not Connected");
specialinvoke v.<UniversalClient: void setMsgProductionRate(java.lang.Object)>("Not Available");
return;
}
private void destroyCurrentSession()
{
java.util.HashMap v, v, v, v, v, v;
jakarta.jms.MessageConsumer v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v;
boolean v, v;
java.util.Iterator v, v;
java.util.Collection v, v;
java.lang.Exception v;
java.lang.Object v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
label:
v = v.<UniversalClient: jakarta.jms.MessageConsumer myConsumer>;
if v == null goto label;
v = v.<UniversalClient: jakarta.jms.MessageConsumer myConsumer>;
interfaceinvoke v.<jakarta.jms.MessageConsumer: void close()>();
label:
v = v.<UniversalClient: java.util.HashMap myProducerMap>;
v = virtualinvoke v.<java.util.HashMap: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<jakarta.jms.MessageProducer: void close()>();
goto label;
label:
v = v.<UniversalClient: java.util.HashMap myProducerMap>;
virtualinvoke v.<java.util.HashMap: void clear()>();
v = v.<UniversalClient: java.util.HashMap mySessionMap>;
v = virtualinvoke v.<java.util.HashMap: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<jakarta.jms.Session: void close()>();
goto label;
label:
v = v.<UniversalClient: java.util.HashMap mySessionMap>;
virtualinvoke v.<java.util.HashMap: void clear()>();
specialinvoke v.<UniversalClient: void clearMessageList()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.Exception: void printStackTrace()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Exception)>(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[])>("Caught Exception: \u0001");
specialinvoke v.<UniversalClient: void errorMessage(java.lang.String)>(v);
v = v.<UniversalClient: java.util.HashMap myProducerMap>;
virtualinvoke v.<java.util.HashMap: void clear()>();
v = v.<UniversalClient: java.util.HashMap mySessionMap>;
virtualinvoke v.<java.util.HashMap: void clear()>();
specialinvoke v.<UniversalClient: void clearMessageList()>();
label:
return;
catch java.lang.Exception from label to label with label;
}
private void clearMessageList()
{
javax.swing.JTable v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
javax.swing.table.TableModel v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: javax.swing.JTable msgTable>;
v = virtualinvoke v.<javax.swing.JTable: javax.swing.table.TableModel getModel()>();
virtualinvoke v.<MsgTable: void clearData()>();
specialinvoke v.<UniversalClient: void setFooter(java.lang.String)>("Message List Cleared");
return;
}
private void errorMessage(java.lang.String)
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: java.lang.String;
specialinvoke v.<UniversalClient: void setFooter(java.lang.String)>(v);
return;
}
private void showInformationDialog(java.lang.String, java.lang.String)
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v;
javax.swing.JFrame v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<UniversalClient: javax.swing.JFrame frame>;
staticinvoke <javax.swing.JOptionPane: void showMessageDialog(java.awt.Component,java.lang.Object,java.lang.String,int)>(v, v, v, 1);
return;
}
private void showErrorDialog(java.lang.String, java.lang.String)
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v;
javax.swing.JFrame v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<UniversalClient: javax.swing.JFrame frame>;
staticinvoke <javax.swing.JOptionPane: void showMessageDialog(java.awt.Component,java.lang.Object,java.lang.String,int)>(v, v, v, 0);
return;
}
private void showErrorDialog(java.lang.Exception, java.lang.String)
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v;
javax.swing.JFrame v;
java.lang.Exception v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: java.lang.Exception;
v := @parameter: java.lang.String;
v = v.<UniversalClient: javax.swing.JFrame frame>;
staticinvoke <javax.swing.JOptionPane: void showMessageDialog(java.awt.Component,java.lang.Object,java.lang.String,int)>(v, v, v, 0);
return;
}
private void setConnected(boolean)
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: boolean;
v.<UniversalClient: boolean connected> = v;
return;
}
private boolean connected()
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: boolean connected>;
return v;
}
private void exit()
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
specialinvoke v.<UniversalClient: void doDisconnect()>();
staticinvoke <java.lang.System: void exit(int)>(0);
return;
}
private javax.swing.JPanel createFooterPanel()
{
javax.swing.JButton v;
javax.swing.border.Border v;
javax.swing.JLabel v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
UniversalClient$DetailsListener v;
java.awt.BorderLayout v;
javax.swing.JPanel v, v, v, v, v, v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = new javax.swing.JPanel;
specialinvoke v.<javax.swing.JPanel: void <init>()>();
v.<UniversalClient: javax.swing.JPanel footerPanel> = v;
v = v.<UniversalClient: javax.swing.JPanel footerPanel>;
v = new java.awt.BorderLayout;
specialinvoke v.<java.awt.BorderLayout: void <init>()>();
virtualinvoke v.<javax.swing.JPanel: void setLayout(java.awt.LayoutManager)>(v);
v = new javax.swing.JLabel;
specialinvoke v.<javax.swing.JLabel: void <init>(java.lang.String)>("");
v.<UniversalClient: javax.swing.JLabel footerLabel> = v;
v = v.<UniversalClient: javax.swing.JPanel footerPanel>;
v = v.<UniversalClient: javax.swing.JLabel footerLabel>;
virtualinvoke v.<javax.swing.JPanel: java.awt.Component add(java.lang.String,java.awt.Component)>("West", v);
v = new javax.swing.JPanel;
specialinvoke v.<javax.swing.JPanel: void <init>()>();
v = new javax.swing.JButton;
specialinvoke v.<javax.swing.JButton: void <init>(java.lang.String)>("Message Details");
virtualinvoke v.<javax.swing.JButton: void setToolTipText(java.lang.String)>("Show Message Details ");
v = new UniversalClient$DetailsListener;
specialinvoke v.<UniversalClient$DetailsListener: void <init>(UniversalClient)>(v);
virtualinvoke v.<javax.swing.JButton: void addActionListener(java.awt.event.ActionListener)>(v);
v = v.<UniversalClient: javax.swing.JPanel footerPanel>;
v = staticinvoke <javax.swing.BorderFactory: javax.swing.border.Border createEtchedBorder(int)>(0);
virtualinvoke v.<javax.swing.JPanel: void setBorder(javax.swing.border.Border)>(v);
virtualinvoke v.<javax.swing.JPanel: java.awt.Component add(java.awt.Component)>(v);
v = v.<UniversalClient: javax.swing.JPanel footerPanel>;
virtualinvoke v.<javax.swing.JPanel: java.awt.Component add(java.lang.String,java.awt.Component)>("East", v);
v = v.<UniversalClient: javax.swing.JPanel footerPanel>;
return v;
}
public boolean isScrollingON()
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: boolean scrollingON>;
return v;
}
public void setScrollingON(boolean)
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: boolean;
v.<UniversalClient: boolean scrollingON> = v;
return;
}
public boolean isFooterInUse()
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: boolean footerInUse>;
return v;
}
public void setFooterInUse(boolean)
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: boolean;
v.<UniversalClient: boolean footerInUse> = v;
return;
}
private void setFooter(java.lang.String)
{
javax.swing.JLabel v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: java.lang.String;
v = v.<UniversalClient: javax.swing.JLabel footerLabel>;
virtualinvoke v.<javax.swing.JLabel: void setText(java.lang.String)>(v);
v = v.<UniversalClient: javax.swing.JLabel footerLabel>;
virtualinvoke v.<javax.swing.JLabel: void repaint()>();
return;
}
private void setClientID()
{
java.awt.Rectangle v;
javax.swing.JLabel v, v, v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v, v, v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = specialinvoke v.<UniversalClient: boolean connected()>();
if v == 0 goto label;
v = v.<UniversalClient: javax.swing.JLabel clientIDLabel>;
v = virtualinvoke v.<UniversalClient: java.lang.String getClientID()>();
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[])>("Client ID:  \u0001");
virtualinvoke v.<javax.swing.JLabel: void setText(java.lang.String)>(v);
goto label;
label:
v = v.<UniversalClient: javax.swing.JLabel clientIDLabel>;
v = v.<UniversalClient: java.lang.String clientID>;
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[])>("Client ID:  \u0001");
virtualinvoke v.<javax.swing.JLabel: void setText(java.lang.String)>(v);
label:
v = v.<UniversalClient: javax.swing.JLabel clientIDLabel>;
v = v.<UniversalClient: javax.swing.JLabel clientIDLabel>;
v = virtualinvoke v.<javax.swing.JLabel: java.awt.Rectangle getBounds()>();
virtualinvoke v.<javax.swing.JLabel: void paintImmediately(java.awt.Rectangle)>(v);
return;
}
private void setHostPortLabelText(java.lang.String)
{
java.awt.Rectangle v;
javax.swing.JLabel v, v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: java.lang.String;
v = v.<UniversalClient: javax.swing.JLabel hostPortLabel>;
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[])>("Hostname & Port:  \u0001");
virtualinvoke v.<javax.swing.JLabel: void setText(java.lang.String)>(v);
v = v.<UniversalClient: javax.swing.JLabel hostPortLabel>;
v = v.<UniversalClient: javax.swing.JLabel hostPortLabel>;
v = virtualinvoke v.<javax.swing.JLabel: java.awt.Rectangle getBounds()>();
virtualinvoke v.<javax.swing.JLabel: void paintImmediately(java.awt.Rectangle)>(v);
return;
}
private void setSendMsgProgressBar(int, java.lang.String)
{
int v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v;
javax.swing.JProgressBar v, v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: int;
v := @parameter: java.lang.String;
v = v.<UniversalClient: javax.swing.JProgressBar sendMsgProgressBar>;
virtualinvoke v.<javax.swing.JProgressBar: void setValue(int)>(v);
v = v.<UniversalClient: javax.swing.JProgressBar sendMsgProgressBar>;
virtualinvoke v.<javax.swing.JProgressBar: void setString(java.lang.String)>(v);
v = v.<UniversalClient: javax.swing.JProgressBar sendMsgProgressBar>;
virtualinvoke v.<javax.swing.JProgressBar: void setStringPainted(boolean)>(1);
return;
}
private void setMsgProductionRate(java.lang.Object)
{
java.awt.Rectangle v;
javax.swing.JLabel v, v, v;
java.lang.Object v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: java.lang.Object;
v = v instanceof java.lang.Double;
if v == 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(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 (msg/sec)");
goto label;
label:
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
label:
v = v.<UniversalClient: javax.swing.JLabel msgProductionRateLabel>;
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[])>("Msg Production Rate:  \u0001");
virtualinvoke v.<javax.swing.JLabel: void setText(java.lang.String)>(v);
v = v.<UniversalClient: javax.swing.JLabel msgProductionRateLabel>;
v = v.<UniversalClient: javax.swing.JLabel msgProductionRateLabel>;
v = virtualinvoke v.<javax.swing.JLabel: java.awt.Rectangle getBounds()>();
virtualinvoke v.<javax.swing.JLabel: void paintImmediately(java.awt.Rectangle)>(v);
return;
}
private void showDetails(jakarta.jms.Message, int)
{
java.awt.Color v;
java.util.Enumeration v;
PropertyPanel v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.awt.BorderLayout v;
javax.swing.JFrame v, v, v, v, v, v, v, v, v, v;
boolean v;
jakarta.jms.Message v;
java.lang.Throwable v, v, v;
java.util.HashMap v, v;
int v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.awt.Container v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
java.lang.Object v, v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: jakarta.jms.Message;
v := @parameter: int;
label:
v = interfaceinvoke v.<jakarta.jms.Message: int getIntProperty(java.lang.String)>("msgNum");
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<jakarta.jms.JMSException: void printStackTrace()>();
label:
v = v.<UniversalClient: javax.swing.JFrame detailsFrame>;
if v != null goto label;
v = new javax.swing.JFrame;
specialinvoke v.<javax.swing.JFrame: void <init>()>();
v.<UniversalClient: javax.swing.JFrame detailsFrame> = v;
v = v.<UniversalClient: javax.swing.JFrame detailsFrame>;
virtualinvoke v.<javax.swing.JFrame: void setTitle(java.lang.String)>("Oracle GlassFish(tm) Server Message Queue Universal Client - Message Details");
v = v.<UniversalClient: javax.swing.JFrame detailsFrame>;
v = <java.awt.Color: java.awt.Color white>;
virtualinvoke v.<javax.swing.JFrame: void setBackground(java.awt.Color)>(v);
v = v.<UniversalClient: javax.swing.JFrame detailsFrame>;
v = virtualinvoke v.<javax.swing.JFrame: java.awt.Container getContentPane()>();
v = new java.awt.BorderLayout;
specialinvoke v.<java.awt.BorderLayout: void <init>()>();
virtualinvoke v.<java.awt.Container: void setLayout(java.awt.LayoutManager)>(v);
v = new PropertyPanel;
specialinvoke v.<PropertyPanel: void <init>()>();
v.<UniversalClient: PropertyPanel msgDetailsHeaderPanel> = v;
v = v.<UniversalClient: PropertyPanel msgDetailsHeaderPanel>;
virtualinvoke v.<PropertyPanel: void setTitle(java.lang.String)>("JMS Headers");
v = v.<UniversalClient: javax.swing.JFrame detailsFrame>;
v = virtualinvoke v.<javax.swing.JFrame: java.awt.Container getContentPane()>();
v = v.<UniversalClient: PropertyPanel msgDetailsHeaderPanel>;
virtualinvoke v.<java.awt.Container: java.awt.Component add(java.lang.String,java.awt.Component)>("North", v);
v = new PropertyPanel;
specialinvoke v.<PropertyPanel: void <init>()>();
v.<UniversalClient: PropertyPanel msgDetailsPropertyPanel> = v;
v = v.<UniversalClient: PropertyPanel msgDetailsPropertyPanel>;
virtualinvoke v.<PropertyPanel: void setTitle(java.lang.String)>("Message Properties");
v = v.<UniversalClient: javax.swing.JFrame detailsFrame>;
v = virtualinvoke v.<javax.swing.JFrame: java.awt.Container getContentPane()>();
v = v.<UniversalClient: PropertyPanel msgDetailsPropertyPanel>;
virtualinvoke v.<java.awt.Container: java.awt.Component add(java.lang.String,java.awt.Component)>("Center", v);
v = new PropertyPanel;
specialinvoke v.<PropertyPanel: void <init>()>();
v.<UniversalClient: PropertyPanel msgDetailsBodyPanel> = v;
v = v.<UniversalClient: PropertyPanel msgDetailsBodyPanel>;
virtualinvoke v.<PropertyPanel: void setTitle(java.lang.String)>("Message body");
v = v.<UniversalClient: javax.swing.JFrame detailsFrame>;
v = virtualinvoke v.<javax.swing.JFrame: java.awt.Container getContentPane()>();
v = v.<UniversalClient: PropertyPanel msgDetailsBodyPanel>;
virtualinvoke v.<java.awt.Container: java.awt.Component add(java.lang.String,java.awt.Component)>("South", v);
v = v.<UniversalClient: javax.swing.JFrame detailsFrame>;
virtualinvoke v.<javax.swing.JFrame: void pack()>();
label:
v = staticinvoke <UniversalClientUtility: java.util.HashMap jmsHeadersToHashMap(jakarta.jms.Message)>(v);
v = v.<UniversalClient: PropertyPanel msgDetailsHeaderPanel>;
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[])>("JMS Headers: Message #\u0001");
virtualinvoke v.<PropertyPanel: void setTitle(java.lang.String)>(v);
v = v.<UniversalClient: PropertyPanel msgDetailsHeaderPanel>;
virtualinvoke v.<PropertyPanel: void load(java.util.HashMap)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<jakarta.jms.JMSException: java.lang.String getMessage()>();
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[])>("Error: \u0001");
specialinvoke v.<UniversalClient: void setFooter(java.lang.String)>(v);
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
label:
v = interfaceinvoke v.<jakarta.jms.Message: java.util.Enumeration getPropertyNames()>();
label:
v = interfaceinvoke v.<java.util.Enumeration: boolean hasMoreElements()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Enumeration: java.lang.Object nextElement()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = interfaceinvoke v.<jakarta.jms.Message: java.lang.Object getObjectProperty(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<jakarta.jms.JMSException: java.lang.String getMessage()>();
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[])>("Error: \u0001");
specialinvoke v.<UniversalClient: void setFooter(java.lang.String)>(v);
label:
v = v.<UniversalClient: PropertyPanel msgDetailsPropertyPanel>;
virtualinvoke v.<PropertyPanel: void load(java.util.HashMap)>(v);
v = v.<UniversalClient: PropertyPanel msgDetailsBodyPanel>;
v = staticinvoke <UniversalClientUtility: java.lang.String messageType(jakarta.jms.Message)>(v);
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[])>("Message Body: (\u)");
virtualinvoke v.<PropertyPanel: void setTitle(java.lang.String)>(v);
v = v.<UniversalClient: PropertyPanel msgDetailsBodyPanel>;
v = staticinvoke <UniversalClientUtility: java.lang.String jmsMsgBodyAsString(jakarta.jms.Message)>(v);
virtualinvoke v.<PropertyPanel: void load(java.lang.String)>(v);
v = v.<UniversalClient: javax.swing.JFrame detailsFrame>;
virtualinvoke v.<javax.swing.JFrame: void setVisible(boolean)>(1);
return;
catch jakarta.jms.JMSException from label to label with label;
catch jakarta.jms.JMSException from label to label with label;
catch jakarta.jms.JMSException from label to label with label;
}
public void onException(jakarta.jms.JMSException)
{
jakarta.jms.JMSException v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: jakarta.jms.JMSException;
virtualinvoke v.<UniversalClient: void setMsgSenderStopped(boolean)>(1);
specialinvoke v.<UniversalClient: void doDisconnect()>();
v = virtualinvoke v.<jakarta.jms.JMSException: java.lang.String toString()>();
specialinvoke v.<UniversalClient: void showErrorDialog(java.lang.String,java.lang.String)>(v, "Connection Closing Event");
return;
}
public boolean isMsgSenderStopped()
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: boolean msgSenderStopped>;
return v;
}
public void setMsgSenderStopped(boolean)
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: boolean;
v.<UniversalClient: boolean msgSenderStopped> = v;
return;
}
public void stopMsgReceiver()
{
jakarta.jms.MessageConsumer v, v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.Exception v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: jakarta.jms.MessageConsumer myConsumer>;
if v == null goto label;
label:
virtualinvoke v.<UniversalClient: void setMsgReceiverStopped(boolean)>(1);
v = v.<UniversalClient: jakarta.jms.MessageConsumer myConsumer>;
interfaceinvoke v.<jakarta.jms.MessageConsumer: void close()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.Exception: void printStackTrace()>();
label:
return;
catch java.lang.Exception from label to label with label;
}
public void printToStatusArea(java.lang.String)
{
java.util.Date v;
glassfish.mq.examples.applications.uclient.UniversalClient v;
java.lang.String v, v;
StatusArea v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: java.lang.String;
v = v.<UniversalClient: StatusArea statusArea>;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.Date,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]  \u0001");
virtualinvoke v.<StatusArea: void appendText(java.lang.String)>(v);
return;
}
public boolean isMsgReceiverStopped()
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v = v.<UniversalClient: boolean msgReceiverStopped>;
return v;
}
public void setMsgReceiverStopped(boolean)
{
glassfish.mq.examples.applications.uclient.UniversalClient v;
boolean v;
v := @this: glassfish.mq.examples.applications.uclient.UniversalClient;
v := @parameter: boolean;
v.<UniversalClient: boolean msgReceiverStopped> = v;
return;
}
}