diff options
| author | Gordon Sim <gsim@apache.org> | 2007-07-24 14:27:31 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2007-07-24 14:27:31 +0000 |
| commit | a6303894d7f9a24df4a691af3ce94647c033ebff (patch) | |
| tree | 943b75df7528c9fbff6b3170c3c4b66758bf22ad /cpp/src/qpid/broker/BrokerMessageMessage.cpp | |
| parent | 9f120205e0d7a0b2666b9fd21a5296db07e32fd8 (diff) | |
| download | qpid-python-a6303894d7f9a24df4a691af3ce94647c033ebff.tar.gz | |
Initial support for latest approved 0-10 xml (with some transitional hacks included).
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@559059 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/BrokerMessageMessage.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/BrokerMessageMessage.cpp | 22 |
1 files changed, 14 insertions, 8 deletions
diff --git a/cpp/src/qpid/broker/BrokerMessageMessage.cpp b/cpp/src/qpid/broker/BrokerMessageMessage.cpp index 01f8250b84..efa295e44f 100644 --- a/cpp/src/qpid/broker/BrokerMessageMessage.cpp +++ b/cpp/src/qpid/broker/BrokerMessageMessage.cpp @@ -43,7 +43,7 @@ MessageMessage::MessageMessage( ConnectionToken* publisher, RequestId requestId_, TransferPtr transfer_ ) : Message(publisher, transfer_->getDestination(), transfer_->getRoutingKey(), - transfer_->getMandatory(), + transfer_->getRejectUnroutable(), transfer_->getImmediate(), transfer_), requestId(requestId_), @@ -57,7 +57,7 @@ MessageMessage::MessageMessage( ReferencePtr reference_ ) : Message(publisher, transfer_->getDestination(), transfer_->getRoutingKey(), - transfer_->getMandatory(), + transfer_->getRejectUnroutable(), transfer_->getImmediate(), transfer_), requestId(requestId_), @@ -113,6 +113,7 @@ void MessageMessage::transferMessage( transfer->getTicket(), consumerTag, getRedelivered(), + transfer->getRejectUnroutable(), transfer->getImmediate(), transfer->getTtl(), transfer->getPriority(), @@ -126,13 +127,14 @@ void MessageMessage::transferMessage( transfer->getReplyTo(), transfer->getContentType(), transfer->getContentEncoding(), + 0, /*content-length*/ + string(), /*type*/ transfer->getUserId(), transfer->getAppId(), transfer->getTransactionId(), transfer->getSecurityToken(), transfer->getApplicationHeaders(), - body, - transfer->getMandatory()))); + body))); } else { // Thing to do here is to construct a simple reference message then deliver that instead // fragmentation will be taken care of in the delivery if necessary; @@ -143,6 +145,7 @@ void MessageMessage::transferMessage( transfer->getTicket(), consumerTag, getRedelivered(), + transfer->getRejectUnroutable(), transfer->getImmediate(), transfer->getTtl(), transfer->getPriority(), @@ -156,13 +159,14 @@ void MessageMessage::transferMessage( transfer->getReplyTo(), transfer->getContentType(), transfer->getContentEncoding(), + 0, /*content-length*/ + string(), /*type*/ transfer->getUserId(), transfer->getAppId(), transfer->getTransactionId(), transfer->getSecurityToken(), transfer->getApplicationHeaders(), - framing::Content(REFERENCE, refname), - transfer->getMandatory())); + framing::Content(REFERENCE, refname))); ReferencePtr newRef(new Reference(refname)); Reference::AppendPtr newAppend(new MessageAppendBody(channel.getVersion(), refname, content)); newRef->append(newAppend); @@ -288,6 +292,7 @@ MessageTransferBody* MessageMessage::copyTransfer(const ProtocolVersion& version transfer->getTicket(), destination, getRedelivered(), + transfer->getRejectUnroutable(), transfer->getImmediate(), transfer->getTtl(), transfer->getPriority(), @@ -301,13 +306,14 @@ MessageTransferBody* MessageMessage::copyTransfer(const ProtocolVersion& version transfer->getReplyTo(), transfer->getContentType(), transfer->getContentEncoding(), + 0, /*content-length*/ + string(), /*type*/ transfer->getUserId(), transfer->getAppId(), transfer->getTransactionId(), transfer->getSecurityToken(), transfer->getApplicationHeaders(), - body, - transfer->getMandatory()); + body); } |