rabbitmq.pb.h 70 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661
  1. // Generated by the protocol buffer compiler. DO NOT EDIT!
  2. // source: rabbitmq.proto
  3. #ifndef PROTOBUF_INCLUDED_rabbitmq_2eproto
  4. #define PROTOBUF_INCLUDED_rabbitmq_2eproto
  5. #include <string>
  6. #include <google/protobuf/stubs/common.h>
  7. #if GOOGLE_PROTOBUF_VERSION < 3006001
  8. #error This file was generated by a newer version of protoc which is
  9. #error incompatible with your Protocol Buffer headers. Please update
  10. #error your headers.
  11. #endif
  12. #if 3006001 < GOOGLE_PROTOBUF_MIN_PROTOC_VERSION
  13. #error This file was generated by an older version of protoc which is
  14. #error incompatible with your Protocol Buffer headers. Please
  15. #error regenerate this file with a newer version of protoc.
  16. #endif
  17. #include <google/protobuf/io/coded_stream.h>
  18. #include <google/protobuf/arena.h>
  19. #include <google/protobuf/arenastring.h>
  20. #include <google/protobuf/generated_message_table_driven.h>
  21. #include <google/protobuf/generated_message_util.h>
  22. #include <google/protobuf/inlined_string_field.h>
  23. #include <google/protobuf/metadata.h>
  24. #include <google/protobuf/message.h>
  25. #include <google/protobuf/repeated_field.h> // IWYU pragma: export
  26. #include <google/protobuf/extension_set.h> // IWYU pragma: export
  27. #include <google/protobuf/unknown_field_set.h>
  28. // @@protoc_insertion_point(includes)
  29. #define PROTOBUF_INTERNAL_EXPORT_protobuf_rabbitmq_2eproto
  30. namespace protobuf_rabbitmq_2eproto {
  31. // Internal implementation detail -- do not use these members.
  32. struct TableStruct {
  33. static const ::google::protobuf::internal::ParseTableField entries[];
  34. static const ::google::protobuf::internal::AuxillaryParseTableField aux[];
  35. static const ::google::protobuf::internal::ParseTable schema[3];
  36. static const ::google::protobuf::internal::FieldMetadata field_metadata[];
  37. static const ::google::protobuf::internal::SerializationTable serialization_table[];
  38. static const ::google::protobuf::uint32 offsets[];
  39. };
  40. void AddDescriptors();
  41. } // namespace protobuf_rabbitmq_2eproto
  42. namespace Rabbitmq_proto {
  43. class Rabbitmq_channel_queue_consume;
  44. class Rabbitmq_channel_queue_consumeDefaultTypeInternal;
  45. extern Rabbitmq_channel_queue_consumeDefaultTypeInternal _Rabbitmq_channel_queue_consume_default_instance_;
  46. class Rabbitmq_parameter;
  47. class Rabbitmq_parameterDefaultTypeInternal;
  48. extern Rabbitmq_parameterDefaultTypeInternal _Rabbitmq_parameter_default_instance_;
  49. class Rabbitmq_parameter_all;
  50. class Rabbitmq_parameter_allDefaultTypeInternal;
  51. extern Rabbitmq_parameter_allDefaultTypeInternal _Rabbitmq_parameter_all_default_instance_;
  52. } // namespace Rabbitmq_proto
  53. namespace google {
  54. namespace protobuf {
  55. template<> ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Arena::CreateMaybeMessage<::Rabbitmq_proto::Rabbitmq_channel_queue_consume>(Arena*);
  56. template<> ::Rabbitmq_proto::Rabbitmq_parameter* Arena::CreateMaybeMessage<::Rabbitmq_proto::Rabbitmq_parameter>(Arena*);
  57. template<> ::Rabbitmq_proto::Rabbitmq_parameter_all* Arena::CreateMaybeMessage<::Rabbitmq_proto::Rabbitmq_parameter_all>(Arena*);
  58. } // namespace protobuf
  59. } // namespace google
  60. namespace Rabbitmq_proto {
  61. // ===================================================================
  62. class Rabbitmq_channel_queue_consume : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:Rabbitmq_proto.Rabbitmq_channel_queue_consume) */ {
  63. public:
  64. Rabbitmq_channel_queue_consume();
  65. virtual ~Rabbitmq_channel_queue_consume();
  66. Rabbitmq_channel_queue_consume(const Rabbitmq_channel_queue_consume& from);
  67. inline Rabbitmq_channel_queue_consume& operator=(const Rabbitmq_channel_queue_consume& from) {
  68. CopyFrom(from);
  69. return *this;
  70. }
  71. #if LANG_CXX11
  72. Rabbitmq_channel_queue_consume(Rabbitmq_channel_queue_consume&& from) noexcept
  73. : Rabbitmq_channel_queue_consume() {
  74. *this = ::std::move(from);
  75. }
  76. inline Rabbitmq_channel_queue_consume& operator=(Rabbitmq_channel_queue_consume&& from) noexcept {
  77. if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) {
  78. if (this != &from) InternalSwap(&from);
  79. } else {
  80. CopyFrom(from);
  81. }
  82. return *this;
  83. }
  84. #endif
  85. inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
  86. return _internal_metadata_.unknown_fields();
  87. }
  88. inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
  89. return _internal_metadata_.mutable_unknown_fields();
  90. }
  91. static const ::google::protobuf::Descriptor* descriptor();
  92. static const Rabbitmq_channel_queue_consume& default_instance();
  93. static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
  94. static inline const Rabbitmq_channel_queue_consume* internal_default_instance() {
  95. return reinterpret_cast<const Rabbitmq_channel_queue_consume*>(
  96. &_Rabbitmq_channel_queue_consume_default_instance_);
  97. }
  98. static constexpr int kIndexInFileMessages =
  99. 0;
  100. void Swap(Rabbitmq_channel_queue_consume* other);
  101. friend void swap(Rabbitmq_channel_queue_consume& a, Rabbitmq_channel_queue_consume& b) {
  102. a.Swap(&b);
  103. }
  104. // implements Message ----------------------------------------------
  105. inline Rabbitmq_channel_queue_consume* New() const final {
  106. return CreateMaybeMessage<Rabbitmq_channel_queue_consume>(NULL);
  107. }
  108. Rabbitmq_channel_queue_consume* New(::google::protobuf::Arena* arena) const final {
  109. return CreateMaybeMessage<Rabbitmq_channel_queue_consume>(arena);
  110. }
  111. void CopyFrom(const ::google::protobuf::Message& from) final;
  112. void MergeFrom(const ::google::protobuf::Message& from) final;
  113. void CopyFrom(const Rabbitmq_channel_queue_consume& from);
  114. void MergeFrom(const Rabbitmq_channel_queue_consume& from);
  115. void Clear() final;
  116. bool IsInitialized() const final;
  117. size_t ByteSizeLong() const final;
  118. bool MergePartialFromCodedStream(
  119. ::google::protobuf::io::CodedInputStream* input) final;
  120. void SerializeWithCachedSizes(
  121. ::google::protobuf::io::CodedOutputStream* output) const final;
  122. ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
  123. bool deterministic, ::google::protobuf::uint8* target) const final;
  124. int GetCachedSize() const final { return _cached_size_.Get(); }
  125. private:
  126. void SharedCtor();
  127. void SharedDtor();
  128. void SetCachedSize(int size) const final;
  129. void InternalSwap(Rabbitmq_channel_queue_consume* other);
  130. private:
  131. inline ::google::protobuf::Arena* GetArenaNoVirtual() const {
  132. return NULL;
  133. }
  134. inline void* MaybeArenaPtr() const {
  135. return NULL;
  136. }
  137. public:
  138. ::google::protobuf::Metadata GetMetadata() const final;
  139. // nested types ----------------------------------------------------
  140. // accessors -------------------------------------------------------
  141. // optional string exchange_name = 2;
  142. bool has_exchange_name() const;
  143. void clear_exchange_name();
  144. static const int kExchangeNameFieldNumber = 2;
  145. const ::std::string& exchange_name() const;
  146. void set_exchange_name(const ::std::string& value);
  147. #if LANG_CXX11
  148. void set_exchange_name(::std::string&& value);
  149. #endif
  150. void set_exchange_name(const char* value);
  151. void set_exchange_name(const char* value, size_t size);
  152. ::std::string* mutable_exchange_name();
  153. ::std::string* release_exchange_name();
  154. void set_allocated_exchange_name(::std::string* exchange_name);
  155. // optional string routing_key = 3;
  156. bool has_routing_key() const;
  157. void clear_routing_key();
  158. static const int kRoutingKeyFieldNumber = 3;
  159. const ::std::string& routing_key() const;
  160. void set_routing_key(const ::std::string& value);
  161. #if LANG_CXX11
  162. void set_routing_key(::std::string&& value);
  163. #endif
  164. void set_routing_key(const char* value);
  165. void set_routing_key(const char* value, size_t size);
  166. ::std::string* mutable_routing_key();
  167. ::std::string* release_routing_key();
  168. void set_allocated_routing_key(::std::string* routing_key);
  169. // optional string binding_key = 5;
  170. bool has_binding_key() const;
  171. void clear_binding_key();
  172. static const int kBindingKeyFieldNumber = 5;
  173. const ::std::string& binding_key() const;
  174. void set_binding_key(const ::std::string& value);
  175. #if LANG_CXX11
  176. void set_binding_key(::std::string&& value);
  177. #endif
  178. void set_binding_key(const char* value);
  179. void set_binding_key(const char* value, size_t size);
  180. ::std::string* mutable_binding_key();
  181. ::std::string* release_binding_key();
  182. void set_allocated_binding_key(::std::string* binding_key);
  183. // optional string queue_name = 6;
  184. bool has_queue_name() const;
  185. void clear_queue_name();
  186. static const int kQueueNameFieldNumber = 6;
  187. const ::std::string& queue_name() const;
  188. void set_queue_name(const ::std::string& value);
  189. #if LANG_CXX11
  190. void set_queue_name(::std::string&& value);
  191. #endif
  192. void set_queue_name(const char* value);
  193. void set_queue_name(const char* value, size_t size);
  194. ::std::string* mutable_queue_name();
  195. ::std::string* release_queue_name();
  196. void set_allocated_queue_name(::std::string* queue_name);
  197. // optional string consume_name = 12;
  198. bool has_consume_name() const;
  199. void clear_consume_name();
  200. static const int kConsumeNameFieldNumber = 12;
  201. const ::std::string& consume_name() const;
  202. void set_consume_name(const ::std::string& value);
  203. #if LANG_CXX11
  204. void set_consume_name(::std::string&& value);
  205. #endif
  206. void set_consume_name(const char* value);
  207. void set_consume_name(const char* value, size_t size);
  208. ::std::string* mutable_consume_name();
  209. ::std::string* release_consume_name();
  210. void set_allocated_consume_name(::std::string* consume_name);
  211. // optional int32 channel = 1;
  212. bool has_channel() const;
  213. void clear_channel();
  214. static const int kChannelFieldNumber = 1;
  215. ::google::protobuf::int32 channel() const;
  216. void set_channel(::google::protobuf::int32 value);
  217. // optional int32 timeout_ms = 4;
  218. bool has_timeout_ms() const;
  219. void clear_timeout_ms();
  220. static const int kTimeoutMsFieldNumber = 4;
  221. ::google::protobuf::int32 timeout_ms() const;
  222. void set_timeout_ms(::google::protobuf::int32 value);
  223. // optional int32 queue_passive = 7 [default = 0];
  224. bool has_queue_passive() const;
  225. void clear_queue_passive();
  226. static const int kQueuePassiveFieldNumber = 7;
  227. ::google::protobuf::int32 queue_passive() const;
  228. void set_queue_passive(::google::protobuf::int32 value);
  229. // optional int32 queue_durable = 8;
  230. bool has_queue_durable() const;
  231. void clear_queue_durable();
  232. static const int kQueueDurableFieldNumber = 8;
  233. ::google::protobuf::int32 queue_durable() const;
  234. void set_queue_durable(::google::protobuf::int32 value);
  235. // optional int32 queue_exclusive = 9 [default = 0];
  236. bool has_queue_exclusive() const;
  237. void clear_queue_exclusive();
  238. static const int kQueueExclusiveFieldNumber = 9;
  239. ::google::protobuf::int32 queue_exclusive() const;
  240. void set_queue_exclusive(::google::protobuf::int32 value);
  241. // optional int32 queue_auto_delete = 10 [default = 0];
  242. bool has_queue_auto_delete() const;
  243. void clear_queue_auto_delete();
  244. static const int kQueueAutoDeleteFieldNumber = 10;
  245. ::google::protobuf::int32 queue_auto_delete() const;
  246. void set_queue_auto_delete(::google::protobuf::int32 value);
  247. // optional int32 queue_meassage_ttl = 11 [default = 0];
  248. bool has_queue_meassage_ttl() const;
  249. void clear_queue_meassage_ttl();
  250. static const int kQueueMeassageTtlFieldNumber = 11;
  251. ::google::protobuf::int32 queue_meassage_ttl() const;
  252. void set_queue_meassage_ttl(::google::protobuf::int32 value);
  253. // optional int32 consume_no_local = 13 [default = 0];
  254. bool has_consume_no_local() const;
  255. void clear_consume_no_local();
  256. static const int kConsumeNoLocalFieldNumber = 13;
  257. ::google::protobuf::int32 consume_no_local() const;
  258. void set_consume_no_local(::google::protobuf::int32 value);
  259. // optional int32 consume_no_ack = 14 [default = 0];
  260. bool has_consume_no_ack() const;
  261. void clear_consume_no_ack();
  262. static const int kConsumeNoAckFieldNumber = 14;
  263. ::google::protobuf::int32 consume_no_ack() const;
  264. void set_consume_no_ack(::google::protobuf::int32 value);
  265. // optional int32 consume_exclusive = 15;
  266. bool has_consume_exclusive() const;
  267. void clear_consume_exclusive();
  268. static const int kConsumeExclusiveFieldNumber = 15;
  269. ::google::protobuf::int32 consume_exclusive() const;
  270. void set_consume_exclusive(::google::protobuf::int32 value);
  271. // @@protoc_insertion_point(class_scope:Rabbitmq_proto.Rabbitmq_channel_queue_consume)
  272. private:
  273. void set_has_channel();
  274. void clear_has_channel();
  275. void set_has_exchange_name();
  276. void clear_has_exchange_name();
  277. void set_has_routing_key();
  278. void clear_has_routing_key();
  279. void set_has_timeout_ms();
  280. void clear_has_timeout_ms();
  281. void set_has_binding_key();
  282. void clear_has_binding_key();
  283. void set_has_queue_name();
  284. void clear_has_queue_name();
  285. void set_has_queue_passive();
  286. void clear_has_queue_passive();
  287. void set_has_queue_durable();
  288. void clear_has_queue_durable();
  289. void set_has_queue_exclusive();
  290. void clear_has_queue_exclusive();
  291. void set_has_queue_auto_delete();
  292. void clear_has_queue_auto_delete();
  293. void set_has_queue_meassage_ttl();
  294. void clear_has_queue_meassage_ttl();
  295. void set_has_consume_name();
  296. void clear_has_consume_name();
  297. void set_has_consume_no_local();
  298. void clear_has_consume_no_local();
  299. void set_has_consume_no_ack();
  300. void clear_has_consume_no_ack();
  301. void set_has_consume_exclusive();
  302. void clear_has_consume_exclusive();
  303. ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
  304. ::google::protobuf::internal::HasBits<1> _has_bits_;
  305. mutable ::google::protobuf::internal::CachedSize _cached_size_;
  306. ::google::protobuf::internal::ArenaStringPtr exchange_name_;
  307. ::google::protobuf::internal::ArenaStringPtr routing_key_;
  308. ::google::protobuf::internal::ArenaStringPtr binding_key_;
  309. ::google::protobuf::internal::ArenaStringPtr queue_name_;
  310. ::google::protobuf::internal::ArenaStringPtr consume_name_;
  311. ::google::protobuf::int32 channel_;
  312. ::google::protobuf::int32 timeout_ms_;
  313. ::google::protobuf::int32 queue_passive_;
  314. ::google::protobuf::int32 queue_durable_;
  315. ::google::protobuf::int32 queue_exclusive_;
  316. ::google::protobuf::int32 queue_auto_delete_;
  317. ::google::protobuf::int32 queue_meassage_ttl_;
  318. ::google::protobuf::int32 consume_no_local_;
  319. ::google::protobuf::int32 consume_no_ack_;
  320. ::google::protobuf::int32 consume_exclusive_;
  321. friend struct ::protobuf_rabbitmq_2eproto::TableStruct;
  322. };
  323. // -------------------------------------------------------------------
  324. class Rabbitmq_parameter : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:Rabbitmq_proto.Rabbitmq_parameter) */ {
  325. public:
  326. Rabbitmq_parameter();
  327. virtual ~Rabbitmq_parameter();
  328. Rabbitmq_parameter(const Rabbitmq_parameter& from);
  329. inline Rabbitmq_parameter& operator=(const Rabbitmq_parameter& from) {
  330. CopyFrom(from);
  331. return *this;
  332. }
  333. #if LANG_CXX11
  334. Rabbitmq_parameter(Rabbitmq_parameter&& from) noexcept
  335. : Rabbitmq_parameter() {
  336. *this = ::std::move(from);
  337. }
  338. inline Rabbitmq_parameter& operator=(Rabbitmq_parameter&& from) noexcept {
  339. if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) {
  340. if (this != &from) InternalSwap(&from);
  341. } else {
  342. CopyFrom(from);
  343. }
  344. return *this;
  345. }
  346. #endif
  347. inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
  348. return _internal_metadata_.unknown_fields();
  349. }
  350. inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
  351. return _internal_metadata_.mutable_unknown_fields();
  352. }
  353. static const ::google::protobuf::Descriptor* descriptor();
  354. static const Rabbitmq_parameter& default_instance();
  355. static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
  356. static inline const Rabbitmq_parameter* internal_default_instance() {
  357. return reinterpret_cast<const Rabbitmq_parameter*>(
  358. &_Rabbitmq_parameter_default_instance_);
  359. }
  360. static constexpr int kIndexInFileMessages =
  361. 1;
  362. void Swap(Rabbitmq_parameter* other);
  363. friend void swap(Rabbitmq_parameter& a, Rabbitmq_parameter& b) {
  364. a.Swap(&b);
  365. }
  366. // implements Message ----------------------------------------------
  367. inline Rabbitmq_parameter* New() const final {
  368. return CreateMaybeMessage<Rabbitmq_parameter>(NULL);
  369. }
  370. Rabbitmq_parameter* New(::google::protobuf::Arena* arena) const final {
  371. return CreateMaybeMessage<Rabbitmq_parameter>(arena);
  372. }
  373. void CopyFrom(const ::google::protobuf::Message& from) final;
  374. void MergeFrom(const ::google::protobuf::Message& from) final;
  375. void CopyFrom(const Rabbitmq_parameter& from);
  376. void MergeFrom(const Rabbitmq_parameter& from);
  377. void Clear() final;
  378. bool IsInitialized() const final;
  379. size_t ByteSizeLong() const final;
  380. bool MergePartialFromCodedStream(
  381. ::google::protobuf::io::CodedInputStream* input) final;
  382. void SerializeWithCachedSizes(
  383. ::google::protobuf::io::CodedOutputStream* output) const final;
  384. ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
  385. bool deterministic, ::google::protobuf::uint8* target) const final;
  386. int GetCachedSize() const final { return _cached_size_.Get(); }
  387. private:
  388. void SharedCtor();
  389. void SharedDtor();
  390. void SetCachedSize(int size) const final;
  391. void InternalSwap(Rabbitmq_parameter* other);
  392. private:
  393. inline ::google::protobuf::Arena* GetArenaNoVirtual() const {
  394. return NULL;
  395. }
  396. inline void* MaybeArenaPtr() const {
  397. return NULL;
  398. }
  399. public:
  400. ::google::protobuf::Metadata GetMetadata() const final;
  401. // nested types ----------------------------------------------------
  402. // accessors -------------------------------------------------------
  403. // repeated .Rabbitmq_proto.Rabbitmq_channel_queue_consume rabbitmq_reciever_vector = 5;
  404. int rabbitmq_reciever_vector_size() const;
  405. void clear_rabbitmq_reciever_vector();
  406. static const int kRabbitmqRecieverVectorFieldNumber = 5;
  407. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* mutable_rabbitmq_reciever_vector(int index);
  408. ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >*
  409. mutable_rabbitmq_reciever_vector();
  410. const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& rabbitmq_reciever_vector(int index) const;
  411. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* add_rabbitmq_reciever_vector();
  412. const ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >&
  413. rabbitmq_reciever_vector() const;
  414. // repeated .Rabbitmq_proto.Rabbitmq_channel_queue_consume rabbitmq_sender_request_vector = 6;
  415. int rabbitmq_sender_request_vector_size() const;
  416. void clear_rabbitmq_sender_request_vector();
  417. static const int kRabbitmqSenderRequestVectorFieldNumber = 6;
  418. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* mutable_rabbitmq_sender_request_vector(int index);
  419. ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >*
  420. mutable_rabbitmq_sender_request_vector();
  421. const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& rabbitmq_sender_request_vector(int index) const;
  422. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* add_rabbitmq_sender_request_vector();
  423. const ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >&
  424. rabbitmq_sender_request_vector() const;
  425. // repeated .Rabbitmq_proto.Rabbitmq_channel_queue_consume rabbitmq_sender_status_vector = 7;
  426. int rabbitmq_sender_status_vector_size() const;
  427. void clear_rabbitmq_sender_status_vector();
  428. static const int kRabbitmqSenderStatusVectorFieldNumber = 7;
  429. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* mutable_rabbitmq_sender_status_vector(int index);
  430. ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >*
  431. mutable_rabbitmq_sender_status_vector();
  432. const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& rabbitmq_sender_status_vector(int index) const;
  433. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* add_rabbitmq_sender_status_vector();
  434. const ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >&
  435. rabbitmq_sender_status_vector() const;
  436. // optional string ip = 1;
  437. bool has_ip() const;
  438. void clear_ip();
  439. static const int kIpFieldNumber = 1;
  440. const ::std::string& ip() const;
  441. void set_ip(const ::std::string& value);
  442. #if LANG_CXX11
  443. void set_ip(::std::string&& value);
  444. #endif
  445. void set_ip(const char* value);
  446. void set_ip(const char* value, size_t size);
  447. ::std::string* mutable_ip();
  448. ::std::string* release_ip();
  449. void set_allocated_ip(::std::string* ip);
  450. // optional string user = 3;
  451. bool has_user() const;
  452. void clear_user();
  453. static const int kUserFieldNumber = 3;
  454. const ::std::string& user() const;
  455. void set_user(const ::std::string& value);
  456. #if LANG_CXX11
  457. void set_user(::std::string&& value);
  458. #endif
  459. void set_user(const char* value);
  460. void set_user(const char* value, size_t size);
  461. ::std::string* mutable_user();
  462. ::std::string* release_user();
  463. void set_allocated_user(::std::string* user);
  464. // optional string password = 4;
  465. bool has_password() const;
  466. void clear_password();
  467. static const int kPasswordFieldNumber = 4;
  468. const ::std::string& password() const;
  469. void set_password(const ::std::string& value);
  470. #if LANG_CXX11
  471. void set_password(::std::string&& value);
  472. #endif
  473. void set_password(const char* value);
  474. void set_password(const char* value, size_t size);
  475. ::std::string* mutable_password();
  476. ::std::string* release_password();
  477. void set_allocated_password(::std::string* password);
  478. // optional int32 port = 2;
  479. bool has_port() const;
  480. void clear_port();
  481. static const int kPortFieldNumber = 2;
  482. ::google::protobuf::int32 port() const;
  483. void set_port(::google::protobuf::int32 value);
  484. // @@protoc_insertion_point(class_scope:Rabbitmq_proto.Rabbitmq_parameter)
  485. private:
  486. void set_has_ip();
  487. void clear_has_ip();
  488. void set_has_port();
  489. void clear_has_port();
  490. void set_has_user();
  491. void clear_has_user();
  492. void set_has_password();
  493. void clear_has_password();
  494. ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
  495. ::google::protobuf::internal::HasBits<1> _has_bits_;
  496. mutable ::google::protobuf::internal::CachedSize _cached_size_;
  497. ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume > rabbitmq_reciever_vector_;
  498. ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume > rabbitmq_sender_request_vector_;
  499. ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume > rabbitmq_sender_status_vector_;
  500. ::google::protobuf::internal::ArenaStringPtr ip_;
  501. ::google::protobuf::internal::ArenaStringPtr user_;
  502. ::google::protobuf::internal::ArenaStringPtr password_;
  503. ::google::protobuf::int32 port_;
  504. friend struct ::protobuf_rabbitmq_2eproto::TableStruct;
  505. };
  506. // -------------------------------------------------------------------
  507. class Rabbitmq_parameter_all : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:Rabbitmq_proto.Rabbitmq_parameter_all) */ {
  508. public:
  509. Rabbitmq_parameter_all();
  510. virtual ~Rabbitmq_parameter_all();
  511. Rabbitmq_parameter_all(const Rabbitmq_parameter_all& from);
  512. inline Rabbitmq_parameter_all& operator=(const Rabbitmq_parameter_all& from) {
  513. CopyFrom(from);
  514. return *this;
  515. }
  516. #if LANG_CXX11
  517. Rabbitmq_parameter_all(Rabbitmq_parameter_all&& from) noexcept
  518. : Rabbitmq_parameter_all() {
  519. *this = ::std::move(from);
  520. }
  521. inline Rabbitmq_parameter_all& operator=(Rabbitmq_parameter_all&& from) noexcept {
  522. if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) {
  523. if (this != &from) InternalSwap(&from);
  524. } else {
  525. CopyFrom(from);
  526. }
  527. return *this;
  528. }
  529. #endif
  530. inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
  531. return _internal_metadata_.unknown_fields();
  532. }
  533. inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
  534. return _internal_metadata_.mutable_unknown_fields();
  535. }
  536. static const ::google::protobuf::Descriptor* descriptor();
  537. static const Rabbitmq_parameter_all& default_instance();
  538. static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
  539. static inline const Rabbitmq_parameter_all* internal_default_instance() {
  540. return reinterpret_cast<const Rabbitmq_parameter_all*>(
  541. &_Rabbitmq_parameter_all_default_instance_);
  542. }
  543. static constexpr int kIndexInFileMessages =
  544. 2;
  545. void Swap(Rabbitmq_parameter_all* other);
  546. friend void swap(Rabbitmq_parameter_all& a, Rabbitmq_parameter_all& b) {
  547. a.Swap(&b);
  548. }
  549. // implements Message ----------------------------------------------
  550. inline Rabbitmq_parameter_all* New() const final {
  551. return CreateMaybeMessage<Rabbitmq_parameter_all>(NULL);
  552. }
  553. Rabbitmq_parameter_all* New(::google::protobuf::Arena* arena) const final {
  554. return CreateMaybeMessage<Rabbitmq_parameter_all>(arena);
  555. }
  556. void CopyFrom(const ::google::protobuf::Message& from) final;
  557. void MergeFrom(const ::google::protobuf::Message& from) final;
  558. void CopyFrom(const Rabbitmq_parameter_all& from);
  559. void MergeFrom(const Rabbitmq_parameter_all& from);
  560. void Clear() final;
  561. bool IsInitialized() const final;
  562. size_t ByteSizeLong() const final;
  563. bool MergePartialFromCodedStream(
  564. ::google::protobuf::io::CodedInputStream* input) final;
  565. void SerializeWithCachedSizes(
  566. ::google::protobuf::io::CodedOutputStream* output) const final;
  567. ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
  568. bool deterministic, ::google::protobuf::uint8* target) const final;
  569. int GetCachedSize() const final { return _cached_size_.Get(); }
  570. private:
  571. void SharedCtor();
  572. void SharedDtor();
  573. void SetCachedSize(int size) const final;
  574. void InternalSwap(Rabbitmq_parameter_all* other);
  575. private:
  576. inline ::google::protobuf::Arena* GetArenaNoVirtual() const {
  577. return NULL;
  578. }
  579. inline void* MaybeArenaPtr() const {
  580. return NULL;
  581. }
  582. public:
  583. ::google::protobuf::Metadata GetMetadata() const final;
  584. // nested types ----------------------------------------------------
  585. // accessors -------------------------------------------------------
  586. // optional .Rabbitmq_proto.Rabbitmq_parameter rabbitmq_parameters = 1;
  587. bool has_rabbitmq_parameters() const;
  588. void clear_rabbitmq_parameters();
  589. static const int kRabbitmqParametersFieldNumber = 1;
  590. private:
  591. const ::Rabbitmq_proto::Rabbitmq_parameter& _internal_rabbitmq_parameters() const;
  592. public:
  593. const ::Rabbitmq_proto::Rabbitmq_parameter& rabbitmq_parameters() const;
  594. ::Rabbitmq_proto::Rabbitmq_parameter* release_rabbitmq_parameters();
  595. ::Rabbitmq_proto::Rabbitmq_parameter* mutable_rabbitmq_parameters();
  596. void set_allocated_rabbitmq_parameters(::Rabbitmq_proto::Rabbitmq_parameter* rabbitmq_parameters);
  597. // @@protoc_insertion_point(class_scope:Rabbitmq_proto.Rabbitmq_parameter_all)
  598. private:
  599. void set_has_rabbitmq_parameters();
  600. void clear_has_rabbitmq_parameters();
  601. ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
  602. ::google::protobuf::internal::HasBits<1> _has_bits_;
  603. mutable ::google::protobuf::internal::CachedSize _cached_size_;
  604. ::Rabbitmq_proto::Rabbitmq_parameter* rabbitmq_parameters_;
  605. friend struct ::protobuf_rabbitmq_2eproto::TableStruct;
  606. };
  607. // ===================================================================
  608. // ===================================================================
  609. #ifdef __GNUC__
  610. #pragma GCC diagnostic push
  611. #pragma GCC diagnostic ignored "-Wstrict-aliasing"
  612. #endif // __GNUC__
  613. // Rabbitmq_channel_queue_consume
  614. // optional int32 channel = 1;
  615. inline bool Rabbitmq_channel_queue_consume::has_channel() const {
  616. return (_has_bits_[0] & 0x00000020u) != 0;
  617. }
  618. inline void Rabbitmq_channel_queue_consume::set_has_channel() {
  619. _has_bits_[0] |= 0x00000020u;
  620. }
  621. inline void Rabbitmq_channel_queue_consume::clear_has_channel() {
  622. _has_bits_[0] &= ~0x00000020u;
  623. }
  624. inline void Rabbitmq_channel_queue_consume::clear_channel() {
  625. channel_ = 0;
  626. clear_has_channel();
  627. }
  628. inline ::google::protobuf::int32 Rabbitmq_channel_queue_consume::channel() const {
  629. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.channel)
  630. return channel_;
  631. }
  632. inline void Rabbitmq_channel_queue_consume::set_channel(::google::protobuf::int32 value) {
  633. set_has_channel();
  634. channel_ = value;
  635. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.channel)
  636. }
  637. // optional string exchange_name = 2;
  638. inline bool Rabbitmq_channel_queue_consume::has_exchange_name() const {
  639. return (_has_bits_[0] & 0x00000001u) != 0;
  640. }
  641. inline void Rabbitmq_channel_queue_consume::set_has_exchange_name() {
  642. _has_bits_[0] |= 0x00000001u;
  643. }
  644. inline void Rabbitmq_channel_queue_consume::clear_has_exchange_name() {
  645. _has_bits_[0] &= ~0x00000001u;
  646. }
  647. inline void Rabbitmq_channel_queue_consume::clear_exchange_name() {
  648. exchange_name_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  649. clear_has_exchange_name();
  650. }
  651. inline const ::std::string& Rabbitmq_channel_queue_consume::exchange_name() const {
  652. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  653. return exchange_name_.GetNoArena();
  654. }
  655. inline void Rabbitmq_channel_queue_consume::set_exchange_name(const ::std::string& value) {
  656. set_has_exchange_name();
  657. exchange_name_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
  658. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  659. }
  660. #if LANG_CXX11
  661. inline void Rabbitmq_channel_queue_consume::set_exchange_name(::std::string&& value) {
  662. set_has_exchange_name();
  663. exchange_name_.SetNoArena(
  664. &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
  665. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  666. }
  667. #endif
  668. inline void Rabbitmq_channel_queue_consume::set_exchange_name(const char* value) {
  669. GOOGLE_DCHECK(value != NULL);
  670. set_has_exchange_name();
  671. exchange_name_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
  672. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  673. }
  674. inline void Rabbitmq_channel_queue_consume::set_exchange_name(const char* value, size_t size) {
  675. set_has_exchange_name();
  676. exchange_name_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
  677. ::std::string(reinterpret_cast<const char*>(value), size));
  678. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  679. }
  680. inline ::std::string* Rabbitmq_channel_queue_consume::mutable_exchange_name() {
  681. set_has_exchange_name();
  682. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  683. return exchange_name_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  684. }
  685. inline ::std::string* Rabbitmq_channel_queue_consume::release_exchange_name() {
  686. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  687. if (!has_exchange_name()) {
  688. return NULL;
  689. }
  690. clear_has_exchange_name();
  691. return exchange_name_.ReleaseNonDefaultNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  692. }
  693. inline void Rabbitmq_channel_queue_consume::set_allocated_exchange_name(::std::string* exchange_name) {
  694. if (exchange_name != NULL) {
  695. set_has_exchange_name();
  696. } else {
  697. clear_has_exchange_name();
  698. }
  699. exchange_name_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), exchange_name);
  700. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  701. }
  702. // optional string routing_key = 3;
  703. inline bool Rabbitmq_channel_queue_consume::has_routing_key() const {
  704. return (_has_bits_[0] & 0x00000002u) != 0;
  705. }
  706. inline void Rabbitmq_channel_queue_consume::set_has_routing_key() {
  707. _has_bits_[0] |= 0x00000002u;
  708. }
  709. inline void Rabbitmq_channel_queue_consume::clear_has_routing_key() {
  710. _has_bits_[0] &= ~0x00000002u;
  711. }
  712. inline void Rabbitmq_channel_queue_consume::clear_routing_key() {
  713. routing_key_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  714. clear_has_routing_key();
  715. }
  716. inline const ::std::string& Rabbitmq_channel_queue_consume::routing_key() const {
  717. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  718. return routing_key_.GetNoArena();
  719. }
  720. inline void Rabbitmq_channel_queue_consume::set_routing_key(const ::std::string& value) {
  721. set_has_routing_key();
  722. routing_key_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
  723. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  724. }
  725. #if LANG_CXX11
  726. inline void Rabbitmq_channel_queue_consume::set_routing_key(::std::string&& value) {
  727. set_has_routing_key();
  728. routing_key_.SetNoArena(
  729. &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
  730. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  731. }
  732. #endif
  733. inline void Rabbitmq_channel_queue_consume::set_routing_key(const char* value) {
  734. GOOGLE_DCHECK(value != NULL);
  735. set_has_routing_key();
  736. routing_key_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
  737. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  738. }
  739. inline void Rabbitmq_channel_queue_consume::set_routing_key(const char* value, size_t size) {
  740. set_has_routing_key();
  741. routing_key_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
  742. ::std::string(reinterpret_cast<const char*>(value), size));
  743. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  744. }
  745. inline ::std::string* Rabbitmq_channel_queue_consume::mutable_routing_key() {
  746. set_has_routing_key();
  747. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  748. return routing_key_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  749. }
  750. inline ::std::string* Rabbitmq_channel_queue_consume::release_routing_key() {
  751. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  752. if (!has_routing_key()) {
  753. return NULL;
  754. }
  755. clear_has_routing_key();
  756. return routing_key_.ReleaseNonDefaultNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  757. }
  758. inline void Rabbitmq_channel_queue_consume::set_allocated_routing_key(::std::string* routing_key) {
  759. if (routing_key != NULL) {
  760. set_has_routing_key();
  761. } else {
  762. clear_has_routing_key();
  763. }
  764. routing_key_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), routing_key);
  765. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  766. }
  767. // optional int32 timeout_ms = 4;
  768. inline bool Rabbitmq_channel_queue_consume::has_timeout_ms() const {
  769. return (_has_bits_[0] & 0x00000040u) != 0;
  770. }
  771. inline void Rabbitmq_channel_queue_consume::set_has_timeout_ms() {
  772. _has_bits_[0] |= 0x00000040u;
  773. }
  774. inline void Rabbitmq_channel_queue_consume::clear_has_timeout_ms() {
  775. _has_bits_[0] &= ~0x00000040u;
  776. }
  777. inline void Rabbitmq_channel_queue_consume::clear_timeout_ms() {
  778. timeout_ms_ = 0;
  779. clear_has_timeout_ms();
  780. }
  781. inline ::google::protobuf::int32 Rabbitmq_channel_queue_consume::timeout_ms() const {
  782. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.timeout_ms)
  783. return timeout_ms_;
  784. }
  785. inline void Rabbitmq_channel_queue_consume::set_timeout_ms(::google::protobuf::int32 value) {
  786. set_has_timeout_ms();
  787. timeout_ms_ = value;
  788. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.timeout_ms)
  789. }
  790. // optional string binding_key = 5;
  791. inline bool Rabbitmq_channel_queue_consume::has_binding_key() const {
  792. return (_has_bits_[0] & 0x00000004u) != 0;
  793. }
  794. inline void Rabbitmq_channel_queue_consume::set_has_binding_key() {
  795. _has_bits_[0] |= 0x00000004u;
  796. }
  797. inline void Rabbitmq_channel_queue_consume::clear_has_binding_key() {
  798. _has_bits_[0] &= ~0x00000004u;
  799. }
  800. inline void Rabbitmq_channel_queue_consume::clear_binding_key() {
  801. binding_key_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  802. clear_has_binding_key();
  803. }
  804. inline const ::std::string& Rabbitmq_channel_queue_consume::binding_key() const {
  805. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  806. return binding_key_.GetNoArena();
  807. }
  808. inline void Rabbitmq_channel_queue_consume::set_binding_key(const ::std::string& value) {
  809. set_has_binding_key();
  810. binding_key_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
  811. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  812. }
  813. #if LANG_CXX11
  814. inline void Rabbitmq_channel_queue_consume::set_binding_key(::std::string&& value) {
  815. set_has_binding_key();
  816. binding_key_.SetNoArena(
  817. &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
  818. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  819. }
  820. #endif
  821. inline void Rabbitmq_channel_queue_consume::set_binding_key(const char* value) {
  822. GOOGLE_DCHECK(value != NULL);
  823. set_has_binding_key();
  824. binding_key_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
  825. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  826. }
  827. inline void Rabbitmq_channel_queue_consume::set_binding_key(const char* value, size_t size) {
  828. set_has_binding_key();
  829. binding_key_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
  830. ::std::string(reinterpret_cast<const char*>(value), size));
  831. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  832. }
  833. inline ::std::string* Rabbitmq_channel_queue_consume::mutable_binding_key() {
  834. set_has_binding_key();
  835. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  836. return binding_key_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  837. }
  838. inline ::std::string* Rabbitmq_channel_queue_consume::release_binding_key() {
  839. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  840. if (!has_binding_key()) {
  841. return NULL;
  842. }
  843. clear_has_binding_key();
  844. return binding_key_.ReleaseNonDefaultNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  845. }
  846. inline void Rabbitmq_channel_queue_consume::set_allocated_binding_key(::std::string* binding_key) {
  847. if (binding_key != NULL) {
  848. set_has_binding_key();
  849. } else {
  850. clear_has_binding_key();
  851. }
  852. binding_key_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), binding_key);
  853. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  854. }
  855. // optional string queue_name = 6;
  856. inline bool Rabbitmq_channel_queue_consume::has_queue_name() const {
  857. return (_has_bits_[0] & 0x00000008u) != 0;
  858. }
  859. inline void Rabbitmq_channel_queue_consume::set_has_queue_name() {
  860. _has_bits_[0] |= 0x00000008u;
  861. }
  862. inline void Rabbitmq_channel_queue_consume::clear_has_queue_name() {
  863. _has_bits_[0] &= ~0x00000008u;
  864. }
  865. inline void Rabbitmq_channel_queue_consume::clear_queue_name() {
  866. queue_name_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  867. clear_has_queue_name();
  868. }
  869. inline const ::std::string& Rabbitmq_channel_queue_consume::queue_name() const {
  870. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  871. return queue_name_.GetNoArena();
  872. }
  873. inline void Rabbitmq_channel_queue_consume::set_queue_name(const ::std::string& value) {
  874. set_has_queue_name();
  875. queue_name_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
  876. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  877. }
  878. #if LANG_CXX11
  879. inline void Rabbitmq_channel_queue_consume::set_queue_name(::std::string&& value) {
  880. set_has_queue_name();
  881. queue_name_.SetNoArena(
  882. &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
  883. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  884. }
  885. #endif
  886. inline void Rabbitmq_channel_queue_consume::set_queue_name(const char* value) {
  887. GOOGLE_DCHECK(value != NULL);
  888. set_has_queue_name();
  889. queue_name_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
  890. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  891. }
  892. inline void Rabbitmq_channel_queue_consume::set_queue_name(const char* value, size_t size) {
  893. set_has_queue_name();
  894. queue_name_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
  895. ::std::string(reinterpret_cast<const char*>(value), size));
  896. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  897. }
  898. inline ::std::string* Rabbitmq_channel_queue_consume::mutable_queue_name() {
  899. set_has_queue_name();
  900. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  901. return queue_name_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  902. }
  903. inline ::std::string* Rabbitmq_channel_queue_consume::release_queue_name() {
  904. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  905. if (!has_queue_name()) {
  906. return NULL;
  907. }
  908. clear_has_queue_name();
  909. return queue_name_.ReleaseNonDefaultNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  910. }
  911. inline void Rabbitmq_channel_queue_consume::set_allocated_queue_name(::std::string* queue_name) {
  912. if (queue_name != NULL) {
  913. set_has_queue_name();
  914. } else {
  915. clear_has_queue_name();
  916. }
  917. queue_name_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), queue_name);
  918. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  919. }
  920. // optional int32 queue_passive = 7 [default = 0];
  921. inline bool Rabbitmq_channel_queue_consume::has_queue_passive() const {
  922. return (_has_bits_[0] & 0x00000080u) != 0;
  923. }
  924. inline void Rabbitmq_channel_queue_consume::set_has_queue_passive() {
  925. _has_bits_[0] |= 0x00000080u;
  926. }
  927. inline void Rabbitmq_channel_queue_consume::clear_has_queue_passive() {
  928. _has_bits_[0] &= ~0x00000080u;
  929. }
  930. inline void Rabbitmq_channel_queue_consume::clear_queue_passive() {
  931. queue_passive_ = 0;
  932. clear_has_queue_passive();
  933. }
  934. inline ::google::protobuf::int32 Rabbitmq_channel_queue_consume::queue_passive() const {
  935. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_passive)
  936. return queue_passive_;
  937. }
  938. inline void Rabbitmq_channel_queue_consume::set_queue_passive(::google::protobuf::int32 value) {
  939. set_has_queue_passive();
  940. queue_passive_ = value;
  941. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_passive)
  942. }
  943. // optional int32 queue_durable = 8;
  944. inline bool Rabbitmq_channel_queue_consume::has_queue_durable() const {
  945. return (_has_bits_[0] & 0x00000100u) != 0;
  946. }
  947. inline void Rabbitmq_channel_queue_consume::set_has_queue_durable() {
  948. _has_bits_[0] |= 0x00000100u;
  949. }
  950. inline void Rabbitmq_channel_queue_consume::clear_has_queue_durable() {
  951. _has_bits_[0] &= ~0x00000100u;
  952. }
  953. inline void Rabbitmq_channel_queue_consume::clear_queue_durable() {
  954. queue_durable_ = 0;
  955. clear_has_queue_durable();
  956. }
  957. inline ::google::protobuf::int32 Rabbitmq_channel_queue_consume::queue_durable() const {
  958. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_durable)
  959. return queue_durable_;
  960. }
  961. inline void Rabbitmq_channel_queue_consume::set_queue_durable(::google::protobuf::int32 value) {
  962. set_has_queue_durable();
  963. queue_durable_ = value;
  964. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_durable)
  965. }
  966. // optional int32 queue_exclusive = 9 [default = 0];
  967. inline bool Rabbitmq_channel_queue_consume::has_queue_exclusive() const {
  968. return (_has_bits_[0] & 0x00000200u) != 0;
  969. }
  970. inline void Rabbitmq_channel_queue_consume::set_has_queue_exclusive() {
  971. _has_bits_[0] |= 0x00000200u;
  972. }
  973. inline void Rabbitmq_channel_queue_consume::clear_has_queue_exclusive() {
  974. _has_bits_[0] &= ~0x00000200u;
  975. }
  976. inline void Rabbitmq_channel_queue_consume::clear_queue_exclusive() {
  977. queue_exclusive_ = 0;
  978. clear_has_queue_exclusive();
  979. }
  980. inline ::google::protobuf::int32 Rabbitmq_channel_queue_consume::queue_exclusive() const {
  981. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_exclusive)
  982. return queue_exclusive_;
  983. }
  984. inline void Rabbitmq_channel_queue_consume::set_queue_exclusive(::google::protobuf::int32 value) {
  985. set_has_queue_exclusive();
  986. queue_exclusive_ = value;
  987. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_exclusive)
  988. }
  989. // optional int32 queue_auto_delete = 10 [default = 0];
  990. inline bool Rabbitmq_channel_queue_consume::has_queue_auto_delete() const {
  991. return (_has_bits_[0] & 0x00000400u) != 0;
  992. }
  993. inline void Rabbitmq_channel_queue_consume::set_has_queue_auto_delete() {
  994. _has_bits_[0] |= 0x00000400u;
  995. }
  996. inline void Rabbitmq_channel_queue_consume::clear_has_queue_auto_delete() {
  997. _has_bits_[0] &= ~0x00000400u;
  998. }
  999. inline void Rabbitmq_channel_queue_consume::clear_queue_auto_delete() {
  1000. queue_auto_delete_ = 0;
  1001. clear_has_queue_auto_delete();
  1002. }
  1003. inline ::google::protobuf::int32 Rabbitmq_channel_queue_consume::queue_auto_delete() const {
  1004. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_auto_delete)
  1005. return queue_auto_delete_;
  1006. }
  1007. inline void Rabbitmq_channel_queue_consume::set_queue_auto_delete(::google::protobuf::int32 value) {
  1008. set_has_queue_auto_delete();
  1009. queue_auto_delete_ = value;
  1010. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_auto_delete)
  1011. }
  1012. // optional int32 queue_meassage_ttl = 11 [default = 0];
  1013. inline bool Rabbitmq_channel_queue_consume::has_queue_meassage_ttl() const {
  1014. return (_has_bits_[0] & 0x00000800u) != 0;
  1015. }
  1016. inline void Rabbitmq_channel_queue_consume::set_has_queue_meassage_ttl() {
  1017. _has_bits_[0] |= 0x00000800u;
  1018. }
  1019. inline void Rabbitmq_channel_queue_consume::clear_has_queue_meassage_ttl() {
  1020. _has_bits_[0] &= ~0x00000800u;
  1021. }
  1022. inline void Rabbitmq_channel_queue_consume::clear_queue_meassage_ttl() {
  1023. queue_meassage_ttl_ = 0;
  1024. clear_has_queue_meassage_ttl();
  1025. }
  1026. inline ::google::protobuf::int32 Rabbitmq_channel_queue_consume::queue_meassage_ttl() const {
  1027. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_meassage_ttl)
  1028. return queue_meassage_ttl_;
  1029. }
  1030. inline void Rabbitmq_channel_queue_consume::set_queue_meassage_ttl(::google::protobuf::int32 value) {
  1031. set_has_queue_meassage_ttl();
  1032. queue_meassage_ttl_ = value;
  1033. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_meassage_ttl)
  1034. }
  1035. // optional string consume_name = 12;
  1036. inline bool Rabbitmq_channel_queue_consume::has_consume_name() const {
  1037. return (_has_bits_[0] & 0x00000010u) != 0;
  1038. }
  1039. inline void Rabbitmq_channel_queue_consume::set_has_consume_name() {
  1040. _has_bits_[0] |= 0x00000010u;
  1041. }
  1042. inline void Rabbitmq_channel_queue_consume::clear_has_consume_name() {
  1043. _has_bits_[0] &= ~0x00000010u;
  1044. }
  1045. inline void Rabbitmq_channel_queue_consume::clear_consume_name() {
  1046. consume_name_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  1047. clear_has_consume_name();
  1048. }
  1049. inline const ::std::string& Rabbitmq_channel_queue_consume::consume_name() const {
  1050. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1051. return consume_name_.GetNoArena();
  1052. }
  1053. inline void Rabbitmq_channel_queue_consume::set_consume_name(const ::std::string& value) {
  1054. set_has_consume_name();
  1055. consume_name_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
  1056. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1057. }
  1058. #if LANG_CXX11
  1059. inline void Rabbitmq_channel_queue_consume::set_consume_name(::std::string&& value) {
  1060. set_has_consume_name();
  1061. consume_name_.SetNoArena(
  1062. &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
  1063. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1064. }
  1065. #endif
  1066. inline void Rabbitmq_channel_queue_consume::set_consume_name(const char* value) {
  1067. GOOGLE_DCHECK(value != NULL);
  1068. set_has_consume_name();
  1069. consume_name_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
  1070. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1071. }
  1072. inline void Rabbitmq_channel_queue_consume::set_consume_name(const char* value, size_t size) {
  1073. set_has_consume_name();
  1074. consume_name_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
  1075. ::std::string(reinterpret_cast<const char*>(value), size));
  1076. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1077. }
  1078. inline ::std::string* Rabbitmq_channel_queue_consume::mutable_consume_name() {
  1079. set_has_consume_name();
  1080. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1081. return consume_name_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  1082. }
  1083. inline ::std::string* Rabbitmq_channel_queue_consume::release_consume_name() {
  1084. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1085. if (!has_consume_name()) {
  1086. return NULL;
  1087. }
  1088. clear_has_consume_name();
  1089. return consume_name_.ReleaseNonDefaultNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  1090. }
  1091. inline void Rabbitmq_channel_queue_consume::set_allocated_consume_name(::std::string* consume_name) {
  1092. if (consume_name != NULL) {
  1093. set_has_consume_name();
  1094. } else {
  1095. clear_has_consume_name();
  1096. }
  1097. consume_name_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), consume_name);
  1098. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1099. }
  1100. // optional int32 consume_no_local = 13 [default = 0];
  1101. inline bool Rabbitmq_channel_queue_consume::has_consume_no_local() const {
  1102. return (_has_bits_[0] & 0x00001000u) != 0;
  1103. }
  1104. inline void Rabbitmq_channel_queue_consume::set_has_consume_no_local() {
  1105. _has_bits_[0] |= 0x00001000u;
  1106. }
  1107. inline void Rabbitmq_channel_queue_consume::clear_has_consume_no_local() {
  1108. _has_bits_[0] &= ~0x00001000u;
  1109. }
  1110. inline void Rabbitmq_channel_queue_consume::clear_consume_no_local() {
  1111. consume_no_local_ = 0;
  1112. clear_has_consume_no_local();
  1113. }
  1114. inline ::google::protobuf::int32 Rabbitmq_channel_queue_consume::consume_no_local() const {
  1115. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_no_local)
  1116. return consume_no_local_;
  1117. }
  1118. inline void Rabbitmq_channel_queue_consume::set_consume_no_local(::google::protobuf::int32 value) {
  1119. set_has_consume_no_local();
  1120. consume_no_local_ = value;
  1121. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_no_local)
  1122. }
  1123. // optional int32 consume_no_ack = 14 [default = 0];
  1124. inline bool Rabbitmq_channel_queue_consume::has_consume_no_ack() const {
  1125. return (_has_bits_[0] & 0x00002000u) != 0;
  1126. }
  1127. inline void Rabbitmq_channel_queue_consume::set_has_consume_no_ack() {
  1128. _has_bits_[0] |= 0x00002000u;
  1129. }
  1130. inline void Rabbitmq_channel_queue_consume::clear_has_consume_no_ack() {
  1131. _has_bits_[0] &= ~0x00002000u;
  1132. }
  1133. inline void Rabbitmq_channel_queue_consume::clear_consume_no_ack() {
  1134. consume_no_ack_ = 0;
  1135. clear_has_consume_no_ack();
  1136. }
  1137. inline ::google::protobuf::int32 Rabbitmq_channel_queue_consume::consume_no_ack() const {
  1138. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_no_ack)
  1139. return consume_no_ack_;
  1140. }
  1141. inline void Rabbitmq_channel_queue_consume::set_consume_no_ack(::google::protobuf::int32 value) {
  1142. set_has_consume_no_ack();
  1143. consume_no_ack_ = value;
  1144. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_no_ack)
  1145. }
  1146. // optional int32 consume_exclusive = 15;
  1147. inline bool Rabbitmq_channel_queue_consume::has_consume_exclusive() const {
  1148. return (_has_bits_[0] & 0x00004000u) != 0;
  1149. }
  1150. inline void Rabbitmq_channel_queue_consume::set_has_consume_exclusive() {
  1151. _has_bits_[0] |= 0x00004000u;
  1152. }
  1153. inline void Rabbitmq_channel_queue_consume::clear_has_consume_exclusive() {
  1154. _has_bits_[0] &= ~0x00004000u;
  1155. }
  1156. inline void Rabbitmq_channel_queue_consume::clear_consume_exclusive() {
  1157. consume_exclusive_ = 0;
  1158. clear_has_consume_exclusive();
  1159. }
  1160. inline ::google::protobuf::int32 Rabbitmq_channel_queue_consume::consume_exclusive() const {
  1161. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_exclusive)
  1162. return consume_exclusive_;
  1163. }
  1164. inline void Rabbitmq_channel_queue_consume::set_consume_exclusive(::google::protobuf::int32 value) {
  1165. set_has_consume_exclusive();
  1166. consume_exclusive_ = value;
  1167. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_exclusive)
  1168. }
  1169. // -------------------------------------------------------------------
  1170. // Rabbitmq_parameter
  1171. // optional string ip = 1;
  1172. inline bool Rabbitmq_parameter::has_ip() const {
  1173. return (_has_bits_[0] & 0x00000001u) != 0;
  1174. }
  1175. inline void Rabbitmq_parameter::set_has_ip() {
  1176. _has_bits_[0] |= 0x00000001u;
  1177. }
  1178. inline void Rabbitmq_parameter::clear_has_ip() {
  1179. _has_bits_[0] &= ~0x00000001u;
  1180. }
  1181. inline void Rabbitmq_parameter::clear_ip() {
  1182. ip_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  1183. clear_has_ip();
  1184. }
  1185. inline const ::std::string& Rabbitmq_parameter::ip() const {
  1186. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1187. return ip_.GetNoArena();
  1188. }
  1189. inline void Rabbitmq_parameter::set_ip(const ::std::string& value) {
  1190. set_has_ip();
  1191. ip_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
  1192. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1193. }
  1194. #if LANG_CXX11
  1195. inline void Rabbitmq_parameter::set_ip(::std::string&& value) {
  1196. set_has_ip();
  1197. ip_.SetNoArena(
  1198. &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
  1199. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1200. }
  1201. #endif
  1202. inline void Rabbitmq_parameter::set_ip(const char* value) {
  1203. GOOGLE_DCHECK(value != NULL);
  1204. set_has_ip();
  1205. ip_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
  1206. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1207. }
  1208. inline void Rabbitmq_parameter::set_ip(const char* value, size_t size) {
  1209. set_has_ip();
  1210. ip_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
  1211. ::std::string(reinterpret_cast<const char*>(value), size));
  1212. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1213. }
  1214. inline ::std::string* Rabbitmq_parameter::mutable_ip() {
  1215. set_has_ip();
  1216. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1217. return ip_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  1218. }
  1219. inline ::std::string* Rabbitmq_parameter::release_ip() {
  1220. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1221. if (!has_ip()) {
  1222. return NULL;
  1223. }
  1224. clear_has_ip();
  1225. return ip_.ReleaseNonDefaultNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  1226. }
  1227. inline void Rabbitmq_parameter::set_allocated_ip(::std::string* ip) {
  1228. if (ip != NULL) {
  1229. set_has_ip();
  1230. } else {
  1231. clear_has_ip();
  1232. }
  1233. ip_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ip);
  1234. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1235. }
  1236. // optional int32 port = 2;
  1237. inline bool Rabbitmq_parameter::has_port() const {
  1238. return (_has_bits_[0] & 0x00000008u) != 0;
  1239. }
  1240. inline void Rabbitmq_parameter::set_has_port() {
  1241. _has_bits_[0] |= 0x00000008u;
  1242. }
  1243. inline void Rabbitmq_parameter::clear_has_port() {
  1244. _has_bits_[0] &= ~0x00000008u;
  1245. }
  1246. inline void Rabbitmq_parameter::clear_port() {
  1247. port_ = 0;
  1248. clear_has_port();
  1249. }
  1250. inline ::google::protobuf::int32 Rabbitmq_parameter::port() const {
  1251. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter.port)
  1252. return port_;
  1253. }
  1254. inline void Rabbitmq_parameter::set_port(::google::protobuf::int32 value) {
  1255. set_has_port();
  1256. port_ = value;
  1257. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_parameter.port)
  1258. }
  1259. // optional string user = 3;
  1260. inline bool Rabbitmq_parameter::has_user() const {
  1261. return (_has_bits_[0] & 0x00000002u) != 0;
  1262. }
  1263. inline void Rabbitmq_parameter::set_has_user() {
  1264. _has_bits_[0] |= 0x00000002u;
  1265. }
  1266. inline void Rabbitmq_parameter::clear_has_user() {
  1267. _has_bits_[0] &= ~0x00000002u;
  1268. }
  1269. inline void Rabbitmq_parameter::clear_user() {
  1270. user_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  1271. clear_has_user();
  1272. }
  1273. inline const ::std::string& Rabbitmq_parameter::user() const {
  1274. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter.user)
  1275. return user_.GetNoArena();
  1276. }
  1277. inline void Rabbitmq_parameter::set_user(const ::std::string& value) {
  1278. set_has_user();
  1279. user_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
  1280. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_parameter.user)
  1281. }
  1282. #if LANG_CXX11
  1283. inline void Rabbitmq_parameter::set_user(::std::string&& value) {
  1284. set_has_user();
  1285. user_.SetNoArena(
  1286. &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
  1287. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_parameter.user)
  1288. }
  1289. #endif
  1290. inline void Rabbitmq_parameter::set_user(const char* value) {
  1291. GOOGLE_DCHECK(value != NULL);
  1292. set_has_user();
  1293. user_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
  1294. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_parameter.user)
  1295. }
  1296. inline void Rabbitmq_parameter::set_user(const char* value, size_t size) {
  1297. set_has_user();
  1298. user_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
  1299. ::std::string(reinterpret_cast<const char*>(value), size));
  1300. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_parameter.user)
  1301. }
  1302. inline ::std::string* Rabbitmq_parameter::mutable_user() {
  1303. set_has_user();
  1304. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_parameter.user)
  1305. return user_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  1306. }
  1307. inline ::std::string* Rabbitmq_parameter::release_user() {
  1308. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_parameter.user)
  1309. if (!has_user()) {
  1310. return NULL;
  1311. }
  1312. clear_has_user();
  1313. return user_.ReleaseNonDefaultNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  1314. }
  1315. inline void Rabbitmq_parameter::set_allocated_user(::std::string* user) {
  1316. if (user != NULL) {
  1317. set_has_user();
  1318. } else {
  1319. clear_has_user();
  1320. }
  1321. user_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), user);
  1322. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_parameter.user)
  1323. }
  1324. // optional string password = 4;
  1325. inline bool Rabbitmq_parameter::has_password() const {
  1326. return (_has_bits_[0] & 0x00000004u) != 0;
  1327. }
  1328. inline void Rabbitmq_parameter::set_has_password() {
  1329. _has_bits_[0] |= 0x00000004u;
  1330. }
  1331. inline void Rabbitmq_parameter::clear_has_password() {
  1332. _has_bits_[0] &= ~0x00000004u;
  1333. }
  1334. inline void Rabbitmq_parameter::clear_password() {
  1335. password_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  1336. clear_has_password();
  1337. }
  1338. inline const ::std::string& Rabbitmq_parameter::password() const {
  1339. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter.password)
  1340. return password_.GetNoArena();
  1341. }
  1342. inline void Rabbitmq_parameter::set_password(const ::std::string& value) {
  1343. set_has_password();
  1344. password_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
  1345. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_parameter.password)
  1346. }
  1347. #if LANG_CXX11
  1348. inline void Rabbitmq_parameter::set_password(::std::string&& value) {
  1349. set_has_password();
  1350. password_.SetNoArena(
  1351. &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
  1352. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_parameter.password)
  1353. }
  1354. #endif
  1355. inline void Rabbitmq_parameter::set_password(const char* value) {
  1356. GOOGLE_DCHECK(value != NULL);
  1357. set_has_password();
  1358. password_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
  1359. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_parameter.password)
  1360. }
  1361. inline void Rabbitmq_parameter::set_password(const char* value, size_t size) {
  1362. set_has_password();
  1363. password_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
  1364. ::std::string(reinterpret_cast<const char*>(value), size));
  1365. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_parameter.password)
  1366. }
  1367. inline ::std::string* Rabbitmq_parameter::mutable_password() {
  1368. set_has_password();
  1369. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_parameter.password)
  1370. return password_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  1371. }
  1372. inline ::std::string* Rabbitmq_parameter::release_password() {
  1373. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_parameter.password)
  1374. if (!has_password()) {
  1375. return NULL;
  1376. }
  1377. clear_has_password();
  1378. return password_.ReleaseNonDefaultNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  1379. }
  1380. inline void Rabbitmq_parameter::set_allocated_password(::std::string* password) {
  1381. if (password != NULL) {
  1382. set_has_password();
  1383. } else {
  1384. clear_has_password();
  1385. }
  1386. password_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), password);
  1387. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_parameter.password)
  1388. }
  1389. // repeated .Rabbitmq_proto.Rabbitmq_channel_queue_consume rabbitmq_reciever_vector = 5;
  1390. inline int Rabbitmq_parameter::rabbitmq_reciever_vector_size() const {
  1391. return rabbitmq_reciever_vector_.size();
  1392. }
  1393. inline void Rabbitmq_parameter::clear_rabbitmq_reciever_vector() {
  1394. rabbitmq_reciever_vector_.Clear();
  1395. }
  1396. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::mutable_rabbitmq_reciever_vector(int index) {
  1397. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_reciever_vector)
  1398. return rabbitmq_reciever_vector_.Mutable(index);
  1399. }
  1400. inline ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >*
  1401. Rabbitmq_parameter::mutable_rabbitmq_reciever_vector() {
  1402. // @@protoc_insertion_point(field_mutable_list:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_reciever_vector)
  1403. return &rabbitmq_reciever_vector_;
  1404. }
  1405. inline const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& Rabbitmq_parameter::rabbitmq_reciever_vector(int index) const {
  1406. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_reciever_vector)
  1407. return rabbitmq_reciever_vector_.Get(index);
  1408. }
  1409. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::add_rabbitmq_reciever_vector() {
  1410. // @@protoc_insertion_point(field_add:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_reciever_vector)
  1411. return rabbitmq_reciever_vector_.Add();
  1412. }
  1413. inline const ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >&
  1414. Rabbitmq_parameter::rabbitmq_reciever_vector() const {
  1415. // @@protoc_insertion_point(field_list:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_reciever_vector)
  1416. return rabbitmq_reciever_vector_;
  1417. }
  1418. // repeated .Rabbitmq_proto.Rabbitmq_channel_queue_consume rabbitmq_sender_request_vector = 6;
  1419. inline int Rabbitmq_parameter::rabbitmq_sender_request_vector_size() const {
  1420. return rabbitmq_sender_request_vector_.size();
  1421. }
  1422. inline void Rabbitmq_parameter::clear_rabbitmq_sender_request_vector() {
  1423. rabbitmq_sender_request_vector_.Clear();
  1424. }
  1425. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::mutable_rabbitmq_sender_request_vector(int index) {
  1426. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_request_vector)
  1427. return rabbitmq_sender_request_vector_.Mutable(index);
  1428. }
  1429. inline ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >*
  1430. Rabbitmq_parameter::mutable_rabbitmq_sender_request_vector() {
  1431. // @@protoc_insertion_point(field_mutable_list:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_request_vector)
  1432. return &rabbitmq_sender_request_vector_;
  1433. }
  1434. inline const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& Rabbitmq_parameter::rabbitmq_sender_request_vector(int index) const {
  1435. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_request_vector)
  1436. return rabbitmq_sender_request_vector_.Get(index);
  1437. }
  1438. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::add_rabbitmq_sender_request_vector() {
  1439. // @@protoc_insertion_point(field_add:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_request_vector)
  1440. return rabbitmq_sender_request_vector_.Add();
  1441. }
  1442. inline const ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >&
  1443. Rabbitmq_parameter::rabbitmq_sender_request_vector() const {
  1444. // @@protoc_insertion_point(field_list:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_request_vector)
  1445. return rabbitmq_sender_request_vector_;
  1446. }
  1447. // repeated .Rabbitmq_proto.Rabbitmq_channel_queue_consume rabbitmq_sender_status_vector = 7;
  1448. inline int Rabbitmq_parameter::rabbitmq_sender_status_vector_size() const {
  1449. return rabbitmq_sender_status_vector_.size();
  1450. }
  1451. inline void Rabbitmq_parameter::clear_rabbitmq_sender_status_vector() {
  1452. rabbitmq_sender_status_vector_.Clear();
  1453. }
  1454. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::mutable_rabbitmq_sender_status_vector(int index) {
  1455. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_status_vector)
  1456. return rabbitmq_sender_status_vector_.Mutable(index);
  1457. }
  1458. inline ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >*
  1459. Rabbitmq_parameter::mutable_rabbitmq_sender_status_vector() {
  1460. // @@protoc_insertion_point(field_mutable_list:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_status_vector)
  1461. return &rabbitmq_sender_status_vector_;
  1462. }
  1463. inline const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& Rabbitmq_parameter::rabbitmq_sender_status_vector(int index) const {
  1464. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_status_vector)
  1465. return rabbitmq_sender_status_vector_.Get(index);
  1466. }
  1467. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::add_rabbitmq_sender_status_vector() {
  1468. // @@protoc_insertion_point(field_add:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_status_vector)
  1469. return rabbitmq_sender_status_vector_.Add();
  1470. }
  1471. inline const ::google::protobuf::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >&
  1472. Rabbitmq_parameter::rabbitmq_sender_status_vector() const {
  1473. // @@protoc_insertion_point(field_list:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_status_vector)
  1474. return rabbitmq_sender_status_vector_;
  1475. }
  1476. // -------------------------------------------------------------------
  1477. // Rabbitmq_parameter_all
  1478. // optional .Rabbitmq_proto.Rabbitmq_parameter rabbitmq_parameters = 1;
  1479. inline bool Rabbitmq_parameter_all::has_rabbitmq_parameters() const {
  1480. return (_has_bits_[0] & 0x00000001u) != 0;
  1481. }
  1482. inline void Rabbitmq_parameter_all::set_has_rabbitmq_parameters() {
  1483. _has_bits_[0] |= 0x00000001u;
  1484. }
  1485. inline void Rabbitmq_parameter_all::clear_has_rabbitmq_parameters() {
  1486. _has_bits_[0] &= ~0x00000001u;
  1487. }
  1488. inline void Rabbitmq_parameter_all::clear_rabbitmq_parameters() {
  1489. if (rabbitmq_parameters_ != NULL) rabbitmq_parameters_->Clear();
  1490. clear_has_rabbitmq_parameters();
  1491. }
  1492. inline const ::Rabbitmq_proto::Rabbitmq_parameter& Rabbitmq_parameter_all::_internal_rabbitmq_parameters() const {
  1493. return *rabbitmq_parameters_;
  1494. }
  1495. inline const ::Rabbitmq_proto::Rabbitmq_parameter& Rabbitmq_parameter_all::rabbitmq_parameters() const {
  1496. const ::Rabbitmq_proto::Rabbitmq_parameter* p = rabbitmq_parameters_;
  1497. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter_all.rabbitmq_parameters)
  1498. return p != NULL ? *p : *reinterpret_cast<const ::Rabbitmq_proto::Rabbitmq_parameter*>(
  1499. &::Rabbitmq_proto::_Rabbitmq_parameter_default_instance_);
  1500. }
  1501. inline ::Rabbitmq_proto::Rabbitmq_parameter* Rabbitmq_parameter_all::release_rabbitmq_parameters() {
  1502. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_parameter_all.rabbitmq_parameters)
  1503. clear_has_rabbitmq_parameters();
  1504. ::Rabbitmq_proto::Rabbitmq_parameter* temp = rabbitmq_parameters_;
  1505. rabbitmq_parameters_ = NULL;
  1506. return temp;
  1507. }
  1508. inline ::Rabbitmq_proto::Rabbitmq_parameter* Rabbitmq_parameter_all::mutable_rabbitmq_parameters() {
  1509. set_has_rabbitmq_parameters();
  1510. if (rabbitmq_parameters_ == NULL) {
  1511. auto* p = CreateMaybeMessage<::Rabbitmq_proto::Rabbitmq_parameter>(GetArenaNoVirtual());
  1512. rabbitmq_parameters_ = p;
  1513. }
  1514. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_parameter_all.rabbitmq_parameters)
  1515. return rabbitmq_parameters_;
  1516. }
  1517. inline void Rabbitmq_parameter_all::set_allocated_rabbitmq_parameters(::Rabbitmq_proto::Rabbitmq_parameter* rabbitmq_parameters) {
  1518. ::google::protobuf::Arena* message_arena = GetArenaNoVirtual();
  1519. if (message_arena == NULL) {
  1520. delete rabbitmq_parameters_;
  1521. }
  1522. if (rabbitmq_parameters) {
  1523. ::google::protobuf::Arena* submessage_arena = NULL;
  1524. if (message_arena != submessage_arena) {
  1525. rabbitmq_parameters = ::google::protobuf::internal::GetOwnedMessage(
  1526. message_arena, rabbitmq_parameters, submessage_arena);
  1527. }
  1528. set_has_rabbitmq_parameters();
  1529. } else {
  1530. clear_has_rabbitmq_parameters();
  1531. }
  1532. rabbitmq_parameters_ = rabbitmq_parameters;
  1533. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_parameter_all.rabbitmq_parameters)
  1534. }
  1535. #ifdef __GNUC__
  1536. #pragma GCC diagnostic pop
  1537. #endif // __GNUC__
  1538. // -------------------------------------------------------------------
  1539. // -------------------------------------------------------------------
  1540. // @@protoc_insertion_point(namespace_scope)
  1541. } // namespace Rabbitmq_proto
  1542. // @@protoc_insertion_point(global_scope)
  1543. #endif // PROTOBUF_INCLUDED_rabbitmq_2eproto