org.oddjob.websocket

Class NotifierClientEndpoint

java.lang.Object

org.oddjob.websocket.NotifierClientEndpoint

All Implemented Interfaces:

RemoteNotifier

public class NotifierClientEndpoint
extends java.lang.Object
implements RemoteNotifier

Web Socket client endpoint for a Remote Notifier.

Field Summary

Fields

Modifier and Type	Field and Description
static long	TIMEOUT_SECONDS

Constructor Summary

Constructors

Constructor and Description
NotifierClientEndpoint(java.util.concurrent.Executor executor)

Method Summary

Modifier and Type	Method and Description
<T> void	addNotificationListener(long remoteId, NotificationType<T> notificationType, NotificationListener<T> notificationListener)
void	close(javax.websocket.Session session)
void	error(javax.websocket.Session session, java.lang.Throwable t)
void	onMessage(javax.websocket.Session session, java.lang.String message)
void	open(javax.websocket.Session session, javax.websocket.EndpointConfig config)
<T> void	removeNotificationListener(long remoteId, NotificationType<T> notificationType, NotificationListener<T> notificationListener)

Methods inherited from class java.lang.Object

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

Field Detail

TIMEOUT_SECONDS

public static final long TIMEOUT_SECONDS

See Also:

Constant Field Values

Constructor Detail

NotifierClientEndpoint

public NotifierClientEndpoint(java.util.concurrent.Executor executor)

Method Detail

open

public void open(javax.websocket.Session session,
                 javax.websocket.EndpointConfig config)

onMessage

public void onMessage(javax.websocket.Session session,
                      java.lang.String message)

close

public void close(javax.websocket.Session session)

error

public void error(javax.websocket.Session session,
                  java.lang.Throwable t)

addNotificationListener

public <T> void addNotificationListener(long remoteId,
                                        NotificationType<T> notificationType,
                                        NotificationListener<T> notificationListener)
                                 throws RemoteException

Specified by:

addNotificationListener in interface RemoteNotifier

Throws:

RemoteException

removeNotificationListener

public <T> void removeNotificationListener(long remoteId,
                                           NotificationType<T> notificationType,
                                           NotificationListener<T> notificationListener)
                                    throws RemoteException

Specified by:

removeNotificationListener in interface RemoteNotifier

Throws:

RemoteException