Creating a branch for experimenting with some ideas for JMS client.rajith_jms_client

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/rajith_jms_client@1128369 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 0 insertions, 120 deletions

diff --git a/cpp/src/qpid/broker/SessionHandler.cpp b/cpp/src/qpid/broker/SessionHandler.cpp
deleted file mode 100644
index 752fa55535..0000000000
--- a/cpp/src/qpid/broker/SessionHandler.cpp
+++ /dev/null
@@ -1,120 +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.
- *
- */
-
-#include "qpid/broker/SessionHandler.h"
-#include "qpid/broker/SessionState.h"
-#include "qpid/broker/Connection.h"
-#include "qpid/log/Statement.h"
-
-#include <boost/bind.hpp>
-
-namespace qpid {
-namespace broker {
-using namespace framing;
-using namespace std;
-using namespace qpid::sys;
-
-SessionHandler::SessionHandler(Connection& c, ChannelId ch)
-    : amqp_0_10::SessionHandler(&c.getOutput(), ch),
-      connection(c),
-      proxy(out),
-      clusterOrderProxy(c.getClusterOrderOutput() ? new SetChannelProxy(ch, c.getClusterOrderOutput()) : 0)
-{}
-
-SessionHandler::~SessionHandler() {}
-
-void SessionHandler::connectionException(framing::connection::CloseCode code, const std::string& msg) {
-    // NOTE: must tell the error listener _before_ calling connection.close()
-    if (connection.getErrorListener()) connection.getErrorListener()->connectionError(msg);
-    connection.close(code, msg);
-}
-
-void SessionHandler::channelException(framing::session::DetachCode, const std::string& msg) {
-    if (connection.getErrorListener()) connection.getErrorListener()->sessionError(getChannel(), msg);
-}
-
-void SessionHandler::executionException(framing::execution::ErrorCode, const std::string& msg) {
-    if (connection.getErrorListener()) connection.getErrorListener()->sessionError(getChannel(), msg);
-}
-
-ConnectionState& SessionHandler::getConnection() { return connection; }
-
-const ConnectionState& SessionHandler::getConnection() const { return connection; }
-
-void SessionHandler::handleDetach() {
-    amqp_0_10::SessionHandler::handleDetach();
-    assert(&connection.getChannel(channel.get()) == this);
-    if (session.get())
-        connection.getBroker().getSessionManager().detach(session);
-    assert(!session.get());
-    connection.closeChannel(channel.get());
-}
-
-void SessionHandler::setState(const std::string& name, bool force) {
-    assert(!session.get());
-    SessionId id(connection.getUserId(), name);
-    session = connection.broker.getSessionManager().attach(*this, id, force);
-}
-
-void SessionHandler::detaching()
-{
-    assert(session.get());
-    session->disableOutput();
-}
-
-FrameHandler* SessionHandler::getInHandler() { return session.get() ? &session->in : 0; }
-qpid::SessionState* SessionHandler::getState() { return session.get(); }
-
-void SessionHandler::readyToSend() {
-    if (session.get()) session->readyToSend();
-}
-
-/**
- * Used by inter-broker bridges to set up session id and attach
- */
-void SessionHandler::attachAs(const std::string& name)
-{
-    SessionId id(connection.getUserId(), name);
-    SessionState::Configuration config = connection.broker.getSessionManager().getSessionConfig();
-    // Delay creating management object till attached(). In a cluster,
-    // only the active link broker calls attachAs but all brokers
-    // receive the subsequent attached() call.
-    session.reset(new SessionState(connection.getBroker(), *this, id, config, true));
-    sendAttach(false);
-}
-
-/**
- * TODO: this is a little ugly, fix it; its currently still relied on
- * for 'push' bridges
- */
-void SessionHandler::attached(const std::string& name)
-{
-    if (session.get()) {
-        session->addManagementObject(); // Delayed from attachAs()
-        amqp_0_10::SessionHandler::attached(name);
-    } else {
-        SessionId id(connection.getUserId(), name);
-        SessionState::Configuration config = connection.broker.getSessionManager().getSessionConfig();
-        session.reset(new SessionState(connection.getBroker(), *this, id, config));
-        markReadyToSend();
-    }
-}
-
-}} // namespace qpid::broker