diff options
Diffstat (limited to 'cpp/src/qpid/client/ClientMessage.h')
| -rw-r--r-- | cpp/src/qpid/client/ClientMessage.h | 86 |
1 files changed, 0 insertions, 86 deletions
diff --git a/cpp/src/qpid/client/ClientMessage.h b/cpp/src/qpid/client/ClientMessage.h deleted file mode 100644 index a573e17940..0000000000 --- a/cpp/src/qpid/client/ClientMessage.h +++ /dev/null @@ -1,86 +0,0 @@ -#ifndef _client_ClientMessage_h -#define _client_ClientMessage_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. - * - */ -#include <string> -#include "qpid/client/Session.h" -#include "qpid/framing/MessageTransferBody.h" -#include "qpid/framing/TransferContent.h" - -namespace qpid { -namespace client { - -/** - * A representation of messages for sent or recived through the - * client api. - * - * \ingroup clientapi - */ -class Message : public framing::TransferContent -{ -public: - Message(const std::string& data_=std::string()) : TransferContent(data_) {} - - std::string getDestination() const - { - return method.getDestination(); - } - - bool isRedelivered() const - { - return hasDeliveryProperties() && getDeliveryProperties().getRedelivered(); - } - - void setRedelivered(bool redelivered) - { - getDeliveryProperties().setRedelivered(redelivered); - } - - framing::FieldTable& getHeaders() - { - return getMessageProperties().getApplicationHeaders(); - } - - void acknowledge(Session& session, bool cumulative = true, bool send = true) const - { - session.execution().completed(id, cumulative, send); - } - - Message(const framing::FrameSet& frameset) : method(*frameset.as<framing::MessageTransferBody>()), id(frameset.getId()) - { - populate(frameset); - } - - const framing::MessageTransferBody& getMethod() const - { - return method; - } - -private: - //method and id are only set for received messages: - const framing::MessageTransferBody method; - const framing::SequenceNumber id; -}; - -}} - -#endif /*!_client_ClientMessage_h*/ |
