Package org.cometd.server.ext

Class BinaryExtension

java.lang.Object

org.cometd.server.ext.BinaryExtension

All Implemented Interfaces:

BayeuxServer.Extension

public class BinaryExtension
extends Object
implements BayeuxServer.Extension

A server 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.

See Also:

• BinarySessionExtension

Constructor Summary

Constructors

Constructor	Description
BinaryExtension()
BinaryExtension(boolean decodeToByteBuffer)

Method Summary

Modifier and Type	Method	Description
boolean	rcv(ServerSession from, ServerMessage.Mutable message)	Blocking version of BayeuxServer.Extension.incoming(ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.
boolean	send(ServerSession from, ServerSession to, ServerMessage.Mutable message)	Blocking version of BayeuxServer.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.BayeuxServer.Extension

incoming, outgoing, rcvMeta, sendMeta

Constructor Details

BinaryExtension

public BinaryExtension()

BinaryExtension

public BinaryExtension(boolean decodeToByteBuffer)

Method Details

rcv

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

Description copied from interface: BayeuxServer.Extension

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

Specified by:

rcv in interface BayeuxServer.Extension

Parameters:

from - the session that sent the message

message - the incoming message

Returns:

whether message processing should continue

send

public boolean send(ServerSession from,
 ServerSession to,
 ServerMessage.Mutable message)

Description copied from interface: BayeuxServer.Extension

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

Specified by:

send in interface BayeuxServer.Extension

Parameters:

from - the session that sent the message or null

to - the session the message is sent to, or null for a publish.

message - the outgoing message

Returns:

whether message processing should continue