diff options
Diffstat (limited to 'cpp/src/qpid/broker/PreviewConnectionHandler.h')
-rw-r--r-- | cpp/src/qpid/broker/PreviewConnectionHandler.h | 107 |
1 files changed, 0 insertions, 107 deletions
diff --git a/cpp/src/qpid/broker/PreviewConnectionHandler.h b/cpp/src/qpid/broker/PreviewConnectionHandler.h deleted file mode 100644 index b71068d81d..0000000000 --- a/cpp/src/qpid/broker/PreviewConnectionHandler.h +++ /dev/null @@ -1,107 +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 _PreviewConnectionAdapter_ -#define _PreviewConnectionAdapter_ - -#include "config.h" - -#include <memory> -#include "qpid/framing/amqp_types.h" -#include "qpid/framing/AMQFrame.h" -#include "qpid/framing/AMQP_ClientOperations.h" -#include "qpid/framing/AMQP_ClientProxy.h" -#include "qpid/framing/AMQP_ServerOperations.h" -#include "qpid/framing/AMQP_ServerProxy.h" -#include "qpid/framing/FrameHandler.h" -#include "qpid/framing/ProtocolInitiation.h" -#include "qpid/framing/ProtocolVersion.h" -#include "qpid/Exception.h" - -#if HAVE_SASL -#include <sasl/sasl.h> -#endif - -namespace qpid { -namespace broker { - -class PreviewConnection; - -// TODO aconway 2007-09-18: Rename to ConnectionHandler -class PreviewConnectionHandler : public framing::FrameHandler -{ - struct Handler : public framing::AMQP_ServerOperations::ConnectionHandler, - public framing::AMQP_ClientOperations::ConnectionHandler - { -#if HAVE_SASL - sasl_conn_t *sasl_conn; -#endif - framing::AMQP_ClientProxy::Connection client; - framing::AMQP_ServerProxy::Connection server; - PreviewConnection& connection; - bool serverMode; - - Handler(PreviewConnection& connection); - ~Handler(); - void startOk(const qpid::framing::FieldTable& clientProperties, - const std::string& mechanism, const std::string& response, - const std::string& locale); - void secureOk(const std::string& response); - void tuneOk(uint16_t channelMax, uint32_t frameMax, uint16_t heartbeat); - void open(const std::string& virtualHost, - const std::string& capabilities, bool insist); - void close(uint16_t replyCode, const std::string& replyText, - uint16_t classId, uint16_t methodId); - void closeOk(); - - - void start(uint8_t versionMajor, - uint8_t versionMinor, - const qpid::framing::FieldTable& serverProperties, - const std::string& mechanisms, - const std::string& locales); - - void secure(const std::string& challenge); - - void tune(uint16_t channelMax, - uint32_t frameMax, - uint16_t heartbeat); - - void openOk(const std::string& knownHosts); - - void redirect(const std::string& host, const std::string& knownHosts); - private: -#if HAVE_SASL - void processAuthenticationStep(int code, - const char *challenge, - unsigned int challenge_len); -#endif - }; - std::auto_ptr<Handler> handler; - public: - PreviewConnectionHandler(PreviewConnection& connection, bool isClient); - void close(framing::ReplyCode code, const std::string& text, framing::ClassId classId, framing::MethodId methodId); - void handle(framing::AMQFrame& frame); -}; - - -}} - -#endif |