net.officefloor.plugin.bayeux

Class BayeuxServerImpl

java.lang.Object

net.officefloor.plugin.bayeux.BayeuxServerImpl

All Implemented Interfaces:

TransportBayeuxServer

public class BayeuxServerImpl
extends Object
implements TransportBayeuxServer

BayeuxServer implementation.

Author:

Daniel Sagenschneider

Constructor Summary

Constructors

Constructor and Description
BayeuxServerImpl() Default constructor.
BayeuxServerImpl(SessionIdentifierGenerator sessionIdentifierGenerator) Configurable initiation.

Method Summary

Modifier and Type	Method and Description
TransportServerSession	addSession(String clientId, org.cometd.bayeux.server.ServerMessage handshakeMessage) Adds a new ServerSession.
void	connect(TransportMessage message, TransportCallback<? super ConnectResult> callback) Undertakes connect.
TransportMessage.TransportMutable	createMessage() Creates the TransportMessage.TransportMutable.
void	disconnect(TransportMessage message, TransportCallback<? super DisconnectResult> callback) Undertakes disconnect.
org.cometd.bayeux.server.BayeuxServer	getBayeuxServer() Obtains the BayeuxServer.
void	handshake(TransportMessage message, TransportCallback<? super HandshakeResult> callback) Undertakes handshake.
void	publish(TransportMessage message, TransportCallback<? super PublishResult> callback) Undertakes publish.
void	subscribe(TransportMessage message, TransportCallback<? super SubscribeResult> callback) Undertakes subscribe.
void	unsubscribe(TransportMessage message, TransportCallback<? super UnsubscribeResult> callback) Undertakes unsubscribe.

Methods inherited from class java.lang.Object

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

Constructor Detail

BayeuxServerImpl

public BayeuxServerImpl()

Default constructor.

BayeuxServerImpl

public BayeuxServerImpl(SessionIdentifierGenerator sessionIdentifierGenerator)

Configurable initiation.

Parameters:

sessionIdentifierGenerator - SessionIdentifierGenerator. May be null to use default.

Method Detail

addSession

public TransportServerSession addSession(String clientId,
                                         org.cometd.bayeux.server.ServerMessage handshakeMessage)

Adds a new ServerSession.

Parameters:

clientId - Identifier for the ServerSession.

handshakeMessage - Handshake ServerMessage.

Returns:

TransportServerSession for the ServerSession or null if not allowed to create the ServerSession.

getBayeuxServer

public org.cometd.bayeux.server.BayeuxServer getBayeuxServer()

Description copied from interface: TransportBayeuxServer

Obtains the BayeuxServer.

Specified by:

getBayeuxServer in interface TransportBayeuxServer

Returns:

BayeuxServer.

createMessage

public TransportMessage.TransportMutable createMessage()

Description copied from interface: TransportBayeuxServer

Creates the TransportMessage.TransportMutable.

Specified by:

createMessage in interface TransportBayeuxServer

Returns:

TransportMessage.TransportMutable.

handshake

public void handshake(TransportMessage message,
                      TransportCallback<? super HandshakeResult> callback)

Description copied from interface: TransportBayeuxServer

Undertakes handshake.

Specified by:

handshake in interface TransportBayeuxServer

Parameters:

message - Handshake TransportMessage.

callback - TransportCallback to notify of HandshakeResult .

connect

public void connect(TransportMessage message,
                    TransportCallback<? super ConnectResult> callback)

Description copied from interface: TransportBayeuxServer

Undertakes connect.

Specified by:

connect in interface TransportBayeuxServer

Parameters:

message - Connect TransportMessage.

callback - TransportCallback to notify of ConnectResult.

disconnect

public void disconnect(TransportMessage message,
                       TransportCallback<? super DisconnectResult> callback)

Description copied from interface: TransportBayeuxServer

Undertakes disconnect.

Specified by:

disconnect in interface TransportBayeuxServer

Parameters:

message - Disconnect TransportMessage.

callback - TransportCallback to notify of DisconnectResult.

subscribe

public void subscribe(TransportMessage message,
                      TransportCallback<? super SubscribeResult> callback)

Description copied from interface: TransportBayeuxServer

Undertakes subscribe.

Specified by:

subscribe in interface TransportBayeuxServer

Parameters:

message - Subscribe TransportMessage.

callback - TransportCallback to notify of SubscribeResult .

unsubscribe

public void unsubscribe(TransportMessage message,
                        TransportCallback<? super UnsubscribeResult> callback)

Description copied from interface: TransportBayeuxServer

Undertakes unsubscribe.

Specified by:

unsubscribe in interface TransportBayeuxServer

Parameters:

message - Unsubscribe TransportMessage.

callback - TransportCallback to notify of UnsubscribeResult.

publish

public void publish(TransportMessage message,
                    TransportCallback<? super PublishResult> callback)

Description copied from interface: TransportBayeuxServer

Undertakes publish.

Specified by:

publish in interface TransportBayeuxServer

Parameters:

message - Publish TransportMessage.

callback - TransportCallback to notify of PublishResult.