From 32dbd341efeff4485b3e68b9def24e11735dc68e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ville=20Skytt=C3=A4?=
* Instances of it can be obtained from {@link ActiveMQBuffers} factory.
*
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQBuffers.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQBuffers.java
index 040420aa793..34fee4d575f 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQBuffers.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQBuffers.java
@@ -53,12 +53,12 @@ public static ActiveMQBuffer dynamicBuffer(final byte[] bytes)
}
/**
- * Creates a ActiveMQBuffer wrapping an underlying NIO ByteBuffer
+ * Creates an ActiveMQBuffer wrapping an underlying NIO ByteBuffer
*
* The position on this buffer won't affect the position on the inner buffer
*
* @param underlying the underlying NIO ByteBuffer
- * @return a ActiveMQBuffer wrapping the underlying NIO ByteBuffer
+ * @return an ActiveMQBuffer wrapping the underlying NIO ByteBuffer
*/
public static ActiveMQBuffer wrappedBuffer(final ByteBuffer underlying)
{
@@ -70,10 +70,10 @@ public static ActiveMQBuffer wrappedBuffer(final ByteBuffer underlying)
}
/**
- * Creates a ActiveMQBuffer wrapping an underlying byte array
+ * Creates an ActiveMQBuffer wrapping an underlying byte array
*
* @param underlying the underlying byte array
- * @return a ActiveMQBuffer wrapping the underlying byte array
+ * @return an ActiveMQBuffer wrapping the underlying byte array
*/
public static ActiveMQBuffer wrappedBuffer(final byte[] underlying)
{
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIllegalStateException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIllegalStateException.java
index ac25f621afe..8ad6b2161b0 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIllegalStateException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIllegalStateException.java
@@ -17,7 +17,7 @@
package org.apache.activemq.artemis.api.core;
/**
- * A ActiveMQ Artemis resource is not in a legal state (e.g. calling ClientConsumer.receive() if a
+ * An ActiveMQ Artemis resource is not in a legal state (e.g. calling ClientConsumer.receive() if a
* MessageHandler is set).
*/
public final class ActiveMQIllegalStateException extends ActiveMQException
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/UUIDGenerator.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/UUIDGenerator.java
index d1985597462..0be8e7b5218 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/UUIDGenerator.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/UUIDGenerator.java
@@ -141,7 +141,7 @@ public byte[] generateDummyAddress()
* If running java 6 or above, returns {@link NetworkInterface#getHardwareAddress()}, else return {@code null}.
* The first hardware address is returned when iterating all the NetworkInterfaces
*
- * @return A byte array containing teh hardware address.
+ * @return A byte array containing the hardware address.
*/
public static byte[] getHardwareAddress()
{
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/config/ActiveMQDefaultConfiguration.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/config/ActiveMQDefaultConfiguration.java
index 5752a5b7070..adb2861ba2f 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/config/ActiveMQDefaultConfiguration.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/config/ActiveMQDefaultConfiguration.java
@@ -386,7 +386,7 @@ public static String getDefaultHapolicyBackupStrategy()
// Will this server, if a backup, restart once it has been stopped because of failback or scaling down.
private static boolean DEFAULT_RESTART_BACKUP = false;
- // Whether a server will automatically stop when a another places a request to take over its place. The use case is when a regular server stops and its backup takes over its duties, later the main server restarts and requests the server (the former backup) to stop operating.
+ // Whether a server will automatically stop when another places a request to take over its place. The use case is when a regular server stops and its backup takes over its duties, later the main server restarts and requests the server (the former backup) to stop operating.
private static boolean DEFAULT_ALLOW_AUTO_FAILBACK = true;
// if we have to start as a replicated server this is the delay to wait before fail-back occurs
@@ -1078,7 +1078,7 @@ public static boolean isDefaultRestartBackup()
}
/**
- * Whether a server will automatically stop when a another places a request to take over its place. The use case is when a regular server stops and its backup takes over its duties, later the main server restarts and requests the server (the former backup) to stop operating.
+ * Whether a server will automatically stop when another places a request to take over its place. The use case is when a regular server stops and its backup takes over its duties, later the main server restarts and requests the server (the former backup) to stop operating.
*/
public static boolean isDefaultAllowAutoFailback()
{
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/Message.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/Message.java
index 4dc63c3bec8..20830ad586f 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/Message.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/Message.java
@@ -158,7 +158,7 @@ public interface Message
* Returns the message timestamp.
*
* This call will block indefinitely until a message is received.
*
- * Calling this method on a closed consumer will throw a ActiveMQException.
+ * Calling this method on a closed consumer will throw an ActiveMQException.
* @return a ClientMessage
* @throws ActiveMQException if an exception occurs while waiting to receive a message
*/
@@ -57,7 +57,7 @@ public interface ClientConsumer extends AutoCloseable
*
* This call will block until a message is received or the given timeout expires.
*
- * Calling this method on a closed consumer will throw a ActiveMQException.
+ * Calling this method on a closed consumer will throw an ActiveMQException.
* @param timeout time (in milliseconds) to wait to receive a message
* @return a message or {@code null} if the time out expired
* @throws ActiveMQException if an exception occurs while waiting to receive a message
@@ -74,7 +74,7 @@ public interface ClientConsumer extends AutoCloseable
* Note however that there is a performance cost as an additional network trip to the server may
* required to check the queue status.
*
- * Calling this method on a closed consumer will throw a ActiveMQException.
+ * Calling this method on a closed consumer will throw an ActiveMQException.
* @return a message or {@code null} if there are no messages in the queue for this consumer
* @throws ActiveMQException if an exception occurs while waiting to receive a message
*/
@@ -83,7 +83,7 @@ public interface ClientConsumer extends AutoCloseable
/**
* Returns the MessageHandler associated to this consumer.
*
- * Calling this method on a closed consumer will throw a ActiveMQException.
+ * Calling this method on a closed consumer will throw an ActiveMQException.
* @return the MessageHandler associated to this consumer or {@code null}
* @throws ActiveMQException if an exception occurs while getting the MessageHandler
*/
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientSession.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientSession.java
index 2b2841d4c3b..c9558587863 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientSession.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientSession.java
@@ -586,7 +586,7 @@ ClientConsumer createConsumer(SimpleString queueName,
* Queries information on a binding.
*
* @param address the address of the biding to query
- * @return a AddressQuery containing information on the binding attached to the given address
+ * @return an AddressQuery containing information on the binding attached to the given address
* @throws ActiveMQException if an exception occurs while querying the binding
*/
AddressQuery addressQuery(SimpleString address) throws ActiveMQException;
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientSessionFactory.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientSessionFactory.java
index 4e12e79b603..6a119aab0d1 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientSessionFactory.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientSessionFactory.java
@@ -25,7 +25,7 @@
* A ClientSessionFactory is the entry point to create and configure ActiveMQ Artemis resources to produce and consume messages.
*
* If the session is not blocking when sending durable or non-durable messages, the session can set
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ActiveMQComponentControl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ActiveMQComponentControl.java
index cb36f532edd..0343439fc98 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ActiveMQComponentControl.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ActiveMQComponentControl.java
@@ -17,7 +17,7 @@
package org.apache.activemq.artemis.api.core.management;
/**
- * A ActiveMQComponentControl is used to manage the life cycle of a ActiveMQ Artemis component.
+ * An ActiveMQComponentControl is used to manage the life cycle of an ActiveMQ Artemis component.
*/
public interface ActiveMQComponentControl
{
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ActiveMQServerControl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ActiveMQServerControl.java
index b9faed4ae22..138bc463387 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ActiveMQServerControl.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ActiveMQServerControl.java
@@ -19,7 +19,7 @@
import javax.management.MBeanOperationInfo;
/**
- * A ActiveMQServerControl is used to manage ActiveMQ Artemis servers.
+ * An ActiveMQServerControl is used to manage ActiveMQ Artemis servers.
*/
public interface ActiveMQServerControl
{
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ManagementHelper.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ManagementHelper.java
index 8e48e245440..23afbd9c6ba 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ManagementHelper.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ManagementHelper.java
@@ -99,7 +99,7 @@ public static void putAttribute(final Message message, final String resourceName
}
/**
- * Stores a operation invocation in a message to invoke the corresponding operation the value from the server resource.
+ * Stores an operation invocation in a message to invoke the corresponding operation the value from the server resource.
*
* @param message message
* @param resourceName the name of the resource
@@ -114,7 +114,7 @@ public static void putOperationInvocation(final Message message,
}
/**
- * Stores a operation invocation in a message to invoke the corresponding operation the value from the server resource.
+ * Stores an operation invocation in a message to invoke the corresponding operation the value from the server resource.
*
* @param message message
* @param resourceName the name of the server resource
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/ActiveMQClientLogger.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/ActiveMQClientLogger.java
index f1ebde27d29..ba3fad85ff9 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/ActiveMQClientLogger.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/ActiveMQClientLogger.java
@@ -248,11 +248,11 @@ public interface ActiveMQClientLogger extends BasicLogger
void propertyNotInteger(String propName, String name);
@LogMessage(level = Logger.Level.WARN)
- @Message(id = 212044, value = "Property {0} must be an Long, it is {1}", format = Message.Format.MESSAGE_FORMAT)
+ @Message(id = 212044, value = "Property {0} must be a Long, it is {1}", format = Message.Format.MESSAGE_FORMAT)
void propertyNotLong(String propName, String name);
@LogMessage(level = Logger.Level.WARN)
- @Message(id = 212045, value = "Property {0} must be an Boolean, it is {1}", format = Message.Format.MESSAGE_FORMAT)
+ @Message(id = 212045, value = "Property {0} must be a Boolean, it is {1}", format = Message.Format.MESSAGE_FORMAT)
void propertyNotBoolean(String propName, String name);
@LogMessage(level = Logger.Level.WARN)
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/ActiveMQClientMessageBundle.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/ActiveMQClientMessageBundle.java
index 13d3fae4352..09cb114d05a 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/ActiveMQClientMessageBundle.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/ActiveMQClientMessageBundle.java
@@ -208,7 +208,7 @@ public interface ActiveMQClientMessageBundle
@Message(id = 119053, value = "Element {0} requires a valid Double value, but ''{1}'' cannot be parsed as a Double", format = Message.Format.MESSAGE_FORMAT)
IllegalArgumentException mustBeDouble(Node elem, String value);
- @Message(id = 119054, value = "Element {0} requires a valid Integer value, but ''{1}'' cannot be parsed as a Integer", format = Message.Format.MESSAGE_FORMAT)
+ @Message(id = 119054, value = "Element {0} requires a valid Integer value, but ''{1}'' cannot be parsed as an Integer", format = Message.Format.MESSAGE_FORMAT)
IllegalArgumentException mustBeInteger(Node elem, String value);
@Message(id = 119055, value = "Element {0} requires a valid Long value, but ''{1}'' cannot be parsed as a Long", format = Message.Format.MESSAGE_FORMAT)
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientConsumerImpl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientConsumerImpl.java
index 0d54e169a21..b9cccecc873 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientConsumerImpl.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientConsumerImpl.java
@@ -78,7 +78,7 @@ public final class ClientConsumerImpl implements ClientConsumerInternal
// while holding a lock or failover could dead lock eventually
// And we can't use the sessionExecutor as that's being used for message handlers
// for that reason we have a separate flowControlExecutor that's using the thread pool
- // Which is a OrderedExecutor
+ // Which is an OrderedExecutor
private final Executor flowControlExecutor;
// Number of pending calls on flow control
@@ -896,7 +896,7 @@ public void flowControl(final int messageBytes, final boolean discountSlowConsum
// ---------------------------------------------------------------------------------------
/**
- * Sending a initial credit for slow consumers
+ * Sending an initial credit for slow consumers
*/
private void startSlowConsumer()
{
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java
index a15f9f1dbc4..85e3d8d11d5 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java
@@ -591,7 +591,7 @@ private void failoverOrReconnect(final Object connectionID, final ActiveMQExcept
if (connection == null || !connection.getID().equals(connectionID) || !clientProtocolManager.isAlive())
{
// We already failed over/reconnected - probably the first failure came in, all the connections were failed
- // over then a async connection exception or disconnect
+ // over then an async connection exception or disconnect
// came in for one of the already exitLoop connections, so we return true - we don't want to call the
// listeners again
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/InflaterReader.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/InflaterReader.java
index 44803e81b56..363391a60b3 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/InflaterReader.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/InflaterReader.java
@@ -22,8 +22,8 @@
import java.util.zip.Inflater;
/**
- * An InflaterReader
- * It takes an compressed input stream and decompressed it as it is being read.
+ * InflaterReader
+ * It takes a compressed input stream and decompressed it as it is being read.
* Not for concurrent use.
*/
public class InflaterReader extends InputStream
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/InflaterWriter.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/InflaterWriter.java
index 94df830d7ab..ddb34a15abc 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/InflaterWriter.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/InflaterWriter.java
@@ -22,7 +22,7 @@
import java.util.zip.Inflater;
/**
- * A InflaterWriter
+ * InflaterWriter
*
* This class takes an OutputStream. Compressed bytes
* can directly be written into this class. The class will
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/json/JSONArray.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/json/JSONArray.java
index 4e971be971e..daa570971d3 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/json/JSONArray.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/json/JSONArray.java
@@ -686,7 +686,7 @@ public JSONArray put(final int value)
}
/**
- * Append an long value. This increases the array's length by one.
+ * Append a long value. This increases the array's length by one.
*
* @param value A long value.
* @return this.
@@ -848,7 +848,7 @@ public JSONArray put(final int index, final Object value) throws JSONException
}
/**
- * Remove a index and close the hole.
+ * Remove an index and close the hole.
* @param index The index of the element to be removed.
* @return The value that was associated with the index,
* or null if there was no value.
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/json/JSONObject.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/json/JSONObject.java
index 441c8cefcef..60d87dd85f8 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/json/JSONObject.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/json/JSONObject.java
@@ -1385,7 +1385,7 @@ public static Object stringToValue(final String s)
}
/**
- * Throw an exception if the object is an NaN or infinite number.
+ * Throw an exception if the object is a NaN or infinite number.
* @param o The object to test.
* @throws JSONException If o is a non-finite number.
*/
diff --git a/artemis-distribution/src/main/resources/README.html b/artemis-distribution/src/main/resources/README.html
index 3114718c08e..f8327061faa 100644
--- a/artemis-distribution/src/main/resources/README.html
+++ b/artemis-distribution/src/main/resources/README.html
@@ -58,7 +58,7 @@
* The discoveryAddress and discoveryPort parameters in this method are used to listen for UDP
@@ -94,7 +94,7 @@ else if (jmsFactoryType.equals(JMSFactoryType.TOPIC_XA_CF))
}
/**
- * Create a ActiveMQConnectionFactory which creates session factories from a set of live servers, no HA backup information is propagated to the client
+ * Create an ActiveMQConnectionFactory which creates session factories from a set of live servers, no HA backup information is propagated to the client
*
* The UDP address and port are used to listen for live servers in the cluster
*
@@ -134,7 +134,7 @@ else if (jmsFactoryType.equals(JMSFactoryType.TOPIC_XA_CF))
}
/**
- * Create a ActiveMQConnectionFactory which will receive cluster topology updates from the cluster
+ * Create an ActiveMQConnectionFactory which will receive cluster topology updates from the cluster
* as servers leave or join and new backups are appointed or removed.
*
* The initial list of servers supplied in this method is simply to make an initial connection to
@@ -180,7 +180,7 @@ else if (jmsFactoryType.equals(JMSFactoryType.TOPIC_XA_CF))
}
/**
- * Create a ActiveMQConnectionFactory which creates session factories using a static list of
+ * Create an ActiveMQConnectionFactory which creates session factories using a static list of
* transportConfigurations.
*
* The ActiveMQConnectionFactory is not updated automatically as the cluster topology changes, and
diff --git a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/api/jms/management/JMSManagementHelper.java b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/api/jms/management/JMSManagementHelper.java
index 0939795b3d6..c7504bb3856 100644
--- a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/api/jms/management/JMSManagementHelper.java
+++ b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/api/jms/management/JMSManagementHelper.java
@@ -54,7 +54,7 @@ public static void putAttribute(final Message message, final String resourceName
}
/**
- * Stores a operation invocation in a JMS message to invoke the corresponding operation the value from the server resource.
+ * Stores an operation invocation in a JMS message to invoke the corresponding operation the value from the server resource.
*
* @param message JMS message
* @param resourceName the name of the resource
@@ -89,7 +89,7 @@ private static JMSException convertFromException(final Exception e)
}
/**
- * Stores a operation invocation in a JMS message to invoke the corresponding operation the value from the server resource.
+ * Stores an operation invocation in a JMS message to invoke the corresponding operation the value from the server resource.
*
* @param message JMS message
* @param resourceName the name of the server resource
diff --git a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQSession.java b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQSession.java
index de536926abe..30397e8b33f 100644
--- a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQSession.java
+++ b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQSession.java
@@ -307,7 +307,7 @@ public MessageProducer createProducer(final Destination destination) throws JMSE
{
if (destination != null && !(destination instanceof ActiveMQDestination))
{
- throw new InvalidDestinationException("Not a ActiveMQ Artemis Destination:" + destination);
+ throw new InvalidDestinationException("Not an ActiveMQ Artemis Destination:" + destination);
}
try
@@ -364,7 +364,7 @@ public MessageConsumer createConsumer(final Destination destination,
if (!(destination instanceof ActiveMQDestination))
{
- throw new InvalidDestinationException("Not a ActiveMQDestination:" + destination);
+ throw new InvalidDestinationException("Not an ActiveMQDestination:" + destination);
}
ActiveMQDestination jbdest = (ActiveMQDestination)destination;
@@ -460,7 +460,7 @@ public TopicSubscriber createDurableSubscriber(final Topic topic,
checkTopic(topic);
if (!(topic instanceof ActiveMQDestination))
{
- throw new InvalidDestinationException("Not a ActiveMQTopic:" + topic);
+ throw new InvalidDestinationException("Not an ActiveMQTopic:" + topic);
}
if ("".equals(messageSelector))
{
@@ -881,7 +881,7 @@ public QueueBrowser createBrowser(final Queue queue, String filterString) throws
}
if (!(queue instanceof ActiveMQDestination))
{
- throw new InvalidDestinationException("Not a ActiveMQQueue:" + queue);
+ throw new InvalidDestinationException("Not an ActiveMQQueue:" + queue);
}
if ("".equals(filterString))
{
diff --git a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/SelectorTranslator.java b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/SelectorTranslator.java
index a9e8d48fedc..15509f96953 100644
--- a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/SelectorTranslator.java
+++ b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/SelectorTranslator.java
@@ -21,7 +21,7 @@
/**
*
- * This class converts a JMS selector expression into a ActiveMQ Artemis core filter expression.
+ * This class converts a JMS selector expression into an ActiveMQ Artemis core filter expression.
*
* JMS selector and ActiveMQ Artemis filters use the same syntax but have different identifiers.
*
diff --git a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/referenceable/ConnectionFactoryObjectFactory.java b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/referenceable/ConnectionFactoryObjectFactory.java
index bec515f3945..ca9ab6d721f 100644
--- a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/referenceable/ConnectionFactoryObjectFactory.java
+++ b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/referenceable/ConnectionFactoryObjectFactory.java
@@ -27,7 +27,7 @@
*
* A ConnectionFactoryObjectFactory.
*
- * Given a reference - reconstructs a ActiveMQRAConnectionFactory
+ * Given a reference - reconstructs an ActiveMQRAConnectionFactory
*/
public class ConnectionFactoryObjectFactory implements ObjectFactory
{
diff --git a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/referenceable/DestinationObjectFactory.java b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/referenceable/DestinationObjectFactory.java
index 7d2f7c435eb..7ae8ed135fb 100644
--- a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/referenceable/DestinationObjectFactory.java
+++ b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/referenceable/DestinationObjectFactory.java
@@ -27,7 +27,7 @@
*
* A DestinationObjectFactory.
*
- * Given a Reference - reconstructs a ActiveMQDestination
+ * Given a Reference - reconstructs an ActiveMQDestination
*/
public class DestinationObjectFactory implements ObjectFactory
{
diff --git a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
index ee5d1ce588f..4424418edfc 100644
--- a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
+++ b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
@@ -1840,7 +1840,7 @@ private static void copyProperties(final Message msg) throws JMSException
if (val instanceof byte[] == false)
{
- //Can't set byte[] array props through the JMS API - if we're bridging a ActiveMQ Artemis message it might have such props
+ //Can't set byte[] array props through the JMS API - if we're bridging an ActiveMQ Artemis message it might have such props
msg.setObjectProperty(propName, entry.getValue());
}
else if (msg instanceof ActiveMQMessage)
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 a82b8a6f96d..b09ee884aee 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
@@ -30,7 +30,7 @@
/**
* Simple bootstrap class that parses activemq config files (server and jms and security) and starts
- * a ActiveMQServer instance and populates it with configured JMS endpoints.
+ * an ActiveMQServer instance and populates it with configured JMS endpoints.
*
* 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
diff --git a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConnectionContext.java b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConnectionContext.java
index e26e6b19a11..def94b6c658 100644
--- a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConnectionContext.java
+++ b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConnectionContext.java
@@ -52,7 +52,7 @@ public class AMQConnectionContext
private boolean faultTolerant;
private final AtomicBoolean stopping = new AtomicBoolean();
private final MessageEvaluationContext messageEvaluationContext;
- private boolean dontSendReponse;
+ private boolean dontSendResponse;
private boolean clientMaster = true;
private ConnectionState connectionState;
private XATransactionId xid;
@@ -97,7 +97,7 @@ public AMQConnectionContext copy()
rc.networkConnection = this.networkConnection;
rc.faultTolerant = this.faultTolerant;
rc.stopping.set(this.stopping.get());
- rc.dontSendReponse = this.dontSendReponse;
+ rc.dontSendResponse = this.dontSendResponse;
rc.clientMaster = this.clientMaster;
return rc;
}
@@ -334,12 +334,12 @@ public AtomicBoolean getStopping()
public void setDontSendReponse(boolean b)
{
- this.dontSendReponse = b;
+ this.dontSendResponse = b;
}
public boolean isDontSendReponse()
{
- return dontSendReponse;
+ return dontSendResponse;
}
/**
diff --git a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQSubscription.java b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQSubscription.java
index 03436d1ac7e..f683eea5cda 100644
--- a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQSubscription.java
+++ b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQSubscription.java
@@ -105,7 +105,7 @@ public interface AMQSubscription extends AMQSubscriptionRecovery
void gc();
/**
- * Used by a Slave Broker to update dispatch infomation
+ * Used by a Slave Broker to update dispatch information
* @param mdn
* @throws Exception
*/
diff --git a/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonContextSender.java b/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonContextSender.java
index e158a74f64a..31ac8a4b92c 100644
--- a/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonContextSender.java
+++ b/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonContextSender.java
@@ -28,7 +28,7 @@
import org.proton.plug.util.NettyWritable;
/**
- * A this is a wrapper around a ActiveMQ Artemis ServerConsumer for handling outgoing messages and incoming acks via a Proton Sender
+ * A this is a wrapper around an ActiveMQ Artemis ServerConsumer for handling outgoing messages and incoming acks via a Proton Sender
*/
public abstract class AbstractProtonContextSender extends ProtonInitializable implements ProtonDeliveryHandler
{
diff --git a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompDecoder.java b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompDecoder.java
index 453e466d96b..51176e60410 100644
--- a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompDecoder.java
+++ b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompDecoder.java
@@ -183,7 +183,7 @@ public boolean hasBytes()
* terminated with a null character
*
* Note: This is the decoder for 1.0 stomp frames. However to support for stomp 1.1
- * and 1.2, it is also responsible for giving out an proper exception when it detects
+ * and 1.2, it is also responsible for giving out a proper exception when it detects
* unsupported EOLs ("\r\n" valid for 1.2 only). The StompConnection will switch
* to proper version decoders on catching such exceptions.
*/
diff --git a/artemis-ra/src/main/java/org/apache/activemq/artemis/ra/ActiveMQRAService.java b/artemis-ra/src/main/java/org/apache/activemq/artemis/ra/ActiveMQRAService.java
index 94f66dfff09..9d585373db5 100644
--- a/artemis-ra/src/main/java/org/apache/activemq/artemis/ra/ActiveMQRAService.java
+++ b/artemis-ra/src/main/java/org/apache/activemq/artemis/ra/ActiveMQRAService.java
@@ -24,7 +24,7 @@
/**
- * A ActiveMQRAService ensures that ActiveMQ Artemis Resource Adapter will be stopped *before* the ActiveMQ Artemis server.
+ * An ActiveMQRAService ensures that ActiveMQ Artemis Resource Adapter will be stopped *before* the ActiveMQ Artemis server.
* https://jira.jboss.org/browse/HORNETQ-339
*/
public class ActiveMQRAService
diff --git a/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/push/ActiveMQPushStrategy.java b/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/push/ActiveMQPushStrategy.java
index de5488782d9..62230f1d4da 100644
--- a/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/push/ActiveMQPushStrategy.java
+++ b/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/push/ActiveMQPushStrategy.java
@@ -24,7 +24,7 @@
import org.jboss.resteasy.spi.Link;
/**
- * Forwarding to a ActiveMQ/REST-* endpoing
+ * Forwarding to an ActiveMQ/REST-* endpoing
*/
public class ActiveMQPushStrategy extends UriTemplateStrategy
{
diff --git a/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/ComparisonExpression.java b/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/ComparisonExpression.java
index e1fc014d73e..2aecfbcb3af 100755
--- a/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/ComparisonExpression.java
+++ b/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/ComparisonExpression.java
@@ -156,7 +156,7 @@ public Object evaluate(Filterable message) throws FilterException
{
return Boolean.FALSE;
// throw new RuntimeException("LIKE can only operate on String
- // identifiers. LIKE attemped on: '" + rv.getClass());
+ // identifiers. LIKE attempted on: '" + rv.getClass());
}
return likePattern.matcher((String) rv).matches() ? Boolean.TRUE : Boolean.FALSE;
@@ -230,7 +230,7 @@ public static BooleanExpression createEqual(Expression left, Expression right)
{
checkEqualOperand(left);
checkEqualOperand(right);
- checkEqualOperandCompatability(left, right);
+ checkEqualOperandCompatibility(left, right);
return doCreateEqual(left, right);
}
@@ -393,7 +393,7 @@ public static void checkEqualOperand(Expression expr)
* @param left
* @param right
*/
- private static void checkEqualOperandCompatability(Expression left, Expression right)
+ private static void checkEqualOperandCompatibility(Expression left, Expression right)
{
if (left instanceof ConstantExpression && right instanceof ConstantExpression)
{
diff --git a/artemis-selector/src/main/javacc/HyphenatedParser.jj b/artemis-selector/src/main/javacc/HyphenatedParser.jj
index f7ea82e536b..8beb85a2c4f 100755
--- a/artemis-selector/src/main/javacc/HyphenatedParser.jj
+++ b/artemis-selector/src/main/javacc/HyphenatedParser.jj
@@ -134,7 +134,7 @@ TOKEN [IGNORE_CASE] :
}
// ----------------------------------------------------------------------------
-// Grammer
+// Grammar
// ----------------------------------------------------------------------------
BooleanExpression JmsSelector() :
{
diff --git a/artemis-selector/src/main/javacc/StrictParser.jj b/artemis-selector/src/main/javacc/StrictParser.jj
index 1085813c135..2be6725f3cf 100755
--- a/artemis-selector/src/main/javacc/StrictParser.jj
+++ b/artemis-selector/src/main/javacc/StrictParser.jj
@@ -134,7 +134,7 @@ TOKEN [IGNORE_CASE] :
}
// ----------------------------------------------------------------------------
-// Grammer
+// Grammar
// ----------------------------------------------------------------------------
BooleanExpression JmsSelector() :
{
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/filter/impl/FilterImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/filter/impl/FilterImpl.java
index ca9a41ea656..00b414ddb26 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/filter/impl/FilterImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/filter/impl/FilterImpl.java
@@ -29,7 +29,7 @@
import org.apache.activemq.artemis.core.server.ServerMessage;
/**
-* This class implements a ActiveMQ Artemis filter
+* This class implements an ActiveMQ Artemis filter
*
* ActiveMQ Artemis filters have the same syntax as JMS 1.1 selectors, but the identifiers are different.
*
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/messagecounter/MessageCounter.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/messagecounter/MessageCounter.java
index c3ed030538b..255fc512854 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/messagecounter/MessageCounter.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/messagecounter/MessageCounter.java
@@ -138,7 +138,7 @@ public void run()
public synchronized void onTimer()
{
// Actor approach here: Instead of having the Counter locking the queue, we will use the Queue's executor
- // instead of possibly making an lock on the queue.
+ // instead of possibly making a lock on the queue.
// This way the scheduled Threads will be free to keep doing their pings in case the server is busy with paging or
// any other deliveries
serverQueue.getExecutor().execute(onTimeExecutor);
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionCounterImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionCounterImpl.java
index 1706b825fce..79f2aac4665 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionCounterImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionCounterImpl.java
@@ -396,14 +396,14 @@ public ItemOper(PageSubscriptionCounterImpl counter, long id, int add)
{
this.counter = counter;
this.id = id;
- this.ammount = add;
+ this.amount = add;
}
PageSubscriptionCounterImpl counter;
long id;
- int ammount;
+ int amount;
}
private static class CounterOperations extends TransactionOperationAbstract implements TransactionOperation
@@ -415,7 +415,7 @@ public void afterCommit(Transaction tx)
{
for (ItemOper oper : operations)
{
- oper.counter.incrementProcessed(oper.id, oper.ammount);
+ oper.counter.incrementProcessed(oper.id, oper.amount);
}
}
}
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageTransactionInfoImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageTransactionInfoImpl.java
index 083ee4a2b38..066c29bac74 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageTransactionInfoImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageTransactionInfoImpl.java
@@ -281,7 +281,7 @@ else if (rolledback)
// Inner classes -------------------------------------------------
/** a Message shouldn't be delivered until it's committed
- * For that reason the page-refernce will be written right away
+ * For that reason the page-reference will be written right away
* But in certain cases we can only deliver after the commit
* For that reason we will perform a late delivery
* through the method redeliver.
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServers.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServers.java
index 75552d3ceb8..79cd370622c 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServers.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServers.java
@@ -28,7 +28,7 @@
/**
* ActiveMQServers is a factory class for instantiating ActiveMQServer instances.
*
- * This class should be used when you want to instantiate a ActiveMQServer instance for embedding in
+ * This class should be used when you want to instantiate an ActiveMQServer instance for embedding in
* your own application, as opposed to directly instantiating an implementing instance.
*/
public final class ActiveMQServers
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java
index 44cf136fb18..3cb048dfe2e 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java
@@ -295,7 +295,7 @@ public synchronized void voteComplete()
}
}
/**
- * this will connect to a node and then cast a vote. whether or not this vote is asked of the target node is dependant
+ * this will connect to a node and then cast a vote. whether or not this vote is asked of the target node is dependent
* on {@link org.apache.activemq.artemis.core.server.cluster.qourum.Vote#isRequestServerVote()}
*/
private final class VoteRunnable implements Runnable
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumVote.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumVote.java
index 9e28d17b792..7ad4aa510d0 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumVote.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumVote.java
@@ -32,7 +32,7 @@ public QuorumVote(SimpleString name)
}
/**
- * called by the {@link org.apache.activemq.artemis.core.server.cluster.qourum.QuorumManager} when one of teh nodes in the quorum is
+ * called by the {@link org.apache.activemq.artemis.core.server.cluster.qourum.QuorumManager} when one of the nodes in the quorum is
* successfully connected to. The QuorumVote can then decide whether or not a decision can be made with just that information.
*
* @return the vote to use
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
index 8e0d1ff3758..29a45090e99 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
@@ -106,7 +106,7 @@ public class QueueImpl implements Queue
public static final int CHECK_QUEUE_SIZE_PERIOD = 100;
/**
- * If The system gets slow for any reason, this is the maximum time an Delivery or
+ * If The system gets slow for any reason, this is the maximum time a Delivery or
* or depage executor should be hanging on
*/
public static final int DELIVERY_TIMEOUT = 1000;
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/transaction/Transaction.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/transaction/Transaction.java
index 6fd75b0bd06..c548cd9391e 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/transaction/Transaction.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/transaction/Transaction.java
@@ -25,7 +25,7 @@
import org.apache.activemq.artemis.core.server.impl.RefsOperation;
/**
- * A ActiveMQ Artemis internal transaction
+ * An ActiveMQ Artemis internal transaction
*/
public interface Transaction
{
diff --git a/artemis-server/src/main/resources/schema/artemis-configuration.xsd b/artemis-server/src/main/resources/schema/artemis-configuration.xsd
index af28c092fc0..6f2583108a2 100644
--- a/artemis-server/src/main/resources/schema/artemis-configuration.xsd
+++ b/artemis-server/src/main/resources/schema/artemis-configuration.xsd
@@ -1223,7 +1223,7 @@
This example demonstrates how you can listen on failover event on the client side. In this example there are two nodes running in a cluster, both server will be running for start,
- but after a while the first server will crash. This will trigger an fail-over event. To run the example, simply type This example shows you how to configure ActiveMQ Artemis so messages are expipired after a certain time.. This example shows you how to configure ActiveMQ Artemis so messages are expipired after a certain time. Messages can be retained in the messaging system for a limited period of time before being removed.
JMS specification states that clients should not receive messages that have been expired (but it does not guarantee this will not happen). ActiveMQ Artemis can assign a expiry address to a given queue so that when messages are expired, they are removed from the queue and
- routed to an this address. These "expired" messages can later be consumed for further inspection.
+ routed to this address. These "expired" messages can later be consumed for further inspection.
The example will send 1 message with a short time-to-live to a queue. We will wait for the message to expire and checks that the message
is no longer in the queue it was sent to.
diff --git a/examples/jms/message-counters/readme.html b/examples/jms/message-counters/readme.html
index 8a7f4c22ead..63b5d97f99f 100644
--- a/examples/jms/message-counters/readme.html
+++ b/examples/jms/message-counters/readme.html
@@ -43,7 +43,7 @@
* The timestamp corresponds to the time this message
- * was handled by a ActiveMQ Artemis server.
+ * was handled by an ActiveMQ Artemis server.
*/
long getTimestamp();
@@ -196,7 +196,7 @@ public interface Message
boolean isLargeMessage();
/**
- * Returns the message body as a ActiveMQBuffer
+ * Returns the message body as an ActiveMQBuffer
*/
ActiveMQBuffer getBodyBuffer();
@@ -211,7 +211,7 @@ public interface Message
Message writeBodyBufferString(String string);
/**
- * Returns a copy of the message body as a ActiveMQBuffer. Any modification
+ * Returns a copy of the message body as an ActiveMQBuffer. Any modification
* of this buffer should not impact the underlying buffer.
*/
ActiveMQBuffer getBodyBufferCopy();
@@ -285,7 +285,7 @@ public interface Message
Message putCharProperty(String key, char value);
/**
- * Puts a int property in this message.
+ * Puts an int property in this message.
*
* @param key property name
* @param value property value
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ActiveMQClient.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ActiveMQClient.java
index 327245fedc5..9619e7cb362 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ActiveMQClient.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ActiveMQClient.java
@@ -115,7 +115,7 @@ public final class ActiveMQClient
public static final String DEFAULT_CORE_PROTOCOL = "CORE";
/**
- * Creates a ActiveMQConnectionFactory;
+ * Creates an ActiveMQConnectionFactory;
*
* @return the ActiveMQConnectionFactory
*/
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientConsumer.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientConsumer.java
index ae62d3653a5..7ab33d1680e 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientConsumer.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClientConsumer.java
@@ -46,7 +46,7 @@ public interface ClientConsumer extends AutoCloseable
*
* It is possible to configure a factory using the setter methods only if no session has been created.
- * Once a session is created, the configuration is fixed and any call to a setter method will throw a IllegalStateException.
+ * Once a session is created, the configuration is fixed and any call to a setter method will throw an IllegalStateException.
*/
public interface ClientSessionFactory extends AutoCloseable
{
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/SendAcknowledgementHandler.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/SendAcknowledgementHandler.java
index 776f9337f3e..5d7c466c7dd 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/SendAcknowledgementHandler.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/SendAcknowledgementHandler.java
@@ -19,7 +19,7 @@
import org.apache.activemq.artemis.api.core.Message;
/**
- * A SendAcknowledgementHandler notifies a client when an message sent asynchronously has been
+ * A SendAcknowledgementHandler notifies a client when a message sent asynchronously has been
* received by the server.
* Creating a broker
-For a full list of availble options for the create process you may use:
+For a full list of available options for the create process you may use:
$ ./artemis help create
diff --git a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/api/jms/ActiveMQJMSClient.java b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/api/jms/ActiveMQJMSClient.java
index 32e1769bf5f..d1f932d5d5d 100644
--- a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/api/jms/ActiveMQJMSClient.java
+++ b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/api/jms/ActiveMQJMSClient.java
@@ -37,7 +37,7 @@
public class ActiveMQJMSClient
{
/**
- * Creates a ActiveMQConnectionFactory;
+ * Creates an ActiveMQConnectionFactory;
*
* @return the ActiveMQConnectionFactory
*/
@@ -48,7 +48,7 @@ public static ActiveMQConnectionFactory createConnectionFactory(final String url
}
/**
- * Creates a ActiveMQConnectionFactory that receives cluster topology updates from the cluster as
+ * Creates an ActiveMQConnectionFactory that receives cluster topology updates from the cluster as
* servers leave or join and new backups are appointed or removed.
* Client Side Kickoff Example
Example step-by-step
mvn verify -Pexample from this directoryExample step-by-step
We now consume those messages on *both* server 0 and server 1.
Note that the messages have been load-balanced between the two nodes, with some
messages on node 0 and others on node 1.
- The "logical" subscription is distributed across the cluster an contains exactly one copy of all the messages sent.
+ The "logical" subscription is distributed across the cluster and contains exactly one copy of all the messages sent.
diff --git a/examples/jms/clustered-durable-subscription/src/main/java/org/apache/activemq/artemis/jms/example/ClusteredDurableSubscriptionExample.java b/examples/jms/clustered-durable-subscription/src/main/java/org/apache/activemq/artemis/jms/example/ClusteredDurableSubscriptionExample.java
index e297ff698f1..c5b3be41d68 100644
--- a/examples/jms/clustered-durable-subscription/src/main/java/org/apache/activemq/artemis/jms/example/ClusteredDurableSubscriptionExample.java
+++ b/examples/jms/clustered-durable-subscription/src/main/java/org/apache/activemq/artemis/jms/example/ClusteredDurableSubscriptionExample.java
@@ -133,7 +133,7 @@ public boolean runExample() throws Exception
// Step 14. We now consume those messages on *both* server 0 and server 1.
// Note that the messages have been load-balanced between the two nodes, with some
// messages on node 0 and others on node 1.
- // The "logical" subscription is distributed across the cluster an contains exactly one copy of all the
+ // The "logical" subscription is distributed across the cluster and contains exactly one copy of all the
// messages
for (int i = 0; i < numMessages; i += 2)
diff --git a/examples/jms/embedded-simple/src/main/java/org/apache/activemq/artemis/jms/example/EmbeddedExample.java b/examples/jms/embedded-simple/src/main/java/org/apache/activemq/artemis/jms/example/EmbeddedExample.java
index f42257f260c..82218730862 100644
--- a/examples/jms/embedded-simple/src/main/java/org/apache/activemq/artemis/jms/example/EmbeddedExample.java
+++ b/examples/jms/embedded-simple/src/main/java/org/apache/activemq/artemis/jms/example/EmbeddedExample.java
@@ -36,7 +36,7 @@
import org.apache.activemq.artemis.api.jms.JMSFactoryType;
/**
- * This example demonstrates how to run a ActiveMQ Artemis embedded with JMS
+ * This example demonstrates how to run an ActiveMQ Artemis embedded with JMS
*/
public class EmbeddedExample extends ActiveMQExample
{
diff --git a/examples/jms/embedded/src/main/java/org/apache/activemq/artemis/jms/example/EmbeddedExample.java b/examples/jms/embedded/src/main/java/org/apache/activemq/artemis/jms/example/EmbeddedExample.java
index 255bf738224..93000585566 100644
--- a/examples/jms/embedded/src/main/java/org/apache/activemq/artemis/jms/example/EmbeddedExample.java
+++ b/examples/jms/embedded/src/main/java/org/apache/activemq/artemis/jms/example/EmbeddedExample.java
@@ -42,7 +42,7 @@
import org.apache.activemq.artemis.jms.server.embedded.EmbeddedJMS;
/**
- * This example demonstrates how to run a ActiveMQ Artemis embedded with JMS
+ * This example demonstrates how to run an ActiveMQ Artemis embedded with JMS
*/
public final class EmbeddedExample extends ActiveMQExample
{
diff --git a/examples/jms/expiry/readme.html b/examples/jms/expiry/readme.html
index 24b3ff7c4f9..acbbe4bbeaa 100644
--- a/examples/jms/expiry/readme.html
+++ b/examples/jms/expiry/readme.html
@@ -27,11 +27,11 @@
JMS Expiration Example
- Example setup
Queues are sampled every 10 seconds by default. For this example we will reduce it to 2 seconds by setting message-counter-sample-period to 2000.
ActiveMQ Artemis holds in memory the message counters' history for a maximum number of days (10 by default). We can change the number of days the history is kept by setting
the message-counter-max-day-history parameter.
The sample period and the max day history parameters have an small impact on the performance of ActiveMQ Artemis (the resources taken to sample a queue are not available to the system's +
The sample period and the max day history parameters have a small impact on the performance of ActiveMQ Artemis (the resources taken to sample a queue are not available to the system's normal use). You should set these parameters accordingly to the use and throughput of your messages.