Package org.cometd.server.ext
Class BinarySessionExtension
- java.lang.Object
-
- org.cometd.server.ext.BinarySessionExtension
-
- All Implemented Interfaces:
ServerSession.Extension
public class BinarySessionExtension extends Object implements ServerSession.Extension
An extension that encodes/decodes binary data for a
ServerSession
.- See Also:
BinaryExtension
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.cometd.bayeux.server.ServerSession.Extension
ServerSession.Extension.Adapter
-
-
Constructor Summary
Constructors Constructor Description BinarySessionExtension(BayeuxServer bayeuxServer)
BinarySessionExtension(BayeuxServer bayeuxServer, boolean decodeToByteBuffer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
rcv(ServerSession session, ServerMessage.Mutable message)
Blocking version ofServerSession.Extension.incoming(ServerSession, ServerMessage.Mutable, Promise)
for non-meta messages.ServerMessage
send(ServerSession session, ServerMessage message)
Blocking version ofServerSession.Extension.outgoing(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 interfaceServerSession.Extension
- Parameters:
session
- the session that sent the messagemessage
- the incoming message- Returns:
- whether message processing should continue
-
send
public ServerMessage send(ServerSession session, ServerMessage message)
Description copied from interface:ServerSession.Extension
Blocking version of
ServerSession.Extension.outgoing(ServerSession, ServerMessage.Mutable, Promise)
for non-meta messages.- Specified by:
send
in interfaceServerSession.Extension
- Parameters:
session
- the session receiving the messagemessage
- the outgoing message- Returns:
- the message to send or null to not send the message
-
-