1 files changed, 4 insertions, 5 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java b/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
index 681082526c..48bfe74cfc 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
@@ -172,6 +172,10 @@ public class AMQProtocolHandler implements ProtocolEngine
     private long _writtenBytes;
     private long _readBytes;
 
+    private int _messageReceivedCount;
+    private int _messagesOut;
+
+
     private NetworkConnection _network;
     private Sender<ByteBuffer> _sender;
     private long _lastReadTime = System.currentTimeMillis();
@@ -451,9 +455,6 @@ public class AMQProtocolHandler implements ProtocolEngine
         _lastFailoverException = null;
     }
 
-    private static int _messageReceivedCount;
-
-
     public void received(ByteBuffer msg)
     {
         _readBytes += msg.remaining();
@@ -559,8 +560,6 @@ public class AMQProtocolHandler implements ProtocolEngine
 
     }
 
-    private static int _messagesOut;
-
     public StateWaiter createWaiter(Set<AMQState> states) throws AMQException
     {
         return getStateManager().createWaiter(states);