#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.