diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2008-07-16 12:36:05 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2008-07-16 12:36:05 +0000 |
| commit | 4aa5c0ff4082adfb77073c08f0cddff0a89d2e1b (patch) | |
| tree | 446c77a99b3835121e7dabf82e981983c4749ce6 /qpid/java/client/src | |
| parent | 94a3e9d3e0b4228bc3e370f90d4c8b26e8073fd9 (diff) | |
| download | qpid-python-4aa5c0ff4082adfb77073c08f0cddff0a89d2e1b.tar.gz | |
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
Diffstat (limited to 'qpid/java/client/src')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/handler/ClientMethodDispatcherImpl.java | 7 | ||||
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQStateManager.java | 12 |
2 files changed, 13 insertions, 6 deletions
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<AMQState> 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) |
