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&,
uint16_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&,
uint16_t ticket,
const std::string& queue,
const std::string& destination,
bool noAck );
void offset(const framing::MethodContext&,
uint64_t value );
void ok( const framing::MethodContext& );
void open(const framing::MethodContext&,
const std::string& reference );
void qos(const framing::MethodContext&,
uint32_t prefetchSize,
uint16_t prefetchCount,
bool global );
void recover(const framing::MethodContext&,
bool requeue );
void reject(const framing::MethodContext&,
uint16_t code,
const std::string& text );
void resume(const framing::MethodContext&,
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 );
private:
ReferenceRegistry references;
};
}} // namespace qpid::broker
#endif /*!_broker_MessageHandlerImpl_h*/
|
