railway_ipc v0.1.6 RailwayIpc.Persistence
Link to this section Summary
Functions
Callback implementation for c:RailwayIpc.PersistenceBehaviour.get_consumed_message/1.
Callback implementation for c:RailwayIpc.PersistenceBehaviour.get_published_message/1.
Callback implementation for c:RailwayIpc.PersistenceBehaviour.insert_consumed_message/1.
Callback implementation for c:RailwayIpc.PersistenceBehaviour.insert_published_message/2.
Callback implementation for c:RailwayIpc.PersistenceBehaviour.lock_message/1.
Callback implementation for c:RailwayIpc.PersistenceBehaviour.update_consumed_message/2.
Link to this section Functions
consumed_message_query(uuid)
get_consumed_message(message_uuid)
Callback implementation for c:RailwayIpc.PersistenceBehaviour.get_consumed_message/1.
get_published_message(message_uuid)
Callback implementation for c:RailwayIpc.PersistenceBehaviour.get_published_message/1.
insert_consumed_message(message_consumption)
Callback implementation for c:RailwayIpc.PersistenceBehaviour.insert_consumed_message/1.
insert_published_message(message, exchange)
Callback implementation for c:RailwayIpc.PersistenceBehaviour.insert_published_message/2.
lock_message(consumed_message)
Callback implementation for c:RailwayIpc.PersistenceBehaviour.lock_message/1.
update_consumed_message(message_record, attrs)
Callback implementation for c:RailwayIpc.PersistenceBehaviour.update_consumed_message/2.