Finalise Message interfaces

[bedrock-adam]

Message

Queue interface

Outboxer::Message.queue(messageable_type: "Event", messageable_id: "AA5312")
=> { id: 1, lock_version: 1 }

Publish interface(s)

when block passed

Outboxer::Message.publish do |message|
  => { id: 1, lock_version: 2, messageable_type: "Event", messageable_id: "AA5312" }
end

when no block passed

message = Outboxer::Message.publish
=> { id: 1, lock_version: 2, messageable_type: "Event", messageable_id: "AA5312" }

Outboxer::Message.published(id: message[:id], lock_version: message[:lock_version])
=> { id: 1 }

Outboxer::Message.publishing_failed(id: message[:id], lock_version: message[:lock_version])
=> { id: 1, lock_version: 3 }

Update interfaces

Outboxer::Message.requeue(id: message[:id], lock_version: message[:lock_version])
=> { id: 1, lock_version: 4 }

Outboxer::Message.delete(id: message[:id], lock_version: message[:lock_version])
=> { id: 1 }

Query interfaces

Outboxer::Message.find_by_id(id: 1)
=> { messages: [{ id: 1, lock_version: 6 }]}

Outboxer::Message.list
=> { messages: [{ id: 1, lock_version: 6 }]}

Outboxer::Message.count_by_status
Outboxer::Message.total_by_status