1 files changed, 105 insertions, 0 deletions
diff --git a/qpid/cpp/lib/common/framing/ChannelAdapter.h b/qpid/cpp/lib/common/framing/ChannelAdapter.h
new file mode 100644
index 0000000000..f6e3986eed
--- /dev/null
+++ b/qpid/cpp/lib/common/framing/ChannelAdapter.h
@@ -0,0 +1,105 @@
+#ifndef _ChannelAdapter_
+#define _ChannelAdapter_
+
+/*
+ *
+ * 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 <boost/shared_ptr.hpp>
+
+#include "BodyHandler.h"
+#include "Requester.h"
+#include "Responder.h"
+#include "framing/amqp_types.h"
+
+namespace qpid {
+namespace framing {
+
+class MethodContext;
+
+// FIXME aconway 2007-02-20: Rename as ChannelBase or just Channel.
+
+/**
+ * Base class for client and broker channels.
+ *
+ * - receives frame bodies from the network.
+ * - Updates request/response data.
+ * - Dispatches requests with a MethodContext for responses.
+ *
+ * send()
+ * - Updates request/resposne ID data.
+ * - Forwards frame to the peer.
+ *
+ * Thread safety: OBJECT UNSAFE. Instances must not be called
+ * concurrently. AMQP defines channels to be serialized.
+ */
+class ChannelAdapter : public BodyHandler {
+  public:
+    /**
+     *@param output Processed frames are forwarded to this handler.
+     */
+    ChannelAdapter(ChannelId id_=0, OutputHandler* out_=0,
+                   ProtocolVersion ver=ProtocolVersion())
+        : id(id_), out(out_), version(ver)  {}
+
+    /** Initialize the channel adapter. */
+    void init(ChannelId, OutputHandler&, ProtocolVersion);
+
+    ChannelId getId() const { return id; }
+    ProtocolVersion getVersion() const { return version; }
+    
+    /**
+     * Wrap body in a frame and send the frame.
+     * Takes ownership of body.
+     */
+    RequestId send(AMQBody::shared_ptr body);
+    RequestId send(AMQBody* body) { return send(AMQBody::shared_ptr(body)); }
+
+    void handleMethod(boost::shared_ptr<qpid::framing::AMQMethodBody>);
+    void handleRequest(boost::shared_ptr<qpid::framing::AMQRequestBody>);
+    void handleResponse(boost::shared_ptr<qpid::framing::AMQResponseBody>);
+
+    virtual bool isOpen() const = 0;
+    
+  protected:
+    void assertMethodOk(AMQMethodBody& method) const;
+    void assertChannelOpen() const;
+    void assertChannelNotOpen() const;
+
+    virtual void handleMethodInContext(
+        boost::shared_ptr<qpid::framing::AMQMethodBody> method,
+        const MethodContext& context) = 0;
+
+    RequestId getFirstAckRequest() { return requester.getFirstAckRequest(); }
+    RequestId getLastAckRequest() { return requester.getLastAckRequest(); }
+    RequestId getNextSendRequestId() { return requester.getNextId(); }
+
+  private:
+    ChannelId id;
+    OutputHandler* out;
+    ProtocolVersion version;
+    Requester requester;
+    Responder responder;
+};
+
+}}
+
+
+#endif