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 | 5cdee4f3847ab6fda3abfba89f9f336e210c264c (patch) | |
| tree | 4fe7907b741d82adc7b8c25f4b190f5fc0da57ce /java/common/src | |
| parent | a81b0113c7384cd8e9f9d0b4eab069718ade6471 (diff) | |
| download | qpid-python-5cdee4f3847ab6fda3abfba89f9f336e210c264c.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/qpid@1003985 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common/src')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/transport/Connection.java | 2 | ||||
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/transport/Session.java | 4 |
2 files changed, 3 insertions, 3 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/transport/Connection.java b/java/common/src/main/java/org/apache/qpid/transport/Connection.java index 174dc54a72..fa3c1737a7 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/Connection.java +++ b/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/java/common/src/main/java/org/apache/qpid/transport/Session.java b/java/common/src/main/java/org/apache/qpid/transport/Session.java index 257f1e495a..eba46e9b1b 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/Session.java +++ b/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) { |