mirror of https://github.com/renaissanceorg/dante
Compare commits
4 Commits
88b36b5e1e
...
8f8917c55e
Author | SHA1 | Date |
---|---|---|
Tristan B. Velloza Kildaire | 8f8917c55e | |
Tristan B. Velloza Kildaire | e410dbf8e1 | |
Tristan B. Velloza Kildaire | 6d5444d7ac | |
Tristan B. Velloza Kildaire | de631bab52 |
2
dub.json
2
dub.json
|
@ -4,7 +4,7 @@
|
||||||
],
|
],
|
||||||
"copyright": "Tristan B. Kildaire",
|
"copyright": "Tristan B. Kildaire",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"davinci": ">=0.1.7",
|
"davinci": "~master",
|
||||||
"gogga": ">=2.1.18",
|
"gogga": ">=2.1.18",
|
||||||
"guillotine": ">=0.2.1-alpha",
|
"guillotine": ">=0.2.1-alpha",
|
||||||
"river": ">=0.3.7",
|
"river": ">=0.3.7",
|
||||||
|
|
|
@ -100,6 +100,9 @@ public class DanteClient
|
||||||
NopMessage testMessage = new NopMessage();
|
NopMessage testMessage = new NopMessage();
|
||||||
testMessage.setTestField("Lekker Boetie");
|
testMessage.setTestField("Lekker Boetie");
|
||||||
|
|
||||||
|
import std.stdio;
|
||||||
|
writeln(testMessage.getEncoded());
|
||||||
|
|
||||||
BaseMessage msg = new BaseMessage(MessageType.CLIENT_TO_SERVER, CommandType.NOP_COMMAND, testMessage);
|
BaseMessage msg = new BaseMessage(MessageType.CLIENT_TO_SERVER, CommandType.NOP_COMMAND, testMessage);
|
||||||
|
|
||||||
return makeRequest(msg);
|
return makeRequest(msg);
|
||||||
|
@ -142,9 +145,13 @@ public class DanteClient
|
||||||
*/
|
*/
|
||||||
private Future makeRequest(BaseMessage request, Queue responseQueue, bool releaseAfterUse = false)
|
private Future makeRequest(BaseMessage request, Queue responseQueue, bool releaseAfterUse = false)
|
||||||
{
|
{
|
||||||
|
byte[] encoded = request.encode();
|
||||||
|
|
||||||
|
// BUG: If you tried encoding INSIDE of the delegate/closure then runtime probelm with msgpack
|
||||||
|
// ... hence I encode outside and then refer to it inside. TELL MSGPACK people about this!
|
||||||
BaseMessage doRequest()
|
BaseMessage doRequest()
|
||||||
{
|
{
|
||||||
TaggedMessage message = new TaggedMessage(responseQueue.getID(), request.encode());
|
TaggedMessage message = new TaggedMessage(responseQueue.getID(), encoded);
|
||||||
this.manager.sendMessage(message);
|
this.manager.sendMessage(message);
|
||||||
|
|
||||||
TaggedMessage response = responseQueue.dequeue();
|
TaggedMessage response = responseQueue.dequeue();
|
||||||
|
|
Loading…
Reference in New Issue