Author: clebert.suconic(a)jboss.com
Date: 2009-11-06 12:45:51 -0500 (Fri, 06 Nov 2009)
New Revision: 8244
Modified:
trunk/src/main/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java
trunk/tests/config/hornetq-jms-for-JMSServerDeployerTest.xml
trunk/tests/src/org/hornetq/tests/integration/jms/server/JMSServerDeployerTest.java
Log:
adding cache-on-client parameter to validation test
Modified: trunk/src/main/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java 2009-11-06
17:26:10 UTC (rev 8243)
+++ trunk/src/main/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java 2009-11-06
17:45:51 UTC (rev 8244)
@@ -430,6 +430,8 @@
reconnectAttempts = DEFAULT_RECONNECT_ATTEMPTS;
failoverOnServerShutdown = DEFAULT_FAILOVER_ON_SERVER_SHUTDOWN;
+
+ cacheLargeMessagesClient = DEFAULT_CACHE_LARGE_MESSAGE_CLIENT;
}
public ClientSessionFactoryImpl(final String discoveryAddress, final int
discoveryPort)
Modified: trunk/tests/config/hornetq-jms-for-JMSServerDeployerTest.xml
===================================================================
--- trunk/tests/config/hornetq-jms-for-JMSServerDeployerTest.xml 2009-11-06 17:26:10 UTC
(rev 8243)
+++ trunk/tests/config/hornetq-jms-for-JMSServerDeployerTest.xml 2009-11-06 17:45:51 UTC
(rev 8244)
@@ -33,6 +33,7 @@
<retry-interval>5</retry-interval>
<retry-interval-multiplier>6.0</retry-interval-multiplier>
<max-retry-interval>300</max-retry-interval>
+ <cache-large-message-client>true</cache-large-message-client>
</connection-factory>
<queue name="fullConfigurationQueue">
Modified:
trunk/tests/src/org/hornetq/tests/integration/jms/server/JMSServerDeployerTest.java
===================================================================
---
trunk/tests/src/org/hornetq/tests/integration/jms/server/JMSServerDeployerTest.java 2009-11-06
17:26:10 UTC (rev 8243)
+++
trunk/tests/src/org/hornetq/tests/integration/jms/server/JMSServerDeployerTest.java 2009-11-06
17:45:51 UTC (rev 8244)
@@ -210,6 +210,7 @@
assertEquals(34, cf.getReconnectAttempts());
assertEquals(5, cf.getRetryInterval());
assertEquals(6.0, cf.getRetryIntervalMultiplier());
+ assertEquals(true, cf.isCacheLargeMessagesClient());
}
for (String binding : queueBindings)