Fixed typo in method name

nats-io · Sep 19, 2018 · 1fd2cc4 · 1fd2cc4
1 parent f15ea35
commit 1fd2cc4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/io/nats/client/impl/NatsConnection.java b/src/main/java/io/nats/client/impl/NatsConnection.java
@@ -1113,7 +1113,7 @@ void queueInternalOutgoing(NatsMessage msg) {
         if (msg.getControlLineLength() > this.options.getMaxControlLine()) {
             throw new IllegalArgumentException("Control line is too long");
         }
-        this.writer.queueInternallMessage(msg);
+        this.writer.queueInternalMessage(msg);
     }
 
     void deliverMessage(NatsMessage msg) {

diff --git a/src/main/java/io/nats/client/impl/NatsConnectionWriter.java b/src/main/java/io/nats/client/impl/NatsConnectionWriter.java
@@ -174,7 +174,7 @@ void queue(NatsMessage msg) {
         this.outgoing.push(msg);
     }
 
-    void queueInternallMessage(NatsMessage msg) {
+    void queueInternalMessage(NatsMessage msg) {
         if (this.reconnectMode.get()) {
             this.reconnectOutgoing.push(msg);
         } else {