|
|
| Line 1: |
Line 1: |
| − | = Marconi AMQP API - v1 Blueprint =
| |
| | | | |
| − | == AMQP Transport ==
| |
| − |
| |
| − | AMQP has a well-defined transport protocol we will stick to. The current version of the AMQP transport driver won't implement concurrency, but is something we will be doing in the short term.
| |
| − |
| |
| − | == AMQP Messages ==
| |
| − |
| |
| − | AMQP also has a well defined structure for messages we will be using.
| |
| − |
| |
| − | == Interaction of an AMQP client with the Marconi server ==
| |
| − |
| |
| − | {| border="1" cellpadding="2" cellspacing="0"
| |
| − | | '''Marconi operation'''
| |
| − | | '''AMQP message'''
| |
| − | |-
| |
| − | | Post message
| |
| − | | ./client.py amqp://127.0.0.1:8888/poptart/ "Saying hi!" "Yada yada yada"
| |
| − | |-
| |
| − | |}
| |
| − |
| |
| − | == Publisher/Subscriber ==
| |
| − |
| |
| − | == Producer/Consumer ==
| |
