org.wicketstuff.push
Class AbstractPushService

java.lang.Object
  org.wicketstuff.push.AbstractPushService

All Implemented Interfaces:

IPushService

public abstract class AbstractPushService
extends Object
implements IPushService

Author:

Sebastian Thomschke

nodesByChannels

protected final ConcurrentHashMap<IPushChannel<?>,CopyOnWriteArraySet<IPushNode<?>>> nodesByChannels

disconnectListeners

protected final Set<IPushNodeDisconnectedListener> disconnectListeners

AbstractPushService

public AbstractPushService()

addNodeDisconnectedListener

public void addNodeDisconnectedListener(IPushNodeDisconnectedListener listener)

Specified by:

addNodeDisconnectedListener in interface IPushService

connectToChannel

public <EventType> void connectToChannel(IPushNode<EventType> node,
                                         IPushChannel<EventType> channel)

Connects the given push node to the given push channel

Specified by:

connectToChannel in interface IPushService

createChannel

public <EventType> IPushChannel<EventType> createChannel(String label)

Creates a new push channel with the given label.

Specified by:

createChannel in interface IPushService

Parameters:

label - the label to associate with the new push channel. (may be null)

Note: The label has only informative purpose. Creating two push channels with the same label will not result in an error.

disconnectFromAllChannels

protected void disconnectFromAllChannels(IPushNode<?> node)

disconnectFromChannel

public <EventType> void disconnectFromChannel(IPushNode<EventType> node,
                                              IPushChannel<EventType> channel)

Specified by:

disconnectFromChannel in interface IPushService

removeChannel

public <EventType> void removeChannel(IPushChannel<EventType> channel)

Specified by:

removeChannel in interface IPushService

removeNodeDisconnectedListener

public void removeNodeDisconnectedListener(IPushNodeDisconnectedListener listener)

Specified by:

removeNodeDisconnectedListener in interface IPushService