Author: ritchiem
Date: Wed Jul 16 05:36:05 2008
New Revision: 677257
URL: http://svn.apache.org/viewvc?rev=677257&view=rev
Log:
Changed erroneous error level logging to info level
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/handler/ClientMethodDispatcherImpl.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQStateManager.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/handler/ClientMethodDispatcherImpl.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/handler/ClientMethodDispatcherImpl.java?rev=677257&r1=677256&r2=677257&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/handler/ClientMethodDispatcherImpl.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/handler/ClientMethodDispatcherImpl.java
Wed Jul 16 05:36:05 2008
@@ -50,7 +50,6 @@
private static final Logger _logger =
LoggerFactory.getLogger(ClientMethodDispatcherImpl.class);
-
private static interface DispatcherFactory
{
public ClientMethodDispatcherImpl
createMethodDispatcher(AMQProtocolSession session);
@@ -83,7 +82,11 @@
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);
}
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQStateManager.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQStateManager.java?rev=677257&r1=677256&r2=677257&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQStateManager.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQStateManager.java
Wed Jul 16 05:36:05 2008
@@ -48,8 +48,6 @@
* 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 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 @@
/**
* 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 @@
/**
* Remove the waiter from the notification list.
+ *
* @param waiter The waiter to remove.
*/
public void removeWaiter(StateWaiter waiter)
