jlengrand/vert.x
1
0
Fork 0
mirror of https://github.com/jlengrand/vert.x.git synced 2026-03-10 08:51:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove unecessary method param

Browse Source
This commit is contained in:
Julien Viet
2019-10-18 14:17:57 +02:00
parent c6dd46d10c
commit deadcc1f93
2 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/io/vertx/core/eventbus/impl/EventBusImpl.java
View File

@@ -310,8 +310,7 @@ public class EventBusImpl implements EventBus, MetricsProvider {
return last;
}
protected <T> void sendReply(MessageImpl replyMessage, MessageImpl replierMessage, DeliveryOptions options,
ReplyHandler<T> replyHandler) {
protected <T> void sendReply(MessageImpl replyMessage, DeliveryOptions options, ReplyHandler<T> replyHandler) {
if (replyMessage.address() == null) {
throw new IllegalStateException("address not specified");
} else {

4
src/main/java/io/vertx/core/eventbus/impl/MessageImpl.java
View File

@@ -110,7 +110,7 @@ public class MessageImpl<U, V> implements Message<V> {
public void reply(Object message, DeliveryOptions options) {
if (replyAddress != null) {
MessageImpl reply = createReply(message, options);
bus.sendReply(reply, this, options, null);
bus.sendReply(reply, options, null);
}
}
@@ -119,7 +119,7 @@ public class MessageImpl<U, V> implements Message<V> {
if (replyAddress != null) {
MessageImpl reply = createReply(message, options);
EventBusImpl.ReplyHandler<R> handler = bus.createReplyHandler(reply, reply.src, options);
bus.sendReply(reply, this, options, handler);
bus.sendReply(reply, options, handler);
return handler.result.future();
} else {
throw new IllegalStateException();