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 2006/10/11 16:47:51 UTC
svn commit: r462820 -
/incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java
Author: ritchiem
Date: Wed Oct 11 07:47:50 2006
New Revision: 462820
URL: http://svn.apache.org/viewvc?view=rev&rev=462820
Log:
Added extra debug output when failover fails.
Modified:
incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java
Modified: incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java?view=diff&rev=462820&r1=462819&r2=462820
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java (original)
+++ incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java Wed Oct 11 07:47:50 2006
@@ -138,7 +138,7 @@
// we only add the SSL filter where we have an SSL connection
if (_useSSL)
{
- //todo FIXME: Bogus context cannot be used in production.
+ //FIXME: Bogus context cannot be used in production.
SSLFilter sslFilter = new SSLFilter(BogusSSLContextFactory.getInstance(false));
sslFilter.setUseClientMode(true);
session.getFilterChain().addBefore("protocolFilter", "ssl", sslFilter);
@@ -190,6 +190,11 @@
{
_logger.info("Failover not allowed by policy.");
+ if (_logger.isDebugEnabled())
+ {
+ _logger.debug(_connection.getFailoverPolicy().toString());
+ }
+
if (_failoverState != FailoverState.IN_PROGRESS)
{
_logger.info("sessionClose() not allowed to failover");
@@ -305,7 +310,7 @@
_logger.debug("Method frame received: " + frame);
}
- final AMQMethodEvent evt = new AMQMethodEvent(frame.channel, (AMQMethodBody)frame.bodyFrame, _protocolSession);
+ final AMQMethodEvent evt = new AMQMethodEvent(frame.channel, (AMQMethodBody) frame.bodyFrame, _protocolSession);
try
{
boolean wasAnyoneInterested = false;
@@ -429,7 +434,7 @@
public AMQMethodEvent syncWrite(AMQFrame frame, Class responseClass) throws AMQException
{
return writeCommandFrameAndWaitForReply(frame,
- new SpecificMethodFrameListener(frame.channel, responseClass));
+ new SpecificMethodFrameListener(frame.channel, responseClass));
}
/**
@@ -438,7 +443,7 @@
* consumer(s) on that session.
*
* @param channelId the channel id of the session
- * @param session the session instance.
+ * @param session the session instance.
*/
public void addSessionByChannel(int channelId, AMQSession session)
{