This is an automated email from the ASF dual-hosted git repository. toulmean pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-tuweni.git
commit 5e27e67f68a3c234088c22acfa827386b7094e7f Author: Antoine Toulme <[email protected]> AuthorDate: Fri May 31 16:55:37 2019 -0700 run sending a message into a worker thread, not the event loop thread --- .../java/org/apache/tuweni/plumtree/vertx/VertxGossipServer.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/plumtree/src/main/java/org/apache/tuweni/plumtree/vertx/VertxGossipServer.java b/plumtree/src/main/java/org/apache/tuweni/plumtree/vertx/VertxGossipServer.java index 5d8e75a..09afd6f 100644 --- a/plumtree/src/main/java/org/apache/tuweni/plumtree/vertx/VertxGossipServer.java +++ b/plumtree/src/main/java/org/apache/tuweni/plumtree/vertx/VertxGossipServer.java @@ -157,7 +157,7 @@ public final class VertxGossipServer { completion.completeExceptionally(res.cause()); } else { state = new State(peerRepository, messageHashing, (verb, attributes, peer, hash, payload) -> { - vertx.runOnContext(handler -> { + vertx.executeBlocking(future -> { Message message = new Message(); message.verb = verb; message.attributes = attributes; @@ -165,9 +165,12 @@ public final class VertxGossipServer { message.payload = payload == null ? null : payload.toHexString(); try { ((SocketPeer) peer).socket().write(Buffer.buffer(mapper.writeValueAsBytes(message))); + future.complete(); } catch (JsonProcessingException e) { - throw new RuntimeException(e); + future.fail(e); } + + }, done -> { }); }, payloadListener, payloadValidator, peerPruningFunction, graftDelay, lazyQueueInterval); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
