* Renamed Session* classes to Connection* to align with AMQP spec

 - broker::SessionHandlerImpl -> broker::Connection
 - broker::SessionHandlerImplFactory -> broker::ConnectionFactory
 - sys::SessionHandler -> ConnectionInputHandler
 - sys::SessionHandlerFactory -> ConnectionInputHandlerFactory


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496848 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 0 insertions, 381 deletions

diff --git a/cpp/lib/broker/SessionHandlerImpl.h b/cpp/lib/broker/SessionHandlerImpl.h
deleted file mode 100644
index 070bd1266e..0000000000
--- a/cpp/lib/broker/SessionHandlerImpl.h
+++ /dev/null
@@ -1,381 +0,0 @@
-/*
- *
- * 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.
- *
- */
-#ifndef _SessionHandlerImpl_
-#define _SessionHandlerImpl_
-
-#include <map>
-#include <sstream>
-#include <vector>
-
-#include <AMQFrame.h>
-#include <AMQP_ClientProxy.h>
-#include <AMQP_ServerOperations.h>
-#include <sys/SessionContext.h>
-#include <sys/SessionHandler.h>
-#include <sys/TimeoutHandler.h>
-#include "Broker.h"
-#include "Exception.h"
-
-namespace qpid {
-namespace broker {
-
-struct ChannelException : public qpid::Exception {
-    u_int16_t code;
-    string text;
-    ChannelException(u_int16_t _code, string _text) : code(_code), text(_text) {}
-    ~ChannelException() throw() {}
-    const char* what() const throw() { return text.c_str(); }
-};
-
-struct ConnectionException : public qpid::Exception {
-    u_int16_t code;
-    string text;
-    ConnectionException(u_int16_t _code, string _text) : code(_code), text(_text) {}
-    ~ConnectionException() throw() {}
-    const char* what() const throw() { return text.c_str(); }
-};
-
-class Settings {
-  public:
-    const u_int32_t timeout;//timeout for auto-deleted queues (in ms)
-    const u_int64_t stagingThreshold;
-
-    Settings(u_int32_t _timeout, u_int64_t _stagingThreshold) : timeout(_timeout), stagingThreshold(_stagingThreshold) {}
-};
-
-class SessionHandlerImpl : public qpid::sys::SessionHandler, 
-                           public qpid::framing::AMQP_ServerOperations, 
-                           public ConnectionToken
-{
-    typedef std::map<u_int16_t, Channel*>::iterator channel_iterator;
-    typedef std::vector<Queue::shared_ptr>::iterator queue_iterator;
-    class Sender : public qpid::framing::OutputHandler {
-      public:
-        Sender(qpid::framing::OutputHandler&,
-               qpid::framing::Requester&, qpid::framing::Responder&);
-        void send(qpid::framing::AMQFrame* frame);
-      private:
-        OutputHandler& out;
-        qpid::framing::Requester& requester;
-        qpid::framing::Responder& responder;
-    };
-    
-    qpid::sys::SessionContext* context;
-    qpid::framing::AMQP_ClientProxy* client;
-    QueueRegistry& queues;
-    ExchangeRegistry& exchanges;
-    AutoDelete& cleaner;
-    Settings settings;
-    qpid::framing::Requester& requester;
-    qpid::framing::Responder& responder;
-    std::auto_ptr<BasicHandler> basicHandler;
-    std::auto_ptr<ChannelHandler> channelHandler;
-    std::auto_ptr<ConnectionHandler> connectionHandler;
-    std::auto_ptr<ExchangeHandler> exchangeHandler;
-    std::auto_ptr<QueueHandler> queueHandler;
-    std::auto_ptr<TxHandler> txHandler;
-    std::auto_ptr<MessageHandler> messageHandler;
-
-    std::map<u_int16_t, Channel*> channels;
-    std::vector<Queue::shared_ptr> exclusiveQueues;
-
-    u_int32_t framemax;
-    u_int16_t heartbeat;
-
-    void handleHeader(u_int16_t channel, qpid::framing::AMQHeaderBody::shared_ptr body);
-    void handleContent(u_int16_t channel, qpid::framing::AMQContentBody::shared_ptr body);
-    void handleMethod(u_int16_t channel, qpid::framing::AMQBody::shared_ptr body);
-    void handleHeartbeat(qpid::framing::AMQHeartbeatBody::shared_ptr body);
-
-    Channel* getChannel(u_int16_t channel);
-    /**
-     * Get named queue, never returns 0.
-     * @return: named queue or default queue for channel if name=""
-     * @exception: ChannelException if no queue of that name is found.
-     * @exception: ConnectionException if no queue specified and channel has not declared one.
-     */
-    Queue::shared_ptr getQueue(const string& name, u_int16_t channel);
-
-    Exchange::shared_ptr findExchange(const string& name);
-    
-  public:
-    SessionHandlerImpl(qpid::sys::SessionContext* context, Broker& broker);
-    virtual void received(qpid::framing::AMQFrame* frame);
-    virtual void initiated(qpid::framing::ProtocolInitiation* header);
-    virtual void idleOut();
-    virtual void idleIn();
-    virtual void closed();
-    virtual ~SessionHandlerImpl();
-
-    class ConnectionHandlerImpl : public ConnectionHandler{
-        SessionHandlerImpl* parent;
-      public:
-        inline ConnectionHandlerImpl(SessionHandlerImpl* _parent) : parent(_parent) {}
-
-        virtual void startOk(u_int16_t channel, const qpid::framing::FieldTable& clientProperties, const string& mechanism, 
-                             const string& response, const string& locale); 
-                
-        // Change to match new code generator function signature (adding const to string&) - kpvdr 2006-11-20
-        virtual void secureOk(u_int16_t channel, const string& response); 
-                
-        virtual void tuneOk(u_int16_t channel, u_int16_t channelMax, u_int32_t frameMax, u_int16_t heartbeat); 
-                
-        // Change to match new code generator function signature (adding const to string&) - kpvdr 2006-11-20
-        virtual void open(u_int16_t channel, const string& virtualHost, const string& capabilities, bool insist); 
-                
-        // Change to match new code generator function signature (adding const to string&) - kpvdr 2006-11-20
-        virtual void close(u_int16_t channel, u_int16_t replyCode, const string& replyText, u_int16_t classId, 
-                           u_int16_t methodId); 
- 
-        virtual void closeOk(u_int16_t channel); 
-                
-        virtual ~ConnectionHandlerImpl(){}
-    };
-    
-    class ChannelHandlerImpl : public ChannelHandler{
-        SessionHandlerImpl* parent;
-      public:
-        inline ChannelHandlerImpl(SessionHandlerImpl* _parent) : parent(_parent) {}
-        
-        // Change to match new code generator function signature (adding const to string&) - kpvdr 2006-11-20
-        virtual void open(u_int16_t channel, const string& outOfBand); 
-        
-        virtual void flow(u_int16_t channel, bool active); 
-                
-        virtual void flowOk(u_int16_t channel, bool active); 
-                
-        virtual void ok( u_int16_t channel );
-
-        virtual void ping( u_int16_t channel );
-
-        virtual void pong( u_int16_t channel );
-
-        virtual void resume( u_int16_t channel,
-                            const string& channelId );
-        
-        virtual void close(u_int16_t channel, u_int16_t replyCode, const string& replyText, 
-                           u_int16_t classId, u_int16_t methodId); 
-                
-        virtual void closeOk(u_int16_t channel); 
-                
-        virtual ~ChannelHandlerImpl(){}
-    };
-    
-    class ExchangeHandlerImpl : public ExchangeHandler{
-        SessionHandlerImpl* parent;
-      public:
-        inline ExchangeHandlerImpl(SessionHandlerImpl* _parent) : parent(_parent) {}
-        
-        virtual void declare(u_int16_t channel, u_int16_t ticket, const string& exchange, const string& type, 
-                             bool passive, bool durable, bool autoDelete, bool internal, bool nowait, 
-                             const qpid::framing::FieldTable& arguments); 
-                
-        virtual void delete_(u_int16_t channel, u_int16_t ticket, const string& exchange, bool ifUnused, bool nowait); 
-                
-        virtual void unbind(u_int16_t channel,
-                            u_int16_t ticket,
-                            const string& queue,
-                            const string& exchange,
-                            const string& routingKey,
-                            const qpid::framing::FieldTable& arguments );
-
-        virtual ~ExchangeHandlerImpl(){}
-    };
-
-    
-    class QueueHandlerImpl : public QueueHandler{
-        SessionHandlerImpl* parent;
-      public:
-        inline QueueHandlerImpl(SessionHandlerImpl* _parent) : parent(_parent) {}
-        
-        virtual void declare(u_int16_t channel, u_int16_t ticket, const string& queue, 
-                             bool passive, bool durable, bool exclusive, 
-                             bool autoDelete, bool nowait, const qpid::framing::FieldTable& arguments); 
-                
-        virtual void bind(u_int16_t channel, u_int16_t ticket, const string& queue, 
-                          const string& exchange, const string& routingKey, bool nowait, 
-                          const qpid::framing::FieldTable& arguments); 
-
-        virtual void unbind(u_int16_t channel,
-                            u_int16_t ticket,
-                            const string& queue,
-                            const string& exchange,
-                            const string& routingKey,
-                            const qpid::framing::FieldTable& arguments );
-
-        virtual void purge(u_int16_t channel, u_int16_t ticket, const string& queue, 
-                           bool nowait); 
-                
-        // Change to match new code generator function signature (adding const to string&) - kpvdr 2006-11-20
-        virtual void delete_(u_int16_t channel, u_int16_t ticket, const string& queue, bool ifUnused, bool ifEmpty, 
-                             bool nowait); 
-
-        virtual ~QueueHandlerImpl(){}
-    };
-
-    class BasicHandlerImpl : public BasicHandler{
-        SessionHandlerImpl* parent;
-      public:
-        inline BasicHandlerImpl(SessionHandlerImpl* _parent) : parent(_parent) {}
-        
-        virtual void qos(u_int16_t channel, u_int32_t prefetchSize, u_int16_t prefetchCount, bool global); 
-
-        virtual void consume(
-            u_int16_t channel, u_int16_t ticket, const string& queue,
-            const string& consumerTag, bool noLocal, bool noAck,
-            bool exclusive, bool nowait,
-            const qpid::framing::FieldTable& fields); 
-        
-        virtual void cancel(u_int16_t channel, const string& consumerTag, bool nowait); 
-                
-        virtual void publish(u_int16_t channel, u_int16_t ticket, const string& exchange, const string& routingKey, 
-                             bool mandatory, bool immediate); 
-                
-        virtual void get(u_int16_t channel, u_int16_t ticket, const string& queue, bool noAck); 
-                
-        virtual void ack(u_int16_t channel, u_int64_t deliveryTag, bool multiple); 
-                
-        virtual void reject(u_int16_t channel, u_int64_t deliveryTag, bool requeue); 
-                
-        virtual void recover(u_int16_t channel, bool requeue); 
-                
-        virtual ~BasicHandlerImpl(){}
-    };
-
-    class TxHandlerImpl : public TxHandler{
-        SessionHandlerImpl* parent;
-      public:
-        TxHandlerImpl(SessionHandlerImpl* _parent) : parent(_parent) {}
-        virtual ~TxHandlerImpl() {}
-        virtual void select(u_int16_t channel);
-        virtual void commit(u_int16_t channel);
-        virtual void rollback(u_int16_t channel);
-    };
-
-    class MessageHandlerImpl : public MessageHandler {
-        SessionHandlerImpl* parent;
-
-        // Constructors and destructors
-
-      public:
-        MessageHandlerImpl() {}
-        MessageHandlerImpl(SessionHandlerImpl* _parent) : parent(_parent) {}
-        virtual ~MessageHandlerImpl() {}
-
-        // Protocol methods
-        virtual void append( u_int16_t channel,
-                            const string& reference,
-                            const string& bytes );
-
-        virtual void cancel( u_int16_t channel,
-                            const string& destination );
-
-        virtual void checkpoint( u_int16_t channel,
-                            const string& reference,
-                            const string& identifier );
-
-        virtual void close( u_int16_t channel,
-                            const string& reference );
-
-        virtual void consume( u_int16_t channel,
-                            u_int16_t ticket,
-                            const string& queue,
-                            const string& destination,
-                            bool noLocal,
-                            bool noAck,
-                            bool exclusive,
-                            const qpid::framing::FieldTable& filter );
-
-        virtual void empty( u_int16_t channel );
-
-        virtual void get( u_int16_t channel,
-                            u_int16_t ticket,
-                            const string& queue,
-                            const string& destination,
-                            bool noAck );
-
-        virtual void offset( u_int16_t channel,
-                            u_int64_t value );
-
-        virtual void ok( u_int16_t channel );
-
-        virtual void open( u_int16_t channel,
-                            const string& reference );
-
-        virtual void qos( u_int16_t channel,
-                            u_int32_t prefetchSize,
-                            u_int16_t prefetchCount,
-                            bool global );
-
-        virtual void recover( u_int16_t channel,
-                            bool requeue );
-
-        virtual void reject( u_int16_t channel,
-                            u_int16_t code,
-                            const string& text );
-
-        virtual void resume( u_int16_t channel,
-                            const string& reference,
-                            const string& identifier );
-
-        virtual void transfer( u_int16_t channel,
-                            u_int16_t ticket,
-                            const string& destination,
-                            bool redelivered,
-                            bool immediate,
-                            u_int64_t ttl,
-                            u_int8_t priority,
-                            u_int64_t timestamp,
-                            u_int8_t deliveryMode,
-                            u_int64_t expiration,
-                            const string& exchange,
-                            const string& routingKey,
-                            const string& messageId,
-                            const string& correlationId,
-                            const string& replyTo,
-                            const string& contentType,
-                            const string& contentEncoding,
-                            const string& userId,
-                            const string& appId,
-                            const string& transactionId,
-                            const string& securityToken,
-                            const qpid::framing::FieldTable& applicationHeaders,
-                            qpid::framing::Content body );
-    };
-
-    virtual ChannelHandler* getChannelHandler(){ return channelHandler.get(); }
-    virtual ConnectionHandler* getConnectionHandler(){ return connectionHandler.get(); }
-    virtual BasicHandler* getBasicHandler(){ return basicHandler.get(); }
-    virtual ExchangeHandler* getExchangeHandler(){ return exchangeHandler.get(); }
-    virtual QueueHandler* getQueueHandler(){ return queueHandler.get(); }
-    virtual TxHandler* getTxHandler(){ return txHandler.get(); }       
-    virtual MessageHandler* getMessageHandler(){ return messageHandler.get(); } 
- 
-    virtual AccessHandler* getAccessHandler(){ throw ConnectionException(540, "Access class not implemented"); }       
-    virtual FileHandler* getFileHandler(){ throw ConnectionException(540, "File class not implemented"); }       
-    virtual StreamHandler* getStreamHandler(){ throw ConnectionException(540, "Stream class not implemented"); }       
-    virtual DtxHandler* getDtxHandler(){ throw ConnectionException(540, "Dtx class not implemented"); }       
-    virtual TunnelHandler* getTunnelHandler(){ throw ConnectionException(540, "Tunnel class not implemented"); } 
-};
-
-}}
-
-#endif