railway_ipc v0.1.6 RailwayIpc.MessageConsumption

Link to this section Summary

Functions

decode_message(arg, message_module)

do_decode_message(message_consumption, message_module)

handle_message(arg)

new(payload, handle_module, exchange, queue)

persist_message(arg)

process(payload, handle_module, exchange, queue, message_module)

Link to this section Functions

Link to this function

decode_message(arg, message_module)

Link to this function

do_decode_message(message_consumption, message_module)

Link to this function

handle_message(arg)

Link to this function

new(payload, handle_module, exchange, queue)

Link to this function

persist_message(arg)

Link to this function

process(payload, handle_module, exchange, queue, message_module)