src/main/activemq/commands/WireFormatInfo.h

Go to the documentation of this file.

#ifndef _ACTIVEMQ_COMMANDS_WIREFORMATINFO_H_
#define _ACTIVEMQ_COMMANDS_WIREFORMATINFO_H_

#include <activemq/util/Config.h>
#include <activemq/commands/BaseCommand.h>
#include <activemq/util/PrimitiveMap.h>
#include <activemq/exceptions/ActiveMQException.h>

#include <vector>

namespace activemq{
namespace commands{

    class AMQCPP_API WireFormatInfo : public BaseCommand {
    private:

        std::vector<unsigned char> magic;
        std::vector<unsigned char> marshalledProperties;

        util::PrimitiveMap properties;

        int version;

    public:

        const static unsigned char ID_WIREFORMATINFO = 1;

    public:

        WireFormatInfo();

        virtual ~WireFormatInfo();

        virtual unsigned char getDataStructureType() const;

        virtual DataStructure* cloneDataStructure() const;

        virtual void copyDataStructure( const DataStructure* src );

        virtual std::string toString() const;

        virtual bool equals( const DataStructure* value ) const;

        virtual bool isMarshalAware() const {
            return true;
        }

        virtual decaf::lang::Pointer<commands::Command> visit(
            activemq::state::CommandVisitor* visitor ) throw( exceptions::ActiveMQException );

        int getVersion() const {
            return version;
        }

        void setVersion( int version ) {
            this->version = version;
        }

        long long getMaxInactivityDuration() const;

        void setMaxInactivityDuration( long long maxInactivityDuration );

        long long getMaxInactivityDurationInitalDelay() const;

        void setMaxInactivityDurationInitalDelay( long long maxInactivityDurationInitalDelay );

        bool isStackTraceEnabled() const;

        void setStackTraceEnabled( bool stackTraceEnabled );

        bool isTcpNoDelayEnabled() const;

        void setTcpNoDelayEnabled( bool tcpNoDelayEnabled );

        bool isCacheEnabled() const;

        void setCacheEnabled( bool cacheEnabled );

        int getCacheSize() const;

        void setCacheSize( int value );

        bool isTightEncodingEnabled() const;

        void setTightEncodingEnabled( bool tightEncodingEnabled );

        bool isSizePrefixDisabled() const;

        void setSizePrefixDisabled( bool sizePrefixDisabled );

        const std::vector<unsigned char>& getMagic() const {
            return magic;
        }

        void setMagic( const std::vector<unsigned char>& magic ) {
            this->magic = magic;
        }

        const std::vector<unsigned char>& getMarshalledProperties() const {
            return marshalledProperties;
        }

        void setMarshalledProperties( const std::vector<unsigned char>& marshalledProperties ) {
            this->marshalledProperties = marshalledProperties;
        }

        virtual const util::PrimitiveMap& getProperties() const {
            return properties;
        }

        virtual util::PrimitiveMap& getProperties() {
            return properties;
        }

        virtual void setProperties( const util::PrimitiveMap& map ) {
            this->properties.copy( map );
        }

        bool isValid() const;

        virtual bool isWireFormatInfo() const {
            return true;
        }

    public:

        virtual void beforeMarshal( wireformat::WireFormat* wireFormat AMQCPP_UNUSED );

        virtual void afterUnmarshal( wireformat::WireFormat* wireFormat AMQCPP_UNUSED );

    };

}}

#endif /*_ACTIVEMQ_COMMANDS_WIREFORMATINFO_H_*/