MQ log : JMX « J2EE « Java
MQ log
/*
* @(#)MQLogViewer.java 1.4 05/08/08
*
* Copyright (c) 2000-2005 Sun Microsystems, Inc. All Rights Reserved.
*
* Sun grants you ("Licensee") a non-exclusive, royalty free, license to use,
* modify and redistribute this software in source and binary code form,
* provided that i) this copyright notice and license appear on all copies of
* the software; and ii) Licensee does not utilize the software in a manner
* which is disparaging to Sun.
*
* This software is provided "AS IS," without a warranty of any kind. ALL
* EXPRESS OR IMPLIED CONDITIONS, REPRESENTATIONS AND WARRANTIES, INCLUDING ANY
* IMPLIED WARRANTY OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE OR
* NON-INFRINGEMENT, ARE HEREBY EXCLUDED. SUN AND ITS LICENSORS SHALL NOT BE
* LIABLE FOR ANY DAMAGES SUFFERED BY LICENSEE AS A RESULT OF USING, MODIFYING
* OR DISTRIBUTING THE SOFTWARE OR ITS DERIVATIVES. IN NO EVENT WILL SUN OR ITS
* LICENSORS BE LIABLE FOR ANY LOST REVENUE, PROFIT OR DATA, OR FOR DIRECT,
* INDIRECT, SPECIAL, CONSEQUENTIAL, INCIDENTAL OR PUNITIVE DAMAGES, HOWEVER
* CAUSED AND REGARDLESS OF THE THEORY OF LIABILITY, ARISING OUT OF THE USE OF
* OR INABILITY TO USE SOFTWARE, EVEN IF SUN HAS BEEN ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGES.
*
* This software is not designed or intended for use in on-line control of
* aircraft, air traffic, aircraft navigation or aircraft communications; or in
* the design, construction, operation or maintenance of any nuclear
* facility. Licensee represents and warrants that it will not use or
* redistribute the Software for such purposes.
*/
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
import java.util.StringTokenizer;
import javax.management.*;
import javax.management.remote.*;
import com.sun.messaging.AdminConnectionFactory;
import com.sun.messaging.AdminConnectionConfiguration;
import com.sun.messaging.jms.management.server.*;
public class MQLogViewer implements ActionListener,
NotificationListener {
JFrame f;
MQConnectDialog connectDialog = null;
JMenuItem exit, connect, disconnect, clearLog;
JCheckBoxMenuItem info, warning, error;
JTextArea logMsgArea, statusTextArea;
JLabel brokerAddress;
String address = null, adminUser = "admin", adminPasswd = "admin";
String logLevelStrings[] = { LogLevel.INFO,
LogLevel.WARNING,
LogLevel.ERROR };
AdminConnectionFactory acf;
JMXConnector jmxc;
MBeanServerConnection mbsc;
ObjectName logCfg = null;
NotificationFilterSupport myFilter = null;
public MQLogViewer(JFrame f, String address,
String adminUser, String adminPasswd) {
this.f = f;
this.address = address;
this.adminUser = adminUser;
this.adminPasswd = adminPasswd;
try {
logCfg = new ObjectName(MQObjectName.LOG_MONITOR_MBEAN_NAME);
} catch (Exception e) {
addStatusText("Caught exception while creating Log MBean ObjectName: " + e);
}
initGUI();
if ((address != null) && (adminUser != null) && (adminPasswd != null)) {
doConnect();
}
}
private void initGUI() {
JMenuBar menubar = createMenubar();
JComponent toolbar = createToolBar();
JPanel mainPanel = createMainPanel();
JPanel statusArea = createStatusArea();
f.setJMenuBar(menubar);
f.getContentPane().add(toolbar, BorderLayout.NORTH);
f.getContentPane().add(mainPanel, BorderLayout.CENTER);
f.getContentPane().add(statusArea, BorderLayout.SOUTH);
}
public void logMessage(LogNotification n) {
logMsgArea.append(n.getMessage());
logMsgArea.setCaretPosition(logMsgArea.getText().length());
}
public void clearLogArea() {
logMsgArea.setText("");
}
public void addStatusText(String statusText) {
statusTextArea.append(statusText);
statusTextArea.setCaretPosition(statusTextArea.getText().length());
statusTextArea.append("\n");
}
public void clearStatus() {
statusTextArea.setText("");
}
public void doConnect() {
try {
acf = new AdminConnectionFactory();
if (address != null) {
acf.setProperty(AdminConnectionConfiguration.imqAddress,
address);
}
jmxc = acf.createConnection(adminUser, adminPasswd);
jmxc.addConnectionNotificationListener(this, null, null);
mbsc = jmxc.getMBeanServerConnection();
addStatusText("Connected to broker at: "
+ acf.getProperty(AdminConnectionConfiguration.imqAddress));
brokerAddress.setText(
acf.getProperty(AdminConnectionConfiguration.imqAddress));
logOn();
connect.setEnabled(false);
disconnect.setEnabled(true);
} catch (Exception e) {
addStatusText("Caught exception while connecting: " + e);
}
}
public void doDisconnect() {
try {
logOff();
addStatusText("Disconnecting from broker at: "
+ acf.getProperty(AdminConnectionConfiguration.imqAddress));
brokerAddress.setText("<none>");
if (jmxc != null) {
jmxc.close();
}
jmxc = null;
mbsc = null;
acf = null;
connect.setEnabled(true);
disconnect.setEnabled(false);
clearLogArea();
} catch (Exception e) {
addStatusText("Caught exception while disconnecting: " + e);
}
}
public void logOff() {
if (myFilter != null) {
try {
if (mbsc != null) {
mbsc.removeNotificationListener(logCfg, this, myFilter, null);
}
myFilter = null;
addStatusText("Unregistered log listener");
} catch(Exception e) {
addStatusText("Caught exception while removing log listener: " + e);
}
}
}
public void logOn() {
String logLevels = getLogLevel();
logOff();
if (logLevels.equals("")) {
addStatusText("No log levels selected.");
return;
}
myFilter = new NotificationFilterSupport();
StringTokenizer st = new StringTokenizer(logLevels, "|");
while (st.hasMoreTokens()) {
String oneLevel = st.nextToken();
myFilter.enableType(LogNotification.LOG_LEVEL_PREFIX + oneLevel);
}
try {
mbsc.addNotificationListener(logCfg, this, myFilter, null);
addStatusText("Registered listener at log levels: " + logLevels);
} catch(Exception e) {
addStatusText("Caught exception while addind log listener: " + e);
}
}
public String getLogLevel() {
String s = null;
if (info.getState()) {
s = info.getText();
}
if (warning.getState()) {
if (s == null) {
s = warning.getText();
} else {
s = s + "|" + warning.getText();
}
}
if (error.getState()) {
if (s == null) {
s = error.getText();
} else {
s = s + "|" + error.getText();
}
}
if (s == null) {
return ("");
}
return (s);
}
public void handleNotification(Notification notification, Object handback) {
if (notification instanceof LogNotification) {
logMessage((LogNotification)notification);
} else if (notification instanceof JMXConnectionNotification) {
JMXConnectionNotification jcn = (JMXConnectionNotification)notification;
/*
* TBD: handle server shutdown
*/
if (jcn.getType().equals(JMXConnectionNotification.CLOSED) ||
jcn.getType().equals(JMXConnectionNotification.FAILED)) {
}
}
}
private JMenuBar createMenubar() {
JMenuBar menubar;
JMenu menu, logLevelMenu;
menubar = new JMenuBar();
menu = new JMenu("LogViewer");
logLevelMenu = new JMenu("Log Levels");
menubar.add(menu);
menubar.add(logLevelMenu);
connect = new JMenuItem("Connect");
connect.addActionListener(this);
menu.add(connect);
disconnect = new JMenuItem("Disconnect");
disconnect.addActionListener(this);
disconnect.setEnabled(false);
menu.add(disconnect);
menu.addSeparator();
clearLog = new JMenuItem("Clear Log Display");
clearLog.addActionListener(this);
menu.add(clearLog);
menu.addSeparator();
exit = new JMenuItem("Exit");
exit.addActionListener(this);
menu.add(exit);
info = new JCheckBoxMenuItem(LogLevel.INFO);
info.addActionListener(this);
info.setState(true);
logLevelMenu.add(info);
warning = new JCheckBoxMenuItem(LogLevel.WARNING);
warning.addActionListener(this);
warning.setState(true);
logLevelMenu.add(warning);
error = new JCheckBoxMenuItem(LogLevel.ERROR);
error.addActionListener(this);
error.setState(true);
logLevelMenu.add(error);
return (menubar);
}
private JPanel createMainPanel() {
JPanel p = new JPanel();
p.setLayout(new BorderLayout());
logMsgArea = new JTextArea(12, 80);
logMsgArea.setEditable(false);
JScrollPane tablePane = new JScrollPane(logMsgArea);
p.add(BorderLayout.CENTER, tablePane);
return (p);
}
private JComponent createToolBar() {
JPanel p = new JPanel();
JLabel l;
p.setLayout(new FlowLayout(FlowLayout.LEFT));
l = new JLabel("Log messages for broker at address: ");
p.add(l);
brokerAddress = new JLabel("<none>");
p.add(brokerAddress);
return (p);
}
private JPanel createStatusArea() {
JPanel p = new JPanel();
p.setLayout(new BorderLayout());
statusTextArea = new JTextArea(3, 80);
statusTextArea.setLineWrap(true);
statusTextArea.setEditable(false);
JScrollPane statusTextPane = new JScrollPane(statusTextArea);
p.add(statusTextPane, BorderLayout.CENTER);
return (p);
}
public void actionPerformed(ActionEvent e) {
Object src = e.getSource();
if (src instanceof JCheckBoxMenuItem) {
JCheckBoxMenuItem cb = (JCheckBoxMenuItem)src;
if (src == info) {
logOn();
} else if (src == warning) {
logOn();
} else if (src == error) {
logOn();
}
} else if (src instanceof JMenuItem) {
JMenuItem mi = (JMenuItem)src;
if (src == exit) {
System.exit(0);
} else if (src == connect) {
showConnectDialog();
} else if (src == disconnect) {
doDisconnect();
} else if (src == clearLog) {
clearLogArea();
}
} else if (src instanceof JButton) {
address = connectDialog.getAddress();
adminUser = connectDialog.getUserName();
adminPasswd = connectDialog.getPassword();
doConnect();
}
}
private void showConnectDialog() {
if (connectDialog == null) {
connectDialog = new MQConnectDialog(f, "Connect to Broker", this);
connectDialog.setAddress((address == null) ?
getDefaultAddress() : address);
connectDialog.setUserName((adminUser == null) ?
getDefaultUserName() : adminUser);
connectDialog.setPassword((adminPasswd == null) ?
getDefaultPassword() : adminPasswd);
}
connectDialog.setLocationRelativeTo(f);
connectDialog.setVisible(true);
}
private static void doExit() {
System.exit(0);
}
private String getDefaultUserName() {
AdminConnectionFactory acf = new AdminConnectionFactory();
String addr;
try {
addr = acf.getProperty(AdminConnectionConfiguration.imqDefaultAdminUsername);
} catch(Exception e) {
addr = null;
}
return (addr);
}
private String getDefaultPassword() {
AdminConnectionFactory acf = new AdminConnectionFactory();
String addr;
try {
addr = acf.getProperty(AdminConnectionConfiguration.imqDefaultAdminPassword);
} catch(Exception e) {
addr = null;
}
return (addr);
}
private String getDefaultAddress() {
/*
AdminConnectionFactory acf = new AdminConnectionFactory();
String addr;
try {
addr = acf.getProperty(AdminConnectionConfiguration.imqAddress);
} catch(Exception e) {
addr = null;
}
return (addr);
*/
return ("localhost:7676");
}
public static void main(String[] args) {
JFrame frame;
MQLogViewer s;
String address = null, adminUser = null, adminPasswd = null,
secondStr = null;
long seconds = 5;
for (int i = 0; i < args.length; ++i) {
if (args[i].equals("-b")) {
if (++i >= args.length) {
usage();
}
address = args[i];
} else if (args[i].equals("-u")) {
if (++i >= args.length) {
usage();
}
adminUser = args[i];
} else if (args[i].equals("-p")) {
if (++i >= args.length) {
usage();
}
adminPasswd = args[i];
} else {
usage();
}
}
frame = new JFrame("MQ Log Viewer");
s = new MQLogViewer(frame, address, adminUser, adminPasswd);
frame.addWindowListener(new WindowAdapter() {
public void windowClosing(WindowEvent e) {
doExit();
}
});
frame.pack();
frame.setVisible(true);
}
public static void usage() {
usage(null);
}
public static void usage(String msg) {
if (msg != null) {
System.err.println(msg);
}
System.err.println("java MQLogViewer"
+ "[-b <host:port>] [-u <admin user name>] [-p <admin password>]");
doExit();
}
}
/*
* @(#)MQConnectDialog.java 1.1 05/06/06
*
* Copyright (c) 2000-2005 Sun Microsystems, Inc. All Rights Reserved.
*
* Sun grants you ("Licensee") a non-exclusive, royalty free, license to use,
* modify and redistribute this software in source and binary code form,
* provided that i) this copyright notice and license appear on all copies of
* the software; and ii) Licensee does not utilize the software in a manner
* which is disparaging to Sun.
*
* This software is provided "AS IS," without a warranty of any kind. ALL
* EXPRESS OR IMPLIED CONDITIONS, REPRESENTATIONS AND WARRANTIES, INCLUDING ANY
* IMPLIED WARRANTY OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE OR
* NON-INFRINGEMENT, ARE HEREBY EXCLUDED. SUN AND ITS LICENSORS SHALL NOT BE
* LIABLE FOR ANY DAMAGES SUFFERED BY LICENSEE AS A RESULT OF USING, MODIFYING
* OR DISTRIBUTING THE SOFTWARE OR ITS DERIVATIVES. IN NO EVENT WILL SUN OR ITS
* LICENSORS BE LIABLE FOR ANY LOST REVENUE, PROFIT OR DATA, OR FOR DIRECT,
* INDIRECT, SPECIAL, CONSEQUENTIAL, INCIDENTAL OR PUNITIVE DAMAGES, HOWEVER
* CAUSED AND REGARDLESS OF THE THEORY OF LIABILITY, ARISING OUT OF THE USE OF
* OR INABILITY TO USE SOFTWARE, EVEN IF SUN HAS BEEN ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGES.
*
* This software is not designed or intended for use in on-line control of
* aircraft, air traffic, aircraft navigation or aircraft communications; or in
* the design, construction, operation or maintenance of any nuclear
* facility. Licensee represents and warrants that it will not use or
* redistribute the Software for such purposes.
*/
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
public class MQConnectDialog extends JDialog
implements ActionListener {
JButton apply, cancel;
JTextField address, username;
JPasswordField password;
private boolean applyHit = false;
private ActionListener applyListener = null;
public MQConnectDialog(Frame parent, String title,
ActionListener applyListener) {
super(parent, title, true);
this.applyListener = applyListener;
initContentPane();
pack();
}
public boolean applyDone() {
return (applyHit);
}
private void initContentPane() {
JPanel panel = new JPanel();
panel.setLayout(new BorderLayout());
/*
* Create 'work' panel
*/
JPanel workPanel = createWorkPanel();
/*
* Create button panel
*/
JPanel buttonPanel = createButtonPanel();
panel.add(workPanel, "Center");
panel.add(buttonPanel, "South");
getContentPane().add(panel);
}
private JPanel createWorkPanel() {
JPanel workPanel = new JPanel();
GridBagLayout gridbag = new GridBagLayout();
GridBagConstraints c = new GridBagConstraints();
JLabel l;
workPanel.setLayout(gridbag);
c.anchor = GridBagConstraints.WEST;
c.fill = GridBagConstraints.NONE;
c.insets = new Insets(2, 2, 2, 2);
c.ipadx = 0;
c.ipady = 0;
c.weightx = 1.0;
c.gridx = 0;
c.gridy = 0;
l = new JLabel("Address:");
gridbag.setConstraints(l,c);
workPanel.add(l);
c.gridx = 1;
c.gridy = 0;
address = new JTextField(20);
gridbag.setConstraints(address,c);
workPanel.add(address);
c.gridx = 0;
c.gridy = 1;
l = new JLabel("Name:");
gridbag.setConstraints(l,c);
workPanel.add(l);
c.gridx = 1;
c.gridy = 1;
username = new JTextField(20);
gridbag.setConstraints(username, c);
workPanel.add(username);
c.gridx = 0;
c.gridy = 2;
l = new JLabel("Password:");
gridbag.setConstraints(l,c);
workPanel.add(l);
c.gridx = 1;
c.gridy = 2;
password = new JPasswordField(20);
gridbag.setConstraints(password, c);
workPanel.add(password);
return (workPanel);
}
public void setAddress(String s) {
address.setText(s);
}
public String getAddress() {
return (address.getText());
}
public void setUserName(String s) {
username.setText(s);
}
public String getUserName() {
return (username.getText());
}
public void setPassword(String s) {
password.setText(s);
}
public String getPassword() {
return (new String(password.getPassword()));
}
private JPanel createButtonPanel() {
JPanel buttonPanel = new JPanel();
buttonPanel.setLayout(new FlowLayout(FlowLayout.RIGHT));
apply = new JButton("Apply");
apply.addActionListener(this);
if (applyListener != null) {
apply.addActionListener(applyListener);
}
buttonPanel.add(apply);
cancel = new JButton("Cancel");
cancel.addActionListener(this);
buttonPanel.add(cancel);
return (buttonPanel);
}
public void actionPerformed(ActionEvent e) {
Object src = e.getSource();
if (src == apply) {
applyHit = true;
setVisible(false);
} else if (src == cancel) {
applyHit = false;
setVisible(false);
}
}
}
