AMQP Connections
This page shows all existing AMQP connections. Via the context menu, you can edit and delete these or create new ones.
See also sections Input Agent AMQP and Response Route AMQP.
Icons in the Connection Overview
|
Active connection. Connection to the broker was successful. |
|
Active connection. Connection to the broker was not successful (e.g. authentication unsuccessful or server offline). |
|
Inactive connection. |
Creating a Connection
(1) The AMQP version (0.9.1, 1.0 and JMS). See also the following sections. Note : For AMQP connections of version 1.0 (and only there) the message header ContentType is set with the value of the system variable AMQP_SYS_ContentType. The message property ContentType, on the other hand, is set with AMQP_ContentType. Example value: application/json
(2) Here you specify the alias of a connected AMQP server. Note: The alias (and therefore the connection) is activated if the corresponding checkbox is set.
(3) The URL/IP and the port of the AMQP server. The default port is 5672.
(4) If SSL is used, the keystore, with the client certificate in format PKCS#12, is expected as file ./conf/amqp/<alias>/keycert.p12. The truststore, containing the public key of the server, is expected as file ./conf/amqp/<alias>/trustStore. The keystore and truststore have to be protected with the same passphrase (7). Obfuscation is allowed. See also (5).
Note: Item (4) applies to AMQP only.
(5) As an alternative to using a truststore, a certificate can be selected here. The certificate need to have option TLS Client set. If one has been selected, the value in (7) is deleted and the field disappears.
(6) User name and password if necessary.
(7) If (4) is set, but there is no passphrase specified (and (5) is not set), the SSL connection will not use a client certificate and the server certificates will not be checked. Keystore and truststore are not necessary in that case.
Special Features for Version 0.9.1
(1) See https://www.rabbitmq.com/vhosts.html.
(2) The connection timeout in seconds should be greater than 0. The value 0 means no timeout.
(3) If the checkbox is set, the queue is not created if it does not exist. This might generate an error if a profile wants to log on to a queue with an inbound agent of type AMQP that does not exist.
(4) If the checkbox is set, a queue that no longer has any profile 'listening' to it, is removed. This can be useful if queues are only used by Lobster_data.
You will also find settings (3) and (4) in the configuration file ./etc/startup.xml.
<
Set
name
=
"QueuesMustExist"
>false</
Set
>
<
Set
name
=
"RemoveQueueOnLastConsumer"
>true</
Set
>
JMS Settings
You can use these settings to connect to a JMS server. JMS queues can then be read out with an AMQP Input Agent and AMQP Response Routes can be used to write into JMS queues.
Note: Please place the jar file (e.g. activemq-all-5.10.0.jar) of your JMS server into folder ./extlib.
(1) Here, the initial JNDI Context Factory of the JMS server must be specified. When using ActiveMQ, you can use the value org.apache.activemq.jndi.ActiveMQInitialContextFactory.
(2) Here, the name of the Connection Factory (of the Context Factory) must be specified. When using ActiveMQ, you can use the default value ConnectionFactory.
(3) The URL of your JMS server. Note: SSL is unfortunately not very generic with JMS. The URL should start with ssl://<broker> instead of tcp://<broker> (unless the manufacturer already does something different). The certificate should be in the keystore (unless you can also override/pass this with JMS properties). Furthermore the two JMS properties jms.ssl.certificate.username and jms.ssl.certificate.password should be defined, see (5).
(4) Optionally, a client ID for the connection can be specified. A client ID is used to uniquely identify an application. This is necessary, for example, for so-called durable subscriptions. For details, see the documentation of your JMS server.
(5) Optionally, further JMS properties can be set for the connection here. For details, see the documentation of your JMS server.