http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/MX4JModelMBean.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/MX4JModelMBean.java b/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/MX4JModelMBean.java deleted file mode 100755 index 81f543d..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/MX4JModelMBean.java +++ /dev/null @@ -1,1239 +0,0 @@ -/* - * Copyright (C) MX4J. - * All rights reserved. - * - * This software is distributed under the terms of the MX4J License version 1.0. - * See the terms of the MX4J License in the documentation provided with this software. - */ - -package org.apache.geode.admin.jmx.internal; - -import java.lang.reflect.InvocationTargetException; -import java.lang.reflect.Method; -import java.util.Date; -import java.util.Iterator; - -import javax.management.Attribute; -import javax.management.AttributeChangeNotification; -import javax.management.AttributeChangeNotificationFilter; -import javax.management.AttributeList; -import javax.management.AttributeNotFoundException; -import javax.management.Descriptor; -import javax.management.InstanceNotFoundException; -import javax.management.InvalidAttributeValueException; -import javax.management.ListenerNotFoundException; -import javax.management.MBeanAttributeInfo; -import javax.management.MBeanException; -import javax.management.MBeanInfo; -import javax.management.MBeanNotificationInfo; -import javax.management.MBeanOperationInfo; -import javax.management.MBeanRegistration; -import javax.management.MBeanRegistrationException; -import javax.management.MBeanServer; -import javax.management.MalformedObjectNameException; -import javax.management.Notification; -import javax.management.NotificationBroadcasterSupport; -import javax.management.NotificationEmitter; -import javax.management.NotificationFilter; -import javax.management.NotificationListener; -import javax.management.ObjectName; -import javax.management.ReflectionException; -import javax.management.RuntimeErrorException; -import javax.management.RuntimeOperationsException; -import javax.management.ServiceNotFoundException; -import javax.management.loading.ClassLoaderRepository; -import javax.management.modelmbean.InvalidTargetObjectTypeException; -import javax.management.modelmbean.ModelMBean; -import javax.management.modelmbean.ModelMBeanAttributeInfo; -import javax.management.modelmbean.ModelMBeanInfo; -import javax.management.modelmbean.ModelMBeanOperationInfo; - -import mx4j.ImplementationException; -import mx4j.log.FileLogger; -import mx4j.log.Log; -import mx4j.log.Logger; -import mx4j.log.MBeanLogger; -import mx4j.persist.FilePersister; -import mx4j.persist.MBeanPersister; -import mx4j.persist.PersisterMBean; -import mx4j.util.Utils; - -import org.apache.geode.internal.i18n.LocalizedStrings; - -/** - * @author <a href="mailto:biorn_stee...@users.sourceforge.net">Simone Bordet</a> - * @version $Revision: 1.14 $ - */ -public class MX4JModelMBean implements ModelMBean, MBeanRegistration, NotificationEmitter -{ - private static final String OBJECT_RESOURCE_TYPE = "ObjectReference"; - - private static final int ALWAYS_STALE = 1; - private static final int NEVER_STALE = 2; - private static final int STALE = 3; - private static final int NOT_STALE = 4; - - private static final int PERSIST_NEVER = -1; - private static final int PERSIST_ON_TIMER = -2; - private static final int PERSIST_ON_UPDATE = -3; - private static final int PERSIST_NO_MORE_OFTEN_THAN = -4; - - private MBeanServer m_mbeanServer; - private Object m_managedResource; - private boolean m_canBeRegistered; - private ModelMBeanInfo m_modelMBeanInfo; - private NotificationBroadcasterSupport m_attributeChangeBroadcaster = new NotificationBroadcasterSupport(); - private NotificationBroadcasterSupport m_generalBroadcaster = new NotificationBroadcasterSupport(); - - public MX4JModelMBean() throws MBeanException, RuntimeOperationsException - { - try - { - load(); - } - catch (Exception x) - { - Logger logger = getLogger(); - logger.warn(LocalizedStrings.MX4JModelMBean_CANNOT_RESTORE_PREVIOUSLY_SAVED_STATUS.toLocalizedString(), x); - } - } - - public MX4JModelMBean(ModelMBeanInfo info) throws MBeanException, RuntimeOperationsException - { - if (info == null) - throw new RuntimeOperationsException(new IllegalArgumentException(LocalizedStrings.MX4JModelMBean_MODELMBEANINFO_PARAMETER_CANT_BE_NULL.toLocalizedString())); - else - setModelMBeanInfo(info); - } - - private Logger getLogger() - { - return Log.getLogger(getClass().getName()); - } - - public ObjectName preRegister(MBeanServer server, ObjectName name) throws Exception - { - if (m_canBeRegistered) - { - m_mbeanServer = server; - return name; - } - else - { - throw new MBeanRegistrationException(new IllegalStateException(LocalizedStrings.MX4JModelMBean_MODELMBEAN_CANNOT_BE_REGISTERED_UNTIL_SETMODELMBEANINFO_HAS_BEEN_CALLED.toLocalizedString())); - } - } - - public void postRegister(Boolean registrationDone) - { - if (!registrationDone.booleanValue()) clear(); - } - - public void preDeregister() throws Exception - { - } - - public void postDeregister() - { - clear(); - } - - private void clear() - { - m_mbeanServer = null; - m_managedResource = null; - m_modelMBeanInfo = null; - m_generalBroadcaster = null; - m_attributeChangeBroadcaster = null; - // PENDING: also remove generic listeners, attribute change listeners, log4j appenders... - } - - public void setModelMBeanInfo(ModelMBeanInfo modelMBeanInfo) throws MBeanException, RuntimeOperationsException - { - if (modelMBeanInfo == null) throw new RuntimeOperationsException(new IllegalArgumentException(LocalizedStrings.MX4JModelMBean_MODELMBEANINFO_CANNOT_BE_NULL.toLocalizedString())); - if (!isModelMBeanInfoValid(modelMBeanInfo)) throw new RuntimeOperationsException(new IllegalArgumentException(LocalizedStrings.MX4JModelMBean_MODELMBEANINFO_IS_INVALID.toLocalizedString())); - - m_modelMBeanInfo = (ModelMBeanInfo)modelMBeanInfo.clone(); - - Logger logger = getLogger(); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("ModelMBeanInfo successfully set to: " + m_modelMBeanInfo); - // Only now the MBean can be registered in the MBeanServer - m_canBeRegistered = true; - } - - private boolean isModelMBeanInfoValid(ModelMBeanInfo info) - { - if (info == null || info.getClassName() == null) return false; - // PENDING: maybe more checks are needed - return true; - } - - public void setManagedResource(Object resource, String resourceType) throws MBeanException, RuntimeOperationsException, InstanceNotFoundException, InvalidTargetObjectTypeException - { - if (resource == null) throw new RuntimeOperationsException(new IllegalArgumentException(LocalizedStrings.MX4JModelMBean_MANAGED_RESOURCE_CANNOT_BE_NULL.toLocalizedString())); - if (!isResourceTypeSupported(resourceType)) throw new InvalidTargetObjectTypeException(resourceType); - - Logger logger = getLogger(); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Setting managed resource to be: " + resource); - m_managedResource = resource; - } - - private boolean isResourceTypeSupported(String resourceType) - { - // For now only object reference is supported - return OBJECT_RESOURCE_TYPE.equals(resourceType); - } - - private Object getManagedResource() - { - return m_managedResource; - } - - public MBeanInfo getMBeanInfo() - { - return m_modelMBeanInfo == null ? null : (MBeanInfo)m_modelMBeanInfo.clone(); - } - - public void addAttributeChangeNotificationListener(NotificationListener listener, String attributeName, Object handback) throws MBeanException, RuntimeOperationsException, IllegalArgumentException - { - if (listener == null) throw new RuntimeOperationsException(new IllegalArgumentException(LocalizedStrings.MX4JModelMBean_LISTENER_CANNOT_BE_NULL.toLocalizedString())); - AttributeChangeNotificationFilter filter = new AttributeChangeNotificationFilter(); - if (attributeName != null) - { - filter.enableAttribute(attributeName); - } - else - { - MBeanAttributeInfo[] ai = m_modelMBeanInfo.getAttributes(); - for (int i = 0; i < ai.length; i++) - { - Descriptor d = ((ModelMBeanAttributeInfo)ai[i]).getDescriptor(); - filter.enableAttribute((String)d.getFieldValue("name")); - } - } - - getAttributeChangeBroadcaster().addNotificationListener(listener, filter, handback); - - Logger logger = getLogger(); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Listener " + listener + " for attribute " + attributeName + " added successfully, handback is " + handback); - } - - public void addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws IllegalArgumentException - { - m_generalBroadcaster.addNotificationListener(listener, filter, handback); - } - - public MBeanNotificationInfo[] getNotificationInfo() - { - return m_modelMBeanInfo.getNotifications(); - } - - public void removeAttributeChangeNotificationListener(NotificationListener listener, String attributeName) throws RuntimeOperationsException, ListenerNotFoundException - { - try - { - removeAttributeChangeNotificationListener(listener, attributeName, null); - } - catch (MBeanException e) - { - throw new RuntimeOperationsException(new RuntimeException(e.getMessage())); - } - } - - // Not in the spec but needed - private void removeAttributeChangeNotificationListener(NotificationListener listener, String attributeName, Object handback) throws MBeanException, RuntimeOperationsException, ListenerNotFoundException - { - if (listener == null) throw new RuntimeOperationsException(new IllegalArgumentException(LocalizedStrings.MX4JModelMBean_LISTENER_CANNOT_BE_NULL.toLocalizedString())); - AttributeChangeNotificationFilter filter = new AttributeChangeNotificationFilter(); - if (attributeName != null) - { - filter.enableAttribute(attributeName); - } - else - { - MBeanAttributeInfo[] ai = m_modelMBeanInfo.getAttributes(); - for (int i = 0; i < ai.length; i++) - { - Descriptor d = ((ModelMBeanAttributeInfo)ai[i]).getDescriptor(); - filter.enableAttribute((String)d.getFieldValue("name")); - } - } - - getAttributeChangeBroadcaster().removeNotificationListener(listener, filter, handback); - - Logger logger = getLogger(); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Listener " + listener + " for attribute " + attributeName + " removed successfully, handback is " + handback); - } - - public void removeNotificationListener(NotificationListener listener) throws RuntimeOperationsException, ListenerNotFoundException - { - m_generalBroadcaster.removeNotificationListener(listener); - } - - public void removeNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws RuntimeOperationsException, ListenerNotFoundException - { - m_generalBroadcaster.removeNotificationListener(listener, filter, handback); - } - - public void sendAttributeChangeNotification(Attribute oldAttribute, Attribute newAttribute) throws MBeanException, RuntimeOperationsException - { - if (oldAttribute == null || newAttribute == null) throw new RuntimeOperationsException(new IllegalArgumentException(LocalizedStrings.MX4JModelMBean_ATTRIBUTE_CANNOT_BE_NULL.toLocalizedString())); - if (!oldAttribute.getName().equals(newAttribute.getName())) throw new RuntimeOperationsException(new IllegalArgumentException(LocalizedStrings.MX4JModelMBean_ATTRIBUTE_NAMES_CANNOT_BE_DIFFERENT.toLocalizedString())); - - // TODO: the source must be the object name of the MBean if the listener was registered through MBeanServer - Object oldValue = oldAttribute.getValue(); - AttributeChangeNotification n = new AttributeChangeNotification(this, - 1, - System.currentTimeMillis(), - "Attribute value changed", - oldAttribute.getName(), - oldValue == null ? null : oldValue.getClass().getName(), - oldValue, - newAttribute.getValue()); - sendAttributeChangeNotification(n); - } - - public void sendAttributeChangeNotification(AttributeChangeNotification notification) throws MBeanException, RuntimeOperationsException - { - if (notification == null) throw new RuntimeOperationsException(new IllegalArgumentException(LocalizedStrings.MX4JModelMBean_NOTIFICATION_CANNOT_BE_NULL.toLocalizedString())); - - getAttributeChangeBroadcaster().sendNotification(notification); - - Logger modelMBeanLogger = getModelMBeanLogger(notification.getType()); - if (modelMBeanLogger != null) if (modelMBeanLogger.isEnabledFor(Logger.DEBUG)) modelMBeanLogger.debug("ModelMBean log: " + new Date() + " - " + notification); - - Logger logger = getLogger(); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Attribute change notification " + notification + " sent"); - } - - public void sendNotification(String message) throws MBeanException, RuntimeOperationsException - { - Notification notification = new Notification("jmx.modelmbean.general", this, 1, message); - sendNotification(notification); - } - - public void sendNotification(Notification notification) throws MBeanException, RuntimeOperationsException - { - if (m_generalBroadcaster != null) { - m_generalBroadcaster.sendNotification(notification); - } - } - - public AttributeList getAttributes(String[] attributes) - { - if (attributes == null) throw new RuntimeOperationsException(new IllegalArgumentException(LocalizedStrings.MX4JModelMBean_ATTRIBUTE_NAMES_CANNOT_BE_NULL.toLocalizedString())); - - Logger logger = getLogger(); - - AttributeList list = new AttributeList(); - for (int i = 0; i < attributes.length; ++i) - { - String attrName = attributes[i]; - Attribute attribute = null; - try - { - Object value = getAttribute(attrName); - attribute = new Attribute(attrName, value); - list.add(attribute); - } - catch (Exception x) - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("getAttribute for attribute " + attrName + " failed", x); - // And go on with the next attribute - } - } - return list; - } - - public Object getAttribute(String attribute) throws AttributeNotFoundException, MBeanException, ReflectionException - { - if (attribute == null) throw new RuntimeOperationsException(new IllegalArgumentException(LocalizedStrings.MX4JModelMBean_ATTRIBUTE_NAME_CANNOT_BE_NULL.toLocalizedString())); - - Logger logger = getLogger(); - - // I want the real info, not its clone - ModelMBeanInfo info = getModelMBeanInfo(); - if (info == null) throw new AttributeNotFoundException(LocalizedStrings.MX4JModelMBean_MODELMBEANINFO_IS_NULL.toLocalizedString()); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("ModelMBeanInfo is: " + info); - - // This is a clone, we use it read only - ModelMBeanAttributeInfo attrInfo = info.getAttribute(attribute); - if (attrInfo == null) throw new AttributeNotFoundException(LocalizedStrings.MX4JModelMBean_CANNOT_FIND_MODELMBEANATTRIBUTEINFO_FOR_ATTRIBUTE_0.toLocalizedString(attribute)); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Attribute info is: " + attrInfo); - if (!attrInfo.isReadable()) throw new AttributeNotFoundException(LocalizedStrings.MX4JModelMBean_ATTRIBUTE_0_IS_NOT_READABLE.toLocalizedString(attribute)); - - // This returns a clone of the mbean descriptor, we use it read only - Descriptor mbeanDescriptor = info.getMBeanDescriptor(); - if (mbeanDescriptor == null) throw new AttributeNotFoundException(LocalizedStrings.MX4JModelMBean_MBEAN_DESCRIPTOR_CANNOT_BE_NULL.toLocalizedString()); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("MBean descriptor is: " + mbeanDescriptor); - - // This descriptor is a clone - Descriptor attributeDescriptor = attrInfo.getDescriptor(); - if (attributeDescriptor == null) throw new AttributeNotFoundException(LocalizedStrings.MX4JModelMBean_ATTRIBUTE_DESCRIPTOR_FOR_ATTRIBUTE_0_CANNOT_BE_NULL.toLocalizedString(attribute)); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Attribute descriptor is: " + attributeDescriptor); - - Object returnValue = null; - - String lastUpdateField = "lastUpdatedTimeStamp"; - - int staleness = getStaleness(attributeDescriptor, mbeanDescriptor, lastUpdateField); - - if (staleness == ALWAYS_STALE || staleness == STALE) - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Value is stale"); - - String getter = (String)attributeDescriptor.getFieldValue("getMethod"); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("getMethod field is: " + getter); - if (getter == null) - { - // No getter, use default value - returnValue = attributeDescriptor.getFieldValue("default"); - - if (returnValue != null) - { - // Check if the return type is of the same type - // As an extension allow covariant return type - Class returned = returnValue.getClass(); - Class declared = loadClassWithContextClassLoader(attrInfo.getType()); - - checkAssignability(returned, declared); - } - - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("getAttribute for attribute " + attribute + " returns default value: " + returnValue); - } - else - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Invoking attribute getter..."); - // As an extension, allow attributes to be called on target objects also - Object target = resolveTargetObject(attributeDescriptor); - returnValue = invokeMethod(target, getter, new Class[0], new Object[0]); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Returned value is: " + returnValue); - - if (returnValue != null) - { - // Check if the return type is of the same type - // As an extension allow covariant return type - Class returned = returnValue.getClass(); - Class declared = loadClassWithContextClassLoader(attrInfo.getType()); - - checkAssignability(returned, declared); - } - - // Cache the new value only if caching is needed - if (staleness != ALWAYS_STALE) - { - attributeDescriptor.setField("value", returnValue); - attributeDescriptor.setField(lastUpdateField, Long.valueOf(System.currentTimeMillis())); - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Returned value has been cached"); - - // And now replace the descriptor with the updated clone - info.setDescriptor(attributeDescriptor, "attribute"); - } - - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("getAttribute for attribute " + attribute + " returns invoked value: " + returnValue); - } - } - else - { - // Return cached value - returnValue = attributeDescriptor.getFieldValue("value"); - - if (returnValue != null) - { - // Check if the return type is of the same type - // As an extension allow covariant return type - Class returned = returnValue.getClass(); - Class declared = loadClassWithContextClassLoader(attrInfo.getType()); - - checkAssignability(returned, declared); - } - - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("getAttribute for attribute " + attribute + " returns cached value: " + returnValue); - } - - // Puff, everything went ok - return returnValue; - } - - public AttributeList setAttributes(AttributeList attributes) - { - if (attributes == null) throw new RuntimeOperationsException(new IllegalArgumentException(LocalizedStrings.MX4JModelMBean_ATTRIBUTE_LIST_CANNOT_BE_NULL.toLocalizedString())); - - Logger logger = getLogger(); - - AttributeList list = new AttributeList(); - for (Iterator i = attributes.iterator(); i.hasNext();) - { - Attribute attribute = (Attribute)i.next(); - String name = attribute.getName(); - try - { - setAttribute(attribute); - list.add(attribute); - } - catch (Exception x) - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("setAttribute for attribute " + name + " failed", x); - // And go on with the next one - } - } - return list; - } - - public void setAttribute(Attribute attribute) throws AttributeNotFoundException, InvalidAttributeValueException, MBeanException, ReflectionException - { - if (attribute == null) throw new RuntimeOperationsException(new IllegalArgumentException(LocalizedStrings.MX4JModelMBean_ATTRIBUTE_CANNOT_BE_NULL.toLocalizedString())); - - Logger logger = getLogger(); - - // No need to synchronize: I work mostly on clones - // I want the real info, not its clone - ModelMBeanInfo info = getModelMBeanInfo(); - if (info == null) throw new AttributeNotFoundException(LocalizedStrings.MX4JModelMBean_MODELMBEANINFO_IS_NULL.toLocalizedString()); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("ModelMBeanInfo is: " + info); - - String attrName = attribute.getName(); - Object attrValue = attribute.getValue(); - - // This is a clone, we use it read only - ModelMBeanAttributeInfo attrInfo = info.getAttribute(attrName); - if (attrInfo == null) throw new AttributeNotFoundException(LocalizedStrings.MX4JModelMBean_CANNOT_FIND_MODELMBEANATTRIBUTEINFO_FOR_ATTRIBUTE_0.toLocalizedString(attrName)); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Attribute info is: " + attrInfo); - - if (!attrInfo.isWritable()) throw new AttributeNotFoundException(LocalizedStrings.MX4JModelMBean_ATTRIBUTE_0_IS_NOT_WRITABLE.toLocalizedString(attrName)); - - // This returns a clone of the mbean descriptor, we use it read only - Descriptor mbeanDescriptor = info.getMBeanDescriptor(); - if (mbeanDescriptor == null) throw new AttributeNotFoundException(LocalizedStrings.MX4JModelMBean_MBEAN_DESCRIPTOR_CANNOT_BE_NULL.toLocalizedString()); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("MBean descriptor is: " + mbeanDescriptor); - - // This descriptor is a clone - Descriptor attributeDescriptor = attrInfo.getDescriptor(); - if (attributeDescriptor == null) throw new AttributeNotFoundException(LocalizedStrings.MX4JModelMBean_ATTRIBUTE_DESCRIPTOR_FOR_ATTRIBUTE_0_CANNOT_BE_NULL.toLocalizedString(attrName)); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Attribute descriptor is: " + attributeDescriptor); - - String lastUpdateField = "lastUpdatedTimeStamp"; - - Object oldValue = null; - try - { - oldValue = getAttribute(attrName); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Previous value of attribute " + attrName + ": " + oldValue); - } - catch (Exception x) - { - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Cannot get previous value of attribute " + attrName, x); - } - - // Check if setMethod is present - String method = (String)attributeDescriptor.getFieldValue("setMethod"); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("setMethod field is: " + method); - if (method != null) - { - Class declared = loadClassWithContextClassLoader(attrInfo.getType()); - if (attrValue != null) - { - Class parameter = attrValue.getClass(); - checkAssignability(parameter, declared); - } - - // As an extension, allow attributes to be called on target objects also - Object target = resolveTargetObject(attributeDescriptor); - invokeMethod(target, method, new Class[]{declared}, new Object[]{attrValue}); - - // Cache the value only if currencyTimeLimit is not 0, ie it is not always stale - int staleness = getStaleness(attributeDescriptor, mbeanDescriptor, lastUpdateField); - if (staleness != ALWAYS_STALE) - { - attributeDescriptor.setField("value", attrValue); - attributeDescriptor.setField(lastUpdateField, Long.valueOf(System.currentTimeMillis())); - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Attribute's value has been cached"); - } - else - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Always stale, avoiding to cache attribute's value"); - } - } - else - { - if (attrValue != null) - { - Class parameter = attrValue.getClass(); - Class declared = loadClassWithContextClassLoader(attrInfo.getType()); - - checkAssignability(parameter, declared); - } - - // Always store the value in the descriptor: no setMethod - attributeDescriptor.setField("value", attrValue); - } - - // And now replace the descriptor with the updated clone - info.setDescriptor(attributeDescriptor, "attribute"); - - // Send notifications to listeners - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Sending attribute change notifications"); - sendAttributeChangeNotification(new Attribute(attrName, oldValue), attribute); - - // Persist this ModelMBean - boolean persistNow = shouldPersistNow(attributeDescriptor, mbeanDescriptor, lastUpdateField); - if (persistNow) - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Persisting this ModelMBean..."); - try - { - store(); - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("ModelMBean persisted successfully"); - } - catch (Exception x) - { - logger.error(LocalizedStrings.MX4JModelMBean_CANNOT_STORE_MODELMBEAN_AFTER_SETATTRIBUTE, x); - if (x instanceof MBeanException) - throw (MBeanException)x; - else - throw new MBeanException(x); - } - } - } - - public Object invoke(String method, Object[] arguments, String[] params) throws MBeanException, ReflectionException - { - if (method == null) throw new RuntimeOperationsException(new IllegalArgumentException(LocalizedStrings.MX4JModelMBean_METHOD_NAME_CANNOT_BE_NULL.toLocalizedString())); - if (arguments == null) arguments = new Object[0]; - if (params == null) params = new String[0]; - - Logger logger = getLogger(); - - // Find operation descriptor - ModelMBeanInfo info = getModelMBeanInfo(); - if (info == null) throw new MBeanException(new ServiceNotFoundException(LocalizedStrings.MX4JModelMBean_MODELMBEANINFO_IS_NULL.toLocalizedString())); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("ModelMBeanInfo is: " + info); - - // This is a clone, we use it read only - ModelMBeanOperationInfo operInfo = info.getOperation(method); - if (operInfo == null) throw new MBeanException(new ServiceNotFoundException(LocalizedStrings.MX4JModelMBean_CANNOT_FIND_MODELMBEANOPERATIONINFO_FOR_OPERATION_0.toLocalizedString(method))); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Operation info is: " + operInfo); - - // This descriptor is a clone - Descriptor operationDescriptor = operInfo.getDescriptor(); - if (operationDescriptor == null) throw new MBeanException(new ServiceNotFoundException(LocalizedStrings.MX4JModelMBean_OPERATION_DESCRIPTOR_FOR_OPERATION_0_CANNOT_BE_NULL.toLocalizedString(method))); - String role = (String)operationDescriptor.getFieldValue("role"); - if (role == null || !role.equals("operation")) throw new MBeanException(new ServiceNotFoundException(LocalizedStrings.MX4JModelMBean_OPERATION_DESCRIPTOR_FIELD_ROLE_MUST_BE_OPERATION_NOT_0.toLocalizedString(role))); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Operation descriptor is: " + operationDescriptor); - - // This returns a clone of the mbean descriptor, we use it read only - Descriptor mbeanDescriptor = info.getMBeanDescriptor(); - if (mbeanDescriptor == null) throw new MBeanException(new ServiceNotFoundException(LocalizedStrings.MX4JModelMBean_MBEAN_DESCRIPTOR_CANNOT_BE_NULL.toLocalizedString())); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("MBean descriptor is: " + mbeanDescriptor); - - Object returnValue = null; - - String lastUpdateField = "lastReturnedTimeStamp"; - - // Check if the method should be invoked given the cache settings - int staleness = getStaleness(operationDescriptor, mbeanDescriptor, lastUpdateField); - - if (staleness == ALWAYS_STALE || staleness == STALE) - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Value is stale"); - - // Find parameters classes - Class[] parameters = null; - try - { - parameters = Utils.loadClasses(Thread.currentThread().getContextClassLoader(), params); - } - catch (ClassNotFoundException x) - { - logger.error(LocalizedStrings.MX4JModelMBean_CANNOT_FIND_OPERATIONS_PARAMETER_CLASSES, x); - throw new ReflectionException(x); - } - - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Invoking operation..."); - - // Find target object - Object target = resolveTargetObject(operationDescriptor); - returnValue = invokeMethod(target, method, parameters, arguments); - - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Returned value is: " + returnValue); - - if (returnValue != null) - { - Class parameter = returnValue.getClass(); - Class declared = loadClassWithContextClassLoader(operInfo.getReturnType()); - - checkAssignability(parameter, declared); - } - - // Cache the new value only if caching is needed - if (staleness != ALWAYS_STALE) - { - operationDescriptor.setField("lastReturnedValue", returnValue); - operationDescriptor.setField(lastUpdateField, Long.valueOf(System.currentTimeMillis())); - if (logger.isEnabledFor(Logger.TRACE)) - { - logger.trace("Returned value has been cached"); - } - - // And now replace the descriptor with the updated clone - info.setDescriptor(operationDescriptor, "operation"); - } - - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("invoke for operation " + method + " returns invoked value: " + returnValue); - } - else - { - // Return cached value - returnValue = operationDescriptor.getFieldValue("lastReturnedValue"); - - if (returnValue != null) - { - Class parameter = returnValue.getClass(); - Class declared = loadClassWithContextClassLoader(operInfo.getReturnType()); - - checkAssignability(parameter, declared); - } - - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("invoke for operation " + method + " returns cached value: " + returnValue); - } - - // As an extension, persist this model mbean also after operation invocation, but using only - // settings provided in the operation descriptor, without falling back to defaults set in - // the MBean descriptor - boolean persistNow = shouldPersistNow(operationDescriptor, null, lastUpdateField); - int impact = operInfo.getImpact(); - if (persistNow && impact != MBeanOperationInfo.INFO) - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Persisting this ModelMBean..."); - try - { - store(); - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("ModelMBean persisted successfully"); - } - catch (Exception x) - { - logger.error(LocalizedStrings.MX4JModelMBean_CANNOT_STORE_MODELMBEAN_AFTER_OPERATION_INVOCATION, x); - if (x instanceof MBeanException) - throw (MBeanException)x; - else - throw new MBeanException(x); - } - } - - return returnValue; - } - - private Object resolveTargetObject(Descriptor descriptor) throws MBeanException - { - Logger logger = getLogger(); - Object target = descriptor.getFieldValue("targetObject"); - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("targetObject is: " + target); - if (target == null) - { - target = getManagedResource(); - } - else - { - String targetObjectType = (String)descriptor.getFieldValue("targetObjectType"); - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("targetObjectType is: " + targetObjectType); - if (targetObjectType == null) - { - // Not defined, assume object reference - targetObjectType = OBJECT_RESOURCE_TYPE; - } - - if (!isResourceTypeSupported(targetObjectType)) throw new MBeanException(new InvalidTargetObjectTypeException(targetObjectType)); - } - return target; - } - - public void load() throws MBeanException, RuntimeOperationsException, InstanceNotFoundException - { - PersisterMBean persister = findPersister(); - if (persister != null) - { - ModelMBeanInfo info = (ModelMBeanInfo)persister.load(); - setModelMBeanInfo(info); - } - } - - public void store() throws MBeanException, RuntimeOperationsException, InstanceNotFoundException - { - PersisterMBean persister = findPersister(); - if (persister != null) - { - // Take a clone to avoid synchronization problems - ModelMBeanInfo info = (ModelMBeanInfo)getMBeanInfo(); - persister.store(info); - } - } - - protected ClassLoaderRepository getClassLoaderRepository() - { - if (m_mbeanServer != null) - return m_mbeanServer.getClassLoaderRepository(); - else - return null; - } - - - private boolean shouldPersistNow(Descriptor attribute, Descriptor mbean, String lastUpdateField) - { - int persist = getPersistPolicy(attribute, mbean); - if (persist == PERSIST_NO_MORE_OFTEN_THAN) - { - Long period = getFieldTimeValue(attribute, mbean, "persistPeriod"); - long now = System.currentTimeMillis(); - Long lastUpdate = (Long)attribute.getFieldValue(lastUpdateField); - if (now - lastUpdate.longValue() < period.longValue()) - return false; - else - return true; - } - else if (persist == PERSIST_NEVER) - { - return false; - } - else if (persist == PERSIST_ON_TIMER) - { - return false; - } - else if (persist == PERSIST_ON_UPDATE) - { - return true; - } - else - { - throw new ImplementationException(LocalizedStrings.MX4JModelMBean_INVALID_PERSIST_VALUE.toLocalizedString()); - } - } - - private int getPersistPolicy(Descriptor descriptor, Descriptor mbean) - { - Logger logger = getLogger(); - - String persist = (String)descriptor.getFieldValue("persistPolicy"); - if (persist == null && mbean != null) persist = (String)mbean.getFieldValue("persistPolicy"); - if (persist == null) - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("No persist policy defined, assuming Never"); - return PERSIST_NEVER; - } - else - { - if (persist.equals("Never")) - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Persist never"); - return PERSIST_NEVER; - } - else if (persist.equals("OnUpdate")) - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Persist on update"); - return PERSIST_ON_UPDATE; - } - else if (persist.equals("OnTimer")) - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Persist on update"); - return PERSIST_ON_TIMER; - } - else if (persist.equals("NoMoreOftenThan")) - { - if (logger.isEnabledFor(Logger.TRACE)) - { - Long period = getFieldTimeValue(descriptor, mbean, "persistPeriod"); - logger.trace("Persist no more often than " + period); - } - return PERSIST_NO_MORE_OFTEN_THAN; - } - else - { - // Garbage, assuming Never - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Invalid persist policy, assuming persist never"); - return PERSIST_NEVER; - } - } - } - - private int getStaleness(Descriptor attribute, Descriptor mbean, String lastUpdateField) - { - Logger logger = getLogger(); - - Long currencyTimeLimit = getFieldTimeValue(attribute, mbean, "currencyTimeLimit"); - if (currencyTimeLimit == null) - { - // No time limit defined - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("No currencyTimeLimit defined, assuming always stale"); - return ALWAYS_STALE; - } - else - { - long ctl = currencyTimeLimit.longValue() * 1000; - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("currencyTimeLimit is (ms): " + ctl); - - if (ctl == 0) - { - // Never stale - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Never stale"); - return NEVER_STALE; - } - else if (ctl < 0) // this should be == -1 but the other cases are in the air - { - // Always stale - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Always stale"); - return ALWAYS_STALE; - } - else - { - Long timestamp = (Long)attribute.getFieldValue(lastUpdateField); - long luts = 0; - - if (timestamp != null) luts = timestamp.longValue(); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug(lastUpdateField + " is: " + luts); - - long now = System.currentTimeMillis(); - if (now < luts + ctl) - { - // Seems to be not stale, but has been set at least once ? - if (timestamp == null) - { - // Return stale to call it the first time - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Stale since was never set"); - return STALE; - } - else - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Not stale"); - return NOT_STALE; - } - } - else - { - // Stale - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Stale"); - return STALE; - } - } - } - } - - private Long getFieldTimeValue(Descriptor descriptor, Descriptor mbean, String field) - { - Logger logger = getLogger(); - - Object value = descriptor.getFieldValue(field); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Descriptor's " + field + " field: " + value); - - if (value == null && mbean != null) - { - value = mbean.getFieldValue(field); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("MBean's " + field + " field: " + value); - if (value == null) return null; - } - - if (value instanceof Number) return Long.valueOf(((Number)value).longValue()); - - if (value instanceof String) - { - try - { - long ctl = Long.parseLong((String)value); - return Long.valueOf(ctl); - } - catch (NumberFormatException x) - { - return Long.valueOf(0); - } - } - return Long.valueOf(0); - } - - private Object invokeMethod(Object target, String methodName, Class[] params, Object[] args) throws MBeanException, ReflectionException - { - // First try on this instance, then on the target - Object realTarget = null; - Method method = null; - try - { - realTarget = this; - method = realTarget.getClass().getMethod(methodName, params); - } - catch (NoSuchMethodException x) - { - realTarget = target; - } - - if (realTarget == null) throw new MBeanException(new ServiceNotFoundException(LocalizedStrings.MX4JModelMBean_COULD_NOT_FIND_TARGET.toLocalizedString())); - - if (method == null) - { - try - { - method = realTarget.getClass().getMethod(methodName, params); - } - catch (NoSuchMethodException x) - { - throw new ReflectionException(x); - } - } - - try - { - Object value = method.invoke(realTarget, args); - Logger logger = getLogger(); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Method invocation returned value: " + value); - return value; - } - catch (IllegalAccessException x) - { - throw new ReflectionException(x); - } - catch (IllegalArgumentException x) - { - throw new MBeanException(x); - } - catch (InvocationTargetException x) - { - Throwable t = x.getTargetException(); - if (t instanceof Error) - throw new MBeanException(new RuntimeErrorException((Error)t)); - else - throw new MBeanException((Exception)t); - } - } - - private Logger getModelMBeanLogger(String notificationType) throws MBeanException - { - // Get a copy to avoid synchronization - ModelMBeanInfo info = getModelMBeanInfo(); - - // First look if there is a suitable notification descriptor, otherwise use MBean descriptor - Descriptor descriptor = null; - Logger modelMBeanLogger = null; - if (notificationType != null) - { - descriptor = info.getDescriptor(notificationType, "notification"); - modelMBeanLogger = findLogger(descriptor); - } - - if (modelMBeanLogger == null) - { - descriptor = info.getMBeanDescriptor(); - modelMBeanLogger = findLogger(descriptor); - if (modelMBeanLogger != null) return modelMBeanLogger; - } - - return null; - } - - private Logger findLogger(Descriptor descriptor) - { - Logger logger = getLogger(); - - if (descriptor == null) - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Can't find MBean logger, descriptor is null"); - return null; - } - - String log = (String)descriptor.getFieldValue("log"); - String location = (String)descriptor.getFieldValue("logFile"); - - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Log fields: log=" + log + ", file=" + location); - - if (log == null || !Boolean.valueOf(log).booleanValue()) - { - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Logging is not supported by this ModelMBean"); - return null; - } - // Logger is supported, where log to ? - if (location == null) - { - // As an extension, see if the field logMBean has been defined - location = (String)descriptor.getFieldValue("logMBean"); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Log fields: mbean=" + location); - - if (location == null) - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Logging is not supported by this ModelMBean"); - return null; - } - - // It seems that the user wants to delegate a registered mbean to log - try - { - ObjectName objectName = new ObjectName(location); - MBeanServer server = getMBeanServer(); - if (server == null) throw new MBeanException(new IllegalStateException(LocalizedStrings.MX4JModelMBean_MX4JMODELMBEAN_IS_NOT_REGISTERED.toLocalizedString())); - if (server.isRegistered(objectName)) - { - MBeanLogger l = new MBeanLogger(server, objectName); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("ModelMBean log supported by delegating to this MBean: " + objectName); - return l; - } - - return null; - } - catch (MalformedObjectNameException x) - { - // Ah, was not a correct object name - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Specified logMBean field does not contain a valid ObjectName: " + location); - return null; - } - catch (MBeanException x) - { - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("logMBean field does not specify an MBean that supports logging delegation", x); - return null; - } - } - else - { - // User decided to log to a file - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("ModelMBean log supported on file system"); - return new FileLogger(location); - } - } - - private NotificationBroadcasterSupport getAttributeChangeBroadcaster() - { - return m_attributeChangeBroadcaster; - } - - private MBeanServer getMBeanServer() - { - return m_mbeanServer; - } - - private ModelMBeanInfo getModelMBeanInfo() - { - // No cloning performed - return m_modelMBeanInfo; - } - - private PersisterMBean findPersister() throws MBeanException, InstanceNotFoundException - { - Logger logger = getLogger(); - - ModelMBeanInfo info = getModelMBeanInfo(); - if (info == null) - { - // Not yet initialized - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Can't find persister, ModelMBeanInfo is null"); - return null; - } - Descriptor mbeanDescriptor = info.getMBeanDescriptor(); - if (mbeanDescriptor == null) - { - // This is normally should not happen if ModelMBeanInfoSupport is used - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Can't find persister, MBean descriptor is null"); - return null; - } - - String location = (String)mbeanDescriptor.getFieldValue("persistLocation"); - String name = (String)mbeanDescriptor.getFieldValue("persistName"); - String mbeanName = (String)mbeanDescriptor.getFieldValue("name"); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Persistence fields: location=" + location + ", name=" + name); - - if (mbeanName == null && name == null) - { - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Persistence is not supported by this ModelMBean"); - return null; - } - - // Try to see if this mbean should delegate to another mbean - if (name != null) - { - try - { - ObjectName objectName = new ObjectName(name.trim()); - // OK, a valid object name - MBeanServer server = getMBeanServer(); - if (server == null) throw new MBeanException(new IllegalStateException(LocalizedStrings.MX4JModelMBean_MX4JMODELMBEAN_IS_NOT_REGISTERED.toLocalizedString())); - - if (server.isRegistered(objectName) && server.isInstanceOf(objectName, PersisterMBean.class.getName())) - { - // OK, the given mbean is registered with this mbean server - PersisterMBean persister = new MBeanPersister(server, objectName); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Persistence is delegated to this MBean: " + objectName); - return persister; - } - else - { - throw new InstanceNotFoundException(objectName.toString()); - } - } - catch (MalformedObjectNameException ignored) - { - // It does not delegates to another mbean, use default - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Persistence is not delegated to another MBean"); - } - - // Default is serialization to file - FilePersister persister = new FilePersister(location, name); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Persistence is realized through file system in " + persister.getFileName()); - return persister; - } - else - { - // Only location given, use MBean name - FilePersister persister = new FilePersister(location, mbeanName); - if (logger.isEnabledFor(Logger.DEBUG)) logger.debug("Persistence is realized through file system in " + persister.getFileName()); - return persister; - } - } - - private Class loadClassWithContextClassLoader(String name) - { - try - { - return Utils.loadClass(Thread.currentThread().getContextClassLoader(), name); - } - catch (ClassNotFoundException x) - { - Logger logger = getLogger(); - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Cannot find attribute's declared return class", x); - return null; - } - } - - private void checkAssignability(Class parameter, Class declared) throws MBeanException - { - Logger logger = getLogger(); - - if (logger.isEnabledFor(Logger.DEBUG)) - { - logger.debug("The class of the parameter is: " + parameter); - if (parameter != null) logger.debug("The classloder of the parameter's class is: " + parameter.getClassLoader()); - logger.debug("The class declared as type of the attribute is: " + declared); - if (declared != null) logger.debug("The classloader of the declared parameter's class is: " + declared.getClassLoader()); - } - - boolean assignable = false; - - if (declared == null || parameter == null) - assignable = false; - else if (declared == boolean.class && parameter == Boolean.class) - assignable = true; - else if (declared == byte.class && parameter == Byte.class) - assignable = true; - else if (declared == char.class && parameter == Character.class) - assignable = true; - else if (declared == short.class && parameter == Short.class) - assignable = true; - else if (declared == int.class && parameter == Integer.class) - assignable = true; - else if (declared == long.class && parameter == Long.class) - assignable = true; - else if (declared == float.class && parameter == Float.class) - assignable = true; - else if (declared == double.class && parameter == Double.class) - assignable = true; - else - assignable = declared.isAssignableFrom(parameter); - - if (!assignable) - { - if (logger.isEnabledFor(Logger.TRACE)) logger.trace("Parameter value's class and attribute's declared return class are not assignable"); - throw new MBeanException(new InvalidAttributeValueException(LocalizedStrings.MX4JModelMBean_RETURNED_TYPE_AND_DECLARED_TYPE_ARE_NOT_ASSIGNABLE.toLocalizedString())); - } - } -}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/MX4JServerSocketFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/MX4JServerSocketFactory.java b/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/MX4JServerSocketFactory.java deleted file mode 100644 index 474f8dd..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/MX4JServerSocketFactory.java +++ /dev/null @@ -1,160 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin.jmx.internal; - -import org.apache.geode.admin.DistributedSystemConfig; -import org.apache.geode.admin.internal.InetAddressUtil; -import org.apache.geode.distributed.internal.DistributionConfig; -import org.apache.geode.internal.net.SocketCreator; -import org.apache.geode.internal.logging.LogService; -import org.apache.geode.internal.net.SocketCreatorFactory; - -import org.apache.logging.log4j.Logger; - -import java.io.IOException; -import java.net.ServerSocket; -import java.util.Properties; - -/** - * Creates <code>ServerSockets</code> for JMX adaptors. - * <p> - * The interface {@link mx4j.tools.adaptor.AdaptorServerSocketFactory} is - * implemented in order to support securing of {@link - * mx4j.tools.adaptor.http.HttpAdaptor}. - * <p> - * The interface {@link java.rmi.server.RMIServerSocketFactory} is implemented - * to support the securing of {@link - * javax.management.remote.JMXConnectorServer}. See {@link - * javax.management.remote.rmi.RMIConnectorServer} for the actual subclass that - * is used for the JMX RMI adaptor. - * <p> - * Complete info on JSSE, including debugging, can be found at - * <a href="http://java.sun.com/j2se/1.4.2/docs/guide/security/jsse/JSSERefGuide.html"> - * http://java.sun.com/j2se/1.4.2/docs/guide/security/jsse/JSSERefGuide.html</a> - * - * @since GemFire 3.5 (old name was SSLAdaptorServerSocketFactory) - */ -public class MX4JServerSocketFactory -implements mx4j.tools.adaptor.AdaptorServerSocketFactory, - java.rmi.server.RMIServerSocketFactory { - - private static final Logger logger = LogService.getLogger(); - - private static final int DEFAULT_BACKLOG = 50; - - private final SocketCreator socketCreator; - private String bindAddress = DistributedSystemConfig.DEFAULT_BIND_ADDRESS; - private int backlog = DEFAULT_BACKLOG; - - /** - * Constructs new instance of MX4JServerSocketFactory. - * - * @param useSSL - * true if ssl is to be enabled - * @param needClientAuth - * true if client authentication is required - * @param protocols - * space-delimited list of ssl protocols to use - * @param ciphers - * space-delimited list of ssl ciphers to use - * @param gfsecurityProps - * vendor properties passed in through gfsecurity.properties - */ - public MX4JServerSocketFactory(boolean useSSL, - boolean needClientAuth, - String protocols, - String ciphers, - Properties gfsecurityProps) { - if (protocols == null || protocols.length() == 0) { - protocols = DistributionConfig.DEFAULT_SSL_PROTOCOLS; - } - if (ciphers == null || ciphers.length() == 0) { - ciphers = DistributionConfig.DEFAULT_SSL_CIPHERS; - } - this.socketCreator = SocketCreatorFactory.createNonDefaultInstance( - useSSL, needClientAuth, protocols, ciphers, gfsecurityProps); - } - - /** - * Constructs new instance of MX4JServerSocketFactory. - * - * @param useSSL - * true if ssl is to be enabled - * @param needClientAuth - * true if client authentication is required - * @param protocols - * space-delimited list of ssl protocols to use - * @param ciphers - * space-delimited list of ssl ciphers to use - * @param bindAddress - * host or address to bind to (bind-address) - * @param backlog - * how many connections are queued - * @param gfsecurityProps - * vendor properties passed in through gfsecurity.properties - */ - public MX4JServerSocketFactory(boolean useSSL, - boolean needClientAuth, - String protocols, - String ciphers, - String bindAddress, // optional for RMI impl - int backlog, // optional for RMI impl - Properties gfsecurityProps) { - this(useSSL, needClientAuth, protocols, ciphers, gfsecurityProps); - this.bindAddress = bindAddress; - this.backlog = backlog; - } - - // ------------------------------------------------------------------------- - // mx4j.tools.adaptor.AdaptorServerSocketFactory impl... - // ------------------------------------------------------------------------- - - public ServerSocket createServerSocket(int port, - int backlog, - String bindAddress) throws IOException { - if ("".equals(bindAddress)) { - return socketCreator.createServerSocket( - port, backlog); - - } else { - return socketCreator.createServerSocket( - port, backlog, InetAddressUtil.toInetAddress(bindAddress)); - } - } - - // ------------------------------------------------------------------------- - // java.rmi.server.RMIServerSocketFactory impl... - // ------------------------------------------------------------------------- - - public ServerSocket createServerSocket(int port) throws IOException { - ServerSocket sock = null; - if ("".equals(bindAddress)) { - sock = socketCreator.createServerSocket(port, this.backlog); - } else { - sock = socketCreator.createServerSocket( - port, this.backlog, InetAddressUtil.toInetAddress(this.bindAddress)); - } - - if (logger.isDebugEnabled()) { - logger.debug("MX4JServerSocketFactory RMIServerSocketFactory, INetAddress {}, LocalPort {}, LocalSocketAddress {}", - sock.getInetAddress(), sock.getLocalPort(), sock.getLocalSocketAddress()); - } - return sock; - } - -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/MailManager.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/MailManager.java b/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/MailManager.java deleted file mode 100755 index 1786406..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/MailManager.java +++ /dev/null @@ -1,331 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin.jmx.internal; - -import java.io.File; -import java.io.FileInputStream; -import java.io.IOException; -import java.util.HashSet; -import java.util.Properties; - -import javax.mail.Message; -import javax.mail.Session; -import javax.mail.Transport; -import javax.mail.internet.InternetAddress; -import javax.mail.internet.MimeMessage; - -import org.apache.logging.log4j.Logger; - -import org.apache.geode.SystemFailure; -import org.apache.geode.internal.i18n.LocalizedStrings; -import org.apache.geode.internal.logging.LogService; -import org.apache.geode.internal.logging.log4j.LocalizedMessage; - -/** - * Provides the ways to send emails to all the registered email id It also - * provides the way to add/remove email ids. Can be used to send email in case - * of any alerts raised / warning / failure in gemfire. - * - * @since GemFire 5.1 - */ -public class MailManager { - - private static final Logger logger = LogService.getLogger(); - - public MailManager() { - } - - public MailManager(Properties mailProperties) { - setMailProperties(mailProperties); - } - - public MailManager(File mailPropertiesFile) throws IOException { - Properties prop = new Properties(); - FileInputStream fio = new FileInputStream(mailPropertiesFile); - try { - prop.load(fio); - } - finally { - fio.close(); - } - setMailProperties(prop); - } - - public MailManager(String mailHost, String mailFrom) { - this.mailHost = mailHost; - this.mailFrom = mailFrom; - } - - /** - * Send email to all the registered email id with given subject and message - */ - public void sendEmail(String subject, String message) { - processEmail(new EmailData(subject, message)); - } - - /** - * Send Emails to all the registered email id - * - * @param emailData - * Instance of EmailData - */ - // Why a separate method & class EmailData needed??? - private void processEmail(EmailData emailData) { - if (logger.isTraceEnabled()) { - logger.trace("Entered MailManager:processEmail"); - } - - if (mailHost == null || mailHost.length() == 0 - || emailData == null || mailToAddresses.length == 0) { - logger.error(LocalizedMessage.create(LocalizedStrings.MailManager_REQUIRED_MAILSERVER_CONFIGURATION_NOT_SPECIFIED)); - if (logger.isDebugEnabled()) { - logger.debug("Exited MailManager:processEmail: Not sending email as conditions not met"); - } - return; - } - - Session session = Session.getDefaultInstance(getMailHostConfiguration()); - MimeMessage mimeMessage = new MimeMessage(session); - String subject = emailData.subject; - String message = emailData.message; - String mailToList = getMailToAddressesAsString(); - - try { - for (int i = 0; i < mailToAddresses.length; i++) { - mimeMessage.addRecipient(Message.RecipientType.TO, new InternetAddress( - mailToAddresses[i])); - } - - if (subject == null) { - subject = LocalizedStrings.MailManager_ALERT_MAIL_SUBJECT.toLocalizedString(); - } - mimeMessage.setSubject(subject); - - if (message == null) { - message = ""; - } - mimeMessage.setText(message); - - Transport.send(mimeMessage); - logger.info(LocalizedMessage.create( - LocalizedStrings.MailManager_EMAIL_ALERT_HAS_BEEN_SENT_0_1_2, - new Object[] { mailToList, subject, message })); - } catch (VirtualMachineError err) { - SystemFailure.initiateFailure(err); - // If this ever returns, rethrow the error. We're poisoned - // now, so don't let this thread continue. - throw err; - } catch (Throwable ex) { - // Whenever you catch Error or Throwable, you must also - // catch VirtualMachineError (see above). However, there is - // _still_ a possibility that you are dealing with a cascading - // error condition, so you also need to check to see if the JVM - // is still usable: - SystemFailure.checkFailure(); - StringBuilder buf = new StringBuilder(); - buf.append(LocalizedStrings.MailManager_AN_EXCEPTION_OCCURRED_WHILE_SENDING_EMAIL.toLocalizedString()); - buf.append(LocalizedStrings.MailManager_UNABLE_TO_SEND_EMAIL_PLEASE_CHECK_YOUR_EMAIL_SETTINGS_AND_LOG_FILE.toLocalizedString()); - buf.append("\n\n").append(LocalizedStrings.MailManager_EXCEPTION_MESSAGE_0.toLocalizedString(ex.getMessage())); - buf.append("\n\n").append(LocalizedStrings.MailManager_FOLLOWING_EMAIL_WAS_NOT_DELIVERED.toLocalizedString()); - buf.append("\n\t").append(LocalizedStrings.MailManager_MAIL_HOST_0.toLocalizedString(mailHost)); - buf.append("\n\t").append(LocalizedStrings.MailManager_FROM_0.toLocalizedString(mailFrom)); - buf.append("\n\t").append(LocalizedStrings.MailManager_TO_0.toLocalizedString(mailToList)); - buf.append("\n\t").append(LocalizedStrings.MailManager_SUBJECT_0.toLocalizedString(subject)); - buf.append("\n\t").append(LocalizedStrings.MailManager_CONTENT_0.toLocalizedString(message)); - - logger.error(buf.toString(), ex); - } - if (logger.isTraceEnabled()) { - logger.trace("Exited MailManager:processEmail"); - } - } - - /** - * Not yet implemented - */ - public void close() { - } - - /** - * @return All the registered email id as string - */ - private String getMailToAddressesAsString() { - StringBuffer mailToList = new StringBuffer(); - for (int i = 0; i < mailToAddresses.length; i++) { - mailToList.append(mailToAddresses[i]); - mailToList.append(", "); - } - return mailToList.toString(); - } - - /** - * - * @return Properties consisting mailHost and mailFrom property - */ - private Properties getMailHostConfiguration() { - Properties result = new Properties(); - if (mailHost == null) { - mailHost = ""; - } - if (mailFrom == null) { - mailFrom = ""; - } - result.setProperty("mail.host", mailHost); - result.put("mail.from", mailFrom); - return result; - } - - /** - * - * @param host - * mail host server name - */ - public void setMailHost(String host) { - this.mailHost = host; - } - - /** - * - * @return mail host server name - */ - public String getMailHost() { - return this.mailHost; - } - - /** - * - * @param fromAddress - * mailFrom email id - */ - public void setMailFromAddress(String fromAddress) { - mailFrom = fromAddress; - } - - /** - * - * @return mailFrom email id - */ - public String getMailFromAddress() { - return mailFrom; - } - - /** - * add new mail id to ToList - */ - public void addMailToAddress(String toAddress) { - mailToSet.add(toAddress); - mailToAddresses = getAllToAddresses(); - } - - /** - * remove given mail id from ToList - */ - public void removeMailToAddress(String toAddress) { - mailToSet.remove(toAddress); - mailToAddresses = getAllToAddresses(); - } - - /** - * @return list all the registered email id - */ - public String[] getAllToAddresses() { - return (String[])mailToSet.toArray(new String[0]); - } - - /** - * remove all the registered email ids from ToList - */ - public void removeAllMailToAddresses() { - mailToSet.clear(); - mailToAddresses = new String[0]; - } - - /** - * Set the mail properties, e.g mail host, mailFrom, MailTo etc - */ - public void setMailProperties(Properties mailProperties) { - mailHost = mailProperties.getProperty(PROPERTY_MAIL_HOST); - mailFrom = mailProperties.getProperty(PROPERTY_MAIL_FROM); - String mailList = mailProperties.getProperty(PROPERTY_MAIL_TO_LIST, ""); - String split[] = mailList.split(","); - removeAllMailToAddresses(); - for (int i = 0; i < split.length; i++) { - addMailToAddress(split[i].trim()); - } - } - - @Override - public String toString() { - StringBuffer buffer = new StringBuffer(200); - buffer.append("[Mail Host: "); - buffer.append(getMailHost()); - buffer.append("]"); - buffer.append(" [Mail From: "); - buffer.append(getMailFromAddress()); - buffer.append("]"); - buffer.append(" [Mail To: "); - if (mailToAddresses.length > 0) { - - for (int i = 0; i < mailToAddresses.length; i++) { - buffer.append(mailToAddresses[i]); - buffer.append(", "); - } - buffer.replace(buffer.length() - 2, buffer.length(), ""); - } - else { - buffer.append(" Undefined"); - } - buffer.append("]"); - return buffer.toString(); - } - - private HashSet mailToSet = new HashSet(); - - private String mailToAddresses[] = new String[0]; - - protected String mailHost; - - protected String mailFrom; - - public final static String PROPERTY_MAIL_HOST = "mail.host"; - - public final static String PROPERTY_MAIL_FROM = "mail.from"; - - public final static String PROPERTY_MAIL_TO_LIST = "mail.toList"; - - /** - * Incorporating subject and message of email - * - * - */ - static private class EmailData { - String subject; - - String message; - - EmailData(String subject, String message) { - this.subject = subject; - this.message = message; - } - } - - public static void main(String args[]) { - MailManager mailManager = new MailManager("mailsrv1.gemstone.com", - "hkha...@gemstone.com"); - mailManager.sendEmail("Alert!", "Test"); - } -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/ManagedResource.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/ManagedResource.java b/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/ManagedResource.java deleted file mode 100755 index 2496013..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/ManagedResource.java +++ /dev/null @@ -1,77 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin.jmx.internal; - -import javax.management.ObjectName; -import javax.management.modelmbean.ModelMBean; - -/** - * Represents a component or resource that is managed by a - * {@link javax.management.modelmbean.ModelMBean}. - * - * @since GemFire 3.5 - * - */ -public interface ManagedResource { - - /** - * The prefix of MBean names. Note: this is NOT used by Members, Stats, or - * any other MBean that has it's own domain. - * - * @see #getMBeanName - */ - public static final String MBEAN_NAME_PREFIX = "GemFire:type="; - - /** - * Returns the name of the ModelMBean that will manage this - * resource. They [some] are of the form - * - * <PRE> - * MBEAN_NAME_PREFIX + typeName + ",id=" + id - * </PRE> - * - * @see #MBEAN_NAME_PREFIX - */ - public String getMBeanName(); - - /** Returns the ModelMBean that is configured to manage this resource */ - public ModelMBean getModelMBean(); - - /** Sets the ModelMBean that is configured to manage this resource */ - public void setModelMBean(ModelMBean modelMBean); - - /** - * Returns the enumerated ManagedResourceType of this resource. - * - * @see ManagedResourceType - */ - public ManagedResourceType getManagedResourceType(); - - /** - * Returns the JMX <code>ObjectName</code> of this managed resource. - * - * @see #getMBeanName - */ - public ObjectName getObjectName(); - - /** - * Perform any cleanup necessary before stopping management of this resource. - */ - public void cleanupResource(); - -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/ManagedResourceType.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/ManagedResourceType.java b/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/ManagedResourceType.java deleted file mode 100755 index cf9b792..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/ManagedResourceType.java +++ /dev/null @@ -1,209 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin.jmx.internal; - -import org.apache.commons.lang.StringUtils; - -/** - * Type-safe definition for ModelMBean managed resources. The class type - * ({@link #getClassTypeName}) must match the fully qualified class name listed - * in the type descriptor in mbeans-descriptors.xml. - * - * @since GemFire 3.5 - * - */ -public class ManagedResourceType implements java.io.Serializable { - private static final long serialVersionUID = 3752874768667480449L; - - /** Agent managed resource type */ - public static final ManagedResourceType AGENT = - new ManagedResourceType("Agent", org.apache.geode.admin.jmx.Agent.class); - - /** DistributedSystem managed resource type */ - public static final ManagedResourceType DISTRIBUTED_SYSTEM = - new ManagedResourceType("AdminDistributedSystem", org.apache.geode.admin.AdminDistributedSystem.class); - - /** SystemMember managed resource type */ - public static final ManagedResourceType SYSTEM_MEMBER = - new ManagedResourceType("SystemMember", org.apache.geode.admin.SystemMember.class); - - /** SystemMemberCache managed resource type */ - public static final ManagedResourceType SYSTEM_MEMBER_CACHE = - new ManagedResourceType("SystemMemberCache", org.apache.geode.admin.SystemMemberCache.class); - - /** SystemMemberCache managed resource type */ - public static final ManagedResourceType SYSTEM_MEMBER_REGION = - new ManagedResourceType("SystemMemberRegion", org.apache.geode.admin.SystemMemberRegion.class); - - /** SystemMemberCacheServer managed resource type */ - public static final ManagedResourceType SYSTEM_MEMBER_CACHE_SERVER = - new ManagedResourceType("SystemMemberCacheServer", org.apache.geode.admin.SystemMemberCacheServer.class); - - /** CacheVm managed resource type */ - public static final ManagedResourceType CACHE_VM = - new ManagedResourceType("CacheVm", org.apache.geode.admin.CacheVm.class); - - /** StatisticResource managed resource type */ - public static final ManagedResourceType STATISTIC_RESOURCE = - new ManagedResourceType("StatisticResource", org.apache.geode.admin.StatisticResource.class); - - public static final ManagedResourceType GEMFIRE_HEALTH = - new ManagedResourceType("GemFireHealth", org.apache.geode.admin.GemFireHealth.class); - - public static final ManagedResourceType DISTRIBUTED_SYSTEM_HEALTH_CONFIG = - new ManagedResourceType("DistributedSystemHealthConfig", org.apache.geode.admin.DistributedSystemHealthConfig.class); - - public static final ManagedResourceType GEMFIRE_HEALTH_CONFIG = - new ManagedResourceType("GemFireHealthConfig", org.apache.geode.admin.GemFireHealthConfig.class); - - public static final ManagedResourceType DISTRIBUTION_LOCATOR = - new ManagedResourceType("DistributionLocator", org.apache.geode.admin.DistributionLocator.class); - - //////////////////// Instance Fields //////////////////// - - /** The display-friendly name of this managed resource type. */ - private final transient String name; - - /** - * The interface/class used to externally represent this type. Note: this must - * match the mbean type descriptor in mbeans-descriptors.xml. - */ - private final transient Class clazz; - - // The 4 declarations below are necessary for serialization - /** int used as ordinal to represent this Scope */ - public final int ordinal = nextOrdinal++; - - private static int nextOrdinal = 0; - - private static final ManagedResourceType[] VALUES = - { AGENT, DISTRIBUTED_SYSTEM, SYSTEM_MEMBER, - SYSTEM_MEMBER_CACHE, SYSTEM_MEMBER_REGION, - SYSTEM_MEMBER_CACHE_SERVER, CACHE_VM, - STATISTIC_RESOURCE, GEMFIRE_HEALTH, DISTRIBUTED_SYSTEM_HEALTH_CONFIG, - GEMFIRE_HEALTH_CONFIG, DISTRIBUTION_LOCATOR - }; - - private Object readResolve() throws java.io.ObjectStreamException { - return VALUES[ordinal]; // Canonicalize - } - - /** Creates a new instance of ManagedResourceType. */ - private ManagedResourceType(String name, Class clazz) { - this.name = name; - this.clazz = clazz; - } - - /** Returns the ManagedResourceType represented by specified ordinal */ - public static ManagedResourceType fromOrdinal(int ordinal) { - return VALUES[ordinal]; - } - - /** Returns the display-friendly name of this managed resource type */ - public String getName() { - return this.name; - } - - /** Returns the interface/class used to externally represent this type */ - public Class getClassType() { - return this.clazz; - } - - /** - * Returns the fully qualified name of the interface/class used to externally - * represent this type - */ - public String getClassTypeName() { - return this.clazz.getName(); - } - - /** Returns true if this is <code>AGENT</code>. */ - public boolean isAgent() { - return this.equals(AGENT); - } - - /** Returns true if this is <code>DISTRIBUTED_SYSTEM</code>. */ - public boolean isDistributedSystem() { - return this.equals(DISTRIBUTED_SYSTEM); - } - - /** Returns true if this is <code>SYSTEM_MEMBER</code>. */ - public boolean isSystemMember() { - return this.equals(SYSTEM_MEMBER); - } - - /** Returns whether this is <code>STATISTIC_RESOURCE</code>. */ - public boolean isStatisticResource() { - return this.equals(STATISTIC_RESOURCE); - } - - /** Return whether this is <code>GEMFIRE_HEALTH</code>. */ - public boolean isGemFireHealth() { - return this.equals(GEMFIRE_HEALTH); - } - - /** - * Returns a string representation for this type. - */ - @Override - public String toString() { - return this.name; - } - - /** - * Indicates whether some other object is "equal to" this one. - * - * @param other the reference object with which to compare. - * @return true if this object is the same as the obj argument; - * false otherwise. - */ - @Override - public boolean equals(Object other) { - if (other == this) return true; - if (other == null) return false; - if (!(other instanceof ManagedResourceType)) return false; - final ManagedResourceType that = (ManagedResourceType) other; - - if (!StringUtils.equals(this.name, that.name)) return false; - if (this.clazz != that.clazz && - !(this.clazz != null && - this.clazz.equals(that.clazz))) return false; - - return true; - } - - /** - * Returns a hash code for the object. This method is supported for the - * benefit of hashtables such as those provided by java.util.Hashtable. - * - * @return the integer 0 if description is null; otherwise a unique integer. - */ - @Override - public int hashCode() { - int result = 17; - final int mult = 37; - - result = mult * result + - (this.name == null ? 0 : this.name.hashCode()); - result = mult * result + - (this.clazz == null ? 0 : this.clazz.hashCode()); - - return result; - } - -} -