src/main/activemq/wireformat/WireFormat.h

Go to the documentation of this file.

#ifndef _ACTIVEMQ_WIREFORMAT_WIREFORMAT_H_
#define _ACTIVEMQ_WIREFORMAT_WIREFORMAT_H_

#include <activemq/wireformat/WireFormatNegotiator.h>

#include <decaf/io/DataInputStream.h>
#include <decaf/io/DataOutputStream.h>
#include <decaf/io/IOException.h>
#include <decaf/lang/Pointer.h>

#include <activemq/util/Config.h>
#include <activemq/commands/Command.h>
#include <activemq/transport/Transport.h>

#include <decaf/lang/exceptions/UnsupportedOperationException.h>

namespace activemq{
namespace wireformat{

    using decaf::lang::Pointer;

    class AMQCPP_API WireFormat {
    public:

        virtual ~WireFormat() {}

        virtual void marshal( const Pointer<commands::Command>& command,
                              const activemq::transport::Transport* transport,
                              decaf::io::DataOutputStream* out ) = 0;

        virtual Pointer<commands::Command> unmarshal( const activemq::transport::Transport* transport,
                                                      decaf::io::DataInputStream* in ) = 0;

        virtual void setVersion( int version ) = 0;

        virtual int getVersion() const = 0;

        virtual bool hasNegotiator() const = 0;

        virtual bool inReceive() const = 0;

        virtual Pointer<transport::Transport> createNegotiator(
            const Pointer<transport::Transport>& transport ) = 0;

    };

}}

#endif /*_ACTIVEMQ_WIREFORMAT_WIREFORMAT_H_*/