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