railway_ipc v0.2.5 RailwayIpc.RabbitMQ.RabbitMQAdapter
Link to this section Summary
Functions
Callback implementation for RailwayIpc.StreamBehaviour.ack/2.
Callback implementation for RailwayIpc.StreamBehaviour.bind_queue/2.
Callback implementation for RailwayIpc.StreamBehaviour.close_connection/1.
Callback implementation for RailwayIpc.StreamBehaviour.connect/0.
Callback implementation for RailwayIpc.StreamBehaviour.consume/4.
Callback implementation for RailwayIpc.StreamBehaviour.create_queue/3.
Callback implementation for RailwayIpc.StreamBehaviour.direct_publish/3.
Callback implementation for RailwayIpc.StreamBehaviour.get_channel/1.
Callback implementation for RailwayIpc.StreamBehaviour.get_channel_from_cache/3.
Callback implementation for RailwayIpc.StreamBehaviour.maybe_bind_queue/3.
Callback implementation for RailwayIpc.StreamBehaviour.maybe_create_exchange/2.
Callback implementation for RailwayIpc.StreamBehaviour.publish/3.
Callback implementation for RailwayIpc.StreamBehaviour.setup_exchange_and_queue/3.
Link to this section Functions
ack(channel, delivery_tag)
Callback implementation for RailwayIpc.StreamBehaviour.ack/2.
bind_queue(channel, map)
Callback implementation for RailwayIpc.StreamBehaviour.bind_queue/2.
close_connection(connection)
Callback implementation for RailwayIpc.StreamBehaviour.close_connection/1.
connect()
Callback implementation for RailwayIpc.StreamBehaviour.connect/0.
connection_url()
consume(channel, queue, consumer \\ self(), options \\ [])
Callback implementation for RailwayIpc.StreamBehaviour.consume/4.
create_queue(channel, queue, opts \\ [])
Callback implementation for RailwayIpc.StreamBehaviour.create_queue/3.
direct_publish(channel, queue, payload)
Callback implementation for RailwayIpc.StreamBehaviour.direct_publish/3.
get_channel(connection)
Callback implementation for RailwayIpc.StreamBehaviour.get_channel/1.
get_channel_from_cache(connection, channels, consumer_module)
Callback implementation for RailwayIpc.StreamBehaviour.get_channel_from_cache/3.
maybe_bind_queue(channel, queue, exchange)
Callback implementation for RailwayIpc.StreamBehaviour.maybe_bind_queue/3.
maybe_create_exchange(channel, exchange)
Callback implementation for RailwayIpc.StreamBehaviour.maybe_create_exchange/2.
publish(channel, exchange, payload)
Callback implementation for RailwayIpc.StreamBehaviour.publish/3.
setup_exchange_and_queue(channel, exchange, queue)
Callback implementation for RailwayIpc.StreamBehaviour.setup_exchange_and_queue/3.