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 | f6e1ce408c28180665e90ef5eb004223b24c7d1b (patch) | |
| tree | fa1fb7e49879723afd38009b51e28fb4e3a1e66f /java/broker/src/test | |
| parent | a4c82040034baa2715373f4ad8b24bacbaf4cd75 (diff) | |
| download | qpid-python-f6e1ce408c28180665e90ef5eb004223b24c7d1b.tar.gz | |
Style Changes
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@750871 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker/src/test')
| -rw-r--r-- | java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java b/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java index 86d1948f20..f39dfe765e 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java +++ b/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) { |