Spelling fixes

This commit is contained in:
Ville Skyttä 2015-11-03 12:08:59 +02:00 committed by Clebert Suconic
parent 797ecea5a9
commit 68c9f3fd69
10 changed files with 16 additions and 16 deletions

View File

@ -57,12 +57,12 @@ public interface Message {
SimpleString HDR_ACTUAL_EXPIRY_TIME = new SimpleString("_AMQ_ACTUAL_EXPIRY"); SimpleString HDR_ACTUAL_EXPIRY_TIME = new SimpleString("_AMQ_ACTUAL_EXPIRY");
/** /**
* The original address of a message when a message is transfered through DLQ or expiry * The original address of a message when a message is transferred through DLQ or expiry
*/ */
SimpleString HDR_ORIGINAL_ADDRESS = new SimpleString("_AMQ_ORIG_ADDRESS"); SimpleString HDR_ORIGINAL_ADDRESS = new SimpleString("_AMQ_ORIG_ADDRESS");
/** /**
* The original address of a message when a message is transfered through DLQ or expiry * The original address of a message when a message is transferred through DLQ or expiry
*/ */
SimpleString HDR_ORIGINAL_QUEUE = new SimpleString("_AMQ_ORIG_QUEUE"); SimpleString HDR_ORIGINAL_QUEUE = new SimpleString("_AMQ_ORIG_QUEUE");

View File

@ -82,7 +82,7 @@ public class TCPServerLocatorSchema extends AbstractServerLocatorSchema {
String newHost = IPV6Util.encloseHost(host); String newHost = IPV6Util.encloseHost(host);
// We really want to check the objects here // We really want to check the objects here
// Some bug finders may report this as an error, hence the SupressWarnings on this method // Some bug finders may report this as an error, hence the SuppressWarnings on this method
if (host != newHost) { if (host != newHost) {
params.put("host", "[" + host + "]"); params.put("host", "[" + host + "]");
} }

View File

@ -321,7 +321,7 @@ public class ClusterController implements ActiveMQComponent {
if (packet.getType() == PacketImpl.CLUSTER_CONNECT) { if (packet.getType() == PacketImpl.CLUSTER_CONNECT) {
ClusterConnection clusterConnection = acceptorUsed.getClusterConnection(); ClusterConnection clusterConnection = acceptorUsed.getClusterConnection();
//if this acceptor isnt associated with a cluster connection use the default //if this acceptor isn't associated with a cluster connection use the default
if (clusterConnection == null) { if (clusterConnection == null) {
clusterConnection = server.getClusterManager().getDefaultConnection(null); clusterConnection = server.getClusterManager().getDefaultConnection(null);
} }

View File

@ -44,7 +44,7 @@ public class JaasCertificateCallbackHandler implements CallbackHandler {
* *
* @param callbacks The callbacks requested. * @param callbacks The callbacks requested.
* @throws IOException * @throws IOException
* @throws UnsupportedCallbackException Thrown if an unkown Callback type is * @throws UnsupportedCallbackException Thrown if an unknown Callback type is
* encountered. * encountered.
*/ */
@Override @Override

View File

@ -1271,7 +1271,7 @@ public abstract class ActiveMQTestBase extends Assert {
if (server.isStarted()) { if (server.isStarted()) {
log.info(threadDump("Server didn't start")); log.info(threadDump("Server didn't start"));
fail("server didnt start: " + server); fail("Server didn't start: " + server);
} }
} }

View File

@ -23,7 +23,7 @@ is a whole section on configuring transports that can be found [here](configurin
The default configuration shipped with the ActiveMQ Artemis distribution comes with a number of acceptors already The default configuration shipped with the ActiveMQ Artemis distribution comes with a number of acceptors already
defined, one for each of the above protocols plus a generic acceptor that supports all protocols. To enable a defined, one for each of the above protocols plus a generic acceptor that supports all protocols. To enable a
protocol on a particular acceptor simply add a url parameter "protocol=AMQP,STOMP" to the acceptor url. Where the value protocol on a particular acceptor simply add a url parameter "protocol=AMQP,STOMP" to the acceptor url. Where the value
of the parameter is a comma separated list of protocol names. If the protocol parameter is ommited from the url all of the parameter is a comma separated list of protocol names. If the protocol parameter is omitted from the url all
protocols are enabled. protocols are enabled.
<!-- The following example enables only MQTT on port 1883 --> <!-- The following example enables only MQTT on port 1883 -->
@ -159,7 +159,7 @@ but if something fails and the message does not reach it's destination (say due
may be lost. This QoS has the least network traffic overhead and the least burden on the client and the broker and is often may be lost. This QoS has the least network traffic overhead and the least burden on the client and the broker and is often
useful for telemetry data where it doesn't matter if some of the data is lost. useful for telemetry data where it doesn't matter if some of the data is lost.
* QoS 1: AT LEAST ONCE: Guarentees that a message will reach it's intended recipient one or more times. The sender will * QoS 1: AT LEAST ONCE: Guarantees that a message will reach it's intended recipient one or more times. The sender will
continue to send the message until it receives an acknowledgment from the recipient, confirming it has received the message. continue to send the message until it receives an acknowledgment from the recipient, confirming it has received the message.
The result of this QoS is that the recipient may receive the message multiple times, and also increases the network The result of this QoS is that the recipient may receive the message multiple times, and also increases the network
overhead than QoS 0, (due to acks). In addition more burden is placed on the sender as it needs to store the message overhead than QoS 0, (due to acks). In addition more burden is placed on the sender as it needs to store the message
@ -189,14 +189,14 @@ Other subscribers to the will topic will receive the will message and can react
### Wild card subscriptions ### Wild card subscriptions
MQTT addresses are hierarchical much like a file system, and use "/" charactor to separate heirarchical levels. MQTT addresses are hierarchical much like a file system, and use "/" character to separate hierarchical levels.
Subscribers are able to subscribe to specific topics or to whole branches of a heirarchy. Subscribers are able to subscribe to specific topics or to whole branches of a hierarchy.
To subscribe to branches of an address hierarchy a subscriber can use wild cards. To subscribe to branches of an address hierarchy a subscriber can use wild cards.
There are 2 types of wild card in MQTT: There are 2 types of wild card in MQTT:
* "#" Multi level wild card. Adding this wild card to an address would match all branches of the address heirarchy * "#" Multi level wild card. Adding this wild card to an address would match all branches of the address hierarchy
under a specified node. For example: /uk/# Would match /uk/cities, /uk/cities/newcastle and also /uk/rivers/tyne. under a specified node. For example: /uk/# Would match /uk/cities, /uk/cities/newcastle and also /uk/rivers/tyne.
Subscribing to an address "#" would result in subscribing to all topics in the broker. This can be useful, but should Subscribing to an address "#" would result in subscribing to all topics in the broker. This can be useful, but should
be done so with care since it has significant performance implications. be done so with care since it has significant performance implications.

View File

@ -394,7 +394,7 @@ Depending on the user login data, authentication proceeds as follows:
- User logs in with a valid password — the guest login module fails to authenticate the user (because the user has - User logs in with a valid password — the guest login module fails to authenticate the user (because the user has
presented a password while the credentialsInvalidate option is enabled) and authentication proceeds to the properties presented a password while the credentialsInvalidate option is enabled) and authentication proceeds to the properties
login module. The properties login module sucessfully authenticates the user and returns. login module. The properties login module successfully authenticates the user and returns.
- User logs in with an invalid password — the guest login module fails to authenticate the user and authentication proceeds - User logs in with an invalid password — the guest login module fails to authenticate the user and authentication proceeds
to the properties login module. The properties login module also fails to authenticate the user. The nett result is to the properties login module. The properties login module also fails to authenticate the user. The nett result is

View File

@ -85,7 +85,7 @@ public class DelayedRedeliveryExample {
messageReceived = (TextMessage) messageConsumer.receive(3000); messageReceived = (TextMessage) messageConsumer.receive(3000);
if (messageReceived != null) { if (messageReceived != null) {
throw new IllegalStateException("Expected to recieve message."); throw new IllegalStateException("Expected to receive message.");
} }
System.out.println("Redelivery has been delayed so received message is " + messageReceived); System.out.println("Redelivery has been delayed so received message is " + messageReceived);

View File

@ -113,7 +113,7 @@ under the License.
<p>Since we have subscribed to a number of topics and sent messages to them, the client should now receive <p>Since we have subscribed to a number of topics and sent messages to them, the client should now receive
2 messages. We are not using callbacks here on message receive so we specifically call receive to get 2 messages. We are not using callbacks here on message receive so we specifically call receive to get
the messages. Once we recieve the message we convert the payload consisting of bytes back to a UTF8 the messages. Once we receive the message we convert the payload consisting of bytes back to a UTF8
encoded string and print the result.</p> encoded string and print the result.</p>
<pre class="prettyprint"> <pre class="prettyprint">

View File

@ -65,7 +65,7 @@ public class ActiveMQClusteredTest extends ActiveMQRAClusteredTestBase {
DummyMessageEndpoint endpoint = new DummyMessageEndpoint(latch); DummyMessageEndpoint endpoint = new DummyMessageEndpoint(latch);
DummyMessageEndpointFactory endpointFactory = new DummyMessageEndpointFactory(endpoint, false); DummyMessageEndpointFactory endpointFactory = new DummyMessageEndpointFactory(endpoint, false);
qResourceAdapter.endpointActivation(endpointFactory, spec); qResourceAdapter.endpointActivation(endpointFactory, spec);
//make sure thet activation didnt start, i.e. no MDB consumers //make sure thet activation didn't start, i.e. no MDB consumers
assertEquals(((Queue) server.getPostOffice().getBinding(MDBQUEUEPREFIXEDSIMPLE).getBindable()).getConsumerCount(), 0); assertEquals(((Queue) server.getPostOffice().getBinding(MDBQUEUEPREFIXEDSIMPLE).getBindable()).getConsumerCount(), 0);
qResourceAdapter.endpointDeactivation(endpointFactory, spec); qResourceAdapter.endpointDeactivation(endpointFactory, spec);