diff options
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) { |