You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2015/08/10 17:13:09 UTC
[10/53] [abbrv] [partial] activemq-artemis git commit: automatic
checkstyle change
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/ConnectionFactoryConfigurationImpl.java
----------------------------------------------------------------------
diff --git a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/ConnectionFactoryConfigurationImpl.java b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/ConnectionFactoryConfigurationImpl.java
index 373c0a1..43c5385 100644
--- a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/ConnectionFactoryConfigurationImpl.java
+++ b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/ConnectionFactoryConfigurationImpl.java
@@ -34,8 +34,7 @@ import org.apache.activemq.artemis.utils.DataConstants;
* <p>
* Every property on this class has to be also set through encoders through EncodingSupport implementation at this class.
*/
-public class ConnectionFactoryConfigurationImpl implements ConnectionFactoryConfiguration
-{
+public class ConnectionFactoryConfigurationImpl implements ConnectionFactoryConfiguration {
// Constants -----------------------------------------------------
// Attributes ----------------------------------------------------
@@ -120,404 +119,332 @@ public class ConnectionFactoryConfigurationImpl implements ConnectionFactoryConf
// Constructors --------------------------------------------------
- public ConnectionFactoryConfigurationImpl()
- {
+ public ConnectionFactoryConfigurationImpl() {
}
// ConnectionFactoryConfiguration implementation -----------------
- public String[] getBindings()
- {
+ public String[] getBindings() {
return bindings;
}
- public ConnectionFactoryConfiguration setBindings(final String... bindings)
- {
+ public ConnectionFactoryConfiguration setBindings(final String... bindings) {
this.bindings = bindings;
return this;
}
- public String getName()
- {
+ public String getName() {
return name;
}
- public ConnectionFactoryConfiguration setName(String name)
- {
+ public ConnectionFactoryConfiguration setName(String name) {
this.name = name;
return this;
}
- public boolean isPersisted()
- {
+ public boolean isPersisted() {
return persisted;
}
/**
* @return the discoveryGroupName
*/
- public String getDiscoveryGroupName()
- {
+ public String getDiscoveryGroupName() {
return discoveryGroupName;
}
/**
* @param discoveryGroupName the discoveryGroupName to set
*/
- public ConnectionFactoryConfiguration setDiscoveryGroupName(String discoveryGroupName)
- {
+ public ConnectionFactoryConfiguration setDiscoveryGroupName(String discoveryGroupName) {
this.discoveryGroupName = discoveryGroupName;
return this;
}
- public List<String> getConnectorNames()
- {
+ public List<String> getConnectorNames() {
return connectorNames;
}
- public ConnectionFactoryConfiguration setConnectorNames(final List<String> connectorNames)
- {
+ public ConnectionFactoryConfiguration setConnectorNames(final List<String> connectorNames) {
this.connectorNames = connectorNames;
return this;
}
- public boolean isHA()
- {
+ public boolean isHA() {
return ha;
}
- public ConnectionFactoryConfiguration setHA(final boolean ha)
- {
+ public ConnectionFactoryConfiguration setHA(final boolean ha) {
this.ha = ha;
return this;
}
- public String getClientID()
- {
+ public String getClientID() {
return clientID;
}
- public ConnectionFactoryConfiguration setClientID(final String clientID)
- {
+ public ConnectionFactoryConfiguration setClientID(final String clientID) {
this.clientID = clientID;
return this;
}
- public long getClientFailureCheckPeriod()
- {
+ public long getClientFailureCheckPeriod() {
return clientFailureCheckPeriod;
}
- public ConnectionFactoryConfiguration setClientFailureCheckPeriod(final long clientFailureCheckPeriod)
- {
+ public ConnectionFactoryConfiguration setClientFailureCheckPeriod(final long clientFailureCheckPeriod) {
this.clientFailureCheckPeriod = clientFailureCheckPeriod;
return this;
}
- public long getConnectionTTL()
- {
+ public long getConnectionTTL() {
return connectionTTL;
}
- public ConnectionFactoryConfiguration setConnectionTTL(final long connectionTTL)
- {
+ public ConnectionFactoryConfiguration setConnectionTTL(final long connectionTTL) {
this.connectionTTL = connectionTTL;
return this;
}
- public long getCallTimeout()
- {
+ public long getCallTimeout() {
return callTimeout;
}
- public ConnectionFactoryConfiguration setCallTimeout(final long callTimeout)
- {
+ public ConnectionFactoryConfiguration setCallTimeout(final long callTimeout) {
this.callTimeout = callTimeout;
return this;
}
- public long getCallFailoverTimeout()
- {
+ public long getCallFailoverTimeout() {
return callFailoverTimeout;
}
- public ConnectionFactoryConfiguration setCallFailoverTimeout(long callFailoverTimeout)
- {
+ public ConnectionFactoryConfiguration setCallFailoverTimeout(long callFailoverTimeout) {
this.callFailoverTimeout = callFailoverTimeout;
return this;
}
- public boolean isCacheLargeMessagesClient()
- {
+ public boolean isCacheLargeMessagesClient() {
return cacheLargeMessagesClient;
}
- public ConnectionFactoryConfiguration setCacheLargeMessagesClient(final boolean cacheLargeMessagesClient)
- {
+ public ConnectionFactoryConfiguration setCacheLargeMessagesClient(final boolean cacheLargeMessagesClient) {
this.cacheLargeMessagesClient = cacheLargeMessagesClient;
return this;
}
- public int getMinLargeMessageSize()
- {
+ public int getMinLargeMessageSize() {
return minLargeMessageSize;
}
- public ConnectionFactoryConfiguration setMinLargeMessageSize(final int minLargeMessageSize)
- {
+ public ConnectionFactoryConfiguration setMinLargeMessageSize(final int minLargeMessageSize) {
this.minLargeMessageSize = minLargeMessageSize;
return this;
}
- public int getConsumerWindowSize()
- {
+ public int getConsumerWindowSize() {
return consumerWindowSize;
}
- public ConnectionFactoryConfiguration setConsumerWindowSize(final int consumerWindowSize)
- {
+ public ConnectionFactoryConfiguration setConsumerWindowSize(final int consumerWindowSize) {
this.consumerWindowSize = consumerWindowSize;
return this;
}
- public int getConsumerMaxRate()
- {
+ public int getConsumerMaxRate() {
return consumerMaxRate;
}
- public ConnectionFactoryConfiguration setConsumerMaxRate(final int consumerMaxRate)
- {
+ public ConnectionFactoryConfiguration setConsumerMaxRate(final int consumerMaxRate) {
this.consumerMaxRate = consumerMaxRate;
return this;
}
- public int getConfirmationWindowSize()
- {
+ public int getConfirmationWindowSize() {
return confirmationWindowSize;
}
- public ConnectionFactoryConfiguration setConfirmationWindowSize(final int confirmationWindowSize)
- {
+ public ConnectionFactoryConfiguration setConfirmationWindowSize(final int confirmationWindowSize) {
this.confirmationWindowSize = confirmationWindowSize;
return this;
}
- public int getProducerMaxRate()
- {
+ public int getProducerMaxRate() {
return producerMaxRate;
}
- public ConnectionFactoryConfiguration setProducerMaxRate(final int producerMaxRate)
- {
+ public ConnectionFactoryConfiguration setProducerMaxRate(final int producerMaxRate) {
this.producerMaxRate = producerMaxRate;
return this;
}
- public int getProducerWindowSize()
- {
+ public int getProducerWindowSize() {
return producerWindowSize;
}
- public ConnectionFactoryConfiguration setProducerWindowSize(final int producerWindowSize)
- {
+ public ConnectionFactoryConfiguration setProducerWindowSize(final int producerWindowSize) {
this.producerWindowSize = producerWindowSize;
return this;
}
- public boolean isBlockOnAcknowledge()
- {
+ public boolean isBlockOnAcknowledge() {
return blockOnAcknowledge;
}
- public ConnectionFactoryConfiguration setBlockOnAcknowledge(final boolean blockOnAcknowledge)
- {
+ public ConnectionFactoryConfiguration setBlockOnAcknowledge(final boolean blockOnAcknowledge) {
this.blockOnAcknowledge = blockOnAcknowledge;
return this;
}
- public boolean isBlockOnDurableSend()
- {
+ public boolean isBlockOnDurableSend() {
return blockOnDurableSend;
}
- public ConnectionFactoryConfiguration setBlockOnDurableSend(final boolean blockOnDurableSend)
- {
+ public ConnectionFactoryConfiguration setBlockOnDurableSend(final boolean blockOnDurableSend) {
this.blockOnDurableSend = blockOnDurableSend;
return this;
}
- public boolean isBlockOnNonDurableSend()
- {
+ public boolean isBlockOnNonDurableSend() {
return blockOnNonDurableSend;
}
- public ConnectionFactoryConfiguration setBlockOnNonDurableSend(final boolean blockOnNonDurableSend)
- {
+ public ConnectionFactoryConfiguration setBlockOnNonDurableSend(final boolean blockOnNonDurableSend) {
this.blockOnNonDurableSend = blockOnNonDurableSend;
return this;
}
- public boolean isAutoGroup()
- {
+ public boolean isAutoGroup() {
return autoGroup;
}
- public ConnectionFactoryConfiguration setAutoGroup(final boolean autoGroup)
- {
+ public ConnectionFactoryConfiguration setAutoGroup(final boolean autoGroup) {
this.autoGroup = autoGroup;
return this;
}
- public boolean isPreAcknowledge()
- {
+ public boolean isPreAcknowledge() {
return preAcknowledge;
}
- public ConnectionFactoryConfiguration setPreAcknowledge(final boolean preAcknowledge)
- {
+ public ConnectionFactoryConfiguration setPreAcknowledge(final boolean preAcknowledge) {
this.preAcknowledge = preAcknowledge;
return this;
}
- public String getLoadBalancingPolicyClassName()
- {
+ public String getLoadBalancingPolicyClassName() {
return loadBalancingPolicyClassName;
}
- public ConnectionFactoryConfiguration setLoadBalancingPolicyClassName(final String loadBalancingPolicyClassName)
- {
+ public ConnectionFactoryConfiguration setLoadBalancingPolicyClassName(final String loadBalancingPolicyClassName) {
this.loadBalancingPolicyClassName = loadBalancingPolicyClassName;
return this;
}
- public int getTransactionBatchSize()
- {
+ public int getTransactionBatchSize() {
return transactionBatchSize;
}
- public ConnectionFactoryConfiguration setTransactionBatchSize(final int transactionBatchSize)
- {
+ public ConnectionFactoryConfiguration setTransactionBatchSize(final int transactionBatchSize) {
this.transactionBatchSize = transactionBatchSize;
return this;
}
- public int getDupsOKBatchSize()
- {
+ public int getDupsOKBatchSize() {
return dupsOKBatchSize;
}
- public ConnectionFactoryConfiguration setDupsOKBatchSize(final int dupsOKBatchSize)
- {
+ public ConnectionFactoryConfiguration setDupsOKBatchSize(final int dupsOKBatchSize) {
this.dupsOKBatchSize = dupsOKBatchSize;
return this;
}
- public long getInitialWaitTimeout()
- {
+ public long getInitialWaitTimeout() {
return initialWaitTimeout;
}
- public ConnectionFactoryConfiguration setInitialWaitTimeout(final long initialWaitTimeout)
- {
+ public ConnectionFactoryConfiguration setInitialWaitTimeout(final long initialWaitTimeout) {
this.initialWaitTimeout = initialWaitTimeout;
return this;
}
- public boolean isUseGlobalPools()
- {
+ public boolean isUseGlobalPools() {
return useGlobalPools;
}
- public ConnectionFactoryConfiguration setUseGlobalPools(final boolean useGlobalPools)
- {
+ public ConnectionFactoryConfiguration setUseGlobalPools(final boolean useGlobalPools) {
this.useGlobalPools = useGlobalPools;
return this;
}
- public int getScheduledThreadPoolMaxSize()
- {
+ public int getScheduledThreadPoolMaxSize() {
return scheduledThreadPoolMaxSize;
}
- public ConnectionFactoryConfiguration setScheduledThreadPoolMaxSize(final int scheduledThreadPoolMaxSize)
- {
+ public ConnectionFactoryConfiguration setScheduledThreadPoolMaxSize(final int scheduledThreadPoolMaxSize) {
this.scheduledThreadPoolMaxSize = scheduledThreadPoolMaxSize;
return this;
}
- public int getThreadPoolMaxSize()
- {
+ public int getThreadPoolMaxSize() {
return threadPoolMaxSize;
}
- public ConnectionFactoryConfiguration setThreadPoolMaxSize(final int threadPoolMaxSize)
- {
+ public ConnectionFactoryConfiguration setThreadPoolMaxSize(final int threadPoolMaxSize) {
this.threadPoolMaxSize = threadPoolMaxSize;
return this;
}
- public long getRetryInterval()
- {
+ public long getRetryInterval() {
return retryInterval;
}
- public ConnectionFactoryConfiguration setRetryInterval(final long retryInterval)
- {
+ public ConnectionFactoryConfiguration setRetryInterval(final long retryInterval) {
this.retryInterval = retryInterval;
return this;
}
- public double getRetryIntervalMultiplier()
- {
+ public double getRetryIntervalMultiplier() {
return retryIntervalMultiplier;
}
- public ConnectionFactoryConfiguration setRetryIntervalMultiplier(final double retryIntervalMultiplier)
- {
+ public ConnectionFactoryConfiguration setRetryIntervalMultiplier(final double retryIntervalMultiplier) {
this.retryIntervalMultiplier = retryIntervalMultiplier;
return this;
}
- public long getMaxRetryInterval()
- {
+ public long getMaxRetryInterval() {
return maxRetryInterval;
}
- public ConnectionFactoryConfiguration setMaxRetryInterval(final long maxRetryInterval)
- {
+ public ConnectionFactoryConfiguration setMaxRetryInterval(final long maxRetryInterval) {
this.maxRetryInterval = maxRetryInterval;
return this;
}
- public int getReconnectAttempts()
- {
+ public int getReconnectAttempts() {
return reconnectAttempts;
}
- public ConnectionFactoryConfiguration setReconnectAttempts(final int reconnectAttempts)
- {
+ public ConnectionFactoryConfiguration setReconnectAttempts(final int reconnectAttempts) {
this.reconnectAttempts = reconnectAttempts;
return this;
}
- public boolean isFailoverOnInitialConnection()
- {
+ public boolean isFailoverOnInitialConnection() {
return failoverOnInitialConnection;
}
- public ConnectionFactoryConfiguration setFailoverOnInitialConnection(final boolean failover)
- {
+ public ConnectionFactoryConfiguration setFailoverOnInitialConnection(final boolean failover) {
failoverOnInitialConnection = failover;
return this;
}
- public String getGroupID()
- {
+ public String getGroupID() {
return groupID;
}
- public ConnectionFactoryConfiguration setGroupID(final String groupID)
- {
+ public ConnectionFactoryConfiguration setGroupID(final String groupID) {
this.groupID = groupID;
return this;
}
@@ -525,8 +452,7 @@ public class ConnectionFactoryConfigurationImpl implements ConnectionFactoryConf
// Encoding Support Implementation --------------------------------------------------------------
@Override
- public void decode(final ActiveMQBuffer buffer)
- {
+ public void decode(final ActiveMQBuffer buffer) {
persisted = true;
name = buffer.readSimpleString().toString();
@@ -535,12 +461,10 @@ public class ConnectionFactoryConfigurationImpl implements ConnectionFactoryConf
int nConnectors = buffer.readInt();
- if (nConnectors > 0)
- {
+ if (nConnectors > 0) {
connectorNames = new ArrayList<String>(nConnectors);
- for (int i = 0; i < nConnectors; i++)
- {
+ for (int i = 0; i < nConnectors; i++) {
SimpleString str = buffer.readSimpleString();
connectorNames.add(str.toString());
@@ -613,24 +537,20 @@ public class ConnectionFactoryConfigurationImpl implements ConnectionFactoryConf
}
@Override
- public void encode(final ActiveMQBuffer buffer)
- {
+ public void encode(final ActiveMQBuffer buffer) {
persisted = true;
BufferHelper.writeAsSimpleString(buffer, name);
BufferHelper.writeAsNullableSimpleString(buffer, discoveryGroupName);
- if (this.connectorNames == null)
- {
+ if (this.connectorNames == null) {
buffer.writeInt(0);
}
- else
- {
+ else {
buffer.writeInt(connectorNames.size());
- for (String tc : connectorNames)
- {
+ for (String tc : connectorNames) {
BufferHelper.writeAsSimpleString(buffer, tc);
}
}
@@ -701,18 +621,15 @@ public class ConnectionFactoryConfigurationImpl implements ConnectionFactoryConf
}
@Override
- public int getEncodeSize()
- {
+ public int getEncodeSize() {
int size = BufferHelper.sizeOfSimpleString(name) +
BufferHelper.sizeOfNullableSimpleString(discoveryGroupName);
size += DataConstants.SIZE_INT;
- if (this.connectorNames != null)
- {
- for (String tc : connectorNames)
- {
+ if (this.connectorNames != null) {
+ for (String tc : connectorNames) {
size += BufferHelper.sizeOfSimpleString(tc);
}
}
@@ -812,27 +729,23 @@ public class ConnectionFactoryConfigurationImpl implements ConnectionFactoryConf
return size;
}
- public ConnectionFactoryConfiguration setFactoryType(final JMSFactoryType factoryType)
- {
+ public ConnectionFactoryConfiguration setFactoryType(final JMSFactoryType factoryType) {
this.factoryType = factoryType;
return this;
}
- public JMSFactoryType getFactoryType()
- {
+ public JMSFactoryType getFactoryType() {
return factoryType;
}
@Override
- public ConnectionFactoryConfiguration setCompressLargeMessages(boolean compressLargeMessage)
- {
+ public ConnectionFactoryConfiguration setCompressLargeMessages(boolean compressLargeMessage) {
this.compressLargeMessage = compressLargeMessage;
return this;
}
@Override
- public boolean isCompressLargeMessages()
- {
+ public boolean isCompressLargeMessages() {
return this.compressLargeMessage;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/FileJMSConfiguration.java
----------------------------------------------------------------------
diff --git a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/FileJMSConfiguration.java b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/FileJMSConfiguration.java
index 8fad9d6..0a657eb 100644
--- a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/FileJMSConfiguration.java
+++ b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/FileJMSConfiguration.java
@@ -36,8 +36,8 @@ import javax.management.MBeanServer;
import java.util.ArrayList;
import java.util.Map;
-public class FileJMSConfiguration extends JMSConfigurationImpl implements Deployable
-{
+public class FileJMSConfiguration extends JMSConfigurationImpl implements Deployable {
+
private static final String CONFIGURATION_SCHEMA_URL = "schema/artemis-jms.xsd";
private static final String CONFIGURATION_SCHEMA_ROOT_ELEMENT = "jms";
@@ -57,43 +57,39 @@ public class FileJMSConfiguration extends JMSConfigurationImpl implements Deploy
private boolean parsed = false;
@Override
- public void parse(Element config) throws Exception
- {
+ public void parse(Element config) throws Exception {
parseConfiguration(config);
parsed = true;
}
@Override
- public boolean isParsed()
- {
+ public boolean isParsed() {
return parsed;
}
@Override
- public String getRootElement()
- {
+ public String getRootElement() {
return CONFIGURATION_SCHEMA_ROOT_ELEMENT;
}
@Override
- public void buildService(ActiveMQSecurityManager securityManager, MBeanServer mBeanServer, Map<String, Deployable> deployables, Map<String, ActiveMQComponent> components) throws Exception
- {
+ public void buildService(ActiveMQSecurityManager securityManager,
+ MBeanServer mBeanServer,
+ Map<String, Deployable> deployables,
+ Map<String, ActiveMQComponent> components) throws Exception {
ActiveMQServerImpl server = (ActiveMQServerImpl) components.get("core");
components.put(CONFIGURATION_SCHEMA_ROOT_ELEMENT, new JMSServerManagerImpl(server, this));
}
@Override
- public String getSchema()
- {
+ public String getSchema() {
return CONFIGURATION_SCHEMA_URL;
}
-
/**
* Parse the JMS Configuration XML
*/
- public void parseConfiguration(final Node rootnode) throws Exception
- {
+ public void parseConfiguration(final Node rootnode) throws Exception {
ArrayList<JMSQueueConfiguration> queues = new ArrayList<>();
ArrayList<TopicConfiguration> topics = new ArrayList<>();
@@ -101,25 +97,20 @@ public class FileJMSConfiguration extends JMSConfigurationImpl implements Deploy
Element e = (Element) rootnode;
String[] elements = new String[]{QUEUE_NODE_NAME, TOPIC_NODE_NAME};
- for (String element : elements)
- {
+ for (String element : elements) {
NodeList children = e.getElementsByTagName(element);
- for (int i = 0; i < children.getLength(); i++)
- {
+ for (int i = 0; i < children.getLength(); i++) {
Node node = children.item(i);
Node keyNode = node.getAttributes().getNamedItem(NAME_ATTR);
- if (keyNode == null)
- {
+ if (keyNode == null) {
ActiveMQJMSServerLogger.LOGGER.jmsConfigMissingKey(node);
continue;
}
- if (node.getNodeName().equals(TOPIC_NODE_NAME))
- {
+ if (node.getNodeName().equals(TOPIC_NODE_NAME)) {
topics.add(parseTopicConfiguration(node));
}
- else if (node.getNodeName().equals(QUEUE_NODE_NAME))
- {
+ else if (node.getNodeName().equals(QUEUE_NODE_NAME)) {
queues.add(parseQueueConfiguration(node));
}
}
@@ -137,8 +128,7 @@ public class FileJMSConfiguration extends JMSConfigurationImpl implements Deploy
* @return topic configuration
* @throws Exception
*/
- public static TopicConfiguration parseTopicConfiguration(final Node node) throws Exception
- {
+ public static TopicConfiguration parseTopicConfiguration(final Node node) throws Exception {
String topicName = node.getAttributes().getNamedItem(NAME_ATTR).getNodeValue();
return newTopic(topicName);
@@ -151,20 +141,17 @@ public class FileJMSConfiguration extends JMSConfigurationImpl implements Deploy
* @return jms queue configuration
* @throws Exception
*/
- public static JMSQueueConfiguration parseQueueConfiguration(final Node node) throws Exception
- {
+ public static JMSQueueConfiguration parseQueueConfiguration(final Node node) throws Exception {
Element e = (Element) node;
NamedNodeMap atts = node.getAttributes();
String queueName = atts.getNamedItem(NAME_ATTR).getNodeValue();
String selectorString = null;
boolean durable = XMLConfigurationUtil.getBoolean(e, "durable", DEFAULT_QUEUE_DURABILITY);
NodeList children = node.getChildNodes();
- for (int i = 0; i < children.getLength(); i++)
- {
+ for (int i = 0; i < children.getLength(); i++) {
Node child = children.item(i);
- if (QUEUE_SELECTOR_NODE_NAME.equals(children.item(i).getNodeName()))
- {
+ if (QUEUE_SELECTOR_NODE_NAME.equals(children.item(i).getNodeName())) {
Node selectorNode = children.item(i);
Node attNode = selectorNode.getAttributes().getNamedItem("string");
selectorString = attNode.getNodeValue();
@@ -178,10 +165,8 @@ public class FileJMSConfiguration extends JMSConfigurationImpl implements Deploy
* @param topicName
* @return
*/
- protected static TopicConfiguration newTopic(final String topicName)
- {
- return new TopicConfigurationImpl()
- .setName(topicName);
+ protected static TopicConfiguration newTopic(final String topicName) {
+ return new TopicConfigurationImpl().setName(topicName);
}
/**
@@ -191,9 +176,8 @@ public class FileJMSConfiguration extends JMSConfigurationImpl implements Deploy
* @return
*/
protected static JMSQueueConfiguration newQueue(final String queueName,
- final String selectorString,
- final boolean durable)
- {
+ final String selectorString,
+ final boolean durable) {
return new JMSQueueConfigurationImpl().
setName(queueName).
setSelector(selectorString).
@@ -206,10 +190,8 @@ public class FileJMSConfiguration extends JMSConfigurationImpl implements Deploy
* @param domain
*/
protected void newConfig(final ArrayList<JMSQueueConfiguration> queues,
- final ArrayList<TopicConfiguration> topics, String domain)
- {
- setQueueConfigurations(queues)
- .setTopicConfigurations(topics)
- .setDomain(domain);
+ final ArrayList<TopicConfiguration> topics,
+ String domain) {
+ setQueueConfigurations(queues).setTopicConfigurations(topics).setDomain(domain);
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/JMSConfigurationImpl.java
----------------------------------------------------------------------
diff --git a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/JMSConfigurationImpl.java b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/JMSConfigurationImpl.java
index 5546bc3..9b36cfc 100644
--- a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/JMSConfigurationImpl.java
+++ b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/JMSConfigurationImpl.java
@@ -25,9 +25,8 @@ import org.apache.activemq.artemis.jms.server.config.JMSConfiguration;
import org.apache.activemq.artemis.jms.server.config.JMSQueueConfiguration;
import org.apache.activemq.artemis.jms.server.config.TopicConfiguration;
+public class JMSConfigurationImpl implements JMSConfiguration {
-public class JMSConfigurationImpl implements JMSConfiguration
-{
private List<ConnectionFactoryConfiguration> connectionFactoryConfigurations = new ArrayList<ConnectionFactoryConfiguration>();
private List<JMSQueueConfiguration> queueConfigurations = new ArrayList<JMSQueueConfiguration>();
@@ -38,50 +37,41 @@ public class JMSConfigurationImpl implements JMSConfiguration
// JMSConfiguration implementation -------------------------------
- public JMSConfigurationImpl()
- {
+ public JMSConfigurationImpl() {
}
- public List<ConnectionFactoryConfiguration> getConnectionFactoryConfigurations()
- {
+ public List<ConnectionFactoryConfiguration> getConnectionFactoryConfigurations() {
return connectionFactoryConfigurations;
}
- public JMSConfigurationImpl setConnectionFactoryConfigurations(List<ConnectionFactoryConfiguration> connectionFactoryConfigurations)
- {
+ public JMSConfigurationImpl setConnectionFactoryConfigurations(List<ConnectionFactoryConfiguration> connectionFactoryConfigurations) {
this.connectionFactoryConfigurations = connectionFactoryConfigurations;
return this;
}
- public List<JMSQueueConfiguration> getQueueConfigurations()
- {
+ public List<JMSQueueConfiguration> getQueueConfigurations() {
return queueConfigurations;
}
- public JMSConfigurationImpl setQueueConfigurations(List<JMSQueueConfiguration> queueConfigurations)
- {
+ public JMSConfigurationImpl setQueueConfigurations(List<JMSQueueConfiguration> queueConfigurations) {
this.queueConfigurations = queueConfigurations;
return this;
}
- public List<TopicConfiguration> getTopicConfigurations()
- {
+ public List<TopicConfiguration> getTopicConfigurations() {
return topicConfigurations;
}
- public JMSConfigurationImpl setTopicConfigurations(List<TopicConfiguration> topicConfigurations)
- {
+ public JMSConfigurationImpl setTopicConfigurations(List<TopicConfiguration> topicConfigurations) {
this.topicConfigurations = topicConfigurations;
return this;
}
- public String getDomain()
- {
+ public String getDomain() {
return domain;
}
- public JMSConfigurationImpl setDomain(final String domain)
- {
+ public JMSConfigurationImpl setDomain(final String domain) {
this.domain = domain;
return this;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/JMSQueueConfigurationImpl.java
----------------------------------------------------------------------
diff --git a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/JMSQueueConfigurationImpl.java b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/JMSQueueConfigurationImpl.java
index 2e6a506..52be423 100644
--- a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/JMSQueueConfigurationImpl.java
+++ b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/JMSQueueConfigurationImpl.java
@@ -18,9 +18,7 @@ package org.apache.activemq.artemis.jms.server.config.impl;
import org.apache.activemq.artemis.jms.server.config.JMSQueueConfiguration;
-
-public class JMSQueueConfigurationImpl implements JMSQueueConfiguration
-{
+public class JMSQueueConfigurationImpl implements JMSQueueConfiguration {
// Constants -----------------------------------------------------
@@ -38,52 +36,43 @@ public class JMSQueueConfigurationImpl implements JMSQueueConfiguration
// Constructors --------------------------------------------------
- public JMSQueueConfigurationImpl()
- {
+ public JMSQueueConfigurationImpl() {
}
// QueueConfiguration implementation -----------------------------
- public String[] getBindings()
- {
+ public String[] getBindings() {
return bindings;
}
- public JMSQueueConfigurationImpl setBindings(String... bindings)
- {
+ public JMSQueueConfigurationImpl setBindings(String... bindings) {
this.bindings = bindings;
return this;
}
- public String getName()
- {
+ public String getName() {
return name;
}
- public JMSQueueConfigurationImpl setName(String name)
- {
+ public JMSQueueConfigurationImpl setName(String name) {
this.name = name;
return this;
}
- public String getSelector()
- {
+ public String getSelector() {
return selector;
}
- public JMSQueueConfigurationImpl setSelector(String selector)
- {
+ public JMSQueueConfigurationImpl setSelector(String selector) {
this.selector = selector;
return this;
}
- public boolean isDurable()
- {
+ public boolean isDurable() {
return durable;
}
- public JMSQueueConfigurationImpl setDurable(boolean durable)
- {
+ public JMSQueueConfigurationImpl setDurable(boolean durable) {
this.durable = durable;
return this;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/TopicConfigurationImpl.java
----------------------------------------------------------------------
diff --git a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/TopicConfigurationImpl.java b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/TopicConfigurationImpl.java
index 5badcbe..e8ad224 100644
--- a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/TopicConfigurationImpl.java
+++ b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/TopicConfigurationImpl.java
@@ -18,9 +18,7 @@ package org.apache.activemq.artemis.jms.server.config.impl;
import org.apache.activemq.artemis.jms.server.config.TopicConfiguration;
-
-public class TopicConfigurationImpl implements TopicConfiguration
-{
+public class TopicConfigurationImpl implements TopicConfiguration {
// Constants -----------------------------------------------------
@@ -34,30 +32,25 @@ public class TopicConfigurationImpl implements TopicConfiguration
// Constructors --------------------------------------------------
- public TopicConfigurationImpl()
- {
+ public TopicConfigurationImpl() {
}
// TopicConfiguration implementation -----------------------------
- public String[] getBindings()
- {
+ public String[] getBindings() {
return bindings;
}
- public TopicConfigurationImpl setBindings(String... bindings)
- {
+ public TopicConfigurationImpl setBindings(String... bindings) {
this.bindings = bindings;
return this;
}
- public String getName()
- {
+ public String getName() {
return name;
}
- public TopicConfigurationImpl setName(String name)
- {
+ public TopicConfigurationImpl setName(String name) {
this.name = name;
return this;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/TransportConfigurationEncodingSupport.java
----------------------------------------------------------------------
diff --git a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/TransportConfigurationEncodingSupport.java b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/TransportConfigurationEncodingSupport.java
index 230ff33..858c68b 100644
--- a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/TransportConfigurationEncodingSupport.java
+++ b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/config/impl/TransportConfigurationEncodingSupport.java
@@ -28,20 +28,17 @@ import org.apache.activemq.artemis.api.core.TransportConfiguration;
import org.apache.activemq.artemis.utils.BufferHelper;
import org.apache.activemq.artemis.utils.DataConstants;
-public class TransportConfigurationEncodingSupport
-{
- public static List<Pair<TransportConfiguration, TransportConfiguration>> decodeConfigs(ActiveMQBuffer buffer)
- {
+public class TransportConfigurationEncodingSupport {
+
+ public static List<Pair<TransportConfiguration, TransportConfiguration>> decodeConfigs(ActiveMQBuffer buffer) {
int size = buffer.readInt();
List<Pair<TransportConfiguration, TransportConfiguration>> configs = new ArrayList<Pair<TransportConfiguration, TransportConfiguration>>(size);
- for (int i = 0; i < size; i++)
- {
+ for (int i = 0; i < size; i++) {
TransportConfiguration live = decode(buffer);
boolean hasBackup = buffer.readBoolean();
TransportConfiguration backup = null;
- if (hasBackup)
- {
+ if (hasBackup) {
backup = decode(buffer);
}
configs.add(new Pair<TransportConfiguration, TransportConfiguration>(live, backup));
@@ -50,14 +47,12 @@ public class TransportConfigurationEncodingSupport
return configs;
}
- public static TransportConfiguration decode(ActiveMQBuffer buffer)
- {
+ public static TransportConfiguration decode(ActiveMQBuffer buffer) {
String name = BufferHelper.readNullableSimpleStringAsString(buffer);
String factoryClassName = buffer.readSimpleString().toString();
int paramSize = buffer.readInt();
Map<String, Object> params = new HashMap<String, Object>();
- for (int i = 0; i < paramSize; i++)
- {
+ for (int i = 0; i < paramSize; i++) {
String key = buffer.readSimpleString().toString();
String value = buffer.readSimpleString().toString();
params.put(key, value);
@@ -67,61 +62,48 @@ public class TransportConfigurationEncodingSupport
}
public static void encodeConfigs(ActiveMQBuffer buffer,
- List<Pair<TransportConfiguration, TransportConfiguration>> configs)
- {
+ List<Pair<TransportConfiguration, TransportConfiguration>> configs) {
buffer.writeInt(configs == null ? 0 : configs.size());
- if (configs != null)
- {
- for (Pair<TransportConfiguration, TransportConfiguration> pair : configs)
- {
+ if (configs != null) {
+ for (Pair<TransportConfiguration, TransportConfiguration> pair : configs) {
encode(buffer, pair.getA());
boolean backup = (pair.getB() != null);
buffer.writeBoolean(backup);
- if (backup)
- {
+ if (backup) {
encode(buffer, pair.getB());
}
}
}
}
- public static void encode(ActiveMQBuffer buffer, TransportConfiguration config)
- {
+ public static void encode(ActiveMQBuffer buffer, TransportConfiguration config) {
BufferHelper.writeAsNullableSimpleString(buffer, config.getName());
BufferHelper.writeAsSimpleString(buffer, config.getFactoryClassName());
buffer.writeInt(config.getParams().size());
- for (Entry<String, Object> param : config.getParams().entrySet())
- {
+ for (Entry<String, Object> param : config.getParams().entrySet()) {
BufferHelper.writeAsSimpleString(buffer, param.getKey());
BufferHelper.writeAsSimpleString(buffer, param.getValue().toString());
}
}
- public static int getEncodeSize(TransportConfiguration config)
- {
- int size = BufferHelper.sizeOfNullableSimpleString(config.getName()) +
- BufferHelper.sizeOfSimpleString(config.getFactoryClassName());
+ public static int getEncodeSize(TransportConfiguration config) {
+ int size = BufferHelper.sizeOfNullableSimpleString(config.getName()) + BufferHelper.sizeOfSimpleString(config.getFactoryClassName());
size += DataConstants.SIZE_INT; // number of params
- for (Entry<String, Object> param : config.getParams().entrySet())
- {
+ for (Entry<String, Object> param : config.getParams().entrySet()) {
size += BufferHelper.sizeOfSimpleString(param.getKey());
size += BufferHelper.sizeOfSimpleString(param.getValue().toString());
}
return size;
}
- public static int getEncodeSize(List<Pair<TransportConfiguration, TransportConfiguration>> configs)
- {
+ public static int getEncodeSize(List<Pair<TransportConfiguration, TransportConfiguration>> configs) {
int size = DataConstants.SIZE_INT; // number of configs;
- if (configs != null)
- {
- for (Pair<TransportConfiguration, TransportConfiguration> pair : configs)
- {
+ if (configs != null) {
+ for (Pair<TransportConfiguration, TransportConfiguration> pair : configs) {
size += getEncodeSize(pair.getA());
size += DataConstants.SIZE_BOOLEAN; // whether there is a backup config
- if (pair.getB() != null)
- {
+ if (pair.getB() != null) {
size += getEncodeSize(pair.getB());
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/embedded/EmbeddedJMS.java
----------------------------------------------------------------------
diff --git a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/embedded/EmbeddedJMS.java b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/embedded/EmbeddedJMS.java
index b09ee88..10962f9 100644
--- a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/embedded/EmbeddedJMS.java
+++ b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/embedded/EmbeddedJMS.java
@@ -35,21 +35,18 @@ import org.apache.activemq.artemis.spi.core.naming.BindingRegistry;
* JMS Endpoints are registered with a simple MapBindingRegistry. If you want to use a different registry
* you must set the registry property of this class or call the setRegistry() method if you want to use JNDI
*/
-public class EmbeddedJMS extends EmbeddedActiveMQ
-{
+public class EmbeddedJMS extends EmbeddedActiveMQ {
+
protected JMSServerManagerImpl serverManager;
protected BindingRegistry registry;
protected JMSConfiguration jmsConfiguration;
protected Context context;
-
- public BindingRegistry getRegistry()
- {
+ public BindingRegistry getRegistry() {
return registry;
}
- public JMSServerManager getJMSServerManager()
- {
+ public JMSServerManager getJMSServerManager() {
return serverManager;
}
@@ -58,8 +55,7 @@ public class EmbeddedJMS extends EmbeddedActiveMQ
*
* @param registry
*/
- public void setRegistry(BindingRegistry registry)
- {
+ public void setRegistry(BindingRegistry registry) {
this.registry = registry;
}
@@ -68,8 +64,7 @@ public class EmbeddedJMS extends EmbeddedActiveMQ
*
* @param jmsConfiguration
*/
- public void setJmsConfiguration(JMSConfiguration jmsConfiguration)
- {
+ public void setJmsConfiguration(JMSConfiguration jmsConfiguration) {
this.jmsConfiguration = jmsConfiguration;
}
@@ -78,8 +73,7 @@ public class EmbeddedJMS extends EmbeddedActiveMQ
*
* @param context
*/
- public void setContext(Context context)
- {
+ public void setContext(Context context) {
this.context = context;
}
@@ -87,31 +81,26 @@ public class EmbeddedJMS extends EmbeddedActiveMQ
* Lookup in the registry for registered object, i.e. a ConnectionFactory.
* <p>
* This is a convenience method.
+ *
* @param name
*/
- public Object lookup(String name)
- {
+ public Object lookup(String name) {
return serverManager.getRegistry().lookup(name);
}
@Override
- public void start() throws Exception
- {
+ public void start() throws Exception {
super.initStart();
- if (jmsConfiguration != null)
- {
+ if (jmsConfiguration != null) {
serverManager = new JMSServerManagerImpl(activeMQServer, jmsConfiguration);
}
- else
- {
+ else {
FileJMSConfiguration fileConfiguration = new FileJMSConfiguration();
FileDeploymentManager deploymentManager;
- if (configResourcePath != null)
- {
+ if (configResourcePath != null) {
deploymentManager = new FileDeploymentManager(configResourcePath);
}
- else
- {
+ else {
deploymentManager = new FileDeploymentManager();
}
deploymentManager.addDeployable(fileConfiguration);
@@ -119,18 +108,18 @@ public class EmbeddedJMS extends EmbeddedActiveMQ
serverManager = new JMSServerManagerImpl(activeMQServer, fileConfiguration);
}
- if (registry == null)
- {
- if (context != null) registry = new JndiBindingRegistry(context);
- else registry = new MapBindingRegistry();
+ if (registry == null) {
+ if (context != null)
+ registry = new JndiBindingRegistry(context);
+ else
+ registry = new MapBindingRegistry();
}
serverManager.setRegistry(registry);
serverManager.start();
}
@Override
- public void stop() throws Exception
- {
+ public void stop() throws Exception {
serverManager.stop();
}