Skip to content

Instantly share code, notes, and snippets.

@vkmc
Last active August 29, 2015 14:03
Show Gist options
  • Save vkmc/c6cb32005a20d8c8926a to your computer and use it in GitHub Desktop.
Save vkmc/c6cb32005a20d8c8926a to your computer and use it in GitHub Desktop.
Transport AMQP 1.0 - Messages
# Messages
Marconi AMQP
POST MESSAGES post_message operation
./client.py amqp://127.0.0.1:8888/poptart/
{subject: 'Saying hi!', body: 'POPTARTS @¿@'}
LIST MESSAGES [D] list_message operation
./client.py amqp://127.0.0.1:8888/poptart/messages
OR
./client.py amqp://127.0.0.1:8888/poptart/
{subject: 'LIST_MESSAGES'}
GET MESSAGE BY ID [D] get_message_id operation
./client.py amqp://127.0.0.1:8888/poptart/messages/id
OR
./client.py amqp://127.0.0.1:8888/poptart
{subject: 'GET_BY_ID', body: 'id1'}
GET MESSAGES BY IDS [D] get_messages_id operation
./client.py amqp://127.0.0.1:8888/poptart/messages/ids
OR
./client.py amqp://127.0.0.1:8888/poptart
{subject: 'GET_BY_ID', body: 'id1, id2, id3, ...'}
DELETE [D] delete operation
./client.py amqp://127.0.0.1:8888/poptart/messages/id
{subject: 'DELETE'}
OR
./client.py amqp://127.0.0.1:8888/poptart
{subject: 'DELETE', id: 'id1'}
[D] Discuss during the meeting
TO DO
- What to do if the client doesn't specify any queue? E.g. ./client.py amqp://127.0.0.1:8888. Raise a Marconi exception.
- Operations marked with [D] - most of them - don't fit any AMQP use case. The downside is that AMQP users will find it weird. The good part is that we are giving support for more Marconi operations.
# Queues
# Claims
# Health
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment