Author: ritchiem
Date: Mon Feb 25 06:50:04 2008
New Revision: 630865

URL: http://svn.apache.org/viewvc?rev=630865&view=rev
Log:
QPID-809 Updated logging and removed an unnecessary printStackTrace().

Modified:
    
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/handler/BasicPublishMethodHandler.java
    
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/security/auth/manager/PrincipalDatabaseAuthenticationManager.java
    
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQSession.java

Modified: 
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/handler/BasicPublishMethodHandler.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/handler/BasicPublishMethodHandler.java?rev=630865&r1=630864&r2=630865&view=diff
==============================================================================
--- 
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/handler/BasicPublishMethodHandler.java
 (original)
+++ 
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/handler/BasicPublishMethodHandler.java
 Mon Feb 25 06:50:04 2008
@@ -35,9 +35,9 @@
 import org.apache.qpid.server.state.StateAwareMethodListener;
 import org.apache.qpid.server.virtualhost.VirtualHost;
 
-public class BasicPublishMethodHandler  implements 
StateAwareMethodListener<BasicPublishBody>
+public class BasicPublishMethodHandler implements 
StateAwareMethodListener<BasicPublishBody>
 {
-    private static final Logger _log = 
Logger.getLogger(BasicPublishMethodHandler.class);
+    private static final Logger _logger = 
Logger.getLogger(BasicPublishMethodHandler.class);
 
     private static final BasicPublishMethodHandler _instance = new 
BasicPublishMethodHandler();
 
@@ -54,12 +54,9 @@
     public void methodReceived(AMQStateManager stateManager, BasicPublishBody 
body, int channelId) throws AMQException
     {
         AMQProtocolSession session = stateManager.getProtocolSession();
-
-
-
-        if (_log.isDebugEnabled())
+        if (_logger.isDebugEnabled())
         {
-            _log.debug("Publish received on channel " + channelId);
+            _logger.debug("Publish received on channel " + channelId);
         }
 
         AMQShortString exchange = body.getExchange();

Modified: 
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/security/auth/manager/PrincipalDatabaseAuthenticationManager.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/security/auth/manager/PrincipalDatabaseAuthenticationManager.java?rev=630865&r1=630864&r2=630865&view=diff
==============================================================================
--- 
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/security/auth/manager/PrincipalDatabaseAuthenticationManager.java
 (original)
+++ 
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/security/auth/manager/PrincipalDatabaseAuthenticationManager.java
 Mon Feb 25 06:50:04 2008
@@ -82,14 +82,6 @@
             if (databaseName == null)
             {
 
-                if (hostConfig instanceof SubsetConfiguration)
-                {
-                    _logger.warn("No authentication specified for '" + 
((SubsetConfiguration) hostConfig).getPrefix() + "'. Using Default 
authentication manager");
-                }
-                else
-                {
-                    _logger.warn("No authentication specified. Using Default 
authentication manager");
-                }
                 _default = 
ApplicationRegistry.getInstance().getAuthenticationManager();
                 return;
             }

Modified: 
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQSession.java?rev=630865&r1=630864&r2=630865&view=diff
==============================================================================
--- 
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
 (original)
+++ 
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
 Mon Feb 25 06:50:04 2008
@@ -615,7 +615,6 @@
                     final AMQFrame frame = body.generateFrame(getChannelId());
 
                     getProtocolHandler().syncWrite(frame, 
ChannelCloseOkBody.class, timeout);
-                     
 
                         // When control resumes at this point, a reply will 
have been received that
                         // indicates the broker has closed the channel 
successfully.
@@ -1758,11 +1757,6 @@
                         catch (AMQException e)
                         {
                             JMSException ex = new JMSException("Error 
registering consumer: " + e);
-
-                            if (_logger.isDebugEnabled())
-                            {
-                                e.printStackTrace();
-                            }
 
                             ex.setLinkedException(e);
                             throw ex;


Reply via email to