summaryrefslogtreecommitdiff
path: root/qpid/java/client/src
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2008-07-16 12:36:05 +0000
committerMartin Ritchie <ritchiem@apache.org>2008-07-16 12:36:05 +0000
commit4aa5c0ff4082adfb77073c08f0cddff0a89d2e1b (patch)
tree446c77a99b3835121e7dabf82e981983c4749ce6 /qpid/java/client/src
parent94a3e9d3e0b4228bc3e370f90d4c8b26e8073fd9 (diff)
downloadqpid-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.java7
-rw-r--r--qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQStateManager.java12
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)