diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2009-03-06 12:27:49 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2009-03-06 12:27:49 +0000 |
| commit | fff143ba920066a1f127c4e69ed5f3c145f73443 (patch) | |
| tree | 173a90c473b92389a9416bcfbec65ff696df1ed9 /qpid/java/broker/src/test | |
| parent | c8f5fbf155a5f85ec09b78fd108660f0d0fef573 (diff) | |
| download | qpid-python-fff143ba920066a1f127c4e69ed5f3c145f73443.tar.gz | |
Style Changes
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@750871 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src/test')
| -rw-r--r-- | qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java index 86d1948f20..f39dfe765e 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java +++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java @@ -415,7 +415,7 @@ public class SimpleAMQQueueTest extends TestCase //Check the queue is still within it's limits. long current = _queue.getMemoryUsageCurrent(); - assertTrue("Queue has gone over quota:" + current+"/"+_queue.getMemoryUsageMaximum() , + assertTrue("Queue has gone over quota:" + current + "/" + _queue.getMemoryUsageMaximum(), current <= _queue.getMemoryUsageMaximum()); assertTrue("Queue has a negative quota:" + _queue.getMemoryUsageCurrent(), _queue.getMemoryUsageCurrent() >= 0); @@ -428,14 +428,14 @@ public class SimpleAMQQueueTest extends TestCase } } - public void testMessagesFlowToDiskPurger() throws AMQException, InterruptedException + public void testMessagesFlowToDiskPurger() throws AMQException, InterruptedException { // Create IncomingMessage and nondurable queue NonTransactionalContext txnContext = new NonTransactionalContext(_transactionLog, null, null, null); MESSAGE_SIZE = 1; /** Set to larger than the purge batch size. Default 100. - * @see FlowableBaseQueueEntryList.BATCH_PROCESS_COUNT */ + * @see FlowableBaseQueueEntryList.BATCH_PROCESS_COUNT */ long MEMORY_MAX = 500; int MESSAGE_COUNT = (int) MEMORY_MAX; //Set the Memory Usage to be very low @@ -454,7 +454,7 @@ public class SimpleAMQQueueTest extends TestCase // Send anothe and ensure we are flowed sendMessage(txnContext); assertEquals(MESSAGE_COUNT + 1, _queue.getMessageCount()); - assertEquals(MESSAGE_COUNT , _queue.getMemoryUsageCurrent()); + assertEquals(MESSAGE_COUNT, _queue.getMemoryUsageCurrent()); assertTrue("Queue is not flowed.", _queue.isFlowed()); _queue.setMemoryUsageMaximum(0L); @@ -469,7 +469,7 @@ public class SimpleAMQQueueTest extends TestCase } assertEquals(MESSAGE_COUNT + 1, _queue.getMessageCount()); - assertEquals(0L , _queue.getMemoryUsageCurrent()); + assertEquals(0L, _queue.getMemoryUsageCurrent()); assertTrue("Queue is not flowed.", _queue.isFlowed()); } @@ -511,6 +511,7 @@ public class SimpleAMQQueueTest extends TestCase assertNotNull(data); } + // FIXME: move this to somewhere useful private static AMQMessage createMessage(final MessagePublishInfo publishBody) { |