#include <InProcessBroker.h>
Public Types | |
| typedef std::vector< TaggedFrame > | Conversation |
| CLIENT | |
| BROKER | |
| enum | Sender { CLIENT, BROKER } |
Public Member Functions | |
| InProcessBroker (framing::ProtocolVersion ver=framing::highestProtocolVersion) | |
| void | connect (const std::string &, int) |
| void | init () |
| void | close () |
| void | setInputHandler (framing::InputHandler *handler) |
| Client's input handler. | |
| void | send (framing::AMQFrame *frame) |
| Called by client to send a frame. | |
Public Attributes | |
| Conversation | conversation |
| Entire client-broker conversation is recorded here. | |
Classes | |
| struct | TaggedFrame |
| A frame tagged with the sender. More... | |
Used to write round-trip tests without requiring an external broker process.
Also allows you to "snoop" on frames exchanged between client & broker.
see FramingTest::testRequestResponseRoundtrip() for example of use.
1.4.7