EventBusBridgeImpl should use EventBus send or reply when no reply handler is specified
@@ -480,9 +480,17 @@ public class EventBusBridgeImpl implements Handler<SockJSSocket> {
}
if (send) {
if (awaitingReply != null) {
+ if (replyAddress != null) {
awaitingReply.replyAndRequest(body, new DeliveryOptions().setSendTimeout(replyTimeout).setHeaders(mHeaders), replyHandler);
} else {
+ awaitingReply.reply(body, new DeliveryOptions().setSendTimeout(replyTimeout).setHeaders(mHeaders));
+ }
+ } else {
+ if (replyAddress != null) {
eb.request(address, body, new DeliveryOptions().setSendTimeout(replyTimeout).setHeaders(mHeaders), replyHandler);
+ } else {
+ eb.send(address, body, new DeliveryOptions().setSendTimeout(replyTimeout).setHeaders(mHeaders));
+ }
}
if (replyAddress != null) {
info.handlerCount++;
