summaryrefslogtreecommitdiff
path: root/cpp/lib/broker/BrokerMessage.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/lib/broker/BrokerMessage.h')
-rw-r--r--cpp/lib/broker/BrokerMessage.h28
1 files changed, 14 insertions, 14 deletions
diff --git a/cpp/lib/broker/BrokerMessage.h b/cpp/lib/broker/BrokerMessage.h
index 871514e55f..fcb104edbb 100644
--- a/cpp/lib/broker/BrokerMessage.h
+++ b/cpp/lib/broker/BrokerMessage.h
@@ -54,9 +54,9 @@ class BasicMessage : public Message {
boost::shared_ptr<framing::AMQHeaderBody> header;
std::auto_ptr<Content> content;
sys::Mutex contentLock;
- u_int64_t size;
+ uint64_t size;
- void sendContent(framing::ChannelAdapter&, u_int32_t framesize);
+ void sendContent(framing::ChannelAdapter&, uint32_t framesize);
public:
typedef boost::shared_ptr<BasicMessage> shared_ptr;
@@ -73,24 +73,24 @@ class BasicMessage : public Message {
void deliver(framing::ChannelAdapter&,
const string& consumerTag,
- u_int64_t deliveryTag,
- u_int32_t framesize);
+ uint64_t deliveryTag,
+ uint32_t framesize);
void sendGetOk(const framing::MethodContext&,
const std::string& destination,
- u_int32_t messageCount,
- u_int64_t deliveryTag,
- u_int32_t framesize);
+ uint32_t messageCount,
+ uint64_t deliveryTag,
+ uint32_t framesize);
framing::BasicHeaderProperties* getHeaderProperties();
const framing::FieldTable& getApplicationHeaders();
bool isPersistent();
- u_int64_t contentSize() const { return size; }
+ uint64_t contentSize() const { return size; }
void decode(framing::Buffer& buffer, bool headersOnly = false,
- u_int32_t contentChunkSize = 0);
+ uint32_t contentChunkSize = 0);
void decodeHeader(framing::Buffer& buffer);
- void decodeContent(framing::Buffer& buffer, u_int32_t contentChunkSize = 0);
+ void decodeContent(framing::Buffer& buffer, uint32_t contentChunkSize = 0);
void encode(framing::Buffer& buffer);
void encodeHeader(framing::Buffer& buffer);
@@ -99,18 +99,18 @@ class BasicMessage : public Message {
* @returns the size of the buffer needed to encode this
* message in its entirety
*/
- u_int32_t encodedSize();
+ uint32_t encodedSize();
/**
* @returns the size of the buffer needed to encode the
* 'header' of this message (not just the header frame,
* but other meta data e.g.routing key and exchange)
*/
- u_int32_t encodedHeaderSize();
+ uint32_t encodedHeaderSize();
/**
* @returns the size of the buffer needed to encode the
* (possibly partial) content held by this message
*/
- u_int32_t encodedContentSize();
+ uint32_t encodedContentSize();
/**
* Releases the in-memory content data held by this
* message. Must pass in a store from which the data can
@@ -121,7 +121,7 @@ class BasicMessage : public Message {
* If headers have been received, returns the expected
* content size else returns 0.
*/
- u_int64_t expectedContentSize();
+ uint64_t expectedContentSize();
/**
* Sets the 'content' implementation of this message (the
* message controls the lifecycle of the content instance