This closes #228
This commit is contained in:
commit
cce107fadc
|
@ -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");
|
||||||
|
|
||||||
|
|
|
@ -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 + "]");
|
||||||
}
|
}
|
||||||
|
|
|
@ -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);
|
||||||
}
|
}
|
||||||
|
|
|
@ -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
|
||||||
|
|
|
@ -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);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -2552,4 +2552,4 @@ public abstract class ActiveMQTestBase extends Assert {
|
||||||
super.finalize();
|
super.finalize();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -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.
|
||||||
|
|
|
@ -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
|
||||||
|
|
|
@ -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);
|
||||||
|
|
|
@ -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">
|
||||||
|
|
|
@ -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);
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue