1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
#ifndef _broker_MessageHandlerImpl_h
#define _broker_MessageHandlerImpl_h
/*
*
* Copyright (c) 2006 The Apache Software Foundation
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*/
#include <memory>
#include "AMQP_ServerOperations.h"
#include "AMQP_ClientProxy.h"
#include "Reference.h"
#include "HandlerImpl.h"
namespace qpid {
namespace broker {
class Connection;
class Broker;
class MessageMessage;
class MessageHandlerImpl :
public framing::AMQP_ServerOperations::MessageHandler,
public HandlerImpl<framing::AMQP_ClientProxy::Message>
{
public:
MessageHandlerImpl(CoreRefs& parent);
void append(const framing::MethodContext&,
const std::string& reference,
const std::string& bytes );
void cancel(const framing::MethodContext&,
const std::string& destination );
void checkpoint(const framing::MethodContext&,
const std::string& reference,
const std::string& identifier );
void close(const framing::MethodContext&,
const std::string& reference );
void consume(const framing::MethodContext&,
u_int16_t ticket,
const std::string& queue,
const std::string& destination,
bool noLocal,
bool noAck,
bool exclusive,
const framing::FieldTable& filter );
void empty( const framing::MethodContext& );
void get(const framing::MethodContext&,
u_int16_t ticket,
const std::string& queue,
const std::string& destination,
bool noAck );
void offset(const framing::MethodContext&,
u_int64_t value );
void ok( const framing::MethodContext& );
void open(const framing::MethodContext&,
const std::string& reference );
void qos(const framing::MethodContext&,
u_int32_t prefetchSize,
u_int16_t prefetchCount,
bool global );
void recover(const framing::MethodContext&,
bool requeue );
void reject(const framing::MethodContext&,
u_int16_t code,
const std::string& text );
void resume(const framing::MethodContext&,
const std::string& reference,
const std::string& identifier );
void transfer(const framing::MethodContext&,
u_int16_t ticket,
const std::string& destination,
bool redelivered,
bool immediate,
u_int64_t ttl,
u_int8_t priority,
u_int64_t timestamp,
u_int8_t deliveryMode,
u_int64_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 );
private:
ReferenceRegistry references;
};
}} // namespace qpid::broker
#endif /*!_broker_MessageHandlerImpl_h*/
|
