CrossClj

2.3.2.1 docs

SourceDocs



RECENT
    VARS
    ->AMQPCredentials
    consumer
    create-and-bind-queue!
    create-exchange
    default-creds
    delete-exchange
    delete-queue
    map->AMQPCredentials
    open-channel
    publish
    start-connection
    wabbit-error

    « 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.
    
    (delete-exchange channel harsh exchange-name creds)
    Destroy an exchange.
    
    (delete-queue channel queue-name creds)
    Destroy a queue.
    
    (map->AMQPCredentials m__7585__auto__)
    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.
    
    (start-connection & [credentials])
    (wabbit-error message)
    Utility function so we can cohesively aggregate error messages.