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_*/

---