From deadcc1f93f3c66307946829e46ffdbde7036668 Mon Sep 17 00:00:00 2001
From: Julien Viet <julien@julienviet.com>
Date: Fri, 18 Oct 2019 14:17:57 +0200
Subject: [PATCH] Remove unecessary method param

---
 src/main/java/io/vertx/core/eventbus/impl/EventBusImpl.java | 3 +--
 src/main/java/io/vertx/core/eventbus/impl/MessageImpl.java  | 4 ++--
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git a/src/main/java/io/vertx/core/eventbus/impl/EventBusImpl.java b/src/main/java/io/vertx/core/eventbus/impl/EventBusImpl.java
index 497734dfd..ff7a677f1 100644
--- a/src/main/java/io/vertx/core/eventbus/impl/EventBusImpl.java
+++ b/src/main/java/io/vertx/core/eventbus/impl/EventBusImpl.java
@@ -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 {
diff --git a/src/main/java/io/vertx/core/eventbus/impl/MessageImpl.java b/src/main/java/io/vertx/core/eventbus/impl/MessageImpl.java
index 198c94364..1de831043 100644
--- a/src/main/java/io/vertx/core/eventbus/impl/MessageImpl.java
+++ b/src/main/java/io/vertx/core/eventbus/impl/MessageImpl.java
@@ -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();