From 088b5c13af5a91b46dbf324830cb030342810f6c Mon Sep 17 00:00:00 2001 From: heck Date: Thu, 20 May 2021 19:22:19 +0200 Subject: [PATCH] Test: Update JNI-153 --- .../pEp/jniadapter/test/jni153/TestAlice.java | 11 ++++++----- .../pEp/jniadapter/test/jni153/TestBob.java | 6 ++++-- 2 files changed, 10 insertions(+), 7 deletions(-) diff --git a/test/java/foundation/pEp/jniadapter/test/jni153/TestAlice.java b/test/java/foundation/pEp/jniadapter/test/jni153/TestAlice.java index ae7f378..b3d8735 100644 --- a/test/java/foundation/pEp/jniadapter/test/jni153/TestAlice.java +++ b/test/java/foundation/pEp/jniadapter/test/jni153/TestAlice.java @@ -23,14 +23,15 @@ class TestAlice { log(AdapterTestUtils.identityToString(ctx.myself.pEpIdent, true)); ctx.transport.start(); - - ctx.transport.sendAsync(AdapterTestUtils.newOutMessage(ctx.myself.pEpIdent, ctx.partner.pEpIdent, "UNIQUE_" + String.valueOf(0))); + Message outMsg = AdapterTestUtils.newOutMessage(ctx.myself.pEpIdent, ctx.partner.pEpIdent, "UNIQUE_" + String.valueOf(0)); + ctx.transport.sendAsync(outMsg.encodeMIME(), ctx.partner); int counter = 0; - +// TestUtils.readKey(); while (true) { while (ctx.transport.canReceiveAsync()) { - ctx.transport.sendAsync(AdapterTestUtils.newOutMessage(ctx.myself.pEpIdent, ctx.partner.pEpIdent, "UNIQUE_" + String.valueOf(counter))); - Message msg = ctx.transport.receiveAsyncNonBlocking(); + outMsg = AdapterTestUtils.newOutMessage(ctx.myself.pEpIdent, ctx.partner.pEpIdent, "UNIQUE_" + String.valueOf(counter)); + ctx.transport.sendAsync(outMsg.encodeMIME(), ctx.partner); + Message msg = new Message(ctx.transport.receiveAsyncNonBlocking()); counter++; } } diff --git a/test/java/foundation/pEp/jniadapter/test/jni153/TestBob.java b/test/java/foundation/pEp/jniadapter/test/jni153/TestBob.java index 773f2fc..5cf9b3a 100644 --- a/test/java/foundation/pEp/jniadapter/test/jni153/TestBob.java +++ b/test/java/foundation/pEp/jniadapter/test/jni153/TestBob.java @@ -32,9 +32,11 @@ class TestBob { while (true) { while (ctx.transport.canReceiveAsync()) { - Message msgRx = ctx.transport.receiveAsyncNonBlocking(); + Message msgRx = new Message(ctx.transport.receiveAsyncNonBlocking()); log(AdapterTestUtils.identityToString(msgRx.getFrom(),true)); - ctx.transport.sendAsync(AdapterTestUtils.newOutMessage(ctx.myself.pEpIdent, msgRx.getFrom(), msgRx.getLongmsg() + " - ACK")); + Message msgOut = AdapterTestUtils.newOutMessage(ctx.myself.pEpIdent, msgRx.getFrom(), msgRx.getLongmsg() + " - ACK"); +// ctx.transport.sendAsync(msgOut, ms); + ctx.transport.sendAsync(msgOut.encodeMIME(), ctx.partner); // HACK NEED TO RESOLVE FROM ADDRESS counter++; if (counter % 4 == 0) {