Methods in org.codehaus.wadi.group with parameters of type Address |
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. |
Peer |
Cluster.getPeerFromAddress(Address address)
|
java.lang.String |
Dispatcher.getPeerName(Address address)
|
void |
Dispatcher.reply(Address from,
Address to,
java.lang.String sourceCorrelationId,
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 |
Envelope.setAddress(Address address)
|
void |
Envelope.setReplyTo(Address replyTo)
|
Methods in org.codehaus.wadi.group.impl with parameters of type Address |
protected abstract void |
AbstractDispatcher.doSend(Address target,
Envelope envelope)
|
Envelope |
AbstractDispatcher.exchangeSend(Address target,
Envelope envelope,
long timeout)
|
Envelope |
AbstractDispatcher.exchangeSend(Address target,
Envelope envelope,
long timeout,
java.lang.String targetCorrelationId)
|
Envelope |
AbstractDispatcher.exchangeSend(Address to,
java.io.Serializable body,
long timeout)
|
Envelope |
AbstractDispatcher.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 |
AbstractDispatcher.send(Address source,
Address target,
Quipu quipu,
java.io.Serializable pojo)
|
void |
AbstractDispatcher.send(Address target,
Envelope envelope)
|
void |
AbstractDispatcher.send(Address target,
Quipu quipu,
java.io.Serializable pojo)
|
void |
AbstractDispatcher.send(Address to,
java.io.Serializable body)
|