[hornetq-commits] JBoss hornetq SVN: r9412 - branches/2_2_0_HA_Improvements/examples/core/perf/src/org/hornetq/core/example.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-07-19 08:19:21 -0400 (Mon, 19 Jul 2010)
New Revision: 9412

Modified:
   branches/2_2_0_HA_Improvements/examples/core/perf/src/org/hornetq/core/example/PerfBase.java
Log:
HA refactoring

* fix core perf example to use ServerLocator API

Modified: branches/2_2_0_HA_Improvements/examples/core/perf/src/org/hornetq/core/example/PerfBase.java
===================================================================
--- branches/2_2_0_HA_Improvements/examples/core/perf/src/org/hornetq/core/example/PerfBase.java	2010-07-19 12:12:07 UTC (rev 9411)
+++ branches/2_2_0_HA_Improvements/examples/core/perf/src/org/hornetq/core/example/PerfBase.java	2010-07-19 12:19:21 UTC (rev 9412)
@@ -195,16 +195,17 @@
       params.put(TransportConstants.HOST_PROP_NAME, perfParams.getHost());
       params.put(TransportConstants.PORT_PROP_NAME, perfParams.getPort());
 
-      factory = HornetQClient.createClientSessionFactory(new TransportConfiguration(NettyConnectorFactory.class.getName(), params));
-      factory.setPreAcknowledge(perfParams.isPreAck());
-      factory.setConfirmationWindowSize(perfParams.getConfirmationWindow());
-      factory.setProducerWindowSize(perfParams.getProducerWindow());
-      factory.setConsumerWindowSize(perfParams.getConsumerWindow());
+      ServerLocator serverLocator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(NettyConnectorFactory.class.getName(), params));
+      serverLocator.setPreAcknowledge(perfParams.isPreAck());
+      serverLocator.setConfirmationWindowSize(perfParams.getConfirmationWindow());
+      serverLocator.setProducerWindowSize(perfParams.getProducerWindow());
+      serverLocator.setConsumerWindowSize(perfParams.getConsumerWindow());
+      serverLocator.setAckBatchSize(perfParams.getBatchSize());
 
-      factory.setAckBatchSize(perfParams.getBatchSize());
+      serverLocator.setBlockOnAcknowledge(perfParams.isBlockOnACK());
+      serverLocator.setBlockOnDurableSend(perfParams.isBlockOnPersistent());
+      factory = serverLocator.createSessionFactory();
 
-      factory.setBlockOnAcknowledge(perfParams.isBlockOnACK());
-      factory.setBlockOnDurableSend(perfParams.isBlockOnPersistent());
    }
 
    private void displayAverage(final long numberOfMessages, final long start, final long end)
@@ -293,11 +294,11 @@
       }
       finally
       {
-         if (session != null)
+         if (factory != null)
          {
             try
             {
-               session.close();
+               factory.close();
             }
             catch (Exception e)
             {