Repository: geode Updated Branches: refs/heads/feature/GEODE-2632-17 [created] fd84df29b
http://git-wip-us.apache.org/repos/asf/geode/blob/24ea6e67/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientProxy.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientProxy.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientProxy.java index 75c89ab..8450db9 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientProxy.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientProxy.java @@ -1951,7 +1951,7 @@ public class CacheClientProxy implements ClientSession { // Close the proxy terminateDispatching(false); - _cacheClientNotifier._statistics.incQueueDroppedCount(); + _cacheClientNotifier.statistics.incQueueDroppedCount(); /** * Setting the expiration task to null again and cancelling existing one, if any. See @@ -2850,7 +2850,7 @@ public class CacheClientProxy implements ClientSession { try { this._messageQueue.put(clientMessage); if (this._proxy.isPaused() && this._proxy.isDurable()) { - this._proxy._cacheClientNotifier._statistics.incEventEnqueuedWhileClientAwayCount(); + this._proxy._cacheClientNotifier.statistics.incEventEnqueuedWhileClientAwayCount(); if (logger.isDebugEnabled()) { logger.debug("{}: Queued message while Durable Client is away {}", this, clientMessage); }