diff options
| author | Bhupendra Bhusman Bhardwaj <bhupendrab@apache.org> | 2007-03-27 09:07:30 +0000 |
|---|---|---|
| committer | Bhupendra Bhusman Bhardwaj <bhupendrab@apache.org> | 2007-03-27 09:07:30 +0000 |
| commit | fb14a2042dd5bdae5a5c79b8cd4f1ad87e59bee1 (patch) | |
| tree | 0a59a872ff849d3056c803836aed199f8a49c1e2 /java/broker/src/test | |
| parent | 4b5818ed830c97978771ffe7be1ff2ac587bd989 (diff) | |
| download | qpid-python-fb14a2042dd5bdae5a5c79b8cd4f1ad87e59bee1.tar.gz | |
merged from M2 (r521792:522567) QPID-408 QPID-421 QPID-428
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@522821 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/AMQQueueAlertTest.java | 8 | ||||
| -rw-r--r-- | java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java | 2 |
2 files changed, 5 insertions, 5 deletions
diff --git a/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueAlertTest.java b/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueAlertTest.java index 1eb3506720..236291968f 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueAlertTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueAlertTest.java @@ -42,7 +42,7 @@ import java.util.HashSet; /** This class tests all the alerts an AMQQueue can throw based on threshold values of different parameters */ public class AMQQueueAlertTest extends TestCase { - private final static int MAX_MESSAGE_COUNT = 50; + private final static long MAX_MESSAGE_COUNT = 50; private final static long MAX_MESSAGE_AGE = 250; // 0.25 sec private final static long MAX_MESSAGE_SIZE = 2000; // 2 KB private final static long MAX_QUEUE_DEPTH = 10000; // 10 KB @@ -175,7 +175,7 @@ public class AMQQueueAlertTest extends TestCase new AMQShortString("consumer_tag"), true, null, false, false); _queueMBean = (AMQQueueMBean) _queue.getManagedObject(); - _queueMBean.setMaximumMessageCount(9999); // Set a high value, because this is not being tested + _queueMBean.setMaximumMessageCount(9999l); // Set a high value, because this is not being tested _queueMBean.setMaximumQueueDepth(MAX_QUEUE_DEPTH); // Send messages(no of message to be little more than what can cause a Queue_Depth alert) @@ -268,9 +268,9 @@ public class AMQQueueAlertTest extends TestCase _virtualHost = applicationRegistry.getVirtualHostRegistry().getVirtualHost("test"); } - private void sendMessages(int messageCount, long size) throws AMQException + private void sendMessages(long messageCount, long size) throws AMQException { - AMQMessage[] messages = new AMQMessage[messageCount]; + AMQMessage[] messages = new AMQMessage[(int)messageCount]; for (int i = 0; i < messages.length; i++) { messages[i] = message(false, size); diff --git a/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java b/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java index 182c6a2d01..551eb8f0a0 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java @@ -116,7 +116,7 @@ public class AMQQueueMBeanTest extends TestCase public void testGeneralProperties() { long maxQueueDepth = 1000; // in bytes - _queueMBean.setMaximumMessageCount(50000); + _queueMBean.setMaximumMessageCount(50000l); _queueMBean.setMaximumMessageSize(2000l); _queueMBean.setMaximumQueueDepth(maxQueueDepth); |