Package org.cometd.server.ext

Class BinarySessionExtension

java.lang.Object

org.cometd.server.ext.BinarySessionExtension

All Implemented Interfaces:

ServerSession.Extension

public class BinarySessionExtension
extends java.lang.Object
implements ServerSession.Extension

An extension that encodes/decodes binary data for a ServerSession.

See Also:

BinaryExtension

Constructor Summary

Constructors

Constructor	Description
BinarySessionExtension(BayeuxServer bayeuxServer)
BinarySessionExtension(BayeuxServer bayeuxServer, boolean decodeToByteBuffer)

Method Summary

Modifier and Type	Method	Description
boolean	rcv(ServerSession session, ServerMessage.Mutable message)	Blocking version of ServerSession.Extension.incoming(ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.
ServerMessage	send(ServerSession sender, ServerSession session, ServerMessage message)	Blocking version of ServerSession.Extension.outgoing(ServerSession, ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.cometd.bayeux.server.ServerSession.Extension

incoming, outgoing, rcvMeta, sendMeta

Constructor Detail

BinarySessionExtension

public BinarySessionExtension(BayeuxServer bayeuxServer)

BinarySessionExtension

public BinarySessionExtension(BayeuxServer bayeuxServer,
                              boolean decodeToByteBuffer)

Method Detail

rcv

public boolean rcv(ServerSession session,
                   ServerMessage.Mutable message)

Description copied from interface: ServerSession.Extension

Blocking version of ServerSession.Extension.incoming(ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.

Specified by:

rcv in interface ServerSession.Extension

Parameters:

session - the session that sent the message

message - the incoming message

Returns:

whether message processing should continue

send

public ServerMessage send(ServerSession sender,
                          ServerSession session,
                          ServerMessage message)

Description copied from interface: ServerSession.Extension

Blocking version of ServerSession.Extension.outgoing(ServerSession, ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.

Specified by:

send in interface ServerSession.Extension

Parameters:

sender - the session that sent the message or null

session - the session receiving the message

message - the outgoing message

Returns:

the message to send or null to not send the message