From 89aa36d093182e9e191c000504c174663932458f Mon Sep 17 00:00:00 2001
From: Gordon Sim <gsim@apache.org>
Date: Thu, 2 Aug 2007 18:09:48 +0000
Subject: Some restructuring of the client code:  * Introduced three separate
 'handlers' for the connection, channel and execution 'layers'.  * Support for
 asynchronous retrieval of response or completion status.  * Channel methods
 no longer included in execution layers command id count.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@562212 13f79535-47bb-0310-9956-ffa450edef68
---
 cpp/src/qpid/client/BasicMessageChannel.h | 92 -------------------------------
 1 file changed, 92 deletions(-)
 delete mode 100644 cpp/src/qpid/client/BasicMessageChannel.h

(limited to 'cpp/src/qpid/client/BasicMessageChannel.h')

diff --git a/cpp/src/qpid/client/BasicMessageChannel.h b/cpp/src/qpid/client/BasicMessageChannel.h
deleted file mode 100644
index 99838321ae..0000000000
--- a/cpp/src/qpid/client/BasicMessageChannel.h
+++ /dev/null
@@ -1,92 +0,0 @@
-#ifndef _client_BasicMessageChannel_h
-#define _client_BasicMessageChannel_h
-
-/*
- *
- * Copyright (c) 2006 The Apache Software Foundation
- *
- * Licensed 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 "MessageChannel.h"
-#include "IncomingMessage.h"
-#include <boost/scoped_ptr.hpp>
-
-namespace qpid {
-namespace client {
-/**
- * Messaging implementation using AMQP 0-8 BasicMessageChannel class
- * to send and receiving messages.
- */
-class BasicMessageChannel : public MessageChannel
-{
-  public:
-    BasicMessageChannel(Channel& parent);
-    
-    void consume(
-        Queue& queue, std::string& tag, MessageListener* listener, 
-        AckMode ackMode = NO_ACK, bool noLocal = false, bool synch = true,
-        const framing::FieldTable* fields = 0);
-        
-    void cancel(const std::string& tag, bool synch = true);
-
-    bool get(Message& msg, const Queue& queue, AckMode ackMode = NO_ACK);
-
-    void publish(const Message& msg, const Exchange& exchange,
-                 const std::string& routingKey, 
-                 bool mandatory = false, bool immediate = false);
-
-    void setReturnedMessageHandler(ReturnedMessageHandler* handler);
-
-    void run();
-
-    void handle(boost::shared_ptr<framing::AMQMethodBody>);
-
-    void handle(shared_ptr<framing::AMQHeaderBody>);
-
-    void handle(shared_ptr<framing::AMQContentBody>);
-    
-    void setQos();
-    
-    void close();
-
-    void cancelAll();
-
-  private:
-
-    struct Consumer{
-        MessageListener* listener;
-        AckMode ackMode;
-        int count;
-        u_int64_t lastDeliveryTag;
-    };
-    typedef std::map<std::string, Consumer> ConsumerMap;
-
-    void deliver(Consumer& consumer, Message& msg);
-    
-    sys::Mutex lock;
-    Channel& channel;
-    IncomingMessage incoming;
-    uint64_t incoming_size;
-    ConsumerMap consumers ;
-    ReturnedMessageHandler* returnsHandler;
-    IncomingMessage::WaitableDestination destGet;
-    IncomingMessage::WaitableDestination destDispatch;
-};
-
-}} // namespace qpid::client
-
-
-
-#endif  /*!_client_BasicMessageChannel_h*/
-- 
cgit v1.2.1