[hornetq-commits] JBoss hornetq SVN: r8016 - trunk/src/main/org/hornetq/core/config/cluster.
do-not-reply at jboss.org
do-not-reply at jboss.org
Wed Sep 30 14:00:34 EDT 2009
Author: timfox
Date: 2009-09-30 14:00:33 -0400 (Wed, 30 Sep 2009)
New Revision: 8016
Modified:
trunk/src/main/org/hornetq/core/config/cluster/BridgeConfiguration.java
trunk/src/main/org/hornetq/core/config/cluster/BroadcastGroupConfiguration.java
trunk/src/main/org/hornetq/core/config/cluster/DiscoveryGroupConfiguration.java
trunk/src/main/org/hornetq/core/config/cluster/DivertConfiguration.java
trunk/src/main/org/hornetq/core/config/cluster/QueueConfiguration.java
Log:
https://jira.jboss.org/jira/browse/HORNETQ-158
Modified: trunk/src/main/org/hornetq/core/config/cluster/BridgeConfiguration.java
===================================================================
--- trunk/src/main/org/hornetq/core/config/cluster/BridgeConfiguration.java 2009-09-30 17:44:47 UTC (rev 8015)
+++ trunk/src/main/org/hornetq/core/config/cluster/BridgeConfiguration.java 2009-09-30 18:00:33 UTC (rev 8016)
@@ -30,29 +30,29 @@
{
private static final long serialVersionUID = -1057244274380572226L;
- private final String name;
+ private String name;
- private final String queueName;
+ private String queueName;
- private final String forwardingAddress;
+ private String forwardingAddress;
- private final String filterString;
+ private String filterString;
- private final Pair<String, String> connectorPair;
+ private Pair<String, String> connectorPair;
- private final String discoveryGroupName;
+ private String discoveryGroupName;
- private final String transformerClassName;
+ private String transformerClassName;
- private final long retryInterval;
+ private long retryInterval;
- private final double retryIntervalMultiplier;
+ private double retryIntervalMultiplier;
- private final int reconnectAttempts;
+ private int reconnectAttempts;
- private final boolean failoverOnServerShutdown;
+ private boolean failoverOnServerShutdown;
- private final boolean useDuplicateDetection;
+ private boolean useDuplicateDetection;
public BridgeConfiguration(final String name,
final String queueName,
@@ -165,4 +165,100 @@
{
return useDuplicateDetection;
}
+
+ /**
+ * @param name the name to set
+ */
+ public void setName(String name)
+ {
+ this.name = name;
+ }
+
+ /**
+ * @param queueName the queueName to set
+ */
+ public void setQueueName(String queueName)
+ {
+ this.queueName = queueName;
+ }
+
+ /**
+ * @param forwardingAddress the forwardingAddress to set
+ */
+ public void setForwardingAddress(String forwardingAddress)
+ {
+ this.forwardingAddress = forwardingAddress;
+ }
+
+ /**
+ * @param filterString the filterString to set
+ */
+ public void setFilterString(String filterString)
+ {
+ this.filterString = filterString;
+ }
+
+ /**
+ * @param connectorPair the connectorPair to set
+ */
+ public void setConnectorPair(Pair<String, String> connectorPair)
+ {
+ this.connectorPair = connectorPair;
+ }
+
+ /**
+ * @param discoveryGroupName the discoveryGroupName to set
+ */
+ public void setDiscoveryGroupName(String discoveryGroupName)
+ {
+ this.discoveryGroupName = discoveryGroupName;
+ }
+
+ /**
+ * @param transformerClassName the transformerClassName to set
+ */
+ public void setTransformerClassName(String transformerClassName)
+ {
+ this.transformerClassName = transformerClassName;
+ }
+
+ /**
+ * @param retryInterval the retryInterval to set
+ */
+ public void setRetryInterval(long retryInterval)
+ {
+ this.retryInterval = retryInterval;
+ }
+
+ /**
+ * @param retryIntervalMultiplier the retryIntervalMultiplier to set
+ */
+ public void setRetryIntervalMultiplier(double retryIntervalMultiplier)
+ {
+ this.retryIntervalMultiplier = retryIntervalMultiplier;
+ }
+
+ /**
+ * @param reconnectAttempts the reconnectAttempts to set
+ */
+ public void setReconnectAttempts(int reconnectAttempts)
+ {
+ this.reconnectAttempts = reconnectAttempts;
+ }
+
+ /**
+ * @param failoverOnServerShutdown the failoverOnServerShutdown to set
+ */
+ public void setFailoverOnServerShutdown(boolean failoverOnServerShutdown)
+ {
+ this.failoverOnServerShutdown = failoverOnServerShutdown;
+ }
+
+ /**
+ * @param useDuplicateDetection the useDuplicateDetection to set
+ */
+ public void setUseDuplicateDetection(boolean useDuplicateDetection)
+ {
+ this.useDuplicateDetection = useDuplicateDetection;
+ }
}
Modified: trunk/src/main/org/hornetq/core/config/cluster/BroadcastGroupConfiguration.java
===================================================================
--- trunk/src/main/org/hornetq/core/config/cluster/BroadcastGroupConfiguration.java 2009-09-30 17:44:47 UTC (rev 8015)
+++ trunk/src/main/org/hornetq/core/config/cluster/BroadcastGroupConfiguration.java 2009-09-30 18:00:33 UTC (rev 8016)
@@ -27,7 +27,6 @@
*
* Created 18 Nov 2008 08:44:30
*
- *
*/
public class BroadcastGroupConfiguration implements Serializable
{
@@ -35,19 +34,19 @@
private static final Logger log = Logger.getLogger(BroadcastGroupConfiguration.class);
- private final String name;
+ private String name;
- private final String localBindAddress;
+ private String localBindAddress;
- private final int localBindPort;
+ private int localBindPort;
- private final String groupAddress;
+ private String groupAddress;
- private final int groupPort;
+ private int groupPort;
- private final long broadcastPeriod;
+ private long broadcastPeriod;
- private final List<Pair<String, String>> connectorInfos;
+ private List<Pair<String, String>> connectorInfos;
public BroadcastGroupConfiguration(final String name,
final String localBindAddress,
@@ -102,4 +101,60 @@
return connectorInfos;
}
+ /**
+ * @param name the name to set
+ */
+ public void setName(String name)
+ {
+ this.name = name;
+ }
+
+ /**
+ * @param localBindAddress the localBindAddress to set
+ */
+ public void setLocalBindAddress(String localBindAddress)
+ {
+ this.localBindAddress = localBindAddress;
+ }
+
+ /**
+ * @param localBindPort the localBindPort to set
+ */
+ public void setLocalBindPort(int localBindPort)
+ {
+ this.localBindPort = localBindPort;
+ }
+
+ /**
+ * @param groupAddress the groupAddress to set
+ */
+ public void setGroupAddress(String groupAddress)
+ {
+ this.groupAddress = groupAddress;
+ }
+
+ /**
+ * @param groupPort the groupPort to set
+ */
+ public void setGroupPort(int groupPort)
+ {
+ this.groupPort = groupPort;
+ }
+
+ /**
+ * @param broadcastPeriod the broadcastPeriod to set
+ */
+ public void setBroadcastPeriod(long broadcastPeriod)
+ {
+ this.broadcastPeriod = broadcastPeriod;
+ }
+
+ /**
+ * @param connectorInfos the connectorInfos to set
+ */
+ public void setConnectorInfos(List<Pair<String, String>> connectorInfos)
+ {
+ this.connectorInfos = connectorInfos;
+ }
+
}
Modified: trunk/src/main/org/hornetq/core/config/cluster/DiscoveryGroupConfiguration.java
===================================================================
--- trunk/src/main/org/hornetq/core/config/cluster/DiscoveryGroupConfiguration.java 2009-09-30 17:44:47 UTC (rev 8015)
+++ trunk/src/main/org/hornetq/core/config/cluster/DiscoveryGroupConfiguration.java 2009-09-30 18:00:33 UTC (rev 8016)
@@ -29,20 +29,19 @@
{
private static final long serialVersionUID = 8657206421727863400L;
- private final String name;
+ private String name;
- private final String groupAddress;
+ private String groupAddress;
- private final int groupPort;
+ private int groupPort;
- private final long refreshTimeout;
+ private long refreshTimeout;
public DiscoveryGroupConfiguration(final String name,
final String groupAddress,
final int groupPort,
final long refreshTimeout)
{
- super();
this.name = name;
this.groupAddress = groupAddress;
this.groupPort = groupPort;
@@ -68,4 +67,36 @@
{
return refreshTimeout;
}
+
+ /**
+ * @param name the name to set
+ */
+ public void setName(String name)
+ {
+ this.name = name;
+ }
+
+ /**
+ * @param groupAddress the groupAddress to set
+ */
+ public void setGroupAddress(String groupAddress)
+ {
+ this.groupAddress = groupAddress;
+ }
+
+ /**
+ * @param groupPort the groupPort to set
+ */
+ public void setGroupPort(int groupPort)
+ {
+ this.groupPort = groupPort;
+ }
+
+ /**
+ * @param refreshTimeout the refreshTimeout to set
+ */
+ public void setRefreshTimeout(long refreshTimeout)
+ {
+ this.refreshTimeout = refreshTimeout;
+ }
}
Modified: trunk/src/main/org/hornetq/core/config/cluster/DivertConfiguration.java
===================================================================
--- trunk/src/main/org/hornetq/core/config/cluster/DivertConfiguration.java 2009-09-30 17:44:47 UTC (rev 8015)
+++ trunk/src/main/org/hornetq/core/config/cluster/DivertConfiguration.java 2009-09-30 18:00:33 UTC (rev 8016)
@@ -33,21 +33,20 @@
private static final Logger log = Logger.getLogger(DivertConfiguration.class);
+ private String name;
- private final String name;
+ private String routingName;
- private final String routingName;
+ private String address;
- private final String address;
+ private String forwardingAddress;
- private final String forwardingAddress;
+ private boolean exclusive;
- private final boolean exclusive;
+ private String filterString;
- private final String filterString;
+ private String transformerClassName;
- private final String transformerClassName;
-
public DivertConfiguration(final String name,
final String routingName,
final String address,
@@ -106,4 +105,60 @@
{
return transformerClassName;
}
+
+ /**
+ * @param name the name to set
+ */
+ public void setName(String name)
+ {
+ this.name = name;
+ }
+
+ /**
+ * @param routingName the routingName to set
+ */
+ public void setRoutingName(String routingName)
+ {
+ this.routingName = routingName;
+ }
+
+ /**
+ * @param address the address to set
+ */
+ public void setAddress(String address)
+ {
+ this.address = address;
+ }
+
+ /**
+ * @param forwardingAddress the forwardingAddress to set
+ */
+ public void setForwardingAddress(String forwardingAddress)
+ {
+ this.forwardingAddress = forwardingAddress;
+ }
+
+ /**
+ * @param exclusive the exclusive to set
+ */
+ public void setExclusive(boolean exclusive)
+ {
+ this.exclusive = exclusive;
+ }
+
+ /**
+ * @param filterString the filterString to set
+ */
+ public void setFilterString(String filterString)
+ {
+ this.filterString = filterString;
+ }
+
+ /**
+ * @param transformerClassName the transformerClassName to set
+ */
+ public void setTransformerClassName(String transformerClassName)
+ {
+ this.transformerClassName = transformerClassName;
+ }
}
Modified: trunk/src/main/org/hornetq/core/config/cluster/QueueConfiguration.java
===================================================================
--- trunk/src/main/org/hornetq/core/config/cluster/QueueConfiguration.java 2009-09-30 17:44:47 UTC (rev 8015)
+++ trunk/src/main/org/hornetq/core/config/cluster/QueueConfiguration.java 2009-09-30 18:00:33 UTC (rev 8016)
@@ -29,13 +29,13 @@
{
private static final long serialVersionUID = 650404974977490254L;
- private final String address;
+ private String address;
- private final String name;
+ private String name;
- private final String filterString;
+ private String filterString;
- private final boolean durable;
+ private boolean durable;
public QueueConfiguration(final String address, final String name, final String filterString, final boolean durable)
{
@@ -64,4 +64,36 @@
{
return durable;
}
+
+ /**
+ * @param address the address to set
+ */
+ public void setAddress(String address)
+ {
+ this.address = address;
+ }
+
+ /**
+ * @param name the name to set
+ */
+ public void setName(String name)
+ {
+ this.name = name;
+ }
+
+ /**
+ * @param filterString the filterString to set
+ */
+ public void setFilterString(String filterString)
+ {
+ this.filterString = filterString;
+ }
+
+ /**
+ * @param durable the durable to set
+ */
+ public void setDurable(boolean durable)
+ {
+ this.durable = durable;
+ }
}
More information about the hornetq-commits
mailing list