oracle.toplink.dataservices.livedata.sse

Class SSEClientNotifier

java.lang.Object

oracle.toplink.dataservices.livedata.sse.SSEClientNotifier

All Implemented Interfaces:

ClientNotifier

public class SSEClientNotifier
extends java.lang.Object
implements ClientNotifier

Callback clients using Server Sent Events This class has a dependency on Jersey 2's Server Sent Event implementation

Author:

tware

Constructor Summary

Constructors

Constructor and Description
SSEClientNotifier(PersistenceContext context)

Method Summary

Methods

Modifier and Type	Method and Description
void	addEventSource(org.glassfish.jersey.media.sse.EventOutput channel)
void	addSubscription(Subscription subscription)
void	close()
void	initialize()
boolean	isOpen()
void	newObject(java.lang.Object newObject)
void	removedObject(java.lang.String entityName, java.lang.Object removedObject)
void	sendMessage(java.lang.String data)
void	updatedObject(java.lang.Object updatedObject)

Methods inherited from class java.lang.Object

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

Constructor Detail

SSEClientNotifier

public SSEClientNotifier(PersistenceContext context)

Method Detail

addEventSource

public void addEventSource(org.glassfish.jersey.media.sse.EventOutput channel)

addSubscription

public void addSubscription(Subscription subscription)

close

public void close()

initialize

public void initialize()

Specified by:

initialize in interface ClientNotifier

isOpen

public boolean isOpen()

Specified by:

isOpen in interface ClientNotifier

newObject

public void newObject(java.lang.Object newObject)

Specified by:

newObject in interface ClientNotifier

removedObject

public void removedObject(java.lang.String entityName,
                 java.lang.Object removedObject)

Specified by:

removedObject in interface ClientNotifier

updatedObject

public void updatedObject(java.lang.Object updatedObject)

Specified by:

updatedObject in interface ClientNotifier

sendMessage

public void sendMessage(java.lang.String data)