diff options
| author | Andrew Donald Kennedy <grkvlt@apache.org> | 2010-10-03 16:02:42 +0000 |
|---|---|---|
| committer | Andrew Donald Kennedy <grkvlt@apache.org> | 2010-10-03 16:02:42 +0000 |
| commit | a3625d8ed5d7edfbd41acf38130d3f574f1c0aa5 (patch) | |
| tree | 60f8230476e27245ec190a402274f077fff0e3c4 /qpid/java/common | |
| parent | a5b1a1073e2596da8b5fbcd24769aec87107d212 (diff) | |
| download | qpid-python-a3625d8ed5d7edfbd41acf38130d3f574f1c0aa5.tar.gz | |
QPID-2839 Add channel (CHN) Operational Loggin on 0-10
Committed patch from SorinS <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1003985 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java | 2 | ||||
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java | 4 |
2 files changed, 3 insertions, 3 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java index 174dc54a72..fa3c1737a7 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java @@ -404,7 +404,7 @@ public class Connection extends ConnectionInvoker { synchronized (lock) { - for (int i = 0; i < getChannelMax(); i++) + for (int i = 1; i <= getChannelMax(); i++) { if (!channels.containsKey(i)) { diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java index 257f1e495a..eba46e9b1b 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java @@ -58,7 +58,7 @@ public class Session extends SessionInvoker private static final Logger log = Logger.get(Session.class); - enum State { NEW, DETACHED, RESUMING, OPEN, CLOSING, CLOSED } + public enum State { NEW, DETACHED, RESUMING, OPEN, CLOSING, CLOSED } static class DefaultSessionListener implements SessionListener { @@ -187,7 +187,7 @@ public class Session extends SessionInvoker } } - void setState(State state) + protected void setState(State state) { synchronized (commands) { |