|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Dispatcher
Method Summary | |
---|---|
void |
addInterceptor(EnvelopeInterceptor interceptor)
|
void |
addRendezVousEnvelope(Envelope envelope)
|
java.util.Collection |
attemptMultiRendezVous(Quipu rv,
long timeout)
|
Envelope |
attemptRendezVous(Quipu rv,
long timeout)
|
Envelope |
createEnvelope()
|
Envelope |
exchangeSend(Address target,
Envelope envelope,
long timeout)
|
Envelope |
exchangeSend(Address target,
Envelope envelope,
long timeout,
java.lang.String targetCorrelationId)
|
Envelope |
exchangeSend(Address target,
java.io.Serializable pojo,
long timeout)
Send a Serializable 'pojo' to 'target' Address - sync - and wait for a reply. |
Envelope |
exchangeSend(Address target,
java.io.Serializable pojo,
long timeout,
java.lang.String targetCorrelationId)
Send a Serializable 'pojo' to a 'target' Address - sync - and wait for a reply. |
Cluster |
getCluster()
|
DispatcherContext |
getContext()
|
java.util.List<EnvelopeInterceptor> |
getInterceptors()
|
java.lang.String |
getPeerName(Address address)
|
Quipu |
newRendezVous(int numLlamas)
|
void |
register(ServiceEndpoint internalDispatcher)
|
void |
removeInterceptor(EnvelopeInterceptor interceptor)
|
void |
reply(Address from,
Address to,
java.lang.String sourceCorrelationId,
java.io.Serializable body)
|
void |
reply(Envelope request,
Envelope reply)
|
void |
reply(Envelope request,
java.io.Serializable body)
|
void |
send(Address source,
Address target,
Quipu quipu,
java.io.Serializable pojo)
send a Serializable 'pojo' to a 'target' Address, with the Message's replyTo field containing the 'source' Address - async - although we are expecting a reply, which will be matched with the sourceCorrelationId. |
void |
send(Address target,
Envelope envelope)
Send a ready-made Message to the Peer at the 'target' Address. |
void |
send(Address target,
Quipu quipu,
java.io.Serializable pojo)
send a Serializable 'pojo' to a 'target' Address, with the Message's replyTo field containing the local cluster Address - async - although we are expecting a reply, which will be matched with the sourceCorrelationId. |
void |
send(Address target,
java.io.Serializable pojo)
send a Serializable pojo to an Address - async - no reply expected |
void |
start()
|
void |
stop()
|
void |
unregister(ServiceEndpoint internalDispatcher,
int nbAttemp,
long delayMillis)
|
Methods inherited from interface org.codehaus.wadi.group.EnvelopeListener |
---|
onEnvelope |
Method Detail |
---|
void addInterceptor(EnvelopeInterceptor interceptor)
void removeInterceptor(EnvelopeInterceptor interceptor)
java.util.List<EnvelopeInterceptor> getInterceptors()
void register(ServiceEndpoint internalDispatcher)
void unregister(ServiceEndpoint internalDispatcher, int nbAttemp, long delayMillis)
void send(Address target, Envelope envelope) throws MessageExchangeException
target
- The Address of the Peer to which the Message should be sentenvelope
- The Message itself
MessageExchangeException
void send(Address target, java.io.Serializable pojo) throws MessageExchangeException
target
- The Address to which we are sending the Messagepojo
- The Object that we want to send inside it
MessageExchangeException
void send(Address target, Quipu quipu, java.io.Serializable pojo) throws MessageExchangeException
target
- The Address of the Peer to which this message is to be sentquipu
- The quipu which will be used to match a response on
the source Peerpojo
- The object to be sent in the Message
MessageExchangeException
void send(Address source, Address target, Quipu quipu, java.io.Serializable pojo) throws MessageExchangeException
source
- The Address of the Peer to which the reply should be senttarget
- The Address of the Peer to which this message is to be sentquipu
- The correlationId which will be used to match a response on
the source Peerpojo
- The object to be sent in the Message
MessageExchangeException
Envelope exchangeSend(Address target, java.io.Serializable pojo, long timeout) throws MessageExchangeException
target
- The address to which we are sending the Messagepojo
- The object that we want to send inside ittimeout
- The length of time that we are willing to wait for a reply
MessageExchangeException
Envelope exchangeSend(Address target, java.io.Serializable pojo, long timeout, java.lang.String targetCorrelationId) throws MessageExchangeException
target
- The address to which we are sending the messagetargetCorrelationId
- Explicitly identifies the message to which we wish to replypojo
- The object that we wish to sendtimeout
- The length of time that we are willing to wait for a reply
MessageExchangeException
Envelope exchangeSend(Address target, Envelope envelope, long timeout) throws MessageExchangeException
MessageExchangeException
Envelope exchangeSend(Address target, Envelope envelope, long timeout, java.lang.String targetCorrelationId) throws MessageExchangeException
MessageExchangeException
void reply(Address from, Address to, java.lang.String sourceCorrelationId, java.io.Serializable body) throws MessageExchangeException
MessageExchangeException
void reply(Envelope request, java.io.Serializable body) throws MessageExchangeException
MessageExchangeException
void reply(Envelope request, Envelope reply) throws MessageExchangeException
MessageExchangeException
void addRendezVousEnvelope(Envelope envelope)
Quipu newRendezVous(int numLlamas)
Envelope attemptRendezVous(Quipu rv, long timeout) throws MessageExchangeException
MessageExchangeException
java.util.Collection attemptMultiRendezVous(Quipu rv, long timeout) throws MessageExchangeException
MessageExchangeException
void start() throws MessageExchangeException
MessageExchangeException
void stop() throws MessageExchangeException
MessageExchangeException
Envelope createEnvelope()
Cluster getCluster()
java.lang.String getPeerName(Address address)
DispatcherContext getContext()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |