[incubator-pulsar] branch master updated: Fix spelling typos (#1998)

[sijie]

This is an automated email from the ASF dual-hosted git repository.

sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new c69003d  Fix spelling typos (#1998)
c69003d is described below

commit c69003dce6908d0567c08a444ca9e98e6b829216
Author: Adam Williams <pwnfact...@gmail.com>
AuthorDate: Wed Jun 20 09:12:59 2018 -0600

    Fix spelling typos (#1998)
    
    Updates occurrences `establised` to `established`
---
 .../src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java
index 10fe6ff..dc98dc2 100644
--- 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java
+++ 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java
@@ -1117,7 +1117,7 @@ public class ConsumerImpl<T> extends ConsumerBase<T> 
implements ConnectionHandle
             return;
         }
         if (cnx == null || (getState() == State.Connecting)) {
-            log.warn("[{}] Client Connection needs to be establised for 
redelivery of unacknowledged messages", this);
+            log.warn("[{}] Client Connection needs to be established for 
redelivery of unacknowledged messages", this);
         } else {
             log.warn("[{}] Reconnecting the client to redeliver the 
messages.", this);
             cnx.ctx().close();
@@ -1164,7 +1164,7 @@ public class ConsumerImpl<T> extends ConsumerBase<T> 
implements ConnectionHandle
             return;
         }
         if (cnx == null || (getState() == State.Connecting)) {
-            log.warn("[{}] Client Connection needs to be establised for 
redelivery of unacknowledged messages", this);
+            log.warn("[{}] Client Connection needs to be established for 
redelivery of unacknowledged messages", this);
         } else {
             log.warn("[{}] Reconnecting the client to redeliver the 
messages.", this);
             cnx.ctx().close();