« Index of all namespaces of this project
(->AMQPCredentials username password port host virtual-host)
Positional factory function for class fudd.wabbit.AMQPCredentials.
(consumer channel queue-name creds)
Provide a queue-name and credentials. Runs a consumer that will only consume once. Great set up for a polling style consumer.
(create-and-bind-queue! bindings channel & [durability])
A one off connnect, create and abind queue to a provided exchange util function.Creates a queue and binds it to the provided exchange. Make sure you keep track of what durability you're setting your queue to be, because you can get connection errors later if you have it incorrect.
(create-exchange exchange-data channel)
Create an exchange on the RabbitMQ server instance.
Factory function for class fudd.wabbit.AMQPCredentials, taking a map of keywords to field values.
(open-channel connection & [prefetch])
Utility function to open a channel on a connection with a RabbitMQ server. Pass an optional QOS (quality of service) value if you want.
(publish conn directions & [creds])
Publish a message through the provided exchange using the provided key. You must provide your AMQP credentials as the second argument. Publishing style is dependent upon what exchange and queues/routing-keys are involved in the message being sent. For more information, refer to the RabbitMQ documentation.