org.objectweb.jonathan.binding.echannel
Class EBinder
- NamingContext
EBinder is a binder allowing the construction of Event Channels
following a publish-subscribe interaction style.
EBinder is currently hardwired to work with the RTP protocol on top
of Multicast IP. Thus, it offers an unreliable and unordered event
disseminations service.
class | EBinder.EId - EId is an indentifier representing an event channel of a given type and
relying on a given multicast address and port.
|
void | bindConsumer(Session_Low consumer, EBinder.EId channel) - Binds a new consumer to an event channel
|
Identifier | decode(byte[] data, int offset, int length) - Decode an indentifier (an EId) representing an event channel out of the
supplied array of bytes
|
Identifier | decode(UnMarshaller u) - Decodes an identifier from the provided unmarshaller.
|
Identifier | export(Object itf, Context hints) - This operation has no meaning in this context: an InternalException is
always thrown.
|
EBinder.EId | newId(String address, int port, String type) - Builds a new identifier representing an event channel of a given type
and relying on a givent multicast address and port
|
EBinder
public EBinder(ChunkFactory chunk_factory,
MarshallerFactory marshaller_factory,
NamingContext context,
StubFactory stub_factory)
Builds a new EBinder instance
chunk_factory
- the chunk factory that the EBinder will use to
construct messagesmarshaller_factory
- the MarshallerFactory that the EBinder will use
to build messagescontext
- the NamingContext which uses this EBinderstub_factory
- the StubFactory to be used by this EBinder
bindConsumer
public void bindConsumer(Session_Low consumer,
EBinder.EId channel)
throws JonathanException
Binds a new consumer to an event channel
consumer
- the interface of the consumer object to be added to the
event channelchannel
- the identifier representing the event channel
decode
public Identifier decode(byte[] data,
int offset,
int length)
throws JonathanException
Decode an indentifier (an EId) representing an event channel out of the
supplied array of bytes
- decode in interface NamingContext
data
- the array of bytes from which to decode the identifieroffset
- the offset in bytes from which to start the decodinglength
- the length in bytes of the portion of the byte array to decode
- an identifier representing the event channel
decode
public Identifier decode(UnMarshaller u)
throws JonathanException
Decodes an identifier from the provided unmarshaller.
- decode in interface NamingContext
u
- an unmarhaller;
- an identifier managed by the target naming context;
export
public Identifier export(Object itf,
Context hints)
This operation has no meaning in this context: an InternalException is
always thrown.
- export in interface NamingContext
itf
- hints
-
- never.
newId
public EBinder.EId newId(String address,
int port,
String type)
throws JonathanException
Builds a new identifier representing an event channel of a given type
and relying on a givent multicast address and port
address
- the multicast IP address of the event channelport
- the port number of the channeltype
- the type of the channel
- an identifier representing the event channel