cpp/src/qpid/asyncStore/PersistableMessageContext.cpp


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

#include "PersistableMessageContext.h"

namespace qpid {
namespace asyncStore {

PersistableMessageContext::PersistableMessageContext(qpid::broker::AsyncStore* store) : m_store(store) {}

PersistableMessageContext::~PersistableMessageContext() {}

void
PersistableMessageContext::encode(qpid::framing::Buffer& /*buffer*/) const {}

uint32_t
PersistableMessageContext::encodedSize() const {
    return 0;
}

bool
PersistableMessageContext::isPersistent() const {
    return false;
}

void
PersistableMessageContext::decodeHeader(framing::Buffer& /*buffer*/) {}

void
PersistableMessageContext::decodeContent(framing::Buffer& /*buffer*/) {}

uint32_t
PersistableMessageContext::encodedHeaderSize() const {
    return 0;
}

boost::intrusive_ptr<qpid::broker::PersistableMessage> PersistableMessageContext::merge(const std::map<std::string, qpid::types::Variant>& /*annotations*/) const {
    boost::intrusive_ptr<qpid::broker::PersistableMessage> pmc;
    return pmc;
}

}} // namespace qpid::asyncStore