Author: jmesnil
Date: 2010-08-24 04:22:54 -0400 (Tue, 24 Aug 2010)
New Revision: 9583
Modified:
branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/divert/PersistentDivertTest.java
Log:
fix PersistentDivertTest
Modified:
branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/divert/PersistentDivertTest.java
===================================================================
---
branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/divert/PersistentDivertTest.java 2010-08-23
15:57:26 UTC (rev 9582)
+++
branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/divert/PersistentDivertTest.java 2010-08-24
08:22:54 UTC (rev 9583)
@@ -106,12 +106,12 @@
ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(new
TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY));
+ locator.setBlockOnAcknowledge(true);
+ locator.setBlockOnNonDurableSend(true);
+ locator.setBlockOnDurableSend(true);
+
ClientSessionFactory sf = locator.createSessionFactory();
- sf.getServerLocator().setBlockOnAcknowledge(true);
- sf.getServerLocator().setBlockOnNonDurableSend(true);
- sf.getServerLocator().setBlockOnDurableSend(true);
-
ClientSession session = sf.createSession(true, true, 0);
final SimpleString queueName1 = new SimpleString("queue1");
@@ -310,12 +310,12 @@
messagingService.start();
ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(new
TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY));
+ locator.setBlockOnAcknowledge(true);
+ locator.setBlockOnNonDurableSend(true);
+ locator.setBlockOnDurableSend(true);
+
ClientSessionFactory sf = locator.createSessionFactory();
- sf.getServerLocator().setBlockOnAcknowledge(true);
- sf.getServerLocator().setBlockOnNonDurableSend(true);
- sf.getServerLocator().setBlockOnDurableSend(true);
-
ClientSession session = sf.createSession(true, true, 0);
final SimpleString queueName1 = new SimpleString("queue1");
@@ -363,10 +363,9 @@
messagingService.start();
ServerLocator locator2 = HornetQClient.createServerLocatorWithoutHA(new
TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY));
- sf = locator2.createSessionFactory();
+ locator2.setBlockOnDurableSend(true);
- sf.getServerLocator().setBlockOnDurableSend(true);
-
+ sf = locator2.createSessionFactory();
session = sf.createSession(false, true, true);
session.start();
@@ -460,11 +459,10 @@
messagingService.start();
ServerLocator locator3 = HornetQClient.createServerLocatorWithoutHA(new
TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY));
+ locator3.setBlockOnDurableSend(true);
sf = locator3.createSessionFactory();
- sf.getServerLocator().setBlockOnDurableSend(true);
-
session = sf.createSession(false, true, true);
consumer1 = session.createConsumer(queueName1);
Show replies by date