[hornetq-commits] JBoss hornetq SVN: r8507 - in trunk/tests/src/org/hornetq/tests/integration: cluster/bridge and 1 other directories.
Author: timfox
Date: 2009-12-02 15:50:50 -0500 (Wed, 02 Dec 2009)
New Revision: 8507
Modified:
trunk/tests/src/org/hornetq/tests/integration/client/PagingTest.java
trunk/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeTest.java
trunk/tests/src/org/hornetq/tests/integration/management/AddressControlTest.java
Log:
fixed some tests
Modified: trunk/tests/src/org/hornetq/tests/integration/client/PagingTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/client/PagingTest.java 2009-12-02
20:03:15 UTC (rev 8506)
+++ trunk/tests/src/org/hornetq/tests/integration/client/PagingTest.java 2009-12-02
20:50:50 UTC (rev 8507)
@@ -1008,7 +1008,7 @@
pagedDestinationA.setPageSizeBytes(1024);
pagedDestinationA.setMaxSizeBytes(10 * 1024);
- int NUMBER_MESSAGES_BEFORE_PAGING = 20;
+ int NUMBER_MESSAGES_BEFORE_PAGING = 11;
addresses.put(PAGED_ADDRESS_A.toString(), pagedDestinationA);
Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeTest.java
===================================================================
---
trunk/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeTest.java 2009-12-02
20:03:15 UTC (rev 8506)
+++
trunk/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeTest.java 2009-12-02
20:50:50 UTC (rev 8507)
@@ -677,7 +677,7 @@
for (int i = 0; i < numMessages; i++)
{
- ClientMessage message = consumer1.receive(200);
+ ClientMessage message = consumer1.receive(5000);
assertNotNull(message);
Modified:
trunk/tests/src/org/hornetq/tests/integration/management/AddressControlTest.java
===================================================================
---
trunk/tests/src/org/hornetq/tests/integration/management/AddressControlTest.java 2009-12-02
20:03:15 UTC (rev 8506)
+++
trunk/tests/src/org/hornetq/tests/integration/management/AddressControlTest.java 2009-12-02
20:50:50 UTC (rev 8507)
@@ -344,7 +344,7 @@
AddressSettings addressSettings = new AddressSettings();
addressSettings.setPageSizeBytes(1024);
addressSettings.setMaxSizeBytes(10 * 1024);
- int NUMBER_MESSAGES_BEFORE_PAGING = 14;
+ int NUMBER_MESSAGES_BEFORE_PAGING = 5;
server.getAddressSettingsRepository().addMatch(address.toString(),
addressSettings);
server.start();