|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.jonathan.libs.binding.echannel.EBinder
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.
Nested Class Summary | |
class |
EBinder.EId
EId is an indentifier representing an event channel of a given type and relying on a given multicast address and port. |
Constructor Summary | |
EBinder(ChunkFactory chunk_factory,
MarshallerFactory marshaller_factory,
NamingContext context,
StubFactory stub_factory)
Builds a new EBinder instance |
Method Summary | |
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(java.lang.Object itf,
org.objectweb.jonathan.apis.kernel.Context hints)
This operation has no meaning in this context: an InternalException is always thrown. |
EBinder.EId |
newId(java.lang.String address,
int port,
java.lang.String type)
Builds a new identifier representing an event channel of a given type and relying on a givent multicast address and port |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public EBinder(ChunkFactory chunk_factory, MarshallerFactory marshaller_factory, NamingContext context, StubFactory stub_factory)
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 EBinderMethod Detail |
public Identifier export(java.lang.Object itf, org.objectweb.jonathan.apis.kernel.Context hints)
export
in interface NamingContext
itf
- hints
-
naming_context.export(org.objectweb.jonathan.model.name)
public void bindConsumer(Session_Low consumer, EBinder.EId channel) throws org.objectweb.jonathan.apis.kernel.JonathanException
consumer
- the interface of the consumer object to be added to the
event channelchannel
- the identifier representing the event channel
org.objectweb.jonathan.apis.kernel.JonathanException
- thrown if the bind operation failspublic Identifier decode(byte[] data, int offset, int length) throws org.objectweb.jonathan.apis.kernel.JonathanException
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
org.objectweb.jonathan.apis.kernel.JonathanException
- thrown if the decoding failspublic Identifier decode(UnMarshaller u) throws org.objectweb.jonathan.apis.kernel.JonathanException
decode
in interface NamingContext
u
- an unmarhaller;
org.objectweb.jonathan.apis.kernel.JonathanException
- if something goes wrong.public EBinder.EId newId(java.lang.String address, int port, java.lang.String type) throws org.objectweb.jonathan.apis.kernel.JonathanException
address
- the multicast IP address of the event channelport
- the port number of the channeltype
- the type of the channel
org.objectweb.jonathan.apis.kernel.JonathanException
- thrown if the identifier cannot be
constructed with the parameters provided
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |