DataStreamMarshaller.h

Go to the documentation of this file.

#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSHAL_DATASTREAMMARSHALLER_H_
#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSHAL_DATASTREAMMARSHALLER_H_

#include <decaf/io/DataInputStream.h>
#include <decaf/io/DataOutputStream.h>
#include <decaf/io/IOException.h>
#include <activemq/commands/DataStructure.h>
#include <activemq/wireformat/openwire/utils/BooleanStream.h>
#include <activemq/wireformat/openwire/OpenWireFormat.h>
#include <activemq/util/Config.h>

namespace activemq {
namespace wireformat {
namespace openwire {
namespace marshal {

    class AMQCPP_API DataStreamMarshaller {
    public:

        virtual ~DataStreamMarshaller();

        virtual unsigned char getDataStructureType() const = 0;

        virtual commands::DataStructure* createObject() const = 0;

        virtual int tightMarshal1(OpenWireFormat* format,
                                  commands::DataStructure* command,
                                  utils::BooleanStream* bs) = 0;

        virtual void tightMarshal2(OpenWireFormat* format,
                                   commands::DataStructure* command,
                                   decaf::io::DataOutputStream* ds,
                                   utils::BooleanStream* bs) = 0;

        virtual void tightUnmarshal(OpenWireFormat* format,
                                    commands::DataStructure* command,
                                    decaf::io::DataInputStream* dis,
                                    utils::BooleanStream* bs) = 0;

        virtual void looseMarshal(OpenWireFormat* format,
                                  commands::DataStructure* command,
                                  decaf::io::DataOutputStream* ds) = 0;

        virtual void looseUnmarshal(OpenWireFormat* format,
                                    commands::DataStructure* command,
                                    decaf::io::DataInputStream* dis) = 0;

    };

}}}}

#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSHAL_DATASTREAMMARSHALLER_H_*/