00001 #ifndef QPID_SYS_CONNECTION_CODEC_H
00002 #define QPID_SYS_CONNECTION_CODEC_H
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024 #include "qpid/framing/ProtocolVersion.h"
00025 #include "OutputControl.h"
00026 #include <memory>
00027 #include <map>
00028
00029 namespace qpid {
00030
00031 namespace broker { class Broker; }
00032
00033 namespace sys {
00034
00039 class ConnectionCodec {
00040 public:
00041 virtual ~ConnectionCodec() {}
00042
00047 virtual size_t decode(const char* buffer, size_t size) = 0;
00048
00049
00051 virtual size_t encode(const char* buffer, size_t size) = 0;
00052
00054 virtual bool canEncode() = 0;
00055
00057 virtual void closed() = 0;
00058
00059 virtual bool isClosed() const = 0;
00060
00061 virtual framing::ProtocolVersion getVersion() const = 0;
00062
00063 struct Factory {
00064 virtual ~Factory() {}
00065
00067 virtual ConnectionCodec* create(
00068 framing::ProtocolVersion, OutputControl&, const std::string& id
00069 ) = 0;
00070
00072 virtual ConnectionCodec* create(
00073 OutputControl&, const std::string& id
00074 ) = 0;
00075 };
00076 };
00077
00078 }}
00079
00080 #endif