exchange package:amqp

(default empty); A set of arguments for the declaration. The syntax and semantics of these arguments depends on the server implementation.

(default False); If set, the exchange is deleted when all queues have finished using it.

(default True); If set when creating a new exchange, the exchange will be marked as durable. Durable exchanges remain active when a server restarts. Non-durable exchanges (transient exchanges) are purged if/when a server restarts.

(default False); If set, the exchange may not be used directly by publishers, but only when bound to other exchanges. Internal exchanges are used to construct wiring that is not visible to applications.

(must be set); the name of the exchange

(default False); If set, the server will not create the exchange. The client can use this to check whether an exchange exists without modifying the server state.

(must be set); the type of the exchange ("fanout", "direct", "topic", "headers")

A record that contains the fields needed when creating a new exhange using declareExchange. The default values apply when you use newExchange.

bindExchange chan destinationName sourceName routingKey binds the exchange to the exchange using the provided routing key

an extended version of bindExchange that allows you to include arbitrary arguments. This is useful to use the headers exchange-type.

declares a new exchange on the AMQP server. Can be used like this: declareExchange channel newExchange {exchangeName = "myExchange", exchangeType = "fanout"}

deletes the exchange with the provided name

an ExchangeOpts with defaults set; you must override at least the exchangeName and exchangeType fields.

unbindExchange chan destinationName sourceName routingKey unbinds an exchange from an exchange. The routingKey must be identical to the one specified when binding the exchange.

an extended version of unbindExchange that allows you to include arguments. The arguments must be identical to the ones specified when binding the exchange.