From 4aa5c0ff4082adfb77073c08f0cddff0a89d2e1b Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Wed, 16 Jul 2008 12:36:05 +0000 Subject: Changed erroneous error level logging to info level git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@677257 13f79535-47bb-0310-9956-ffa450edef68 --- .../qpid/client/handler/ClientMethodDispatcherImpl.java | 7 +++++-- .../java/org/apache/qpid/client/state/AMQStateManager.java | 12 ++++++++---- 2 files changed, 13 insertions(+), 6 deletions(-) (limited to 'qpid/java/client') diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/handler/ClientMethodDispatcherImpl.java b/qpid/java/client/src/main/java/org/apache/qpid/client/handler/ClientMethodDispatcherImpl.java index a0f3808b23..9c791730ca 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/handler/ClientMethodDispatcherImpl.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/handler/ClientMethodDispatcherImpl.java @@ -50,7 +50,6 @@ public class ClientMethodDispatcherImpl implements MethodDispatcher private static final Logger _logger = LoggerFactory.getLogger(ClientMethodDispatcherImpl.class); - private static interface DispatcherFactory { public ClientMethodDispatcherImpl createMethodDispatcher(AMQProtocolSession session); @@ -83,7 +82,11 @@ public class ClientMethodDispatcherImpl implements MethodDispatcher public static ClientMethodDispatcherImpl newMethodDispatcher(ProtocolVersion version, AMQProtocolSession session) { - _logger.error("New Method Dispatcher:" + session); + if (_logger.isInfoEnabled()) + { + _logger.info("New Method Dispatcher:" + session); + } + DispatcherFactory factory = _dispatcherFactories.get(version); return factory.createMethodDispatcher(session); } diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQStateManager.java b/qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQStateManager.java index 7a5d70ad15..f8645139f2 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQStateManager.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQStateManager.java @@ -48,8 +48,6 @@ import java.util.concurrent.CopyOnWriteArrayList; * The two step process is required as there is an inherit race condition between starting a process that will cause * the state to change and then attempting to wait for that change. The interest in the change must be first set up so * that any asynchrous errors that occur can be delivered to the correct waiters. - * - * */ public class AMQStateManager implements AMQMethodListener { @@ -124,13 +122,16 @@ public class AMQStateManager implements AMQMethodListener */ public void setProtocolSession(AMQProtocolSession session) { - _logger.error("Setting ProtocolSession:" + session); + if (_logger.isInfoEnabled()) + { + _logger.info("Setting ProtocolSession:" + session); + } _protocolSession = session; } /** * Propogate error to waiters - * + * * @param error The error to propogate. */ public void error(Exception error) @@ -160,7 +161,9 @@ public class AMQStateManager implements AMQMethodListener /** * Create and add a new waiter to the notifcation list. + * * @param states The waiter will attempt to wait for one of these desired set states to be achived. + * * @return the created StateWaiter. */ public StateWaiter createWaiter(Set states) @@ -178,6 +181,7 @@ public class AMQStateManager implements AMQMethodListener /** * Remove the waiter from the notification list. + * * @param waiter The waiter to remove. */ public void removeWaiter(StateWaiter waiter) -- cgit v1.2.1