[hornetq-commits] JBoss hornetq SVN: r12073 - in trunk: tests/unit-tests/src/test/java/org/hornetq/tests/unit/ra and 1 other directory.

Author: ataylor Date: 2012-02-03 06:23:59 -0500 (Fri, 03 Feb 2012) New Revision: 12073 Modified: trunk/hornetq-ra/hornetq-ra-jar/src/main/java/org/hornetq/ra/ConnectionFactoryProperties.java trunk/hornetq-ra/hornetq-ra-jar/src/main/java/org/hornetq/ra/HornetQResourceAdapter.java trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/ra/HornetQResourceAdapterConfigTest.java trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/ra/ResourceAdapterTest.java Log: https://issues.jboss.org/browse/HORNETQ-836 - added local bind address to RA Modified: trunk/hornetq-ra/hornetq-ra-jar/src/main/java/org/hornetq/ra/ConnectionFactoryProperties.java =================================================================== --- trunk/hornetq-ra/hornetq-ra-jar/src/main/java/org/hornetq/ra/ConnectionFactoryProperties.java 2012-02-03 11:21:52 UTC (rev 12072) +++ trunk/hornetq-ra/hornetq-ra-jar/src/main/java/org/hornetq/ra/ConnectionFactoryProperties.java 2012-02-03 11:23:59 UTC (rev 12073) @@ -52,6 +52,8 @@ private Integer discoveryPort; + private String discoveryLocalBindAddress; + private Long discoveryRefreshTimeout; private Long discoveryInitialWaitTimeout; @@ -183,6 +185,25 @@ return discoveryPort; } + public void setDiscoveryLocalBindAddress(final String discoveryLocalBindAddress) + { + if (ConnectionFactoryProperties.trace) + { + ConnectionFactoryProperties.log.trace("setDiscoveryLocalBindAddress(" + discoveryLocalBindAddress + ")"); + } + hasBeenUpdated = true; + this.discoveryLocalBindAddress = discoveryLocalBindAddress; + } + + public String getDiscoveryLocalBindAddress() + { + if (ConnectionFactoryProperties.trace) + { + ConnectionFactoryProperties.log.trace("getDiscoveryLocalBindAddress()"); + } + return discoveryLocalBindAddress; + } + public void setDiscoveryPort(final Integer discoveryPort) { if (ConnectionFactoryProperties.trace) Modified: trunk/hornetq-ra/hornetq-ra-jar/src/main/java/org/hornetq/ra/HornetQResourceAdapter.java =================================================================== --- trunk/hornetq-ra/hornetq-ra-jar/src/main/java/org/hornetq/ra/HornetQResourceAdapter.java 2012-02-03 11:21:52 UTC (rev 12072) +++ trunk/hornetq-ra/hornetq-ra-jar/src/main/java/org/hornetq/ra/HornetQResourceAdapter.java 2012-02-03 11:23:59 UTC (rev 12073) @@ -38,7 +38,6 @@ import org.hornetq.api.jms.JMSFactoryType; import org.hornetq.core.logging.Logger; import org.hornetq.jms.client.HornetQConnectionFactory; -import org.hornetq.jms.server.recovery.XARecoveryConfig; import org.hornetq.ra.inflow.HornetQActivation; import org.hornetq.ra.inflow.HornetQActivationSpec; import org.hornetq.ra.recovery.RecoveryManager; @@ -355,6 +354,36 @@ } /** + * set the discovery local bind address + * + * @param discoveryLocalBindAddress the address value + */ + public void setDiscoveryLocalBindAddress(final String discoveryLocalBindAddress) + { + if (HornetQResourceAdapter.trace) + { + HornetQResourceAdapter.log.trace("setDiscoveryLocalBindAddress(" + discoveryLocalBindAddress + ")"); + } + + raProperties.setDiscoveryLocalBindAddress(discoveryLocalBindAddress); + } + + /** + * get the discovery local bind address + * + * @return the address value + */ + public String getDiscoveryLocalBindAddress() + { + if (HornetQResourceAdapter.trace) + { + HornetQResourceAdapter.log.trace("getDiscoveryLocalBindAddress()"); + } + + return raProperties.getDiscoveryLocalBindAddress(); + } + + /** * Set the discovery group port * * @param dgp The value @@ -1447,7 +1476,7 @@ { Integer discoveryPort = overrideProperties.getDiscoveryPort() != null ? overrideProperties.getDiscoveryPort() : getDiscoveryPort(); - + if(discoveryPort == null) { discoveryPort = HornetQClient.DEFAULT_DISCOVERY_PORT; @@ -1479,6 +1508,11 @@ groupConfiguration.setRefreshTimeout(refreshTimeout); + String localBindAddress = overrideProperties.getDiscoveryLocalBindAddress() != null ? overrideProperties.getDiscoveryLocalBindAddress() + : raProperties.getDiscoveryLocalBindAddress(); + + groupConfiguration.setLocalBindAdress(localBindAddress); + if (ha) { cf = HornetQJMSClient.createConnectionFactoryWithHA(groupConfiguration, JMSFactoryType.XA_CF); @@ -1587,6 +1621,11 @@ groupConfiguration.setRefreshTimeout(refreshTimeout); + String localBindAddress = overrideProperties.getDiscoveryLocalBindAddress() != null ? overrideProperties.getDiscoveryLocalBindAddress() + : raProperties.getDiscoveryLocalBindAddress(); + + groupConfiguration.setLocalBindAdress(localBindAddress); + cf = HornetQJMSClient.createConnectionFactoryWithoutHA(groupConfiguration, JMSFactoryType.XA_CF); } else Modified: trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/ra/HornetQResourceAdapterConfigTest.java =================================================================== --- trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/ra/HornetQResourceAdapterConfigTest.java 2012-02-03 11:21:52 UTC (rev 12072) +++ trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/ra/HornetQResourceAdapterConfigTest.java 2012-02-03 11:23:59 UTC (rev 12073) @@ -101,6 +101,12 @@ " </config-property>\n" + " <config-property>\n" + " <description>The discovery group address</description>\n" + + " <config-property-name>DiscoveryLocalBindAddress</config-property-name>\n" + + " <config-property-type>java.lang.String</config-property-type>\n" + + " <config-property-value></config-property-value>\n" + + " </config-property>\n" + + " <config-property>\n" + + " <description>The discovery group local bind address</description>\n" + " <config-property-name>DiscoveryAddress</config-property-name>\n" + " <config-property-type>java.lang.String</config-property-type>\n" + " <config-property-value></config-property-value>\n" + Modified: trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/ra/ResourceAdapterTest.java =================================================================== --- trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/ra/ResourceAdapterTest.java 2012-02-03 11:21:52 UTC (rev 12072) +++ trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/ra/ResourceAdapterTest.java 2012-02-03 11:23:59 UTC (rev 12073) @@ -263,9 +263,13 @@ ConnectionFactoryProperties connectionFactoryProperties = new ConnectionFactoryProperties(); connectionFactoryProperties.setDiscoveryAddress("myhost"); connectionFactoryProperties.setDiscoveryPort(5678); + connectionFactoryProperties.setDiscoveryLocalBindAddress("newAddress"); HornetQConnectionFactory factory = ra.createHornetQConnectionFactory(connectionFactoryProperties); HornetQConnectionFactory defaultFactory = ra.getDefaultHornetQConnectionFactory(); Assert.assertNotSame(factory, defaultFactory); + Assert.assertEquals(factory.getDiscoveryGroupConfiguration().getLocalBindAddress(), "newAddress"); + Assert.assertEquals(factory.getDiscoveryGroupConfiguration().getGroupAddress(), "myhost"); + Assert.assertEquals(factory.getDiscoveryGroupConfiguration().getGroupPort(), 5678); } public void testCreateConnectionFactoryMultipleConnectors()