diff options
| author | Robert Gemmell <robbie@apache.org> | 2010-03-18 16:24:10 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2010-03-18 16:24:10 +0000 |
| commit | ddf51178562aeb7c990461234b8c3e7e02ca7719 (patch) | |
| tree | 202cd7c027b7c15462c6c3df58c94df1c86bafb8 /qpid/java | |
| parent | 8e1e53dd5b7c261fd810b7833ccf876dbdecdd39 (diff) | |
| download | qpid-python-ddf51178562aeb7c990461234b8c3e7e02ca7719.tar.gz | |
QPID-2379: remove some unused parameters
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@924880 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java index 54a05da84d..fe5da20fa5 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java @@ -319,7 +319,7 @@ public class AMQChannel implements SessionConfig } 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 SessionConfig } - private AMQMessage createAMQMessage(IncomingMessage incomingMessage, boolean transactional) + private AMQMessage createAMQMessage(IncomingMessage incomingMessage) throws AMQException { @@ -1061,7 +1061,6 @@ public class AMQChannel implements SessionConfig 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 SessionConfig ArrayList<? extends BaseQueue> destinationQueues, boolean transactional) { - _transactional = transactional; _incommingMessage = currentMessage; _destinationQueues = destinationQueues; } @@ -1080,7 +1078,7 @@ public class AMQChannel implements SessionConfig { 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) |