Package org.apache.cassandra.streaming.management

Class StreamEventJMXNotifier

java.lang.Object

javax.management.NotificationBroadcasterSupport

org.apache.cassandra.streaming.management.StreamEventJMXNotifier

All Implemented Interfaces:

com.google.common.util.concurrent.FutureCallback<StreamState>, NotificationBroadcaster, NotificationEmitter, StreamEventHandler

public class StreamEventJMXNotifier
extends NotificationBroadcasterSupport
implements StreamEventHandler

Constructor Summary

Constructors

Constructor	Description
StreamEventJMXNotifier()

Method Summary

Modifier and Type	Method	Description
void	handleStreamEvent(StreamEvent event)	Callback for various streaming events.
void	onFailure(Throwable t)
void	onSuccess(StreamState result)

Methods inherited from class javax.management.NotificationBroadcasterSupport

addNotificationListener, getNotificationInfo, handleNotification, removeNotificationListener, removeNotificationListener, sendNotification

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

StreamEventJMXNotifier

public StreamEventJMXNotifier()

Method Details

handleStreamEvent

public void handleStreamEvent(StreamEvent event)

Description copied from interface: StreamEventHandler

Callback for various streaming events.

Specified by:

handleStreamEvent in interface StreamEventHandler

Parameters:

event - Stream event.

See Also:

• StreamEvent.Type

onSuccess

public void onSuccess(StreamState result)

Specified by:

onSuccess in interface com.google.common.util.concurrent.FutureCallback<StreamState>

onFailure

public void onFailure(Throwable t)

Specified by:

onFailure in interface com.google.common.util.concurrent.FutureCallback<StreamState>