From 1fd2cc4fab4e4b2c739dc4685970d6100aaff27c Mon Sep 17 00:00:00 2001 From: Stephen Asbury Date: Wed, 19 Sep 2018 14:00:46 -0700 Subject: [PATCH] Fixed typo in method name --- src/main/java/io/nats/client/impl/NatsConnection.java | 2 +- src/main/java/io/nats/client/impl/NatsConnectionWriter.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/io/nats/client/impl/NatsConnection.java b/src/main/java/io/nats/client/impl/NatsConnection.java index 7ebca6404..55b06b8b8 100644 --- 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 index 511065d41..3a60f8b81 100644 --- 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 {