From 5cdee4f3847ab6fda3abfba89f9f336e210c264c Mon Sep 17 00:00:00 2001 From: Andrew Donald Kennedy Date: Sun, 3 Oct 2010 16:02:42 +0000 Subject: QPID-2839 Add channel (CHN) Operational Loggin on 0-10 Committed patch from SorinS git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1003985 13f79535-47bb-0310-9956-ffa450edef68 --- java/common/src/main/java/org/apache/qpid/transport/Connection.java | 2 +- java/common/src/main/java/org/apache/qpid/transport/Session.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) (limited to 'java/common/src') 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) { -- cgit v1.2.1