Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-157 fixing isHA on connectionFactory

This commit is contained in:
Clebert Suconic 2015-07-22 17:17:37 +01:00
parent 0bd784df43
commit d5dde68f0c
3 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/uri/URISchema.java
View File

@ -234,7 +234,7 @@ public abstract class URISchema<T, P>
PropertyDescriptor[] descriptors = beanUtils.getPropertyUtils().getPropertyDescriptors(bean); PropertyDescriptor[] descriptors = beanUtils.getPropertyUtils().getPropertyDescriptors(bean);
for (PropertyDescriptor descriptor : descriptors) for (PropertyDescriptor descriptor : descriptors)
{ {
if (descriptor.getReadMethod() != null && descriptor.getWriteMethod() != null && isWriteable(descriptor, ignored)) if (descriptor.getReadMethod() != null && isWriteable(descriptor, ignored))
{ {
String value = beanUtils.getProperty(bean, descriptor.getName()); String value = beanUtils.getProperty(bean, descriptor.getName());
if (value != null) if (value != null)

11
artemis-core-client/src/main/java/org/apache/activemq/artemis/uri/ConnectionOptions.java
View File

@ -63,6 +63,17 @@ public class ConnectionOptions
this.ha = ha; this.ha = ha;
} }
/** Se need both options (ha / HA in case of typos on the URI) */
public boolean isHA()
{
return ha;
}
public void setHA(boolean ha)
{
this.ha = ha;
}
@Override @Override
public String toString() public String toString()
{ {

1
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/connection/ConnectionFactorySerializationTest.java
View File

@ -144,6 +144,7 @@ public class ConnectionFactorySerializationTest extends JMSTestBase
byte[] x = serialize(cf); byte[] x = serialize(cf);
ActiveMQConnectionFactory y = deserialize(x, ActiveMQConnectionFactory.class); ActiveMQConnectionFactory y = deserialize(x, ActiveMQConnectionFactory.class);
checkEquals(cf, y); checkEquals(cf, y);
Assert.assertEquals(cf.isHA(), y.isHA());
TransportConfiguration[] staticConnectors = y.getStaticConnectors(); TransportConfiguration[] staticConnectors = y.getStaticConnectors();
Assert.assertEquals(staticConnectors.length, 2); Assert.assertEquals(staticConnectors.length, 2);
TransportConfiguration tc0 = cf.getStaticConnectors()[0]; TransportConfiguration tc0 = cf.getStaticConnectors()[0];