/*
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation. Oracle designates this
* particular file as subject to the "Classpath" exception as provided
* by Oracle in the LICENSE file that accompanied this code.
*
* This code is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
* version 2 for more details (a copy is included in the LICENSE file that
* accompanied this code).
*
* You should have received a copy of the GNU General Public License version
* 2 along with this work; if not, write to the Free Software Foundation,
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
*
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
* or visit www.oracle.com if you need additional information or have any
* questions.
*/
package javax.management;
/**
* <p>Provides an implementation of {@link
* javax.management.NotificationEmitter NotificationEmitter}
* interface. This can be used as the super class of an MBean that
* sends notifications.</p>
*
* <p>By default, the notification dispatch model is synchronous.
* That is, when a thread calls sendNotification, the
* <code>NotificationListener.handleNotification</code> method of each listener
* is called within that thread. You can override this default
* by overriding <code>handleNotification</code> in a subclass, or by passing an
* Executor to the constructor.</p>
*
* <p>If the method call of a filter or listener throws an {@link Exception},
* then that exception does not prevent other listeners from being invoked. However,
* if the method call of a filter or of {@code Executor.execute} or of
* {@code handleNotification} (when no {@code Excecutor} is specified) throws an
* {@link Error}, then that {@code Error} is propagated to the caller of
* {@link #sendNotification sendNotification}.</p>
*
* <p>Remote listeners added using the JMX Remote API (see JMXConnector) are not
* usually called synchronously. That is, when sendNotification returns, it is
* not guaranteed that any remote listeners have yet received the notification.</p>
*
* @since 1.5
*/
/**
* Constructs a NotificationBroadcasterSupport where each listener is invoked by the
* thread sending the notification. This constructor is equivalent to
* {@link NotificationBroadcasterSupport#NotificationBroadcasterSupport(Executor,
* MBeanNotificationInfo[] info) NotificationBroadcasterSupport(null, null)}.
*/
public NotificationBroadcasterSupport() {
}
/**
* Constructs a NotificationBroadcasterSupport where each listener is invoked using
* the given {@link java.util.concurrent.Executor}. When {@link #sendNotification
* sendNotification} is called, a listener is selected if it was added with a null
* {@link NotificationFilter}, or if {@link NotificationFilter#isNotificationEnabled
* isNotificationEnabled} returns true for the notification being sent. The call to
* <code>NotificationFilter.isNotificationEnabled</code> takes place in the thread
* that called <code>sendNotification</code>. Then, for each selected listener,
* {@link Executor#execute executor.execute} is called with a command
* that calls the <code>handleNotification</code> method.
* This constructor is equivalent to
* {@link NotificationBroadcasterSupport#NotificationBroadcasterSupport(Executor,
* MBeanNotificationInfo[] info) NotificationBroadcasterSupport(executor, null)}.
* @param executor an executor used by the method <code>sendNotification</code> to
* send each notification. If it is null, the thread calling <code>sendNotification</code>
* will invoke the <code>handleNotification</code> method itself.
* @since 1.6
*/
}
/**
* <p>Constructs a NotificationBroadcasterSupport with information
* about the notifications that may be sent. Each listener is
* invoked by the thread sending the notification. This
* constructor is equivalent to {@link
* NotificationBroadcasterSupport#NotificationBroadcasterSupport(Executor,
* MBeanNotificationInfo[] info)
* NotificationBroadcasterSupport(null, info)}.</p>
*
* <p>If the <code>info</code> array is not empty, then it is
* cloned by the constructor as if by {@code info.clone()}, and
* each call to {@link #getNotificationInfo()} returns a new
* clone.</p>
*
* @param info an array indicating, for each notification this
* MBean may send, the name of the Java class of the notification
* and the notification type. Can be null, which is equivalent to
* an empty array.
*
* @since 1.6
*/
}
/**
* <p>Constructs a NotificationBroadcasterSupport with information about the notifications that may be sent,
* and where each listener is invoked using the given {@link java.util.concurrent.Executor}.</p>
*
* <p>When {@link #sendNotification sendNotification} is called, a
* listener is selected if it was added with a null {@link
* NotificationFilter}, or if {@link
* NotificationFilter#isNotificationEnabled isNotificationEnabled}
* returns true for the notification being sent. The call to
* <code>NotificationFilter.isNotificationEnabled</code> takes
* place in the thread that called
* <code>sendNotification</code>. Then, for each selected
* listener, {@link Executor#execute executor.execute} is called
* with a command that calls the <code>handleNotification</code>
* method.</p>
*
* <p>If the <code>info</code> array is not empty, then it is
* cloned by the constructor as if by {@code info.clone()}, and
* each call to {@link #getNotificationInfo()} returns a new
* clone.</p>
*
* @param executor an executor used by the method
* <code>sendNotification</code> to send each notification. If it
* is null, the thread calling <code>sendNotification</code> will
* invoke the <code>handleNotification</code> method itself.
*
* @param info an array indicating, for each notification this
* MBean may send, the name of the Java class of the notification
* and the notification type. Can be null, which is equivalent to
* an empty array.
*
* @since 1.6
*/
MBeanNotificationInfo... info) {
}
/**
* Adds a listener.
*
* @param listener The listener to receive notifications.
* @param filter The filter object. If filter is null, no
* filtering will be performed before handling notifications.
* @param handback An opaque object to be sent back to the
* listener when a notification is emitted. This object cannot be
* used by the Notification broadcaster object. It should be
* resent unchanged with the notification to the listener.
*
* @exception IllegalArgumentException thrown if the listener is null.
*
* @see #removeNotificationListener
*/
throw new IllegalArgumentException ("Listener can't be null") ;
}
}
throws ListenerNotFoundException {
boolean removed =
if (!removed)
throw new ListenerNotFoundException("Listener not registered");
}
throws ListenerNotFoundException {
if (!removed) {
throw new ListenerNotFoundException("Listener not registered " +
"(with this filter and " +
"handback)");
// or perhaps not registered at all
}
}
return notifInfo;
else
}
/**
* Sends a notification.
*
* If an {@code Executor} was specified in the constructor, it will be given one
* task per selected listener to deliver the notification to that listener.
*
* @param notification The notification to send.
*/
if (notification == null) {
return;
}
boolean enabled;
try {
} catch (Exception e) {
}
continue;
}
if (enabled) {
}
}
}
/**
* <p>This method is called by {@link #sendNotification
* sendNotification} for each listener in order to send the
* notification to that listener. It can be overridden in
* subclasses to change the behavior of notification delivery,
* for instance to deliver the notification in a separate
* thread.</p>
*
* <p>The default implementation of this method is equivalent to
* <pre>
* listener.handleNotification(notif, handback);
* </pre>
*
* @param listener the listener to which the notification is being
* delivered.
* @param notif the notification being delivered to the listener.
* @param handback the handback object that was supplied when the
* listener was added.
*
*/
}
// private stuff
private static class ListenerInfo {
}
if (!(o instanceof ListenerInfo))
return false;
if (li instanceof WildcardListenerInfo)
else
}
}
}
assert (!(o instanceof WildcardListenerInfo));
return o.equals(this);
}
}
new CopyOnWriteArrayList<ListenerInfo>();
// since 1.6
// DirectExecutor using caller thread
r.run();
}
};
new MBeanNotificationInfo[0];
this.listenerInfo = listenerInfo;
}
public void run() {
try {
} catch (Exception e) {
}
}
}
}
}