java类javax.management.NotificationBroadcaster的实例源码-第2页-面圈网

MBeanIntrospector.java 文件源码项目：OLD-OpenJDK8 阅读 22 收藏 0 点赞 0 评论 0

static MBeanNotificationInfo[] findNotifications(Object moi) {
    if (!(moi instanceof NotificationBroadcaster))
        return null;
    MBeanNotificationInfo[] mbn =
            ((NotificationBroadcaster) moi).getNotificationInfo();
    if (mbn == null)
        return null;
    MBeanNotificationInfo[] result =
            new MBeanNotificationInfo[mbn.length];
    for (int i = 0; i < mbn.length; i++) {
        MBeanNotificationInfo ni = mbn[i];
        if (ni.getClass() != MBeanNotificationInfo.class)
            ni = (MBeanNotificationInfo) ni.clone();
        result[i] = ni;
    }
    return result;
}

DefaultMBeanServerInterceptor.java 文件源码项目：openjdk-jdk7u-jdk 阅读 18 收藏 0 点赞 0 评论 0

private static <T extends NotificationBroadcaster>
        T getNotificationBroadcaster(ObjectName name, Object instance,
                                     Class<T> reqClass) {
    if (reqClass.isInstance(instance))
        return reqClass.cast(instance);
    if (instance instanceof DynamicMBean2)
        instance = ((DynamicMBean2) instance).getResource();
    if (reqClass.isInstance(instance))
        return reqClass.cast(instance);
    final RuntimeException exc =
        new IllegalArgumentException(name.getCanonicalName());
    final String msg =
        "MBean " + name.getCanonicalName() + " does not " +
        "implement " + reqClass.getName();
    throw new RuntimeOperationsException(exc, msg);
}

StandardMBeanIntrospector.java 文件源码项目：openjdk-jdk7u-jdk 阅读 29 收藏 0 点赞 0 评论 0

static boolean isDefinitelyImmutableInfo(Class<?> implClass) {
    if (!NotificationBroadcaster.class.isAssignableFrom(implClass))
        return true;
    synchronized (definitelyImmutable) {
        Boolean immutable = definitelyImmutable.get(implClass);
        if (immutable == null) {
            final Class<NotificationBroadcasterSupport> nbs =
                    NotificationBroadcasterSupport.class;
            if (nbs.isAssignableFrom(implClass)) {
                try {
                    Method m = implClass.getMethod("getNotificationInfo");
                    immutable = (m.getDeclaringClass() == nbs);
                } catch (Exception e) {
                    // Too bad, we'll say no for now.
                    return false;
                }
            } else
                immutable = false;
            definitelyImmutable.put(implClass, immutable);
        }
        return immutable;
    }
}

MBeanIntrospector.java 文件源码项目：openjdk-jdk7u-jdk 阅读 27 收藏 0 点赞 0 评论 0

static MBeanNotificationInfo[] findNotifications(Object moi) {
    if (!(moi instanceof NotificationBroadcaster))
        return null;
    MBeanNotificationInfo[] mbn =
            ((NotificationBroadcaster) moi).getNotificationInfo();
    if (mbn == null)
        return null;
    MBeanNotificationInfo[] result =
            new MBeanNotificationInfo[mbn.length];
    for (int i = 0; i < mbn.length; i++) {
        MBeanNotificationInfo ni = mbn[i];
        if (ni.getClass() != MBeanNotificationInfo.class)
            ni = (MBeanNotificationInfo) ni.clone();
        result[i] = ni;
    }
    return result;
}

DefaultMBeanServerInterceptor.java 文件源码项目：openjdk-icedtea7 阅读 25 收藏 0 点赞 0 评论 0

private static <T extends NotificationBroadcaster>
        T getNotificationBroadcaster(ObjectName name, Object instance,
                                     Class<T> reqClass) {
    if (reqClass.isInstance(instance))
        return reqClass.cast(instance);
    if (instance instanceof DynamicMBean2)
        instance = ((DynamicMBean2) instance).getResource();
    if (reqClass.isInstance(instance))
        return reqClass.cast(instance);
    final RuntimeException exc =
        new IllegalArgumentException(name.getCanonicalName());
    final String msg =
        "MBean " + name.getCanonicalName() + " does not " +
        "implement " + reqClass.getName();
    throw new RuntimeOperationsException(exc, msg);
}

StandardMBeanIntrospector.java 文件源码项目：openjdk-icedtea7 阅读 33 收藏 0 点赞 0 评论 0

