diff options
Diffstat (limited to 'cpp/src/qpid/client/Channel.h')
| -rw-r--r-- | cpp/src/qpid/client/Channel.h | 316 |
1 files changed, 0 insertions, 316 deletions
diff --git a/cpp/src/qpid/client/Channel.h b/cpp/src/qpid/client/Channel.h deleted file mode 100644 index 9a22c455c4..0000000000 --- a/cpp/src/qpid/client/Channel.h +++ /dev/null @@ -1,316 +0,0 @@ -#ifndef _client_Channel_h -#define _client_Channel_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 <memory> -#include <boost/scoped_ptr.hpp> -#include "qpid/framing/amqp_framing.h" -#include "qpid/framing/Uuid.h" -#include "Exchange.h" -#include "Message.h" -#include "Queue.h" -#include "ConnectionImpl.h" -#include "qpid/client/Session.h" -#include "qpid/Exception.h" -#include "qpid/sys/Mutex.h" -#include "qpid/sys/Runnable.h" -#include "qpid/sys/Thread.h" -#include "AckMode.h" - -namespace qpid { - -namespace framing { -class ChannelCloseBody; -class AMQMethodBody; -} - -namespace client { - -class Connection; -class MessageChannel; -class MessageListener; -class ReturnedMessageHandler; - -/** - * THIS CLASS IS DEPRECATED AND WILL BE SHORTLY REMOVED - * - * Represents an AMQP channel, i.e. loosely a session of work. It - * is through a channel that most of the AMQP 'methods' are - * exposed. - * - */ -class Channel : private sys::Runnable -{ - private: - struct Consumer{ - MessageListener* listener; - AckMode ackMode; - uint32_t count; - }; - typedef std::map<std::string, Consumer> ConsumerMap; - - mutable sys::Mutex lock; - sys::Thread dispatcher; - - uint32_t prefetch; - const bool transactional; - framing::ProtocolVersion version; - - mutable sys::Mutex stopLock; - bool running; - - ConsumerMap consumers; - Session session; - framing::ChannelId channelId; - sys::BlockingQueue<framing::FrameSet::shared_ptr> gets; - framing::Uuid uniqueId; - uint32_t nameCounter; - bool active; - - void stop(); - - void open(const Session& session); - void closeInternal(); - void join(); - - void dispatch(framing::FrameSet& msg, const std::string& destination); - - friend class Connection; - - public: - /** - * Creates a channel object. - * - * @param transactional if true, the publishing and acknowledgement - * of messages will be transactional and can be committed or - * aborted in atomic units (@see commit(), @see rollback()). - * - * @param prefetch specifies the number of unacknowledged - * messages the channel is willing to have sent to it - * asynchronously. - */ - Channel(bool transactional = false, u_int16_t prefetch = 0); - - ~Channel(); - - /** - * Declares an exchange. - * - * In AMQP, Exchanges are the destinations to which messages - * are published. They have Queues bound to them and route - * messages they receive to those queues. The routing rules - * depend on the type of the exchange. - * - * @param exchange an Exchange object representing the - * exchange to declare. - * - * @param synch if true this call will block until a response - * is received from the broker. - */ - void declareExchange(Exchange& exchange, bool synch = true); - /** - * Deletes an exchange. - * - * @param exchange an Exchange object representing the exchange to delete. - * - * @param synch if true this call will block until a response - * is received from the broker. - */ - void deleteExchange(Exchange& exchange, bool synch = true); - /** - * Declares a Queue. - * - * @param queue a Queue object representing the queue to declare. - * - * @param synch if true this call will block until a response - * is received from the broker. - */ - void declareQueue(Queue& queue, bool synch = true); - /** - * Deletes a Queue. - * - * @param queue a Queue object representing the queue to delete. - * - * @param synch if true this call will block until a response - * is received from the broker. - */ - void deleteQueue(Queue& queue, bool ifunused = false, bool ifempty = false, bool synch = true); - /** - * Binds a queue to an exchange. The exact semantics of this - * (in particular how 'routing keys' and 'binding arguments' - * are used) depends on the type of the exchange. - * - * @param exchange an Exchange object representing the - * exchange to bind to. - * - * @param queue a Queue object representing the queue to be - * bound. - * - * @param key the 'routing key' for the binding. - * - * @param args the 'binding arguments' for the binding. - * - * @param synch if true this call will block until a response - * is received from the broker. - */ - void bind(const Exchange& exchange, const Queue& queue, - const std::string& key, - const framing::FieldTable& args=framing::FieldTable(), - bool synch = true); - - /** - * For a transactional channel this will commit all - * publications and acknowledgements since the last commit (or - * the channel that was opened if there has been no previous - * commit). This will cause published messages to become - * available to consumers and acknowledged messages to be - * consumed and removed from the queues they were dispatched - * from. - * - * A channel is specified as transactional or not when the channel - * object is created (@see Channel()). - */ - void commit(); - - /** - * For a transactional channel, this will rollback any - * publications or acknowledgements. It will be as if the - * published messages were never sent and the acknowledged - * messages were never consumed. - */ - void rollback(); - - /** - * Change the prefetch in use. - */ - void setPrefetch(uint32_t prefetch); - - uint32_t getPrefetch() { return prefetch; } - - /** - * Start message dispatching on a new thread. - */ - void start(); - - /** - * Close the channel. Closing a channel that is not open has no - * effect. - */ - void close(); - - /** True if the channel is transactional. */ - bool isTransactional() { return transactional; } - - /** True if the channel is open. */ - bool isOpen() const; - - /** Return the protocol version. */ - framing::ProtocolVersion getVersion() const { return version ; } - - /** - * Creates a 'consumer' for a queue. Messages in (or arriving - * at) that queue will be delivered to consumers - * asynchronously. - * - * @param queue a Queue instance representing the queue to - * consume from. - * - * @param tag an identifier to associate with the consumer - * that can be used to cancel its subscription (if empty, this - * will be assigned by the broker). - * - * @param listener a pointer to an instance of an - * implementation of the MessageListener interface. Messages - * received from this queue for this consumer will result in - * invocation of the received() method on the listener, with - * the message itself passed in. - * - * @param ackMode the mode of acknowledgement that the broker - * should assume for this consumer. @see AckMode - * - * @param noLocal if true, this consumer will not be sent any - * message published by this connection. - * - * @param synch if true this call will block until a response - * is received from the broker. - */ - void consume( - Queue& queue, const std::string& tag, MessageListener* listener, - AckMode ackMode = NO_ACK, bool noLocal = false, bool synch = true, - framing::FieldTable* fields = 0); - - /** - * Cancels a subscription previously set up through a call to consume(). - * - * @param tag the identifier used (or assigned) in the consume - * request that set up the subscription to be cancelled. - * - * @param synch if true this call will block until a response - * is received from the broker. - */ - void cancel(const std::string& tag, bool synch = true); - /** - * Synchronous pull of a message from a queue. - * - * @param msg a message object that will contain the message - * headers and content if the call completes. - * - * @param queue the queue to consume from. - * - * @param ackMode the acknowledgement mode to use (@see - * AckMode) - * - * @return true if a message was succcessfully dequeued from - * the queue, false if the queue was empty. - */ - bool get(Message& msg, const Queue& queue, AckMode ackMode = NO_ACK); - - /** - * Publishes (i.e. sends a message to the broker). - * - * @param msg the message to publish. - * - * @param exchange the exchange to publish the message to. - * - * @param routingKey the routing key to publish with. - * - * @param mandatory if true and the exchange to which this - * publish is directed has no matching bindings, the message - * will be returned (see setReturnedMessageHandler()). - * - * @param immediate if true and there is no consumer to - * receive this message on publication, the message will be - * returned (see setReturnedMessageHandler()). - */ - void publish(Message& msg, const Exchange& exchange, - const std::string& routingKey, - bool mandatory = false, bool immediate = false); - - /** - * Deliver incoming messages to the appropriate MessageListener. - */ - void run(); -}; - -}} - -#endif /*!_client_Channel_h*/ |