|
ActiveMQ supports the AMQP 1.0 protocol which is an OASIS standard.
Enabling the ActiveMQ Broker for AMQPIts very easy to enable ActiveMQ for AMQP. Just add a connector to the broker using the amqp URL. <transportConnectors> <transportConnector name="amqp" uri="amqp://0.0.0.0:5672"/> </transportConnectors> It is enabled in the default ActiveMQ server configuration. For more help see Run Broker. SecurityThe AMQP implementation fully supports an ActiveMQ security mechanism. This means that the broker accepts plain SASL authentication. Also, the authorization policies will be applied when you try to access (read/write) certain destinations.
Enabling AMQP over NIOFor better scalability (and performance) you might want to run the AMQP protocol over the NIO transport. To do that just use amqp+nio transport prefix instead of amqp. For example, add the following transport configuration in your XML file:
<transportConnector name="amqp+nio" uri="amqp+nio://localhost:5672"/>
This transport uses the NIO transport underneath and will generally use much less threads than the standard connector. This connector can help if you want to use large number of queues Enabling AMQP over SSLIt's easy to configure ActiveMQ to use AMQP over a SSL connection. All you have to do is use the amqp+ssl transport prefix instead of amqp. For example, add the following transport configuration in your XML file:
<transportConnector name="amqp+ssl" uri="amqp+ssl://localhost:5671"/>
Working with Destinations with AMQPYou should prefix destination address with `queue://` to use Queue based destinations or `topic://` to use topic based destinations. If an AMQP address is used without the prefix, it will be used as a Queue. Mapping to JMSThere are three basic conversion strategies that can be used with AMQP and interoperating with the JMS API.
Set the transformer transport option on the transportConnector to the desired mapping strategy. For example, to interoperate with JMS at the payload level, set the transformer option to jms
<transportConnector name="amqp" uri="amqp://localhost:5672?transport.transformer=jms"/>
AMQP 1.0 client libraryYou can use Apache Qpid Proton. |