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; + } }