mirror of https://github.com/renaissanceorg/dante
Client
- `nopRequest()` now registers a tristanable queue, then creates a delegate which sends the message and waits on said queue, we submit this delegate to the guillotine executor
This commit is contained in:
parent
8fecd9409b
commit
00646cb9ee
|
@ -89,7 +89,22 @@ public class DanteClient
|
|||
// TODO: Encode message
|
||||
// TODO: Send with tristanable
|
||||
// TODO: Wrap a tristanable `dequeue()` in a FutureTask via guillotine and return that
|
||||
Queue uniqueQueue = this.manager.getUniqueQueue();
|
||||
|
||||
|
||||
BaseMessage doRequest()
|
||||
{
|
||||
TaggedMessage message = new TaggedMessage(uniqueQueue.getID(), msg.encode());
|
||||
this.manager.sendMessage(message);
|
||||
|
||||
TaggedMessage response = uniqueQueue.dequeue();
|
||||
return BaseMessage.decode(response.getPayload());
|
||||
}
|
||||
|
||||
this.executor.submitTask!(doRequest);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
unittest
|
||||
|
|
Loading…
Reference in New Issue