src/main/activemq/wireformat/openwire/utils/BooleanStream.h

Go to the documentation of this file.

#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_UTILS_BOOLEANSTREAM_H_
#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_UTILS_BOOLEANSTREAM_H_

#include <decaf/io/DataInputStream.h>
#include <decaf/io/DataOutputStream.h>
#include <activemq/util/Config.h>

namespace activemq{
namespace wireformat{
namespace openwire{
namespace utils{

    class AMQCPP_API BooleanStream {
    private:

        // Internal Buffer of data
        std::vector<unsigned char> data;

        // Limit on buffer size
        short arrayLimit;

        // Byte we are on from the buffer
        short arrayPos;

        // Bit we are on in the byte we are on from the buffer
        unsigned char bytePos;

    public:

        BooleanStream();

        virtual ~BooleanStream() throw();

        bool readBoolean();

        void writeBoolean( bool value );

        void marshal( decaf::io::DataOutputStream* dataOut );

        void marshal( std::vector< unsigned char >& dataOut );

        void unmarshal( decaf::io::DataInputStream* dataIn );

        void clear();

        int marshalledSize();

    };

}}}}

#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_UTILS_BOOLEANSTREAM_H_*/