diff options
| author | Andrew Donald Kennedy <grkvlt@apache.org> | 2010-12-20 16:05:45 +0000 |
|---|---|---|
| committer | Andrew Donald Kennedy <grkvlt@apache.org> | 2010-12-20 16:05:45 +0000 |
| commit | 63d4b6a773f6f93dfbd8a56420246f9a25a8cd8d (patch) | |
| tree | a65167294e1573597c181a8d7bfac84f5be0913f | |
| parent | 3a4a5a79c0856f93f0f52ab0522efcaabecbd42d (diff) | |
| download | qpid-python-63d4b6a773f6f93dfbd8a56420246f9a25a8cd8d.tar.gz | |
QPID-2970: use dlq property in tests
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.5.x-dev@1051159 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/java/perftests/src/main/java/org/apache/qpid/perftests/dlq/client/Create.java | 4 | ||||
| -rw-r--r-- | qpid/java/perftests/src/main/java/org/apache/qpid/perftests/dlq/client/Receiver.java | 4 |
2 files changed, 5 insertions, 3 deletions
diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/perftests/dlq/client/Create.java b/qpid/java/perftests/src/main/java/org/apache/qpid/perftests/dlq/client/Create.java index 83d5d58d6d..9f34da07e6 100644 --- a/qpid/java/perftests/src/main/java/org/apache/qpid/perftests/dlq/client/Create.java +++ b/qpid/java/perftests/src/main/java/org/apache/qpid/perftests/dlq/client/Create.java @@ -37,7 +37,8 @@ public class Create extends Client { _connection.start(); - BindingURL burl = new AMQBindingURL("direct://amq.direct//" + _queueName + "?maxdeliverycount='" + _maxRedelivery + "'"); + BindingURL burl = new AMQBindingURL("direct://amq.direct//" + _queueName + + (_dlq ? "?maxdeliverycount='" + _maxRedelivery + "'" : "")); _queue = new AMQQueue(burl); final Map<String,Object> arguments = new HashMap<String, Object>(); @@ -55,6 +56,7 @@ public class Create extends Client _queue = _session.createQueue(_queueName + AMQQueueFactory.DEFAULT_DLQ_NAME_SUFFIX); _consumer = _session.createConsumer(_queue); while (_consumer.receive(1000) != null); + _consumer.close(); } } } diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/perftests/dlq/client/Receiver.java b/qpid/java/perftests/src/main/java/org/apache/qpid/perftests/dlq/client/Receiver.java index 22f590d893..9961ca0831 100644 --- a/qpid/java/perftests/src/main/java/org/apache/qpid/perftests/dlq/client/Receiver.java +++ b/qpid/java/perftests/src/main/java/org/apache/qpid/perftests/dlq/client/Receiver.java @@ -60,7 +60,7 @@ public class Receiver extends Client _sessionOk = (_transacted || _clientAck) || ((_sessionType == Session.AUTO_ACKNOWLEDGE || _sessionType == Session.DUPS_OK_ACKNOWLEDGE) && _listener); - _rejectedCheck = (!_sessionOk || _messageIdsDisabled || _maxRedelivery == 0 || _rejectCount < _maxRedelivery) ? 0 : _count / _reject; + _rejectedCheck = (!_dlq || !_sessionOk || _messageIdsDisabled || _maxRedelivery == 0 || _rejectCount < _maxRedelivery) ? 0 : _count / _reject; _consumedCheck = (_count - _rejectedCheck); // + (_sessionOk ? ((_count / _reject) * _rejectCount) : 0); _consumer = _session.createConsumer(_queue); @@ -204,4 +204,4 @@ public class Receiver extends Client { return _rejectedCheck; } -}
\ No newline at end of file +} |