18#ifndef _ACTIVEMQ_TRANSPORT_CORRELATOR_RESPONSECORRELATOR_H_
19#define _ACTIVEMQ_TRANSPORT_CORRELATOR_RESPONSECORRELATOR_H_
46 class AMQCPP_API ResponseCorrelator :
public TransportFilter {
53 ResponseCorrelator(
const ResponseCorrelator&);
54 ResponseCorrelator& operator= (
const ResponseCorrelator&);
#define AMQCPP_API
Definition Config.h:30
Pointer< Transport > next
The transport that this filter wraps around.
Definition TransportFilter.h:54
virtual void onException(const decaf::lang::Exception &ex)
Event handler for an exception from a command transport.
virtual Pointer< Response > request(const Pointer< Command > command)
Sends the given command to the broker and then waits for the response.
virtual Pointer< Response > request(const Pointer< Command > command, unsigned int timeout)
Sends the given command to the broker and then waits for the response.
virtual ~ResponseCorrelator()
virtual void oneway(const Pointer< Command > command)
Sends a one-way command.
ResponseCorrelator(Pointer< Transport > next)
Creates a new ResponseCorrelator transport filter that wraps the given transport.
virtual Pointer< FutureResponse > asyncRequest(const Pointer< Command > command, const Pointer< ResponseCallback > responseCallback)
Sends a commands asynchronously, returning a FutureResponse object that the caller can use to check t...
virtual void onCommand(const Pointer< Command > command)
This is called in the context of the nested transport's reading thread.
virtual void doClose()
Subclasses can override this method to do their own close work.
Definition Exception.h:38
Decaf's implementation of a Smart Pointer that is a template on a Type and is Thread Safe if the defa...
Definition Pointer.h:53
Definition ResponseCorrelator.h:33
Definition AbstractTransportFactory.h:30
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24