mmservlet.java

mobile to system control

                        Object[] params = new Object[mpi.length];
                        String[] types = new String[mpi.length];
                        String paramName = null;
                        try {
                            for (int j = 0; j < mpi.length; j++) {
                                types[j] = mpi[j].getType();
                                paramName = mpi[j].getName();
                                params[j] = findAndSetParameter
                                (paramName, types[j], request);
                            }
                            retVal = connectorClient.invoke
                            (mBeanName, action, params, types);
                        } catch (MMParameterException mpe) {
                            return
                            ((paramName + ": " + mpe.getMessage()).getBytes());
                        }
                    } else {
                        retVal = connectorClient.invoke
                        (mBeanName, action, null, null);
                    }
                    if (retVal instanceof Page) return retVal;
                    return convertReturnValue(retVal, retType);
                }
            }
            return("Operation " + action + " not found").getBytes();
        } catch (Exception e) {
            log(e.getClass().getName(), e);
            return("Exception occured: " + e.getMessage()).getBytes();
        }
    }
    
    private byte[] getDescription(String host, String mbean, String action) {
        StringBuffer sb = new StringBuffer();
        RmiConnectorClient connectorClient = null;
        try {
            connectorClient = connect(host);
            ObjectName mBeanName = new ObjectName(mbean);
            MBeanInfo mbi = connectorClient.getMBeanInfo(mBeanName);
            MBeanAttributeInfo[] mai = mbi.getAttributes();
            for (int i = 0; i < mai.length; i++) {
                if (action.equals("is" + mai[i].getName())
                || action.equals("get" + mai[i].getName())
                || action.equals("set" + mai[i].getName())) {
                    sb.append(mai[i].getDescription());
                    break;
                }
            }
            MBeanOperationInfo[] moi = mbi.getOperations();
            for (int i = 0; i < moi.length; i++) {
                if (action.equals(moi[i].getName())) {
                    sb.append(moi[i].getDescription()).append("\n");
                    MBeanParameterInfo mpi[] = moi[i].getSignature();
                    if (mpi.length > 0) {
                        for (int j = 0; j < mpi.length; j++) {
                            sb.append(mpi[j].getName()).append(": ")
                            .append(mpi[j].getDescription()).append("\n");
                        }
                    }
                    break;
                }
            }
        } catch (Exception e) {
            log(e.getClass().getName(), e);
            sb.append("Exception occured: ").append(e.getMessage());
        }
        return sb.toString().getBytes();
    }
    
    private Object findAndSetParameter(String name, String type,
    HttpServletRequest request) throws MMParameterException {
        String value = request.getParameter(name);
        if ((value == null) || (value.length() < 1))
            throw new MMParameterException
            ("No value supplied for this parameter");
        return convertValue(value, type);
    }
    
    private byte[] convertReturnValue(Object o, String type) {
        if (o == null) return "null".getBytes();
        if (type.equals("void") || type.equals("java.lang.Void"))
            return "No return value".getBytes();
        if (o instanceof java.lang.String) {
            return ((String)o).getBytes();
        } else if (o instanceof java.lang.Integer) {
            return ((Integer)o).toString().getBytes();
        } else if (o instanceof java.lang.Byte) {
            return ((Byte)o).toString().getBytes();
        } else if (o instanceof java.lang.Short) {
            return ((Short)o).toString().getBytes();
        } else if (o instanceof java.lang.Long) {
            return ((Long)o).toString().getBytes();
        } else if (o instanceof java.lang.Boolean) {
            return ((Boolean)o).toString().getBytes();
        } else if (o instanceof java.lang.Character) {
            return ((Character)o).toString().getBytes();
        } else if (o instanceof java.lang.Float) {
            return ((Float)o).toString().getBytes();
        } else if (o instanceof java.lang.Double) {
            return ((Double)o).toString().getBytes();
        } else if (o instanceof byte[]) {
            return (byte[])o;
        } else if (o instanceof java.net.URL[]) {
            URL[] urlarr = (URL[])o;
            StringBuffer sb = new StringBuffer();
            for (int i = 0; i < urlarr.length; i++) {
                sb.append(urlarr[i].toString()).append("\n");
            }
            return sb.toString().getBytes();
        } else if (o instanceof javax.management.ObjectName) {
            return ((ObjectName)o).toString().getBytes();
        } else {
            return "Unsupported data type".getBytes();
        }
    }
    
    private Object convertValue(String value, String type) throws MMParameterException {
        try {
            if (type.equals("java.lang.String")) {
                return value;
            } else if (type.equals("javax.management.ObjectName")) {
                return new ObjectName(value);
            } else if (type.equals("int")
            || type.equals("java.lang.Integer")) {
                return new Integer(Integer.parseInt(value));
            } else if (type.equals("byte")
            || type.equals("java.lang.Byte")) {
                return new Byte(Byte.parseByte(value));
            } else if (type.equals("short")
            || type.equals("java.lang.Short")) {
                return new Short(Short.parseShort(value));
            } else if (type.equals("long")
            || type.equals("java.lang.Long")) {
                return new Long(Long.parseLong(value));
            } else if (type.equals("boolean")
            || type.equals("java.lang.Boolean")) {
                return new Boolean(value);
            } else if (type.equals("char")
            || type.equals("java.lang.Character")) {
                return new Character(value.charAt(0));
            } else if (type.equals("float")
            || type.equals("java.lang.Float")) {
                return new Float(Float.parseFloat(value));
            } else if (type.equals("double")
            || type.equals("java.lang.Double")) {
                return new Double(Double.parseDouble(value));
            } else {
                throw new MMParameterException("Unsupported type: " + type);
            }
        } catch (NumberFormatException nfe) {
            throw new MMParameterException
            ("Can't convert " + value + " to " + type);
        } catch (MalformedObjectNameException mon) {
            throw new MMParameterException
            ("Can't convert " + value + " to " + type);
        }
    }
    
    private byte[] getParameters(String host, String mbean, String action) {
        StringBuffer sb = new StringBuffer();
        boolean notFound = true;
        RmiConnectorClient connectorClient = null;
        try {
            connectorClient = connect(host);
            ObjectName mBeanName = new ObjectName(mbean);
            MBeanInfo mbi = connectorClient.getMBeanInfo(mBeanName);
            MBeanOperationInfo[] moi = mbi.getOperations();
            for (int i = 0; i < moi.length; i++) {
                if (action.equals(moi[i].getName())) {
                    MBeanParameterInfo mpi[] = moi[i].getSignature();
                    if (mpi.length > 0) {
                        for (int j = 0; j < mpi.length; j++) {
                            sb.append(mpi[j].getName()).append(":")
                            .append(mpi[j].getType()).append("\n");
                        }
                    }
                    notFound = false;
                    break;
                }
            }
            if (notFound && action.startsWith("set")) {
                MBeanAttributeInfo[] mai = mbi.getAttributes();
                for (int i = 0; i < mai.length; i++) {
                    if (action.substring(3).equals(mai[i].getName())) {
                        sb.append(mai[i].getName()).append(":")
                        .append(mai[i].getType());
                        break;
                    }
                }
            }
        } catch (Exception e) {
            log(e.getClass().getName(), e);
            sb.append("Exception occured: ").append(e.getMessage());
        }
        return sb.toString().getBytes();
    }
    
    private byte[] listDomains(String host) {
        StringBuffer sb = new StringBuffer();
        RmiConnectorClient connectorClient = null;
        try {
            connectorClient = connect(host);
            HashSet hs = new HashSet();
            Set s = connectorClient.queryNames(null, null);
            Iterator it = s.iterator();
            while (it.hasNext()) {
                ObjectName on = (ObjectName)it.next();
                hs.add(on.getDomain());
            }
            it = hs.iterator();
            while (it.hasNext()) {
                sb.append((String)it.next()).append("\n");
            }
        } catch (Exception e) {
            log(e.getClass().getName(), e);
            sb.append("Exception occured: ").append(e.getMessage());
        }
        return sb.toString().getBytes();
    }
    
    private RmiConnectorClient connect(String host)
    throws NoSuchElementException {
        Object o = hostConnections.get(host);
        if (o == null) throw new NoSuchElementException("Connection to " + host + " not found");
        while ((o != null) && (o instanceof String)
        && ((String)o).equals("RETRYING")) {
            try {
                Thread.sleep(5000);
            } catch (InterruptedException ie) {}
            o = hostConnections.get(host);
            if (o == null) throw new NoSuchElementException
            ("Connection to " + host + " not found");
        }
        RmiConnectorClient rcc = (RmiConnectorClient)o;
        return rcc;
    }
    
    private void readProperties() {
        try {
            servletResources = ResourceBundle.getBundle(SERVLET_RESOURCE_FILE);
        } catch (MissingResourceException mre) {
            log("Unable to read servlet properties");
            servletResources = null;
        }
    }
    
    public void handleNotification(Notification notification, Object handback) {
        log("Notification received");
        if (notification instanceof HeartBeatNotification) {
            handleHeartBeatNotification(notification);
        } else if (notification instanceof MonitorNotification) {
            MonitorNotification mn = (MonitorNotification)notification;
            log(mn.getObservedAttribute());
            log(mn.getTrigger().toString());
            log(mn.getDerivedGauge().toString());
        }
    }
    
    private void handleHeartBeatNotification(Notification notification) {
        ConnectorAddress notif_address =
        ((HeartBeatNotification)notification).getConnectorAddress();
        if (notif_address instanceof RmiConnectorAddress) {
            RmiConnectorAddress rmi_address =
            (RmiConnectorAddress)notif_address;
            log("HOST  = " + rmi_address.getHost());
            log("EVENT = " + notification.getType());
            if (notification.getType()
            .equals(HeartBeatNotification.CONNECTION_TERMINATED)) {
                try {
                    log("Trying to reconnect to " + rmi_address.getHost());
                    reconnect(rmi_address.getHost());
                } catch (ConnectException ce) {
                    hostConnections.remove(rmi_address.getHost());
                }
            }
        } else {
            log("Unknown notification received from " + notif_address.toString());
        }
    }
    
    private void subscribeToMonitorNotifications(RmiConnectorClient rcc) {
        try {
            Set s = rcc.queryNames(new ObjectName("Monitor:*"), null);
            Iterator it = s.iterator();
            while (it.hasNext()) {
                ObjectName on = (ObjectName)it.next();
                rcc.addNotificationListener(on, this, null, null);
                log("Listening to notifications from " + on.getCanonicalName());
            }
        } catch (Exception e) {
            log(e.getClass().getName(), e);
        }
    }
    
    private void reconnect(String hostName) throws ConnectException {
        RmiConnectorClient rcc = new RmiConnectorClient();
        RmiConnectorAddress address = new RmiConnectorAddress
        (hostName, ServiceName.RMI_CONNECTOR_PORT,
        ServiceName.RMI_CONNECTOR_SERVER);
        synchronized(lock) {
            hostConnections.remove(hostName);
            hostConnections.put(hostName, "RETRYING");
            for (int i = 0; i < reconnectMaxRetries; i++) {
                try {
                    rcc.connect(address) ; // CONNECTION
                    rcc.addHeartBeatNotificationListener(this, null, null);
                    subscribeToMonitorNotifications(rcc);
                    hostConnections.remove(hostName);
                    hostConnections.put(hostName, rcc);
                    log("Reconnected to " + hostName);
                    break;
                } catch (Exception e) {
                    try {
                        Thread.sleep(5000);
                    } catch (InterruptedException ie) {}
                }
            }
        }
        if (!rcc.isConnected())
            throw new ConnectException
            ("Unable to connect to host " + hostName);
    }
    
    private Object invokePageOperation(RmiConnectorClient connectorClient,
    ObjectName mBeanName, String action, int pageNo) {
        String pageAction = action + "Page";
        try {
            MBeanInfo mbi = connectorClient.getMBeanInfo(mBeanName);
            MBeanOperationInfo moi[] = mbi.getOperations();
            for (int i = 0; i < moi.length; i++) {
                if (moi[i].getName().equals(pageAction)) {
                    String retType = moi[i].getReturnType();
                    if (!retType.equals("mobimon.common.Page")) continue;
                    Object retVal;
                    MBeanParameterInfo mpi[] = moi[i].getSignature();
                    if (mpi.length > 0) {
                        if (mpi.length > 1) continue;
                        Object[] params = new Object[mpi.length];
                        String[] types = new String[mpi.length];
                        types[0] = mpi[0].getType();
                        if (!types[0].equals("int")) continue;
                        params[0] = new Integer(pageNo);
                        return connectorClient.invoke
                        (mBeanName, pageAction, params, types);
                    } else {
                        continue;
                    }
                }
            }
            return getMBeanAttribute
            (connectorClient, mBeanName, action.substring(3));
        } catch (Exception e) {
            log(e.getClass().getName(), e);
            return("Exception occured: " + e.getMessage()).getBytes();
        }
    }
    
}