AMQP TCP

f review the docid 2quwgspcauwe1ubuqgcc8 overview amqp tcp integration enables an edge system to connect with an amqp broker supported versions supports rabbitmq versions starting with 2 0 but primarily tested against recent 3 x releases some features and behaviors may be server version specific supported communication outbound (publish data from edge to amqp broker) yes inbound (subscribe data from amqp broker to edge) no configurations variable detail required name enter a name for the connector yes hostname ip address or hostname of amqp broker (must be reachable from the edge system) yes port enter the amqp broker port yes virtual host specifies the namespace of permissions, exchanges, queues and bindings on the server no username enter the username no password enter the password no exchange enter the amqp exchange no exchange type select one of the following direct, fanout, topic, x custom no exchange durable see the exchange options section below no exchange auto delete see the exchange options section below no exchange internal see the exchange options section below no exchange no wait see the exchange options section below no routing key enter the amqp routing key yes iso8601 timestamp convert a message timestamp into iso8601 format before sending no throttling limit set a limit on the number of outbound messages per second if sending data to a server that has restrictions on the rate of incoming messages, this ensures that no messages are lost no persistent storage if enabled, messages in the outbound queue are stored on disk if there are interruptions in connection or power loss, messages will be retained and eventually sent when the connection is restored no queue mode select the sequence of data transfer fifo or lifo selecting fifo (first in first out) will send the earliest message first selecting lifo (last in first out) will send the latest message first no exchange options exchange names starting with "amq " are reserved for pre declared and standardized exchanges the client may declare an exchange starting with "amq " if the passive option is set, or the exchange already exists names can consist of a non empty sequence of letters, digits, hyphen, underscore, period, or colon each exchange belongs to one of a set of exchange kinds/types implemented by the server the exchange types define the functionality of the exchange i e how messages are routed through it once an exchange is declared, its type cannot be changed the common types are "direct", "fanout", "topic" and "headers" durable and non auto deleted exchanges survive server restarts and remain declared when there are no remaining bindings these selections are best for long lived exchange configurations like stable routes and default exchanges non durable and auto deleted exchanges are deleted when there are no remaining bindings and not restored on server restart these selections are useful for temporary topologies that should not pollute the virtual host on failure or after the consumers have completed non durable and non auto deleted exchanges remain while the server is running, including when there are no remaining bindings these selections are useful for temporary topologies that may have long delays between bindings durable and auto deleted exchanges survive server restarts and are removed before and after server restarts when there are no remaining bindings these selections are useful for robust temporary topologies or when you require binding durable queues to auto deleted exchanges note rabbitmq declares the default exchange types like 'amq fanout' as durable, so queues that bind to these pre declared exchanges must also be durable exchanges declared as internal do not accept publishing internal exchanges are useful when you wish to implement inter exchange topologies that should not be exposed to users of the broker when no wait is selected, you can continue without waiting for a confirmation from the server the channel may be closed because of an error add a notifyclose listener to respond to any exceptions compatibility validation this information is just for reference more products and versions may be supported provided they are compatible with the supported version as mentioned above product version date rabbitmq 3 6 6 nov 21, 2016