qsm v0.1.0 Qsm.SqsManager View Source

Link to this section Summary

Functions

Message handler function responsible for parsing sqs messages and enqueueing the next state

Function to place states on SQS queue. Used for both entry and transition

Link to this section Functions

Link to this function message_handler(queue_name, message) View Source
message_handler(Qsm.queue_name(), String.t()) :: :ok

Message handler function responsible for parsing sqs messages and enqueueing the next state.

Example

iex> msg = %Qsm.QueueMessage{module_name: Qsm.MockEntryState, body: "foo"}
iex> Qsm.SqsManager.message_handler("test_queue", Poison.encode!(msg))
:ok
Link to this function send_message(queue_name, state, data) View Source
send_message(Qsm.queue_name(), Qsm.State, Qsm.state_data()) :: :ok

Function to place states on SQS queue. Used for both entry and transition

Example

iex> Qsm.SqsManager.send_message("test_queue", Qsm.MockEntryState, "foo")
:ok