Methods in org.codehaus.wadi.group that throw MessageExchangeException |
java.util.Collection |
Dispatcher.attemptMultiRendezVous(Quipu rv,
long timeout)
|
Envelope |
Dispatcher.attemptRendezVous(Quipu rv,
long timeout)
|
Envelope |
Dispatcher.exchangeSend(Address target,
Envelope envelope,
long timeout)
|
Envelope |
Dispatcher.exchangeSend(Address target,
Envelope envelope,
long timeout,
java.lang.String targetCorrelationId)
|
Envelope |
Dispatcher.exchangeSend(Address target,
java.io.Serializable pojo,
long timeout)
Send a Serializable 'pojo' to 'target' Address - sync - and wait for a
reply. |
Envelope |
Dispatcher.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. |
void |
Dispatcher.reply(Address from,
Address to,
java.lang.String sourceCorrelationId,
java.io.Serializable body)
|
void |
Dispatcher.reply(Envelope request,
Envelope reply)
|
void |
Dispatcher.reply(Envelope request,
java.io.Serializable body)
|
void |
Dispatcher.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 |
Dispatcher.send(Address target,
Envelope envelope)
Send a ready-made Message to the Peer at the 'target' Address. |
void |
Dispatcher.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 |
Dispatcher.send(Address target,
java.io.Serializable pojo)
send a Serializable pojo to an Address - async - no reply expected |
void |
Dispatcher.start()
|
void |
Dispatcher.stop()
|
Methods in org.codehaus.wadi.group.impl that throw MessageExchangeException |
java.util.Collection |
AbstractDispatcher.attemptMultiRendezVous(Quipu rv,
long timeout)
|
java.util.Collection |
SharedDispatcher.attemptMultiRendezVous(Quipu rv,
long timeout)
|
Envelope |
AbstractDispatcher.attemptRendezVous(Quipu rv,
long timeout)
|
Envelope |
SharedDispatcher.attemptRendezVous(Quipu rv,
long timeout)
|
protected abstract void |
AbstractDispatcher.doSend(Address target,
Envelope envelope)
|
Envelope |
AbstractDispatcher.exchangeSend(Address target,
Envelope envelope,
long timeout)
|
Envelope |
SharedDispatcher.exchangeSend(Address target,
Envelope envelope,
long timeout)
|
Envelope |
AbstractDispatcher.exchangeSend(Address target,
Envelope envelope,
long timeout,
java.lang.String targetCorrelationId)
|
Envelope |
SharedDispatcher.exchangeSend(Address target,
Envelope envelope,
long timeout,
java.lang.String targetCorrelationId)
|
Envelope |
AbstractDispatcher.exchangeSend(Address to,
java.io.Serializable body,
long timeout)
|
Envelope |
SharedDispatcher.exchangeSend(Address target,
java.io.Serializable pojo,
long timeout)
|
Envelope |
AbstractDispatcher.exchangeSend(Address target,
java.io.Serializable pojo,
long timeout,
java.lang.String targetCorrelationId)
|
Envelope |
SharedDispatcher.exchangeSend(Address target,
java.io.Serializable pojo,
long timeout,
java.lang.String targetCorrelationId)
|
void |
AbstractDispatcher.reply(Address from,
Address to,
java.lang.String incomingCorrelationId,
java.io.Serializable body)
|
void |
SharedDispatcher.reply(Address from,
Address to,
java.lang.String sourceCorrelationId,
java.io.Serializable body)
|
void |
AbstractDispatcher.reply(Envelope request,
Envelope reply)
|
void |
SharedDispatcher.reply(Envelope request,
Envelope reply)
|
void |
AbstractDispatcher.reply(Envelope envelope,
java.io.Serializable body)
|
void |
SharedDispatcher.reply(Envelope envelope,
java.io.Serializable body)
|
void |
AbstractDispatcher.send(Address source,
Address target,
Quipu quipu,
java.io.Serializable pojo)
|
void |
SharedDispatcher.send(Address source,
Address target,
Quipu quipu,
java.io.Serializable pojo)
|
void |
AbstractDispatcher.send(Address target,
Envelope envelope)
|
void |
SharedDispatcher.send(Address target,
Envelope envelope)
|
void |
AbstractDispatcher.send(Address target,
Quipu quipu,
java.io.Serializable pojo)
|
void |
SharedDispatcher.send(Address target,
Quipu quipu,
java.io.Serializable pojo)
|
void |
AbstractDispatcher.send(Address to,
java.io.Serializable body)
|
void |
SharedDispatcher.send(Address target,
java.io.Serializable pojo)
|
void |
SharedDispatcher.start()
|
void |
SharedDispatcher.stop()
|