/usr/include/qpid/framing/MessageSubscribeBody.h is in libqpidcommon2-dev 0.16-9ubuntu2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 131 132 133 134 135 136 137 138 | #ifndef QPID_FRAMING_MESSAGESUBSCRIBEBODY_H
#define QPID_FRAMING_MESSAGESUBSCRIBEBODY_H
/*
*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you 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.
*
*/
///
/// This file was automatically generated from the AMQP specification.
/// Do not edit.
///
#include "qpid/framing/AMQMethodBody.h"
#include "qpid/framing/AMQP_ServerOperations.h"
#include "qpid/framing/MethodBodyConstVisitor.h"
#include "qpid/framing/ModelMethod.h"
#include <ostream>
#include "qpid/framing/amqp_types_full.h"
#include "qpid/CommonImportExport.h"
namespace qpid {
namespace framing {
class QPID_COMMON_CLASS_EXTERN MessageSubscribeBody : public ModelMethod {
std::string queue;
std::string destination;
uint8_t acceptMode;
uint8_t acquireMode;
std::string resumeId;
uint64_t resumeTtl;
FieldTable arguments;
uint16_t flags;
public:
static const ClassId CLASS_ID = 0x4;
static const MethodId METHOD_ID = 0x7;
MessageSubscribeBody(
ProtocolVersion, const std::string& _queue,
const std::string& _destination,
uint8_t _acceptMode,
uint8_t _acquireMode,
bool _exclusive,
const std::string& _resumeId,
uint64_t _resumeTtl,
const FieldTable& _arguments) :
queue(_queue),
destination(_destination),
acceptMode(_acceptMode),
acquireMode(_acquireMode),
resumeId(_resumeId),
resumeTtl(_resumeTtl),
arguments(_arguments),
flags(0){
setExclusive(_exclusive);
flags |= (1 << 8);
flags |= (1 << 9);
flags |= (1 << 10);
flags |= (1 << 11);
flags |= (1 << 13);
flags |= (1 << 14);
flags |= (1 << 15);
}
MessageSubscribeBody(ProtocolVersion=ProtocolVersion()) : acceptMode(0), acquireMode(0), resumeTtl(0), flags(0) {}
QPID_COMMON_EXTERN void setQueue(const std::string& _queue);
QPID_COMMON_EXTERN const std::string& getQueue() const;
QPID_COMMON_EXTERN bool hasQueue() const;
QPID_COMMON_EXTERN void clearQueueFlag();
QPID_COMMON_EXTERN void setDestination(const std::string& _destination);
QPID_COMMON_EXTERN const std::string& getDestination() const;
QPID_COMMON_EXTERN bool hasDestination() const;
QPID_COMMON_EXTERN void clearDestinationFlag();
QPID_COMMON_EXTERN void setAcceptMode(uint8_t _acceptMode);
QPID_COMMON_EXTERN uint8_t getAcceptMode() const;
QPID_COMMON_EXTERN bool hasAcceptMode() const;
QPID_COMMON_EXTERN void clearAcceptModeFlag();
QPID_COMMON_EXTERN void setAcquireMode(uint8_t _acquireMode);
QPID_COMMON_EXTERN uint8_t getAcquireMode() const;
QPID_COMMON_EXTERN bool hasAcquireMode() const;
QPID_COMMON_EXTERN void clearAcquireModeFlag();
QPID_COMMON_EXTERN void setExclusive(bool _exclusive);
QPID_COMMON_EXTERN bool getExclusive() const;
QPID_COMMON_EXTERN void setResumeId(const std::string& _resumeId);
QPID_COMMON_EXTERN const std::string& getResumeId() const;
QPID_COMMON_EXTERN bool hasResumeId() const;
QPID_COMMON_EXTERN void clearResumeIdFlag();
QPID_COMMON_EXTERN void setResumeTtl(uint64_t _resumeTtl);
QPID_COMMON_EXTERN uint64_t getResumeTtl() const;
QPID_COMMON_EXTERN bool hasResumeTtl() const;
QPID_COMMON_EXTERN void clearResumeTtlFlag();
QPID_COMMON_EXTERN void setArguments(const FieldTable& _arguments);
QPID_COMMON_EXTERN const FieldTable& getArguments() const;
QPID_COMMON_EXTERN FieldTable& getArguments();
QPID_COMMON_EXTERN bool hasArguments() const;
QPID_COMMON_EXTERN void clearArgumentsFlag();
typedef void ResultType;
template <class T> ResultType invoke(T& invocable) const {
return invocable.subscribe(getQueue(), getDestination(), getAcceptMode(), getAcquireMode(), getExclusive(), getResumeId(), getResumeTtl(), getArguments());
}
using AMQMethodBody::accept;
void accept(MethodBodyConstVisitor& v) const { v.visit(*this); }
boost::intrusive_ptr<AMQBody> clone() const { return BodyFactory::copy(*this); }
ClassId amqpClassId() const { return CLASS_ID; }
MethodId amqpMethodId() const { return METHOD_ID; }
bool isContentBearing() const { return false; }
bool resultExpected() const { return false; }
bool responseExpected() const { return false; }
QPID_COMMON_EXTERN void encode(Buffer&) const;
QPID_COMMON_EXTERN void decode(Buffer&, uint32_t=0);
QPID_COMMON_EXTERN void encodeStructBody(Buffer&) const;
QPID_COMMON_EXTERN void decodeStructBody(Buffer&, uint32_t=0);
QPID_COMMON_EXTERN uint32_t encodedSize() const;
QPID_COMMON_EXTERN uint32_t bodySize() const;
QPID_COMMON_EXTERN void print(std::ostream& out) const;
}; /* class MessageSubscribeBody */
}}
#endif /*!QPID_FRAMING_MESSAGESUBSCRIBEBODY_H*/
|