aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java
diff options
context:
space:
mode:
Diffstat (limited to 'messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java')
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java
index 0b731a4c6fb..204bf2f7906 100644
--- a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java
+++ b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java
@@ -186,7 +186,7 @@ public final class SourceSession implements ReplyHandler, MessageBus.SendBlocked
if (msg.isExpired()) {
Error error = new Error(ErrorCode.TIMEOUT, "Timed out in sendQ");
notifyComplete(new Result(error));
- replyHandler.handleReply(createSendTimedoutReply(msg, error));
+ replyHandler.handleReply(createSendTimedOutReply(msg, error));
return true;
}
return false;
@@ -214,7 +214,7 @@ public final class SourceSession implements ReplyHandler, MessageBus.SendBlocked
}
}
- private Reply createSendTimedoutReply(Message msg, Error error) {
+ private Reply createSendTimedOutReply(Message msg, Error error) {
Reply reply = new EmptyReply();
reply.setMessage(msg);
reply.addError(error);