|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.jeremie.libs.binding.echannel.EventChannelFactory
The EventChannelFactory service allows the construction of EventChannels providing best-effort unreliable and unordered event dissemination. It relies on the RTP protocol on top of IP multicast.
Constructor Summary | |
EventChannelFactory(ChunkFactory chunk_factory,
MarshallerFactory marshaller_factory)
|
Method Summary | |
void |
bindConsumer(java.lang.Object consumer,
EBinder.EId id)
Binds a consumer object to the event channel represented by the given identifier. |
Identifier |
decode(byte[] data,
int offset,
int length)
Decode an indentifier 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. |
EventChannel |
newEventChannel(java.lang.String address,
int port,
java.lang.String type)
Constructs and returns a new EventChannel |
java.lang.Object |
newStub(SessionIdentifier ep,
Identifier[] ids,
org.objectweb.jonathan.apis.kernel.Context hints)
Builds a new stub adapted for one-way event generation |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public EventChannelFactory(ChunkFactory chunk_factory, MarshallerFactory marshaller_factory)
Method 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 java.lang.Object newStub(SessionIdentifier ep, Identifier[] ids, org.objectweb.jonathan.apis.kernel.Context hints) throws org.objectweb.jonathan.apis.kernel.JonathanException
newStub
in interface StubFactory
ep
- the protocol SessionIdentifier of the event channelids
- the set of indentifiers for the stubshints
- a String containing the type of the EventChannel
org.objectweb.jonathan.apis.kernel.JonathanException
- if something goes wrongpublic EventChannel newEventChannel(java.lang.String address, int port, java.lang.String type) throws org.objectweb.jonathan.apis.kernel.JonathanException
address
- the IP multicast address to useport
- the port number to usetype
- the type of the EventChannel
org.objectweb.jonathan.apis.kernel.JonathanException
- thrown if something goes wrongpublic void bindConsumer(java.lang.Object consumer, EBinder.EId id) throws org.objectweb.jonathan.apis.kernel.JonathanException
consumer
- the consumer object to add to the channelid
- the identifier of the EventChannel
org.objectweb.jonathan.apis.kernel.JonathanException
- thrown if something goes wrongpublic 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.
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |