You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2008/07/16 14:36:06 UTC
svn commit: r677257 - in
/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client:
handler/ClientMethodDispatcherImpl.java state/AMQStateManager.java
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)