Package org.cometd.client.ext
Class BinaryExtension
java.lang.Object
org.cometd.bayeux.client.ClientSession.Extension.Adapter
org.cometd.client.ext.BinaryExtension
- All Implemented Interfaces:
ClientSession.Extension
public class BinaryExtension extends ClientSession.Extension.Adapter
A client extension that encodes byte[] or ByteBuffer into a BinaryData
object using the Z85 format for outgoing messages, and decodes BinaryData
objects back into byte[] or ByteBuffer for incoming messages.
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.cometd.bayeux.client.ClientSession.Extension
ClientSession.Extension.Adapter -
Constructor Summary
Constructors Constructor Description BinaryExtension()BinaryExtension(boolean decodeToByteBuffer) -
Method Summary
Modifier and Type Method Description booleanrcv(ClientSession session, Message.Mutable message)Callback method invoked every time a normal message is received.booleansend(ClientSession session, Message.Mutable message)Callback method invoked every time a normal message is being sent.Methods inherited from class org.cometd.bayeux.client.ClientSession.Extension.Adapter
rcvMeta, sendMeta
-
Constructor Details
-
BinaryExtension
public BinaryExtension() -
BinaryExtension
public BinaryExtension(boolean decodeToByteBuffer)
-
-
Method Details
-
rcv
Description copied from interface:ClientSession.ExtensionCallback method invoked every time a normal message is received.- Specified by:
rcvin interfaceClientSession.Extension- Overrides:
rcvin classClientSession.Extension.Adapter- Parameters:
session- the session object that is receiving the messagemessage- the message received- Returns:
- true if message processing should continue, false if it should stop
-
send
Description copied from interface:ClientSession.ExtensionCallback method invoked every time a normal message is being sent.- Specified by:
sendin interfaceClientSession.Extension- Overrides:
sendin classClientSession.Extension.Adapter- Parameters:
session- the session object that is sending the messagemessage- the message being sent- Returns:
- true if message processing should continue, false if it should stop
-