MQ log : JMX « J2EE平台 « Java

En
Java
1. 图形用户界面
2. 三维图形动画
3. 高级图形
4. 蚂蚁编译
5. Apache类库
6. 统计图
7. 
8. 集合数据结构
9. 数据类型
10. 数据库JDBC
11. 设计模式
12. 开发相关类
13. EJB3
14. 电子邮件
15. 事件
16. 文件输入输出
17. 游戏
18. 泛型
19. GWT
20. Hibernate
21. 本地化
22. J2EE平台
23. 基于J2ME
24. JDK-6
25. JNDI的LDAP
26. JPA
27. JSP技术
28. JSTL
29. 语言基础知识
30. 网络协议
31. PDF格式RTF格式
32. 映射
33. 常规表达式
34. 脚本
35. 安全
36. Servlets
37. Spring
38. Swing组件
39. 图形用户界面
40. SWT-JFace-Eclipse
41. 线程
42. 应用程序
43. Velocity
44. Web服务SOA
45. 可扩展标记语言
Java 教程
Java » J2EE平台 » JMX屏幕截图 
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(1280);
  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(380);
  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(2222);
  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);
  }
    }
}

        
Related examples in the same category
1. JMX客户端
2. JMX目的地列表
3. JMX客户端交互的JMX代理
4. Create the Hello MBean and QueueSampler MXBean, register them in the platform MBean server
5. how failure to supply an appropriate authentication mechanism results in a failure to create an initial context
6. JMX ( Java管理扩展) :扫描目录
www.java2java.com | Contact Us
Copyright 2010 - 2030 Java Source and Support. All rights reserved.
All other trademarks are property of their respective owners.