00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018 #ifndef _ACTIVEMQ_COMMANDS_CONNECTIONCONTROL_H_
00019 #define _ACTIVEMQ_COMMANDS_CONNECTIONCONTROL_H_
00020
00021
00022 #ifdef _MSC_VER
00023 #pragma warning( disable : 4290 )
00024 #endif
00025
00026 #include <activemq/commands/BaseCommand.h>
00027 #include <activemq/util/Config.h>
00028 #include <decaf/lang/Pointer.h>
00029 #include <string>
00030 #include <vector>
00031
00032 namespace activemq {
00033 namespace commands {
00034
00035 using decaf::lang::Pointer;
00036
00037
00038
00039
00040
00041
00042
00043
00044
00045
00046 class AMQCPP_API ConnectionControl : public BaseCommand {
00047 protected:
00048
00049 bool close;
00050 bool exit;
00051 bool faultTolerant;
00052 bool resume;
00053 bool suspend;
00054 std::string connectedBrokers;
00055 std::string reconnectTo;
00056 bool rebalanceConnection;
00057 std::vector<unsigned char> token;
00058
00059 public:
00060
00061 const static unsigned char ID_CONNECTIONCONTROL = 18;
00062
00063 private:
00064
00065 ConnectionControl(const ConnectionControl&);
00066 ConnectionControl& operator= (const ConnectionControl&);
00067
00068 public:
00069
00070 ConnectionControl();
00071
00072 virtual ~ConnectionControl();
00073
00074 virtual unsigned char getDataStructureType() const;
00075
00076 virtual ConnectionControl* cloneDataStructure() const;
00077
00078 virtual void copyDataStructure(const DataStructure* src);
00079
00080 virtual std::string toString() const;
00081
00082 virtual bool equals(const DataStructure* value) const;
00083
00084 virtual bool isClose() const;
00085 virtual void setClose( bool close );
00086
00087 virtual bool isExit() const;
00088 virtual void setExit( bool exit );
00089
00090 virtual bool isFaultTolerant() const;
00091 virtual void setFaultTolerant( bool faultTolerant );
00092
00093 virtual bool isResume() const;
00094 virtual void setResume( bool resume );
00095
00096 virtual bool isSuspend() const;
00097 virtual void setSuspend( bool suspend );
00098
00099 virtual const std::string& getConnectedBrokers() const;
00100 virtual std::string& getConnectedBrokers();
00101 virtual void setConnectedBrokers( const std::string& connectedBrokers );
00102
00103 virtual const std::string& getReconnectTo() const;
00104 virtual std::string& getReconnectTo();
00105 virtual void setReconnectTo( const std::string& reconnectTo );
00106
00107 virtual bool isRebalanceConnection() const;
00108 virtual void setRebalanceConnection( bool rebalanceConnection );
00109
00110 virtual const std::vector<unsigned char>& getToken() const;
00111 virtual std::vector<unsigned char>& getToken();
00112 virtual void setToken( const std::vector<unsigned char>& token );
00113
00117 virtual bool isConnectionControl() const {
00118 return true;
00119 }
00120
00121 virtual Pointer<Command> visit(activemq::state::CommandVisitor* visitor);
00122
00123 };
00124
00125 }}
00126
00127 #endif