static boolean isDefinitelyImmutableInfo(Class<?> implClass) {
    if (!NotificationBroadcaster.class.isAssignableFrom(implClass))
        return true;
    synchronized (definitelyImmutable) {
        Boolean immutable = definitelyImmutable.get(implClass);
        if (immutable == null) {
            final Class<NotificationBroadcasterSupport> nbs =
                    NotificationBroadcasterSupport.class;
            if (nbs.isAssignableFrom(implClass)) {
                try {
                    Method m = implClass.getMethod("getNotificationInfo");
                    immutable = (m.getDeclaringClass() == nbs);
                } catch (Exception e) {
                    // Too bad, we'll say no for now.
                    return false;
                }
            } else
                immutable = false;
            definitelyImmutable.put(implClass, immutable);
        }
        return immutable;
    }
}

MBeanIntrospector.java 文件源码项目：openjdk-icedtea7 阅读 17 收藏 0 点赞 0 评论 0

static MBeanNotificationInfo[] findNotifications(Object moi) {
    if (!(moi instanceof NotificationBroadcaster))
        return null;
    MBeanNotificationInfo[] mbn =
            ((NotificationBroadcaster) moi).getNotificationInfo();
    if (mbn == null)
        return null;
    MBeanNotificationInfo[] result =
            new MBeanNotificationInfo[mbn.length];
    for (int i = 0; i < mbn.length; i++) {
        MBeanNotificationInfo ni = mbn[i];
        if (ni.getClass() != MBeanNotificationInfo.class)
            ni = (MBeanNotificationInfo) ni.clone();
        result[i] = ni;
    }
    return result;
}

DefaultMBeanServerInterceptor.java 文件源码项目：OpenJSharp 阅读 21 收藏 0 点赞 0 评论 0

public void addNotificationListener(ObjectName name,
                                    NotificationListener listener,
                                    NotificationFilter filter,
                                    Object handback)
        throws InstanceNotFoundException {

    // ------------------------------
    // ------------------------------
    if (MBEANSERVER_LOGGER.isLoggable(Level.FINER)) {
        MBEANSERVER_LOGGER.logp(Level.FINER,
                DefaultMBeanServerInterceptor.class.getName(),
                "addNotificationListener", "ObjectName = " + name);
    }

    DynamicMBean instance = getMBean(name);
    checkMBeanPermission(instance, null, name, "addNotificationListener");

    NotificationBroadcaster broadcaster =
            getNotificationBroadcaster(name, instance,
                                       NotificationBroadcaster.class);

    // ------------------
    // Check listener
    // ------------------
    if (listener == null) {
        throw new RuntimeOperationsException(new
            IllegalArgumentException("Null listener"),"Null listener");
    }

    NotificationListener listenerWrapper =
        getListenerWrapper(listener, name, instance, true);
    broadcaster.addNotificationListener(listenerWrapper, filter, handback);
}

DefaultMBeanServerInterceptor.java 文件源码项目：jdk8u-jdk 阅读 19 收藏 0 点赞 0 评论 0

public void addNotificationListener(ObjectName name,
                                    NotificationListener listener,
                                    NotificationFilter filter,
                                    Object handback)
        throws InstanceNotFoundException {

    // ------------------------------
    // ------------------------------
    if (MBEANSERVER_LOGGER.isLoggable(Level.FINER)) {
        MBEANSERVER_LOGGER.logp(Level.FINER,
                DefaultMBeanServerInterceptor.class.getName(),
                "addNotificationListener", "ObjectName = " + name);
    }

    DynamicMBean instance = getMBean(name);
    checkMBeanPermission(instance, null, name, "addNotificationListener");

    NotificationBroadcaster broadcaster =
            getNotificationBroadcaster(name, instance,
                                       NotificationBroadcaster.class);

    // ------------------
    // Check listener
    // ------------------
    if (listener == null) {
        throw new RuntimeOperationsException(new
            IllegalArgumentException("Null listener"),"Null listener");
    }

    NotificationListener listenerWrapper =
        getListenerWrapper(listener, name, instance, true);
    broadcaster.addNotificationListener(listenerWrapper, filter, handback);
}

OldMBeanServerTest.java 文件源码项目：jdk8u-jdk 阅读 16 收藏 0 点赞 0 评论 0

public void addNotificationListener(
        ObjectName name, NotificationListener listener,
        NotificationFilter filter, Object handback)
        throws InstanceNotFoundException {
    NotificationBroadcaster userMBean =
            (NotificationBroadcaster) getUserMBean(name);
    NotificationListener wrappedListener =
          wrappedListener(name, userMBean, listener);
    userMBean.addNotificationListener(wrappedListener, filter, handback);
}