You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2010/03/18 17:24:10 UTC
svn commit: r924880 -
/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
Author: robbie
Date: Thu Mar 18 16:24:10 2010
New Revision: 924880
URL: http://svn.apache.org/viewvc?rev=924880&view=rev
Log:
QPID-2379: remove some unused parameters
Modified:
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
Modified: qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java?rev=924880&r1=924879&r2=924880&view=diff
==============================================================================
--- qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java (original)
+++ qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java Thu Mar 18 16:24:10 2010
@@ -319,7 +319,7 @@ public class AMQChannel implements Sessi
}
else
{
- _logger.warn("MESSAGE DISCARDED: No routes for message - " + createAMQMessage(_currentMessage,isTransactional()));
+ _logger.warn("MESSAGE DISCARDED: No routes for message - " + createAMQMessage(_currentMessage));
}
}
@@ -1037,7 +1037,7 @@ public class AMQChannel implements Sessi
}
- private AMQMessage createAMQMessage(IncomingMessage incomingMessage, boolean transactional)
+ private AMQMessage createAMQMessage(IncomingMessage incomingMessage)
throws AMQException
{
@@ -1061,7 +1061,6 @@ public class AMQChannel implements Sessi
private class MessageDeliveryAction implements ServerTransaction.Action
{
- private boolean _transactional;
private IncomingMessage _incommingMessage;
private ArrayList<? extends BaseQueue> _destinationQueues;
@@ -1069,7 +1068,6 @@ public class AMQChannel implements Sessi
ArrayList<? extends BaseQueue> destinationQueues,
boolean transactional)
{
- _transactional = transactional;
_incommingMessage = currentMessage;
_destinationQueues = destinationQueues;
}
@@ -1080,7 +1078,7 @@ public class AMQChannel implements Sessi
{
final boolean immediate = _incommingMessage.isImmediate();
- final AMQMessage amqMessage = createAMQMessage(_incommingMessage, _transactional);
+ final AMQMessage amqMessage = createAMQMessage(_incommingMessage);
MessageReference ref = amqMessage.newReference();
for(final BaseQueue queue : _destinationQueues)
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org