Methods in org.codehaus.wadi.group that return Envelope |
Envelope |
Dispatcher.attemptRendezVous(Quipu rv,
long timeout)
|
Envelope |
Dispatcher.createEnvelope()
|
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. |
Envelope |
NoOpEnvelopeInterceptor.onInboundEnvelope(Envelope envelope)
|
Envelope |
EnvelopeInterceptor.onInboundEnvelope(Envelope envelope)
|
Envelope |
NoOpEnvelopeInterceptor.onOutboundEnvelope(Envelope envelope)
|
Envelope |
EnvelopeInterceptor.onOutboundEnvelope(Envelope envelope)
|
Methods in org.codehaus.wadi.group.impl that return Envelope |
Envelope |
AbstractDispatcher.attemptRendezVous(Quipu rv,
long timeout)
|
Envelope |
SharedDispatcher.attemptRendezVous(Quipu rv,
long timeout)
|
Envelope |
SharedDispatcher.createEnvelope()
|
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)
|
protected Envelope |
AbstractDispatcher.onInboundEnvelope(Envelope envelope)
|
Envelope |
EnvelopeLogger.onInboundEnvelope(Envelope envelope)
|
protected Envelope |
AbstractDispatcher.onOutboundEnvelope(Envelope envelope)
|
Envelope |
EnvelopeLogger.onOutboundEnvelope(Envelope envelope)
|
Methods in org.codehaus.wadi.group.impl with parameters of type Envelope |
void |
AbstractDispatcher.addRendezVousEnvelope(Envelope envelope)
|
void |
SharedDispatcher.addRendezVousEnvelope(Envelope envelope)
|
protected void |
AbstractDispatcher.doOnEnvelope(Envelope envelope)
|
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)
|
static boolean |
EnvelopeHelper.isReply(Envelope envelope)
|
void |
AbstractDispatcher.onEnvelope(Envelope envelope)
|
void |
SharedDispatcher.onEnvelope(Envelope message)
|
protected Envelope |
AbstractDispatcher.onInboundEnvelope(Envelope envelope)
|
Envelope |
EnvelopeLogger.onInboundEnvelope(Envelope envelope)
|
protected Envelope |
AbstractDispatcher.onOutboundEnvelope(Envelope envelope)
|
Envelope |
EnvelopeLogger.onOutboundEnvelope(Envelope envelope)
|
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 target,
Envelope envelope)
|
void |
SharedDispatcher.send(Address target,
Envelope envelope)
|
static void |
EnvelopeHelper.setAsReply(Envelope envelope)
|
boolean |
AbstractMsgDispatcher.testDispatchEnvelope(Envelope envelope)
|