diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-20 23:29:33 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-21 02:49:28 +0200 |
commit | 662f4a01c3fb28a8e5211b53da7668af2c7ca126 (patch) | |
tree | 832bac5ac5c5bf32b41fbde24dfd22b48e79d1bc /jdisc_messagebus_service/src/main/java | |
parent | 6a086a21ad64926ae1d7f494bcbcecabe1a84b23 (diff) |
Send in own thread
Diffstat (limited to 'jdisc_messagebus_service/src/main/java')
-rw-r--r-- | jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/jdisc/MbusClient.java | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/jdisc/MbusClient.java b/jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/jdisc/MbusClient.java index 76ddddebe4e..4bd78813cba 100644 --- a/jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/jdisc/MbusClient.java +++ b/jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/jdisc/MbusClient.java @@ -36,7 +36,7 @@ public final class MbusClient extends AbstractResource implements ClientProvider private final ResourceReference sessionReference; @Inject - public MbusClient(final ClientSession session) { + public MbusClient(ClientSession session) { this.session = session; this.sessionReference = session.refer(); } @@ -47,7 +47,7 @@ public final class MbusClient extends AbstractResource implements ClientProvider } @Override - public ContentChannel handleRequest(final Request request, final ResponseHandler handler) { + public ContentChannel handleRequest(Request request, ResponseHandler handler) { if (!(request instanceof MbusRequest)) { throw new RequestDeniedException(request); } @@ -61,12 +61,12 @@ public final class MbusClient extends AbstractResource implements ClientProvider } msg.setContext(handler); msg.pushHandler(this); - queue.add((MbusRequest)request); + sendBlocking((MbusRequest)request); return null; } @Override - public void handleTimeout(final Request request, final ResponseHandler handler) { + public void handleTimeout(Request request, final ResponseHandler handler) { // ignore, mbus has guaranteed reply } @@ -90,17 +90,17 @@ public final class MbusClient extends AbstractResource implements ClientProvider } } - private void sendBlocking(final MbusRequest request) { + private void sendBlocking(MbusRequest request) { while (!sendMessage(request)) { try { - Thread.sleep(100); + Thread.sleep(5); } catch (final InterruptedException e) { // ignore } } } - private boolean sendMessage(final MbusRequest request) { + private boolean sendMessage(MbusRequest request) { Error error; final Long millis = request.timeRemaining(TimeUnit.MILLISECONDS); if (millis != null && millis <= 0) { |