[hornetq-commits] JBoss hornetq SVN: r9412 - branches/2_2_0_HA_Improvements/examples/core/perf/src/org/hornetq/core/example.
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)
{