Fix spelling typos
Updates occurrences `establised` to `established`
@@ -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();
