Package org.oddjob.websocket

Class NotifierClientEndpoint

java.lang.Object

org.oddjob.websocket.NotifierClientEndpoint

All Implemented Interfaces:

RemoteNotifier

public class NotifierClientEndpoint
extends Object
implements RemoteNotifier

Web Socket client endpoint for a Remote Notifier.

Field Summary

Fields

Modifier and Type	Field	Description
static final long	HEARTBEAT_SECONDS
static final long	TIMEOUT_SECONDS

Constructor Summary

Constructors

Constructor	Description
NotifierClientEndpoint(ScheduledExecutorService executor, com.google.gson.Gson gson)
NotifierClientEndpoint(ScheduledExecutorService executor, Clock clock, com.google.gson.Gson gson)

Method Summary

Modifier and Type	Method	Description
<T> void	addNotificationListener(long remoteId, NotificationType<T> notificationType, NotificationListener<T> notificationListener)
void	close(javax.websocket.Session session)
void	error(javax.websocket.Session session, Throwable t)
void	onMessage(javax.websocket.Session session, 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 Details

HEARTBEAT_SECONDS

public static final long HEARTBEAT_SECONDS

See Also:

• Constant Field Values

TIMEOUT_SECONDS

public static final long TIMEOUT_SECONDS

See Also:

• Constant Field Values

Constructor Details

NotifierClientEndpoint

public NotifierClientEndpoint(ScheduledExecutorService executor,
 com.google.gson.Gson gson)

NotifierClientEndpoint

public NotifierClientEndpoint(ScheduledExecutorService executor,
 Clock clock,
 com.google.gson.Gson gson)

Method Details

open

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

onMessage

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

close

public void close(javax.websocket.Session session)

error

public void error(javax.websocket.Session session,
 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