summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/MessageHandlerImpl.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/MessageHandlerImpl.h')
-rw-r--r--cpp/src/qpid/broker/MessageHandlerImpl.h66
1 files changed, 15 insertions, 51 deletions
diff --git a/cpp/src/qpid/broker/MessageHandlerImpl.h b/cpp/src/qpid/broker/MessageHandlerImpl.h
index 47c8cf0ce0..86c54023b5 100644
--- a/cpp/src/qpid/broker/MessageHandlerImpl.h
+++ b/cpp/src/qpid/broker/MessageHandlerImpl.h
@@ -40,22 +40,16 @@ class MessageHandlerImpl :
public:
MessageHandlerImpl(CoreRefs& parent);
- void append(const framing::MethodContext&,
- const std::string& reference,
- const std::string& bytes );
+ void append(const framing::MethodContext& context);
- void cancel(const framing::MethodContext&,
- const std::string& destination );
+ void cancel(const std::string& destination );
- void checkpoint(const framing::MethodContext&,
- const std::string& reference,
+ void checkpoint(const std::string& reference,
const std::string& identifier );
- void close(const framing::MethodContext&,
- const std::string& reference );
+ void close(const std::string& reference );
- void consume(const framing::MethodContext&,
- uint16_t ticket,
+ void consume(uint16_t ticket,
const std::string& queue,
const std::string& destination,
bool noLocal,
@@ -63,62 +57,32 @@ class MessageHandlerImpl :
bool exclusive,
const framing::FieldTable& filter );
- void empty( const framing::MethodContext& );
+ void empty();
- void get(const framing::MethodContext&,
- uint16_t ticket,
+ void get(uint16_t ticket,
const std::string& queue,
const std::string& destination,
bool noAck );
- void offset(const framing::MethodContext&,
- uint64_t value );
+ void offset(uint64_t value);
- void ok( const framing::MethodContext& );
+ void ok();
- void open(const framing::MethodContext&,
- const std::string& reference );
+ void open(const std::string& reference );
- void qos(const framing::MethodContext&,
- uint32_t prefetchSize,
+ void qos(uint32_t prefetchSize,
uint16_t prefetchCount,
bool global );
- void recover(const framing::MethodContext&,
- bool requeue );
+ void recover(bool requeue );
- void reject(const framing::MethodContext&,
- uint16_t code,
+ void reject(uint16_t code,
const std::string& text );
- void resume(const framing::MethodContext&,
- const std::string& reference,
+ void resume(const std::string& reference,
const std::string& identifier );
- void transfer(const framing::MethodContext&,
- uint16_t ticket,
- const std::string& destination,
- bool redelivered,
- bool immediate,
- uint64_t ttl,
- uint8_t priority,
- uint64_t timestamp,
- uint8_t deliveryMode,
- uint64_t expiration,
- const std::string& exchange,
- const std::string& routingKey,
- const std::string& messageId,
- const std::string& correlationId,
- const std::string& replyTo,
- const std::string& contentType,
- const std::string& contentEncoding,
- const std::string& userId,
- const std::string& appId,
- const std::string& transactionId,
- const std::string& securityToken,
- const framing::FieldTable& applicationHeaders,
- const framing::Content& body,
- bool mandatory );
+ void transfer(const framing::MethodContext& context);
private:
ReferenceRegistry references;
};