rabbitmq.pb.h 98 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254
  1. // Generated by the protocol buffer compiler. DO NOT EDIT!
  2. // source: rabbitmq.proto
  3. #ifndef GOOGLE_PROTOBUF_INCLUDED_rabbitmq_2eproto
  4. #define GOOGLE_PROTOBUF_INCLUDED_rabbitmq_2eproto
  5. #include <limits>
  6. #include <string>
  7. #include <google/protobuf/port_def.inc>
  8. #if PROTOBUF_VERSION < 3012000
  9. #error This file was generated by a newer version of protoc which is
  10. #error incompatible with your Protocol Buffer headers. Please update
  11. #error your headers.
  12. #endif
  13. #if 3012004 < PROTOBUF_MIN_PROTOC_VERSION
  14. #error This file was generated by an older version of protoc which is
  15. #error incompatible with your Protocol Buffer headers. Please
  16. #error regenerate this file with a newer version of protoc.
  17. #endif
  18. #include <google/protobuf/port_undef.inc>
  19. #include <google/protobuf/io/coded_stream.h>
  20. #include <google/protobuf/arena.h>
  21. #include <google/protobuf/arenastring.h>
  22. #include <google/protobuf/generated_message_table_driven.h>
  23. #include <google/protobuf/generated_message_util.h>
  24. #include <google/protobuf/inlined_string_field.h>
  25. #include <google/protobuf/metadata_lite.h>
  26. #include <google/protobuf/generated_message_reflection.h>
  27. #include <google/protobuf/message.h>
  28. #include <google/protobuf/repeated_field.h> // IWYU pragma: export
  29. #include <google/protobuf/extension_set.h> // IWYU pragma: export
  30. #include <google/protobuf/unknown_field_set.h>
  31. // @@protoc_insertion_point(includes)
  32. #include <google/protobuf/port_def.inc>
  33. #define PROTOBUF_INTERNAL_EXPORT_rabbitmq_2eproto
  34. PROTOBUF_NAMESPACE_OPEN
  35. namespace internal {
  36. class AnyMetadata;
  37. } // namespace internal
  38. PROTOBUF_NAMESPACE_CLOSE
  39. // Internal implementation detail -- do not use these members.
  40. struct TableStruct_rabbitmq_2eproto {
  41. static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTableField entries[]
  42. PROTOBUF_SECTION_VARIABLE(protodesc_cold);
  43. static const ::PROTOBUF_NAMESPACE_ID::internal::AuxillaryParseTableField aux[]
  44. PROTOBUF_SECTION_VARIABLE(protodesc_cold);
  45. static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTable schema[3]
  46. PROTOBUF_SECTION_VARIABLE(protodesc_cold);
  47. static const ::PROTOBUF_NAMESPACE_ID::internal::FieldMetadata field_metadata[];
  48. static const ::PROTOBUF_NAMESPACE_ID::internal::SerializationTable serialization_table[];
  49. static const ::PROTOBUF_NAMESPACE_ID::uint32 offsets[];
  50. };
  51. extern const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_rabbitmq_2eproto;
  52. namespace Rabbitmq_proto {
  53. class Rabbitmq_channel_queue_consume;
  54. class Rabbitmq_channel_queue_consumeDefaultTypeInternal;
  55. extern Rabbitmq_channel_queue_consumeDefaultTypeInternal _Rabbitmq_channel_queue_consume_default_instance_;
  56. class Rabbitmq_parameter;
  57. class Rabbitmq_parameterDefaultTypeInternal;
  58. extern Rabbitmq_parameterDefaultTypeInternal _Rabbitmq_parameter_default_instance_;
  59. class Rabbitmq_parameter_all;
  60. class Rabbitmq_parameter_allDefaultTypeInternal;
  61. extern Rabbitmq_parameter_allDefaultTypeInternal _Rabbitmq_parameter_all_default_instance_;
  62. } // namespace Rabbitmq_proto
  63. PROTOBUF_NAMESPACE_OPEN
  64. template<> ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Arena::CreateMaybeMessage<::Rabbitmq_proto::Rabbitmq_channel_queue_consume>(Arena*);
  65. template<> ::Rabbitmq_proto::Rabbitmq_parameter* Arena::CreateMaybeMessage<::Rabbitmq_proto::Rabbitmq_parameter>(Arena*);
  66. template<> ::Rabbitmq_proto::Rabbitmq_parameter_all* Arena::CreateMaybeMessage<::Rabbitmq_proto::Rabbitmq_parameter_all>(Arena*);
  67. PROTOBUF_NAMESPACE_CLOSE
  68. namespace Rabbitmq_proto {
  69. // ===================================================================
  70. class Rabbitmq_channel_queue_consume PROTOBUF_FINAL :
  71. public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:Rabbitmq_proto.Rabbitmq_channel_queue_consume) */ {
  72. public:
  73. inline Rabbitmq_channel_queue_consume() : Rabbitmq_channel_queue_consume(nullptr) {};
  74. virtual ~Rabbitmq_channel_queue_consume();
  75. Rabbitmq_channel_queue_consume(const Rabbitmq_channel_queue_consume& from);
  76. Rabbitmq_channel_queue_consume(Rabbitmq_channel_queue_consume&& from) noexcept
  77. : Rabbitmq_channel_queue_consume() {
  78. *this = ::std::move(from);
  79. }
  80. inline Rabbitmq_channel_queue_consume& operator=(const Rabbitmq_channel_queue_consume& from) {
  81. CopyFrom(from);
  82. return *this;
  83. }
  84. inline Rabbitmq_channel_queue_consume& operator=(Rabbitmq_channel_queue_consume&& from) noexcept {
  85. if (GetArena() == from.GetArena()) {
  86. if (this != &from) InternalSwap(&from);
  87. } else {
  88. CopyFrom(from);
  89. }
  90. return *this;
  91. }
  92. inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
  93. return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
  94. }
  95. inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
  96. return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
  97. }
  98. static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
  99. return GetDescriptor();
  100. }
  101. static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
  102. return GetMetadataStatic().descriptor;
  103. }
  104. static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
  105. return GetMetadataStatic().reflection;
  106. }
  107. static const Rabbitmq_channel_queue_consume& default_instance();
  108. static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
  109. static inline const Rabbitmq_channel_queue_consume* internal_default_instance() {
  110. return reinterpret_cast<const Rabbitmq_channel_queue_consume*>(
  111. &_Rabbitmq_channel_queue_consume_default_instance_);
  112. }
  113. static constexpr int kIndexInFileMessages =
  114. 0;
  115. friend void swap(Rabbitmq_channel_queue_consume& a, Rabbitmq_channel_queue_consume& b) {
  116. a.Swap(&b);
  117. }
  118. inline void Swap(Rabbitmq_channel_queue_consume* other) {
  119. if (other == this) return;
  120. if (GetArena() == other->GetArena()) {
  121. InternalSwap(other);
  122. } else {
  123. ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
  124. }
  125. }
  126. void UnsafeArenaSwap(Rabbitmq_channel_queue_consume* other) {
  127. if (other == this) return;
  128. GOOGLE_DCHECK(GetArena() == other->GetArena());
  129. InternalSwap(other);
  130. }
  131. // implements Message ----------------------------------------------
  132. inline Rabbitmq_channel_queue_consume* New() const final {
  133. return CreateMaybeMessage<Rabbitmq_channel_queue_consume>(nullptr);
  134. }
  135. Rabbitmq_channel_queue_consume* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
  136. return CreateMaybeMessage<Rabbitmq_channel_queue_consume>(arena);
  137. }
  138. void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
  139. void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
  140. void CopyFrom(const Rabbitmq_channel_queue_consume& from);
  141. void MergeFrom(const Rabbitmq_channel_queue_consume& from);
  142. PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
  143. bool IsInitialized() const final;
  144. size_t ByteSizeLong() const final;
  145. const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
  146. ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize(
  147. ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
  148. int GetCachedSize() const final { return _cached_size_.Get(); }
  149. private:
  150. inline void SharedCtor();
  151. inline void SharedDtor();
  152. void SetCachedSize(int size) const final;
  153. void InternalSwap(Rabbitmq_channel_queue_consume* other);
  154. friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
  155. static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
  156. return "Rabbitmq_proto.Rabbitmq_channel_queue_consume";
  157. }
  158. protected:
  159. explicit Rabbitmq_channel_queue_consume(::PROTOBUF_NAMESPACE_ID::Arena* arena);
  160. private:
  161. static void ArenaDtor(void* object);
  162. inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
  163. public:
  164. ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
  165. private:
  166. static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
  167. ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_rabbitmq_2eproto);
  168. return ::descriptor_table_rabbitmq_2eproto.file_level_metadata[kIndexInFileMessages];
  169. }
  170. public:
  171. // nested types ----------------------------------------------------
  172. // accessors -------------------------------------------------------
  173. enum : int {
  174. kExchangeNameFieldNumber = 2,
  175. kRoutingKeyFieldNumber = 3,
  176. kBindingKeyFieldNumber = 5,
  177. kQueueNameFieldNumber = 6,
  178. kConsumeNameFieldNumber = 12,
  179. kChannelFieldNumber = 1,
  180. kTimeoutMsFieldNumber = 4,
  181. kQueuePassiveFieldNumber = 7,
  182. kQueueDurableFieldNumber = 8,
  183. kQueueExclusiveFieldNumber = 9,
  184. kQueueAutoDeleteFieldNumber = 10,
  185. kQueueMeassageTtlFieldNumber = 11,
  186. kConsumeNoLocalFieldNumber = 13,
  187. kConsumeNoAckFieldNumber = 14,
  188. kConsumeExclusiveFieldNumber = 15,
  189. };
  190. // optional string exchange_name = 2;
  191. bool has_exchange_name() const;
  192. private:
  193. bool _internal_has_exchange_name() const;
  194. public:
  195. void clear_exchange_name();
  196. const std::string& exchange_name() const;
  197. void set_exchange_name(const std::string& value);
  198. void set_exchange_name(std::string&& value);
  199. void set_exchange_name(const char* value);
  200. void set_exchange_name(const char* value, size_t size);
  201. std::string* mutable_exchange_name();
  202. std::string* release_exchange_name();
  203. void set_allocated_exchange_name(std::string* exchange_name);
  204. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  205. " string fields are deprecated and will be removed in a"
  206. " future release.")
  207. std::string* unsafe_arena_release_exchange_name();
  208. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  209. " string fields are deprecated and will be removed in a"
  210. " future release.")
  211. void unsafe_arena_set_allocated_exchange_name(
  212. std::string* exchange_name);
  213. private:
  214. const std::string& _internal_exchange_name() const;
  215. void _internal_set_exchange_name(const std::string& value);
  216. std::string* _internal_mutable_exchange_name();
  217. public:
  218. // optional string routing_key = 3;
  219. bool has_routing_key() const;
  220. private:
  221. bool _internal_has_routing_key() const;
  222. public:
  223. void clear_routing_key();
  224. const std::string& routing_key() const;
  225. void set_routing_key(const std::string& value);
  226. void set_routing_key(std::string&& value);
  227. void set_routing_key(const char* value);
  228. void set_routing_key(const char* value, size_t size);
  229. std::string* mutable_routing_key();
  230. std::string* release_routing_key();
  231. void set_allocated_routing_key(std::string* routing_key);
  232. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  233. " string fields are deprecated and will be removed in a"
  234. " future release.")
  235. std::string* unsafe_arena_release_routing_key();
  236. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  237. " string fields are deprecated and will be removed in a"
  238. " future release.")
  239. void unsafe_arena_set_allocated_routing_key(
  240. std::string* routing_key);
  241. private:
  242. const std::string& _internal_routing_key() const;
  243. void _internal_set_routing_key(const std::string& value);
  244. std::string* _internal_mutable_routing_key();
  245. public:
  246. // optional string binding_key = 5;
  247. bool has_binding_key() const;
  248. private:
  249. bool _internal_has_binding_key() const;
  250. public:
  251. void clear_binding_key();
  252. const std::string& binding_key() const;
  253. void set_binding_key(const std::string& value);
  254. void set_binding_key(std::string&& value);
  255. void set_binding_key(const char* value);
  256. void set_binding_key(const char* value, size_t size);
  257. std::string* mutable_binding_key();
  258. std::string* release_binding_key();
  259. void set_allocated_binding_key(std::string* binding_key);
  260. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  261. " string fields are deprecated and will be removed in a"
  262. " future release.")
  263. std::string* unsafe_arena_release_binding_key();
  264. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  265. " string fields are deprecated and will be removed in a"
  266. " future release.")
  267. void unsafe_arena_set_allocated_binding_key(
  268. std::string* binding_key);
  269. private:
  270. const std::string& _internal_binding_key() const;
  271. void _internal_set_binding_key(const std::string& value);
  272. std::string* _internal_mutable_binding_key();
  273. public:
  274. // optional string queue_name = 6;
  275. bool has_queue_name() const;
  276. private:
  277. bool _internal_has_queue_name() const;
  278. public:
  279. void clear_queue_name();
  280. const std::string& queue_name() const;
  281. void set_queue_name(const std::string& value);
  282. void set_queue_name(std::string&& value);
  283. void set_queue_name(const char* value);
  284. void set_queue_name(const char* value, size_t size);
  285. std::string* mutable_queue_name();
  286. std::string* release_queue_name();
  287. void set_allocated_queue_name(std::string* queue_name);
  288. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  289. " string fields are deprecated and will be removed in a"
  290. " future release.")
  291. std::string* unsafe_arena_release_queue_name();
  292. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  293. " string fields are deprecated and will be removed in a"
  294. " future release.")
  295. void unsafe_arena_set_allocated_queue_name(
  296. std::string* queue_name);
  297. private:
  298. const std::string& _internal_queue_name() const;
  299. void _internal_set_queue_name(const std::string& value);
  300. std::string* _internal_mutable_queue_name();
  301. public:
  302. // optional string consume_name = 12;
  303. bool has_consume_name() const;
  304. private:
  305. bool _internal_has_consume_name() const;
  306. public:
  307. void clear_consume_name();
  308. const std::string& consume_name() const;
  309. void set_consume_name(const std::string& value);
  310. void set_consume_name(std::string&& value);
  311. void set_consume_name(const char* value);
  312. void set_consume_name(const char* value, size_t size);
  313. std::string* mutable_consume_name();
  314. std::string* release_consume_name();
  315. void set_allocated_consume_name(std::string* consume_name);
  316. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  317. " string fields are deprecated and will be removed in a"
  318. " future release.")
  319. std::string* unsafe_arena_release_consume_name();
  320. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  321. " string fields are deprecated and will be removed in a"
  322. " future release.")
  323. void unsafe_arena_set_allocated_consume_name(
  324. std::string* consume_name);
  325. private:
  326. const std::string& _internal_consume_name() const;
  327. void _internal_set_consume_name(const std::string& value);
  328. std::string* _internal_mutable_consume_name();
  329. public:
  330. // optional int32 channel = 1;
  331. bool has_channel() const;
  332. private:
  333. bool _internal_has_channel() const;
  334. public:
  335. void clear_channel();
  336. ::PROTOBUF_NAMESPACE_ID::int32 channel() const;
  337. void set_channel(::PROTOBUF_NAMESPACE_ID::int32 value);
  338. private:
  339. ::PROTOBUF_NAMESPACE_ID::int32 _internal_channel() const;
  340. void _internal_set_channel(::PROTOBUF_NAMESPACE_ID::int32 value);
  341. public:
  342. // optional int32 timeout_ms = 4;
  343. bool has_timeout_ms() const;
  344. private:
  345. bool _internal_has_timeout_ms() const;
  346. public:
  347. void clear_timeout_ms();
  348. ::PROTOBUF_NAMESPACE_ID::int32 timeout_ms() const;
  349. void set_timeout_ms(::PROTOBUF_NAMESPACE_ID::int32 value);
  350. private:
  351. ::PROTOBUF_NAMESPACE_ID::int32 _internal_timeout_ms() const;
  352. void _internal_set_timeout_ms(::PROTOBUF_NAMESPACE_ID::int32 value);
  353. public:
  354. // optional int32 queue_passive = 7 [default = 0];
  355. bool has_queue_passive() const;
  356. private:
  357. bool _internal_has_queue_passive() const;
  358. public:
  359. void clear_queue_passive();
  360. ::PROTOBUF_NAMESPACE_ID::int32 queue_passive() const;
  361. void set_queue_passive(::PROTOBUF_NAMESPACE_ID::int32 value);
  362. private:
  363. ::PROTOBUF_NAMESPACE_ID::int32 _internal_queue_passive() const;
  364. void _internal_set_queue_passive(::PROTOBUF_NAMESPACE_ID::int32 value);
  365. public:
  366. // optional int32 queue_durable = 8;
  367. bool has_queue_durable() const;
  368. private:
  369. bool _internal_has_queue_durable() const;
  370. public:
  371. void clear_queue_durable();
  372. ::PROTOBUF_NAMESPACE_ID::int32 queue_durable() const;
  373. void set_queue_durable(::PROTOBUF_NAMESPACE_ID::int32 value);
  374. private:
  375. ::PROTOBUF_NAMESPACE_ID::int32 _internal_queue_durable() const;
  376. void _internal_set_queue_durable(::PROTOBUF_NAMESPACE_ID::int32 value);
  377. public:
  378. // optional int32 queue_exclusive = 9 [default = 0];
  379. bool has_queue_exclusive() const;
  380. private:
  381. bool _internal_has_queue_exclusive() const;
  382. public:
  383. void clear_queue_exclusive();
  384. ::PROTOBUF_NAMESPACE_ID::int32 queue_exclusive() const;
  385. void set_queue_exclusive(::PROTOBUF_NAMESPACE_ID::int32 value);
  386. private:
  387. ::PROTOBUF_NAMESPACE_ID::int32 _internal_queue_exclusive() const;
  388. void _internal_set_queue_exclusive(::PROTOBUF_NAMESPACE_ID::int32 value);
  389. public:
  390. // optional int32 queue_auto_delete = 10 [default = 0];
  391. bool has_queue_auto_delete() const;
  392. private:
  393. bool _internal_has_queue_auto_delete() const;
  394. public:
  395. void clear_queue_auto_delete();
  396. ::PROTOBUF_NAMESPACE_ID::int32 queue_auto_delete() const;
  397. void set_queue_auto_delete(::PROTOBUF_NAMESPACE_ID::int32 value);
  398. private:
  399. ::PROTOBUF_NAMESPACE_ID::int32 _internal_queue_auto_delete() const;
  400. void _internal_set_queue_auto_delete(::PROTOBUF_NAMESPACE_ID::int32 value);
  401. public:
  402. // optional int32 queue_meassage_ttl = 11 [default = 0];
  403. bool has_queue_meassage_ttl() const;
  404. private:
  405. bool _internal_has_queue_meassage_ttl() const;
  406. public:
  407. void clear_queue_meassage_ttl();
  408. ::PROTOBUF_NAMESPACE_ID::int32 queue_meassage_ttl() const;
  409. void set_queue_meassage_ttl(::PROTOBUF_NAMESPACE_ID::int32 value);
  410. private:
  411. ::PROTOBUF_NAMESPACE_ID::int32 _internal_queue_meassage_ttl() const;
  412. void _internal_set_queue_meassage_ttl(::PROTOBUF_NAMESPACE_ID::int32 value);
  413. public:
  414. // optional int32 consume_no_local = 13 [default = 0];
  415. bool has_consume_no_local() const;
  416. private:
  417. bool _internal_has_consume_no_local() const;
  418. public:
  419. void clear_consume_no_local();
  420. ::PROTOBUF_NAMESPACE_ID::int32 consume_no_local() const;
  421. void set_consume_no_local(::PROTOBUF_NAMESPACE_ID::int32 value);
  422. private:
  423. ::PROTOBUF_NAMESPACE_ID::int32 _internal_consume_no_local() const;
  424. void _internal_set_consume_no_local(::PROTOBUF_NAMESPACE_ID::int32 value);
  425. public:
  426. // optional int32 consume_no_ack = 14 [default = 0];
  427. bool has_consume_no_ack() const;
  428. private:
  429. bool _internal_has_consume_no_ack() const;
  430. public:
  431. void clear_consume_no_ack();
  432. ::PROTOBUF_NAMESPACE_ID::int32 consume_no_ack() const;
  433. void set_consume_no_ack(::PROTOBUF_NAMESPACE_ID::int32 value);
  434. private:
  435. ::PROTOBUF_NAMESPACE_ID::int32 _internal_consume_no_ack() const;
  436. void _internal_set_consume_no_ack(::PROTOBUF_NAMESPACE_ID::int32 value);
  437. public:
  438. // optional int32 consume_exclusive = 15;
  439. bool has_consume_exclusive() const;
  440. private:
  441. bool _internal_has_consume_exclusive() const;
  442. public:
  443. void clear_consume_exclusive();
  444. ::PROTOBUF_NAMESPACE_ID::int32 consume_exclusive() const;
  445. void set_consume_exclusive(::PROTOBUF_NAMESPACE_ID::int32 value);
  446. private:
  447. ::PROTOBUF_NAMESPACE_ID::int32 _internal_consume_exclusive() const;
  448. void _internal_set_consume_exclusive(::PROTOBUF_NAMESPACE_ID::int32 value);
  449. public:
  450. // @@protoc_insertion_point(class_scope:Rabbitmq_proto.Rabbitmq_channel_queue_consume)
  451. private:
  452. class _Internal;
  453. template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
  454. typedef void InternalArenaConstructable_;
  455. typedef void DestructorSkippable_;
  456. ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
  457. mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
  458. ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr exchange_name_;
  459. ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr routing_key_;
  460. ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr binding_key_;
  461. ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr queue_name_;
  462. ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr consume_name_;
  463. ::PROTOBUF_NAMESPACE_ID::int32 channel_;
  464. ::PROTOBUF_NAMESPACE_ID::int32 timeout_ms_;
  465. ::PROTOBUF_NAMESPACE_ID::int32 queue_passive_;
  466. ::PROTOBUF_NAMESPACE_ID::int32 queue_durable_;
  467. ::PROTOBUF_NAMESPACE_ID::int32 queue_exclusive_;
  468. ::PROTOBUF_NAMESPACE_ID::int32 queue_auto_delete_;
  469. ::PROTOBUF_NAMESPACE_ID::int32 queue_meassage_ttl_;
  470. ::PROTOBUF_NAMESPACE_ID::int32 consume_no_local_;
  471. ::PROTOBUF_NAMESPACE_ID::int32 consume_no_ack_;
  472. ::PROTOBUF_NAMESPACE_ID::int32 consume_exclusive_;
  473. friend struct ::TableStruct_rabbitmq_2eproto;
  474. };
  475. // -------------------------------------------------------------------
  476. class Rabbitmq_parameter PROTOBUF_FINAL :
  477. public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:Rabbitmq_proto.Rabbitmq_parameter) */ {
  478. public:
  479. inline Rabbitmq_parameter() : Rabbitmq_parameter(nullptr) {};
  480. virtual ~Rabbitmq_parameter();
  481. Rabbitmq_parameter(const Rabbitmq_parameter& from);
  482. Rabbitmq_parameter(Rabbitmq_parameter&& from) noexcept
  483. : Rabbitmq_parameter() {
  484. *this = ::std::move(from);
  485. }
  486. inline Rabbitmq_parameter& operator=(const Rabbitmq_parameter& from) {
  487. CopyFrom(from);
  488. return *this;
  489. }
  490. inline Rabbitmq_parameter& operator=(Rabbitmq_parameter&& from) noexcept {
  491. if (GetArena() == from.GetArena()) {
  492. if (this != &from) InternalSwap(&from);
  493. } else {
  494. CopyFrom(from);
  495. }
  496. return *this;
  497. }
  498. inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
  499. return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
  500. }
  501. inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
  502. return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
  503. }
  504. static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
  505. return GetDescriptor();
  506. }
  507. static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
  508. return GetMetadataStatic().descriptor;
  509. }
  510. static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
  511. return GetMetadataStatic().reflection;
  512. }
  513. static const Rabbitmq_parameter& default_instance();
  514. static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
  515. static inline const Rabbitmq_parameter* internal_default_instance() {
  516. return reinterpret_cast<const Rabbitmq_parameter*>(
  517. &_Rabbitmq_parameter_default_instance_);
  518. }
  519. static constexpr int kIndexInFileMessages =
  520. 1;
  521. friend void swap(Rabbitmq_parameter& a, Rabbitmq_parameter& b) {
  522. a.Swap(&b);
  523. }
  524. inline void Swap(Rabbitmq_parameter* other) {
  525. if (other == this) return;
  526. if (GetArena() == other->GetArena()) {
  527. InternalSwap(other);
  528. } else {
  529. ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
  530. }
  531. }
  532. void UnsafeArenaSwap(Rabbitmq_parameter* other) {
  533. if (other == this) return;
  534. GOOGLE_DCHECK(GetArena() == other->GetArena());
  535. InternalSwap(other);
  536. }
  537. // implements Message ----------------------------------------------
  538. inline Rabbitmq_parameter* New() const final {
  539. return CreateMaybeMessage<Rabbitmq_parameter>(nullptr);
  540. }
  541. Rabbitmq_parameter* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
  542. return CreateMaybeMessage<Rabbitmq_parameter>(arena);
  543. }
  544. void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
  545. void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
  546. void CopyFrom(const Rabbitmq_parameter& from);
  547. void MergeFrom(const Rabbitmq_parameter& from);
  548. PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
  549. bool IsInitialized() const final;
  550. size_t ByteSizeLong() const final;
  551. const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
  552. ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize(
  553. ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
  554. int GetCachedSize() const final { return _cached_size_.Get(); }
  555. private:
  556. inline void SharedCtor();
  557. inline void SharedDtor();
  558. void SetCachedSize(int size) const final;
  559. void InternalSwap(Rabbitmq_parameter* other);
  560. friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
  561. static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
  562. return "Rabbitmq_proto.Rabbitmq_parameter";
  563. }
  564. protected:
  565. explicit Rabbitmq_parameter(::PROTOBUF_NAMESPACE_ID::Arena* arena);
  566. private:
  567. static void ArenaDtor(void* object);
  568. inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
  569. public:
  570. ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
  571. private:
  572. static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
  573. ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_rabbitmq_2eproto);
  574. return ::descriptor_table_rabbitmq_2eproto.file_level_metadata[kIndexInFileMessages];
  575. }
  576. public:
  577. // nested types ----------------------------------------------------
  578. // accessors -------------------------------------------------------
  579. enum : int {
  580. kRabbitmqRecieverVectorFieldNumber = 5,
  581. kRabbitmqSenderRequestVectorFieldNumber = 6,
  582. kRabbitmqSenderStatusVectorFieldNumber = 7,
  583. kIpFieldNumber = 1,
  584. kUserFieldNumber = 3,
  585. kPasswordFieldNumber = 4,
  586. kPortFieldNumber = 2,
  587. };
  588. // repeated .Rabbitmq_proto.Rabbitmq_channel_queue_consume rabbitmq_reciever_vector = 5;
  589. int rabbitmq_reciever_vector_size() const;
  590. private:
  591. int _internal_rabbitmq_reciever_vector_size() const;
  592. public:
  593. void clear_rabbitmq_reciever_vector();
  594. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* mutable_rabbitmq_reciever_vector(int index);
  595. ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >*
  596. mutable_rabbitmq_reciever_vector();
  597. private:
  598. const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& _internal_rabbitmq_reciever_vector(int index) const;
  599. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* _internal_add_rabbitmq_reciever_vector();
  600. public:
  601. const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& rabbitmq_reciever_vector(int index) const;
  602. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* add_rabbitmq_reciever_vector();
  603. const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >&
  604. rabbitmq_reciever_vector() const;
  605. // repeated .Rabbitmq_proto.Rabbitmq_channel_queue_consume rabbitmq_sender_request_vector = 6;
  606. int rabbitmq_sender_request_vector_size() const;
  607. private:
  608. int _internal_rabbitmq_sender_request_vector_size() const;
  609. public:
  610. void clear_rabbitmq_sender_request_vector();
  611. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* mutable_rabbitmq_sender_request_vector(int index);
  612. ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >*
  613. mutable_rabbitmq_sender_request_vector();
  614. private:
  615. const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& _internal_rabbitmq_sender_request_vector(int index) const;
  616. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* _internal_add_rabbitmq_sender_request_vector();
  617. public:
  618. const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& rabbitmq_sender_request_vector(int index) const;
  619. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* add_rabbitmq_sender_request_vector();
  620. const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >&
  621. rabbitmq_sender_request_vector() const;
  622. // repeated .Rabbitmq_proto.Rabbitmq_channel_queue_consume rabbitmq_sender_status_vector = 7;
  623. int rabbitmq_sender_status_vector_size() const;
  624. private:
  625. int _internal_rabbitmq_sender_status_vector_size() const;
  626. public:
  627. void clear_rabbitmq_sender_status_vector();
  628. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* mutable_rabbitmq_sender_status_vector(int index);
  629. ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >*
  630. mutable_rabbitmq_sender_status_vector();
  631. private:
  632. const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& _internal_rabbitmq_sender_status_vector(int index) const;
  633. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* _internal_add_rabbitmq_sender_status_vector();
  634. public:
  635. const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& rabbitmq_sender_status_vector(int index) const;
  636. ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* add_rabbitmq_sender_status_vector();
  637. const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >&
  638. rabbitmq_sender_status_vector() const;
  639. // optional string ip = 1;
  640. bool has_ip() const;
  641. private:
  642. bool _internal_has_ip() const;
  643. public:
  644. void clear_ip();
  645. const std::string& ip() const;
  646. void set_ip(const std::string& value);
  647. void set_ip(std::string&& value);
  648. void set_ip(const char* value);
  649. void set_ip(const char* value, size_t size);
  650. std::string* mutable_ip();
  651. std::string* release_ip();
  652. void set_allocated_ip(std::string* ip);
  653. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  654. " string fields are deprecated and will be removed in a"
  655. " future release.")
  656. std::string* unsafe_arena_release_ip();
  657. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  658. " string fields are deprecated and will be removed in a"
  659. " future release.")
  660. void unsafe_arena_set_allocated_ip(
  661. std::string* ip);
  662. private:
  663. const std::string& _internal_ip() const;
  664. void _internal_set_ip(const std::string& value);
  665. std::string* _internal_mutable_ip();
  666. public:
  667. // optional string user = 3;
  668. bool has_user() const;
  669. private:
  670. bool _internal_has_user() const;
  671. public:
  672. void clear_user();
  673. const std::string& user() const;
  674. void set_user(const std::string& value);
  675. void set_user(std::string&& value);
  676. void set_user(const char* value);
  677. void set_user(const char* value, size_t size);
  678. std::string* mutable_user();
  679. std::string* release_user();
  680. void set_allocated_user(std::string* user);
  681. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  682. " string fields are deprecated and will be removed in a"
  683. " future release.")
  684. std::string* unsafe_arena_release_user();
  685. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  686. " string fields are deprecated and will be removed in a"
  687. " future release.")
  688. void unsafe_arena_set_allocated_user(
  689. std::string* user);
  690. private:
  691. const std::string& _internal_user() const;
  692. void _internal_set_user(const std::string& value);
  693. std::string* _internal_mutable_user();
  694. public:
  695. // optional string password = 4;
  696. bool has_password() const;
  697. private:
  698. bool _internal_has_password() const;
  699. public:
  700. void clear_password();
  701. const std::string& password() const;
  702. void set_password(const std::string& value);
  703. void set_password(std::string&& value);
  704. void set_password(const char* value);
  705. void set_password(const char* value, size_t size);
  706. std::string* mutable_password();
  707. std::string* release_password();
  708. void set_allocated_password(std::string* password);
  709. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  710. " string fields are deprecated and will be removed in a"
  711. " future release.")
  712. std::string* unsafe_arena_release_password();
  713. GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
  714. " string fields are deprecated and will be removed in a"
  715. " future release.")
  716. void unsafe_arena_set_allocated_password(
  717. std::string* password);
  718. private:
  719. const std::string& _internal_password() const;
  720. void _internal_set_password(const std::string& value);
  721. std::string* _internal_mutable_password();
  722. public:
  723. // optional int32 port = 2;
  724. bool has_port() const;
  725. private:
  726. bool _internal_has_port() const;
  727. public:
  728. void clear_port();
  729. ::PROTOBUF_NAMESPACE_ID::int32 port() const;
  730. void set_port(::PROTOBUF_NAMESPACE_ID::int32 value);
  731. private:
  732. ::PROTOBUF_NAMESPACE_ID::int32 _internal_port() const;
  733. void _internal_set_port(::PROTOBUF_NAMESPACE_ID::int32 value);
  734. public:
  735. // @@protoc_insertion_point(class_scope:Rabbitmq_proto.Rabbitmq_parameter)
  736. private:
  737. class _Internal;
  738. template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
  739. typedef void InternalArenaConstructable_;
  740. typedef void DestructorSkippable_;
  741. ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
  742. mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
  743. ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume > rabbitmq_reciever_vector_;
  744. ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume > rabbitmq_sender_request_vector_;
  745. ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume > rabbitmq_sender_status_vector_;
  746. ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr ip_;
  747. ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr user_;
  748. ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr password_;
  749. ::PROTOBUF_NAMESPACE_ID::int32 port_;
  750. friend struct ::TableStruct_rabbitmq_2eproto;
  751. };
  752. // -------------------------------------------------------------------
  753. class Rabbitmq_parameter_all PROTOBUF_FINAL :
  754. public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:Rabbitmq_proto.Rabbitmq_parameter_all) */ {
  755. public:
  756. inline Rabbitmq_parameter_all() : Rabbitmq_parameter_all(nullptr) {};
  757. virtual ~Rabbitmq_parameter_all();
  758. Rabbitmq_parameter_all(const Rabbitmq_parameter_all& from);
  759. Rabbitmq_parameter_all(Rabbitmq_parameter_all&& from) noexcept
  760. : Rabbitmq_parameter_all() {
  761. *this = ::std::move(from);
  762. }
  763. inline Rabbitmq_parameter_all& operator=(const Rabbitmq_parameter_all& from) {
  764. CopyFrom(from);
  765. return *this;
  766. }
  767. inline Rabbitmq_parameter_all& operator=(Rabbitmq_parameter_all&& from) noexcept {
  768. if (GetArena() == from.GetArena()) {
  769. if (this != &from) InternalSwap(&from);
  770. } else {
  771. CopyFrom(from);
  772. }
  773. return *this;
  774. }
  775. inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
  776. return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
  777. }
  778. inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
  779. return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
  780. }
  781. static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
  782. return GetDescriptor();
  783. }
  784. static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
  785. return GetMetadataStatic().descriptor;
  786. }
  787. static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
  788. return GetMetadataStatic().reflection;
  789. }
  790. static const Rabbitmq_parameter_all& default_instance();
  791. static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
  792. static inline const Rabbitmq_parameter_all* internal_default_instance() {
  793. return reinterpret_cast<const Rabbitmq_parameter_all*>(
  794. &_Rabbitmq_parameter_all_default_instance_);
  795. }
  796. static constexpr int kIndexInFileMessages =
  797. 2;
  798. friend void swap(Rabbitmq_parameter_all& a, Rabbitmq_parameter_all& b) {
  799. a.Swap(&b);
  800. }
  801. inline void Swap(Rabbitmq_parameter_all* other) {
  802. if (other == this) return;
  803. if (GetArena() == other->GetArena()) {
  804. InternalSwap(other);
  805. } else {
  806. ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
  807. }
  808. }
  809. void UnsafeArenaSwap(Rabbitmq_parameter_all* other) {
  810. if (other == this) return;
  811. GOOGLE_DCHECK(GetArena() == other->GetArena());
  812. InternalSwap(other);
  813. }
  814. // implements Message ----------------------------------------------
  815. inline Rabbitmq_parameter_all* New() const final {
  816. return CreateMaybeMessage<Rabbitmq_parameter_all>(nullptr);
  817. }
  818. Rabbitmq_parameter_all* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
  819. return CreateMaybeMessage<Rabbitmq_parameter_all>(arena);
  820. }
  821. void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
  822. void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
  823. void CopyFrom(const Rabbitmq_parameter_all& from);
  824. void MergeFrom(const Rabbitmq_parameter_all& from);
  825. PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
  826. bool IsInitialized() const final;
  827. size_t ByteSizeLong() const final;
  828. const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
  829. ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize(
  830. ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
  831. int GetCachedSize() const final { return _cached_size_.Get(); }
  832. private:
  833. inline void SharedCtor();
  834. inline void SharedDtor();
  835. void SetCachedSize(int size) const final;
  836. void InternalSwap(Rabbitmq_parameter_all* other);
  837. friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
  838. static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
  839. return "Rabbitmq_proto.Rabbitmq_parameter_all";
  840. }
  841. protected:
  842. explicit Rabbitmq_parameter_all(::PROTOBUF_NAMESPACE_ID::Arena* arena);
  843. private:
  844. static void ArenaDtor(void* object);
  845. inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
  846. public:
  847. ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
  848. private:
  849. static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
  850. ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_rabbitmq_2eproto);
  851. return ::descriptor_table_rabbitmq_2eproto.file_level_metadata[kIndexInFileMessages];
  852. }
  853. public:
  854. // nested types ----------------------------------------------------
  855. // accessors -------------------------------------------------------
  856. enum : int {
  857. kRabbitmqParametersFieldNumber = 1,
  858. };
  859. // optional .Rabbitmq_proto.Rabbitmq_parameter rabbitmq_parameters = 1;
  860. bool has_rabbitmq_parameters() const;
  861. private:
  862. bool _internal_has_rabbitmq_parameters() const;
  863. public:
  864. void clear_rabbitmq_parameters();
  865. const ::Rabbitmq_proto::Rabbitmq_parameter& rabbitmq_parameters() const;
  866. ::Rabbitmq_proto::Rabbitmq_parameter* release_rabbitmq_parameters();
  867. ::Rabbitmq_proto::Rabbitmq_parameter* mutable_rabbitmq_parameters();
  868. void set_allocated_rabbitmq_parameters(::Rabbitmq_proto::Rabbitmq_parameter* rabbitmq_parameters);
  869. private:
  870. const ::Rabbitmq_proto::Rabbitmq_parameter& _internal_rabbitmq_parameters() const;
  871. ::Rabbitmq_proto::Rabbitmq_parameter* _internal_mutable_rabbitmq_parameters();
  872. public:
  873. void unsafe_arena_set_allocated_rabbitmq_parameters(
  874. ::Rabbitmq_proto::Rabbitmq_parameter* rabbitmq_parameters);
  875. ::Rabbitmq_proto::Rabbitmq_parameter* unsafe_arena_release_rabbitmq_parameters();
  876. // @@protoc_insertion_point(class_scope:Rabbitmq_proto.Rabbitmq_parameter_all)
  877. private:
  878. class _Internal;
  879. template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
  880. typedef void InternalArenaConstructable_;
  881. typedef void DestructorSkippable_;
  882. ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
  883. mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
  884. ::Rabbitmq_proto::Rabbitmq_parameter* rabbitmq_parameters_;
  885. friend struct ::TableStruct_rabbitmq_2eproto;
  886. };
  887. // ===================================================================
  888. // ===================================================================
  889. #ifdef __GNUC__
  890. #pragma GCC diagnostic push
  891. #pragma GCC diagnostic ignored "-Wstrict-aliasing"
  892. #endif // __GNUC__
  893. // Rabbitmq_channel_queue_consume
  894. // optional int32 channel = 1;
  895. inline bool Rabbitmq_channel_queue_consume::_internal_has_channel() const {
  896. bool value = (_has_bits_[0] & 0x00000020u) != 0;
  897. return value;
  898. }
  899. inline bool Rabbitmq_channel_queue_consume::has_channel() const {
  900. return _internal_has_channel();
  901. }
  902. inline void Rabbitmq_channel_queue_consume::clear_channel() {
  903. channel_ = 0;
  904. _has_bits_[0] &= ~0x00000020u;
  905. }
  906. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::_internal_channel() const {
  907. return channel_;
  908. }
  909. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::channel() const {
  910. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.channel)
  911. return _internal_channel();
  912. }
  913. inline void Rabbitmq_channel_queue_consume::_internal_set_channel(::PROTOBUF_NAMESPACE_ID::int32 value) {
  914. _has_bits_[0] |= 0x00000020u;
  915. channel_ = value;
  916. }
  917. inline void Rabbitmq_channel_queue_consume::set_channel(::PROTOBUF_NAMESPACE_ID::int32 value) {
  918. _internal_set_channel(value);
  919. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.channel)
  920. }
  921. // optional string exchange_name = 2;
  922. inline bool Rabbitmq_channel_queue_consume::_internal_has_exchange_name() const {
  923. bool value = (_has_bits_[0] & 0x00000001u) != 0;
  924. return value;
  925. }
  926. inline bool Rabbitmq_channel_queue_consume::has_exchange_name() const {
  927. return _internal_has_exchange_name();
  928. }
  929. inline void Rabbitmq_channel_queue_consume::clear_exchange_name() {
  930. exchange_name_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  931. _has_bits_[0] &= ~0x00000001u;
  932. }
  933. inline const std::string& Rabbitmq_channel_queue_consume::exchange_name() const {
  934. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  935. return _internal_exchange_name();
  936. }
  937. inline void Rabbitmq_channel_queue_consume::set_exchange_name(const std::string& value) {
  938. _internal_set_exchange_name(value);
  939. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  940. }
  941. inline std::string* Rabbitmq_channel_queue_consume::mutable_exchange_name() {
  942. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  943. return _internal_mutable_exchange_name();
  944. }
  945. inline const std::string& Rabbitmq_channel_queue_consume::_internal_exchange_name() const {
  946. return exchange_name_.Get();
  947. }
  948. inline void Rabbitmq_channel_queue_consume::_internal_set_exchange_name(const std::string& value) {
  949. _has_bits_[0] |= 0x00000001u;
  950. exchange_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value, GetArena());
  951. }
  952. inline void Rabbitmq_channel_queue_consume::set_exchange_name(std::string&& value) {
  953. _has_bits_[0] |= 0x00000001u;
  954. exchange_name_.Set(
  955. &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value), GetArena());
  956. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  957. }
  958. inline void Rabbitmq_channel_queue_consume::set_exchange_name(const char* value) {
  959. GOOGLE_DCHECK(value != nullptr);
  960. _has_bits_[0] |= 0x00000001u;
  961. exchange_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value),
  962. GetArena());
  963. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  964. }
  965. inline void Rabbitmq_channel_queue_consume::set_exchange_name(const char* value,
  966. size_t size) {
  967. _has_bits_[0] |= 0x00000001u;
  968. exchange_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(
  969. reinterpret_cast<const char*>(value), size), GetArena());
  970. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  971. }
  972. inline std::string* Rabbitmq_channel_queue_consume::_internal_mutable_exchange_name() {
  973. _has_bits_[0] |= 0x00000001u;
  974. return exchange_name_.Mutable(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  975. }
  976. inline std::string* Rabbitmq_channel_queue_consume::release_exchange_name() {
  977. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  978. if (!_internal_has_exchange_name()) {
  979. return nullptr;
  980. }
  981. _has_bits_[0] &= ~0x00000001u;
  982. return exchange_name_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  983. }
  984. inline void Rabbitmq_channel_queue_consume::set_allocated_exchange_name(std::string* exchange_name) {
  985. if (exchange_name != nullptr) {
  986. _has_bits_[0] |= 0x00000001u;
  987. } else {
  988. _has_bits_[0] &= ~0x00000001u;
  989. }
  990. exchange_name_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), exchange_name,
  991. GetArena());
  992. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  993. }
  994. inline std::string* Rabbitmq_channel_queue_consume::unsafe_arena_release_exchange_name() {
  995. // @@protoc_insertion_point(field_unsafe_arena_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  996. GOOGLE_DCHECK(GetArena() != nullptr);
  997. _has_bits_[0] &= ~0x00000001u;
  998. return exchange_name_.UnsafeArenaRelease(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  999. GetArena());
  1000. }
  1001. inline void Rabbitmq_channel_queue_consume::unsafe_arena_set_allocated_exchange_name(
  1002. std::string* exchange_name) {
  1003. GOOGLE_DCHECK(GetArena() != nullptr);
  1004. if (exchange_name != nullptr) {
  1005. _has_bits_[0] |= 0x00000001u;
  1006. } else {
  1007. _has_bits_[0] &= ~0x00000001u;
  1008. }
  1009. exchange_name_.UnsafeArenaSetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1010. exchange_name, GetArena());
  1011. // @@protoc_insertion_point(field_unsafe_arena_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.exchange_name)
  1012. }
  1013. // optional string routing_key = 3;
  1014. inline bool Rabbitmq_channel_queue_consume::_internal_has_routing_key() const {
  1015. bool value = (_has_bits_[0] & 0x00000002u) != 0;
  1016. return value;
  1017. }
  1018. inline bool Rabbitmq_channel_queue_consume::has_routing_key() const {
  1019. return _internal_has_routing_key();
  1020. }
  1021. inline void Rabbitmq_channel_queue_consume::clear_routing_key() {
  1022. routing_key_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1023. _has_bits_[0] &= ~0x00000002u;
  1024. }
  1025. inline const std::string& Rabbitmq_channel_queue_consume::routing_key() const {
  1026. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  1027. return _internal_routing_key();
  1028. }
  1029. inline void Rabbitmq_channel_queue_consume::set_routing_key(const std::string& value) {
  1030. _internal_set_routing_key(value);
  1031. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  1032. }
  1033. inline std::string* Rabbitmq_channel_queue_consume::mutable_routing_key() {
  1034. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  1035. return _internal_mutable_routing_key();
  1036. }
  1037. inline const std::string& Rabbitmq_channel_queue_consume::_internal_routing_key() const {
  1038. return routing_key_.Get();
  1039. }
  1040. inline void Rabbitmq_channel_queue_consume::_internal_set_routing_key(const std::string& value) {
  1041. _has_bits_[0] |= 0x00000002u;
  1042. routing_key_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value, GetArena());
  1043. }
  1044. inline void Rabbitmq_channel_queue_consume::set_routing_key(std::string&& value) {
  1045. _has_bits_[0] |= 0x00000002u;
  1046. routing_key_.Set(
  1047. &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value), GetArena());
  1048. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  1049. }
  1050. inline void Rabbitmq_channel_queue_consume::set_routing_key(const char* value) {
  1051. GOOGLE_DCHECK(value != nullptr);
  1052. _has_bits_[0] |= 0x00000002u;
  1053. routing_key_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value),
  1054. GetArena());
  1055. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  1056. }
  1057. inline void Rabbitmq_channel_queue_consume::set_routing_key(const char* value,
  1058. size_t size) {
  1059. _has_bits_[0] |= 0x00000002u;
  1060. routing_key_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(
  1061. reinterpret_cast<const char*>(value), size), GetArena());
  1062. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  1063. }
  1064. inline std::string* Rabbitmq_channel_queue_consume::_internal_mutable_routing_key() {
  1065. _has_bits_[0] |= 0x00000002u;
  1066. return routing_key_.Mutable(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1067. }
  1068. inline std::string* Rabbitmq_channel_queue_consume::release_routing_key() {
  1069. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  1070. if (!_internal_has_routing_key()) {
  1071. return nullptr;
  1072. }
  1073. _has_bits_[0] &= ~0x00000002u;
  1074. return routing_key_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1075. }
  1076. inline void Rabbitmq_channel_queue_consume::set_allocated_routing_key(std::string* routing_key) {
  1077. if (routing_key != nullptr) {
  1078. _has_bits_[0] |= 0x00000002u;
  1079. } else {
  1080. _has_bits_[0] &= ~0x00000002u;
  1081. }
  1082. routing_key_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), routing_key,
  1083. GetArena());
  1084. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  1085. }
  1086. inline std::string* Rabbitmq_channel_queue_consume::unsafe_arena_release_routing_key() {
  1087. // @@protoc_insertion_point(field_unsafe_arena_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  1088. GOOGLE_DCHECK(GetArena() != nullptr);
  1089. _has_bits_[0] &= ~0x00000002u;
  1090. return routing_key_.UnsafeArenaRelease(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1091. GetArena());
  1092. }
  1093. inline void Rabbitmq_channel_queue_consume::unsafe_arena_set_allocated_routing_key(
  1094. std::string* routing_key) {
  1095. GOOGLE_DCHECK(GetArena() != nullptr);
  1096. if (routing_key != nullptr) {
  1097. _has_bits_[0] |= 0x00000002u;
  1098. } else {
  1099. _has_bits_[0] &= ~0x00000002u;
  1100. }
  1101. routing_key_.UnsafeArenaSetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1102. routing_key, GetArena());
  1103. // @@protoc_insertion_point(field_unsafe_arena_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.routing_key)
  1104. }
  1105. // optional int32 timeout_ms = 4;
  1106. inline bool Rabbitmq_channel_queue_consume::_internal_has_timeout_ms() const {
  1107. bool value = (_has_bits_[0] & 0x00000040u) != 0;
  1108. return value;
  1109. }
  1110. inline bool Rabbitmq_channel_queue_consume::has_timeout_ms() const {
  1111. return _internal_has_timeout_ms();
  1112. }
  1113. inline void Rabbitmq_channel_queue_consume::clear_timeout_ms() {
  1114. timeout_ms_ = 0;
  1115. _has_bits_[0] &= ~0x00000040u;
  1116. }
  1117. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::_internal_timeout_ms() const {
  1118. return timeout_ms_;
  1119. }
  1120. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::timeout_ms() const {
  1121. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.timeout_ms)
  1122. return _internal_timeout_ms();
  1123. }
  1124. inline void Rabbitmq_channel_queue_consume::_internal_set_timeout_ms(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1125. _has_bits_[0] |= 0x00000040u;
  1126. timeout_ms_ = value;
  1127. }
  1128. inline void Rabbitmq_channel_queue_consume::set_timeout_ms(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1129. _internal_set_timeout_ms(value);
  1130. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.timeout_ms)
  1131. }
  1132. // optional string binding_key = 5;
  1133. inline bool Rabbitmq_channel_queue_consume::_internal_has_binding_key() const {
  1134. bool value = (_has_bits_[0] & 0x00000004u) != 0;
  1135. return value;
  1136. }
  1137. inline bool Rabbitmq_channel_queue_consume::has_binding_key() const {
  1138. return _internal_has_binding_key();
  1139. }
  1140. inline void Rabbitmq_channel_queue_consume::clear_binding_key() {
  1141. binding_key_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1142. _has_bits_[0] &= ~0x00000004u;
  1143. }
  1144. inline const std::string& Rabbitmq_channel_queue_consume::binding_key() const {
  1145. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  1146. return _internal_binding_key();
  1147. }
  1148. inline void Rabbitmq_channel_queue_consume::set_binding_key(const std::string& value) {
  1149. _internal_set_binding_key(value);
  1150. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  1151. }
  1152. inline std::string* Rabbitmq_channel_queue_consume::mutable_binding_key() {
  1153. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  1154. return _internal_mutable_binding_key();
  1155. }
  1156. inline const std::string& Rabbitmq_channel_queue_consume::_internal_binding_key() const {
  1157. return binding_key_.Get();
  1158. }
  1159. inline void Rabbitmq_channel_queue_consume::_internal_set_binding_key(const std::string& value) {
  1160. _has_bits_[0] |= 0x00000004u;
  1161. binding_key_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value, GetArena());
  1162. }
  1163. inline void Rabbitmq_channel_queue_consume::set_binding_key(std::string&& value) {
  1164. _has_bits_[0] |= 0x00000004u;
  1165. binding_key_.Set(
  1166. &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value), GetArena());
  1167. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  1168. }
  1169. inline void Rabbitmq_channel_queue_consume::set_binding_key(const char* value) {
  1170. GOOGLE_DCHECK(value != nullptr);
  1171. _has_bits_[0] |= 0x00000004u;
  1172. binding_key_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value),
  1173. GetArena());
  1174. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  1175. }
  1176. inline void Rabbitmq_channel_queue_consume::set_binding_key(const char* value,
  1177. size_t size) {
  1178. _has_bits_[0] |= 0x00000004u;
  1179. binding_key_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(
  1180. reinterpret_cast<const char*>(value), size), GetArena());
  1181. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  1182. }
  1183. inline std::string* Rabbitmq_channel_queue_consume::_internal_mutable_binding_key() {
  1184. _has_bits_[0] |= 0x00000004u;
  1185. return binding_key_.Mutable(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1186. }
  1187. inline std::string* Rabbitmq_channel_queue_consume::release_binding_key() {
  1188. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  1189. if (!_internal_has_binding_key()) {
  1190. return nullptr;
  1191. }
  1192. _has_bits_[0] &= ~0x00000004u;
  1193. return binding_key_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1194. }
  1195. inline void Rabbitmq_channel_queue_consume::set_allocated_binding_key(std::string* binding_key) {
  1196. if (binding_key != nullptr) {
  1197. _has_bits_[0] |= 0x00000004u;
  1198. } else {
  1199. _has_bits_[0] &= ~0x00000004u;
  1200. }
  1201. binding_key_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), binding_key,
  1202. GetArena());
  1203. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  1204. }
  1205. inline std::string* Rabbitmq_channel_queue_consume::unsafe_arena_release_binding_key() {
  1206. // @@protoc_insertion_point(field_unsafe_arena_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  1207. GOOGLE_DCHECK(GetArena() != nullptr);
  1208. _has_bits_[0] &= ~0x00000004u;
  1209. return binding_key_.UnsafeArenaRelease(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1210. GetArena());
  1211. }
  1212. inline void Rabbitmq_channel_queue_consume::unsafe_arena_set_allocated_binding_key(
  1213. std::string* binding_key) {
  1214. GOOGLE_DCHECK(GetArena() != nullptr);
  1215. if (binding_key != nullptr) {
  1216. _has_bits_[0] |= 0x00000004u;
  1217. } else {
  1218. _has_bits_[0] &= ~0x00000004u;
  1219. }
  1220. binding_key_.UnsafeArenaSetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1221. binding_key, GetArena());
  1222. // @@protoc_insertion_point(field_unsafe_arena_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.binding_key)
  1223. }
  1224. // optional string queue_name = 6;
  1225. inline bool Rabbitmq_channel_queue_consume::_internal_has_queue_name() const {
  1226. bool value = (_has_bits_[0] & 0x00000008u) != 0;
  1227. return value;
  1228. }
  1229. inline bool Rabbitmq_channel_queue_consume::has_queue_name() const {
  1230. return _internal_has_queue_name();
  1231. }
  1232. inline void Rabbitmq_channel_queue_consume::clear_queue_name() {
  1233. queue_name_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1234. _has_bits_[0] &= ~0x00000008u;
  1235. }
  1236. inline const std::string& Rabbitmq_channel_queue_consume::queue_name() const {
  1237. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  1238. return _internal_queue_name();
  1239. }
  1240. inline void Rabbitmq_channel_queue_consume::set_queue_name(const std::string& value) {
  1241. _internal_set_queue_name(value);
  1242. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  1243. }
  1244. inline std::string* Rabbitmq_channel_queue_consume::mutable_queue_name() {
  1245. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  1246. return _internal_mutable_queue_name();
  1247. }
  1248. inline const std::string& Rabbitmq_channel_queue_consume::_internal_queue_name() const {
  1249. return queue_name_.Get();
  1250. }
  1251. inline void Rabbitmq_channel_queue_consume::_internal_set_queue_name(const std::string& value) {
  1252. _has_bits_[0] |= 0x00000008u;
  1253. queue_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value, GetArena());
  1254. }
  1255. inline void Rabbitmq_channel_queue_consume::set_queue_name(std::string&& value) {
  1256. _has_bits_[0] |= 0x00000008u;
  1257. queue_name_.Set(
  1258. &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value), GetArena());
  1259. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  1260. }
  1261. inline void Rabbitmq_channel_queue_consume::set_queue_name(const char* value) {
  1262. GOOGLE_DCHECK(value != nullptr);
  1263. _has_bits_[0] |= 0x00000008u;
  1264. queue_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value),
  1265. GetArena());
  1266. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  1267. }
  1268. inline void Rabbitmq_channel_queue_consume::set_queue_name(const char* value,
  1269. size_t size) {
  1270. _has_bits_[0] |= 0x00000008u;
  1271. queue_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(
  1272. reinterpret_cast<const char*>(value), size), GetArena());
  1273. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  1274. }
  1275. inline std::string* Rabbitmq_channel_queue_consume::_internal_mutable_queue_name() {
  1276. _has_bits_[0] |= 0x00000008u;
  1277. return queue_name_.Mutable(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1278. }
  1279. inline std::string* Rabbitmq_channel_queue_consume::release_queue_name() {
  1280. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  1281. if (!_internal_has_queue_name()) {
  1282. return nullptr;
  1283. }
  1284. _has_bits_[0] &= ~0x00000008u;
  1285. return queue_name_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1286. }
  1287. inline void Rabbitmq_channel_queue_consume::set_allocated_queue_name(std::string* queue_name) {
  1288. if (queue_name != nullptr) {
  1289. _has_bits_[0] |= 0x00000008u;
  1290. } else {
  1291. _has_bits_[0] &= ~0x00000008u;
  1292. }
  1293. queue_name_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), queue_name,
  1294. GetArena());
  1295. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  1296. }
  1297. inline std::string* Rabbitmq_channel_queue_consume::unsafe_arena_release_queue_name() {
  1298. // @@protoc_insertion_point(field_unsafe_arena_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  1299. GOOGLE_DCHECK(GetArena() != nullptr);
  1300. _has_bits_[0] &= ~0x00000008u;
  1301. return queue_name_.UnsafeArenaRelease(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1302. GetArena());
  1303. }
  1304. inline void Rabbitmq_channel_queue_consume::unsafe_arena_set_allocated_queue_name(
  1305. std::string* queue_name) {
  1306. GOOGLE_DCHECK(GetArena() != nullptr);
  1307. if (queue_name != nullptr) {
  1308. _has_bits_[0] |= 0x00000008u;
  1309. } else {
  1310. _has_bits_[0] &= ~0x00000008u;
  1311. }
  1312. queue_name_.UnsafeArenaSetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1313. queue_name, GetArena());
  1314. // @@protoc_insertion_point(field_unsafe_arena_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_name)
  1315. }
  1316. // optional int32 queue_passive = 7 [default = 0];
  1317. inline bool Rabbitmq_channel_queue_consume::_internal_has_queue_passive() const {
  1318. bool value = (_has_bits_[0] & 0x00000080u) != 0;
  1319. return value;
  1320. }
  1321. inline bool Rabbitmq_channel_queue_consume::has_queue_passive() const {
  1322. return _internal_has_queue_passive();
  1323. }
  1324. inline void Rabbitmq_channel_queue_consume::clear_queue_passive() {
  1325. queue_passive_ = 0;
  1326. _has_bits_[0] &= ~0x00000080u;
  1327. }
  1328. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::_internal_queue_passive() const {
  1329. return queue_passive_;
  1330. }
  1331. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::queue_passive() const {
  1332. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_passive)
  1333. return _internal_queue_passive();
  1334. }
  1335. inline void Rabbitmq_channel_queue_consume::_internal_set_queue_passive(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1336. _has_bits_[0] |= 0x00000080u;
  1337. queue_passive_ = value;
  1338. }
  1339. inline void Rabbitmq_channel_queue_consume::set_queue_passive(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1340. _internal_set_queue_passive(value);
  1341. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_passive)
  1342. }
  1343. // optional int32 queue_durable = 8;
  1344. inline bool Rabbitmq_channel_queue_consume::_internal_has_queue_durable() const {
  1345. bool value = (_has_bits_[0] & 0x00000100u) != 0;
  1346. return value;
  1347. }
  1348. inline bool Rabbitmq_channel_queue_consume::has_queue_durable() const {
  1349. return _internal_has_queue_durable();
  1350. }
  1351. inline void Rabbitmq_channel_queue_consume::clear_queue_durable() {
  1352. queue_durable_ = 0;
  1353. _has_bits_[0] &= ~0x00000100u;
  1354. }
  1355. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::_internal_queue_durable() const {
  1356. return queue_durable_;
  1357. }
  1358. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::queue_durable() const {
  1359. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_durable)
  1360. return _internal_queue_durable();
  1361. }
  1362. inline void Rabbitmq_channel_queue_consume::_internal_set_queue_durable(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1363. _has_bits_[0] |= 0x00000100u;
  1364. queue_durable_ = value;
  1365. }
  1366. inline void Rabbitmq_channel_queue_consume::set_queue_durable(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1367. _internal_set_queue_durable(value);
  1368. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_durable)
  1369. }
  1370. // optional int32 queue_exclusive = 9 [default = 0];
  1371. inline bool Rabbitmq_channel_queue_consume::_internal_has_queue_exclusive() const {
  1372. bool value = (_has_bits_[0] & 0x00000200u) != 0;
  1373. return value;
  1374. }
  1375. inline bool Rabbitmq_channel_queue_consume::has_queue_exclusive() const {
  1376. return _internal_has_queue_exclusive();
  1377. }
  1378. inline void Rabbitmq_channel_queue_consume::clear_queue_exclusive() {
  1379. queue_exclusive_ = 0;
  1380. _has_bits_[0] &= ~0x00000200u;
  1381. }
  1382. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::_internal_queue_exclusive() const {
  1383. return queue_exclusive_;
  1384. }
  1385. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::queue_exclusive() const {
  1386. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_exclusive)
  1387. return _internal_queue_exclusive();
  1388. }
  1389. inline void Rabbitmq_channel_queue_consume::_internal_set_queue_exclusive(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1390. _has_bits_[0] |= 0x00000200u;
  1391. queue_exclusive_ = value;
  1392. }
  1393. inline void Rabbitmq_channel_queue_consume::set_queue_exclusive(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1394. _internal_set_queue_exclusive(value);
  1395. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_exclusive)
  1396. }
  1397. // optional int32 queue_auto_delete = 10 [default = 0];
  1398. inline bool Rabbitmq_channel_queue_consume::_internal_has_queue_auto_delete() const {
  1399. bool value = (_has_bits_[0] & 0x00000400u) != 0;
  1400. return value;
  1401. }
  1402. inline bool Rabbitmq_channel_queue_consume::has_queue_auto_delete() const {
  1403. return _internal_has_queue_auto_delete();
  1404. }
  1405. inline void Rabbitmq_channel_queue_consume::clear_queue_auto_delete() {
  1406. queue_auto_delete_ = 0;
  1407. _has_bits_[0] &= ~0x00000400u;
  1408. }
  1409. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::_internal_queue_auto_delete() const {
  1410. return queue_auto_delete_;
  1411. }
  1412. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::queue_auto_delete() const {
  1413. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_auto_delete)
  1414. return _internal_queue_auto_delete();
  1415. }
  1416. inline void Rabbitmq_channel_queue_consume::_internal_set_queue_auto_delete(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1417. _has_bits_[0] |= 0x00000400u;
  1418. queue_auto_delete_ = value;
  1419. }
  1420. inline void Rabbitmq_channel_queue_consume::set_queue_auto_delete(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1421. _internal_set_queue_auto_delete(value);
  1422. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_auto_delete)
  1423. }
  1424. // optional int32 queue_meassage_ttl = 11 [default = 0];
  1425. inline bool Rabbitmq_channel_queue_consume::_internal_has_queue_meassage_ttl() const {
  1426. bool value = (_has_bits_[0] & 0x00000800u) != 0;
  1427. return value;
  1428. }
  1429. inline bool Rabbitmq_channel_queue_consume::has_queue_meassage_ttl() const {
  1430. return _internal_has_queue_meassage_ttl();
  1431. }
  1432. inline void Rabbitmq_channel_queue_consume::clear_queue_meassage_ttl() {
  1433. queue_meassage_ttl_ = 0;
  1434. _has_bits_[0] &= ~0x00000800u;
  1435. }
  1436. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::_internal_queue_meassage_ttl() const {
  1437. return queue_meassage_ttl_;
  1438. }
  1439. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::queue_meassage_ttl() const {
  1440. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_meassage_ttl)
  1441. return _internal_queue_meassage_ttl();
  1442. }
  1443. inline void Rabbitmq_channel_queue_consume::_internal_set_queue_meassage_ttl(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1444. _has_bits_[0] |= 0x00000800u;
  1445. queue_meassage_ttl_ = value;
  1446. }
  1447. inline void Rabbitmq_channel_queue_consume::set_queue_meassage_ttl(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1448. _internal_set_queue_meassage_ttl(value);
  1449. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.queue_meassage_ttl)
  1450. }
  1451. // optional string consume_name = 12;
  1452. inline bool Rabbitmq_channel_queue_consume::_internal_has_consume_name() const {
  1453. bool value = (_has_bits_[0] & 0x00000010u) != 0;
  1454. return value;
  1455. }
  1456. inline bool Rabbitmq_channel_queue_consume::has_consume_name() const {
  1457. return _internal_has_consume_name();
  1458. }
  1459. inline void Rabbitmq_channel_queue_consume::clear_consume_name() {
  1460. consume_name_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1461. _has_bits_[0] &= ~0x00000010u;
  1462. }
  1463. inline const std::string& Rabbitmq_channel_queue_consume::consume_name() const {
  1464. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1465. return _internal_consume_name();
  1466. }
  1467. inline void Rabbitmq_channel_queue_consume::set_consume_name(const std::string& value) {
  1468. _internal_set_consume_name(value);
  1469. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1470. }
  1471. inline std::string* Rabbitmq_channel_queue_consume::mutable_consume_name() {
  1472. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1473. return _internal_mutable_consume_name();
  1474. }
  1475. inline const std::string& Rabbitmq_channel_queue_consume::_internal_consume_name() const {
  1476. return consume_name_.Get();
  1477. }
  1478. inline void Rabbitmq_channel_queue_consume::_internal_set_consume_name(const std::string& value) {
  1479. _has_bits_[0] |= 0x00000010u;
  1480. consume_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value, GetArena());
  1481. }
  1482. inline void Rabbitmq_channel_queue_consume::set_consume_name(std::string&& value) {
  1483. _has_bits_[0] |= 0x00000010u;
  1484. consume_name_.Set(
  1485. &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value), GetArena());
  1486. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1487. }
  1488. inline void Rabbitmq_channel_queue_consume::set_consume_name(const char* value) {
  1489. GOOGLE_DCHECK(value != nullptr);
  1490. _has_bits_[0] |= 0x00000010u;
  1491. consume_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value),
  1492. GetArena());
  1493. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1494. }
  1495. inline void Rabbitmq_channel_queue_consume::set_consume_name(const char* value,
  1496. size_t size) {
  1497. _has_bits_[0] |= 0x00000010u;
  1498. consume_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(
  1499. reinterpret_cast<const char*>(value), size), GetArena());
  1500. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1501. }
  1502. inline std::string* Rabbitmq_channel_queue_consume::_internal_mutable_consume_name() {
  1503. _has_bits_[0] |= 0x00000010u;
  1504. return consume_name_.Mutable(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1505. }
  1506. inline std::string* Rabbitmq_channel_queue_consume::release_consume_name() {
  1507. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1508. if (!_internal_has_consume_name()) {
  1509. return nullptr;
  1510. }
  1511. _has_bits_[0] &= ~0x00000010u;
  1512. return consume_name_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1513. }
  1514. inline void Rabbitmq_channel_queue_consume::set_allocated_consume_name(std::string* consume_name) {
  1515. if (consume_name != nullptr) {
  1516. _has_bits_[0] |= 0x00000010u;
  1517. } else {
  1518. _has_bits_[0] &= ~0x00000010u;
  1519. }
  1520. consume_name_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), consume_name,
  1521. GetArena());
  1522. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1523. }
  1524. inline std::string* Rabbitmq_channel_queue_consume::unsafe_arena_release_consume_name() {
  1525. // @@protoc_insertion_point(field_unsafe_arena_release:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1526. GOOGLE_DCHECK(GetArena() != nullptr);
  1527. _has_bits_[0] &= ~0x00000010u;
  1528. return consume_name_.UnsafeArenaRelease(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1529. GetArena());
  1530. }
  1531. inline void Rabbitmq_channel_queue_consume::unsafe_arena_set_allocated_consume_name(
  1532. std::string* consume_name) {
  1533. GOOGLE_DCHECK(GetArena() != nullptr);
  1534. if (consume_name != nullptr) {
  1535. _has_bits_[0] |= 0x00000010u;
  1536. } else {
  1537. _has_bits_[0] &= ~0x00000010u;
  1538. }
  1539. consume_name_.UnsafeArenaSetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1540. consume_name, GetArena());
  1541. // @@protoc_insertion_point(field_unsafe_arena_set_allocated:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_name)
  1542. }
  1543. // optional int32 consume_no_local = 13 [default = 0];
  1544. inline bool Rabbitmq_channel_queue_consume::_internal_has_consume_no_local() const {
  1545. bool value = (_has_bits_[0] & 0x00001000u) != 0;
  1546. return value;
  1547. }
  1548. inline bool Rabbitmq_channel_queue_consume::has_consume_no_local() const {
  1549. return _internal_has_consume_no_local();
  1550. }
  1551. inline void Rabbitmq_channel_queue_consume::clear_consume_no_local() {
  1552. consume_no_local_ = 0;
  1553. _has_bits_[0] &= ~0x00001000u;
  1554. }
  1555. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::_internal_consume_no_local() const {
  1556. return consume_no_local_;
  1557. }
  1558. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::consume_no_local() const {
  1559. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_no_local)
  1560. return _internal_consume_no_local();
  1561. }
  1562. inline void Rabbitmq_channel_queue_consume::_internal_set_consume_no_local(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1563. _has_bits_[0] |= 0x00001000u;
  1564. consume_no_local_ = value;
  1565. }
  1566. inline void Rabbitmq_channel_queue_consume::set_consume_no_local(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1567. _internal_set_consume_no_local(value);
  1568. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_no_local)
  1569. }
  1570. // optional int32 consume_no_ack = 14 [default = 0];
  1571. inline bool Rabbitmq_channel_queue_consume::_internal_has_consume_no_ack() const {
  1572. bool value = (_has_bits_[0] & 0x00002000u) != 0;
  1573. return value;
  1574. }
  1575. inline bool Rabbitmq_channel_queue_consume::has_consume_no_ack() const {
  1576. return _internal_has_consume_no_ack();
  1577. }
  1578. inline void Rabbitmq_channel_queue_consume::clear_consume_no_ack() {
  1579. consume_no_ack_ = 0;
  1580. _has_bits_[0] &= ~0x00002000u;
  1581. }
  1582. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::_internal_consume_no_ack() const {
  1583. return consume_no_ack_;
  1584. }
  1585. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::consume_no_ack() const {
  1586. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_no_ack)
  1587. return _internal_consume_no_ack();
  1588. }
  1589. inline void Rabbitmq_channel_queue_consume::_internal_set_consume_no_ack(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1590. _has_bits_[0] |= 0x00002000u;
  1591. consume_no_ack_ = value;
  1592. }
  1593. inline void Rabbitmq_channel_queue_consume::set_consume_no_ack(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1594. _internal_set_consume_no_ack(value);
  1595. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_no_ack)
  1596. }
  1597. // optional int32 consume_exclusive = 15;
  1598. inline bool Rabbitmq_channel_queue_consume::_internal_has_consume_exclusive() const {
  1599. bool value = (_has_bits_[0] & 0x00004000u) != 0;
  1600. return value;
  1601. }
  1602. inline bool Rabbitmq_channel_queue_consume::has_consume_exclusive() const {
  1603. return _internal_has_consume_exclusive();
  1604. }
  1605. inline void Rabbitmq_channel_queue_consume::clear_consume_exclusive() {
  1606. consume_exclusive_ = 0;
  1607. _has_bits_[0] &= ~0x00004000u;
  1608. }
  1609. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::_internal_consume_exclusive() const {
  1610. return consume_exclusive_;
  1611. }
  1612. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_channel_queue_consume::consume_exclusive() const {
  1613. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_exclusive)
  1614. return _internal_consume_exclusive();
  1615. }
  1616. inline void Rabbitmq_channel_queue_consume::_internal_set_consume_exclusive(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1617. _has_bits_[0] |= 0x00004000u;
  1618. consume_exclusive_ = value;
  1619. }
  1620. inline void Rabbitmq_channel_queue_consume::set_consume_exclusive(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1621. _internal_set_consume_exclusive(value);
  1622. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_channel_queue_consume.consume_exclusive)
  1623. }
  1624. // -------------------------------------------------------------------
  1625. // Rabbitmq_parameter
  1626. // optional string ip = 1;
  1627. inline bool Rabbitmq_parameter::_internal_has_ip() const {
  1628. bool value = (_has_bits_[0] & 0x00000001u) != 0;
  1629. return value;
  1630. }
  1631. inline bool Rabbitmq_parameter::has_ip() const {
  1632. return _internal_has_ip();
  1633. }
  1634. inline void Rabbitmq_parameter::clear_ip() {
  1635. ip_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1636. _has_bits_[0] &= ~0x00000001u;
  1637. }
  1638. inline const std::string& Rabbitmq_parameter::ip() const {
  1639. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1640. return _internal_ip();
  1641. }
  1642. inline void Rabbitmq_parameter::set_ip(const std::string& value) {
  1643. _internal_set_ip(value);
  1644. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1645. }
  1646. inline std::string* Rabbitmq_parameter::mutable_ip() {
  1647. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1648. return _internal_mutable_ip();
  1649. }
  1650. inline const std::string& Rabbitmq_parameter::_internal_ip() const {
  1651. return ip_.Get();
  1652. }
  1653. inline void Rabbitmq_parameter::_internal_set_ip(const std::string& value) {
  1654. _has_bits_[0] |= 0x00000001u;
  1655. ip_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value, GetArena());
  1656. }
  1657. inline void Rabbitmq_parameter::set_ip(std::string&& value) {
  1658. _has_bits_[0] |= 0x00000001u;
  1659. ip_.Set(
  1660. &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value), GetArena());
  1661. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1662. }
  1663. inline void Rabbitmq_parameter::set_ip(const char* value) {
  1664. GOOGLE_DCHECK(value != nullptr);
  1665. _has_bits_[0] |= 0x00000001u;
  1666. ip_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value),
  1667. GetArena());
  1668. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1669. }
  1670. inline void Rabbitmq_parameter::set_ip(const char* value,
  1671. size_t size) {
  1672. _has_bits_[0] |= 0x00000001u;
  1673. ip_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(
  1674. reinterpret_cast<const char*>(value), size), GetArena());
  1675. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1676. }
  1677. inline std::string* Rabbitmq_parameter::_internal_mutable_ip() {
  1678. _has_bits_[0] |= 0x00000001u;
  1679. return ip_.Mutable(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1680. }
  1681. inline std::string* Rabbitmq_parameter::release_ip() {
  1682. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1683. if (!_internal_has_ip()) {
  1684. return nullptr;
  1685. }
  1686. _has_bits_[0] &= ~0x00000001u;
  1687. return ip_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1688. }
  1689. inline void Rabbitmq_parameter::set_allocated_ip(std::string* ip) {
  1690. if (ip != nullptr) {
  1691. _has_bits_[0] |= 0x00000001u;
  1692. } else {
  1693. _has_bits_[0] &= ~0x00000001u;
  1694. }
  1695. ip_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ip,
  1696. GetArena());
  1697. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1698. }
  1699. inline std::string* Rabbitmq_parameter::unsafe_arena_release_ip() {
  1700. // @@protoc_insertion_point(field_unsafe_arena_release:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1701. GOOGLE_DCHECK(GetArena() != nullptr);
  1702. _has_bits_[0] &= ~0x00000001u;
  1703. return ip_.UnsafeArenaRelease(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1704. GetArena());
  1705. }
  1706. inline void Rabbitmq_parameter::unsafe_arena_set_allocated_ip(
  1707. std::string* ip) {
  1708. GOOGLE_DCHECK(GetArena() != nullptr);
  1709. if (ip != nullptr) {
  1710. _has_bits_[0] |= 0x00000001u;
  1711. } else {
  1712. _has_bits_[0] &= ~0x00000001u;
  1713. }
  1714. ip_.UnsafeArenaSetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1715. ip, GetArena());
  1716. // @@protoc_insertion_point(field_unsafe_arena_set_allocated:Rabbitmq_proto.Rabbitmq_parameter.ip)
  1717. }
  1718. // optional int32 port = 2;
  1719. inline bool Rabbitmq_parameter::_internal_has_port() const {
  1720. bool value = (_has_bits_[0] & 0x00000008u) != 0;
  1721. return value;
  1722. }
  1723. inline bool Rabbitmq_parameter::has_port() const {
  1724. return _internal_has_port();
  1725. }
  1726. inline void Rabbitmq_parameter::clear_port() {
  1727. port_ = 0;
  1728. _has_bits_[0] &= ~0x00000008u;
  1729. }
  1730. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_parameter::_internal_port() const {
  1731. return port_;
  1732. }
  1733. inline ::PROTOBUF_NAMESPACE_ID::int32 Rabbitmq_parameter::port() const {
  1734. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter.port)
  1735. return _internal_port();
  1736. }
  1737. inline void Rabbitmq_parameter::_internal_set_port(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1738. _has_bits_[0] |= 0x00000008u;
  1739. port_ = value;
  1740. }
  1741. inline void Rabbitmq_parameter::set_port(::PROTOBUF_NAMESPACE_ID::int32 value) {
  1742. _internal_set_port(value);
  1743. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_parameter.port)
  1744. }
  1745. // optional string user = 3;
  1746. inline bool Rabbitmq_parameter::_internal_has_user() const {
  1747. bool value = (_has_bits_[0] & 0x00000002u) != 0;
  1748. return value;
  1749. }
  1750. inline bool Rabbitmq_parameter::has_user() const {
  1751. return _internal_has_user();
  1752. }
  1753. inline void Rabbitmq_parameter::clear_user() {
  1754. user_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1755. _has_bits_[0] &= ~0x00000002u;
  1756. }
  1757. inline const std::string& Rabbitmq_parameter::user() const {
  1758. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter.user)
  1759. return _internal_user();
  1760. }
  1761. inline void Rabbitmq_parameter::set_user(const std::string& value) {
  1762. _internal_set_user(value);
  1763. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_parameter.user)
  1764. }
  1765. inline std::string* Rabbitmq_parameter::mutable_user() {
  1766. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_parameter.user)
  1767. return _internal_mutable_user();
  1768. }
  1769. inline const std::string& Rabbitmq_parameter::_internal_user() const {
  1770. return user_.Get();
  1771. }
  1772. inline void Rabbitmq_parameter::_internal_set_user(const std::string& value) {
  1773. _has_bits_[0] |= 0x00000002u;
  1774. user_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value, GetArena());
  1775. }
  1776. inline void Rabbitmq_parameter::set_user(std::string&& value) {
  1777. _has_bits_[0] |= 0x00000002u;
  1778. user_.Set(
  1779. &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value), GetArena());
  1780. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_parameter.user)
  1781. }
  1782. inline void Rabbitmq_parameter::set_user(const char* value) {
  1783. GOOGLE_DCHECK(value != nullptr);
  1784. _has_bits_[0] |= 0x00000002u;
  1785. user_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value),
  1786. GetArena());
  1787. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_parameter.user)
  1788. }
  1789. inline void Rabbitmq_parameter::set_user(const char* value,
  1790. size_t size) {
  1791. _has_bits_[0] |= 0x00000002u;
  1792. user_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(
  1793. reinterpret_cast<const char*>(value), size), GetArena());
  1794. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_parameter.user)
  1795. }
  1796. inline std::string* Rabbitmq_parameter::_internal_mutable_user() {
  1797. _has_bits_[0] |= 0x00000002u;
  1798. return user_.Mutable(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1799. }
  1800. inline std::string* Rabbitmq_parameter::release_user() {
  1801. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_parameter.user)
  1802. if (!_internal_has_user()) {
  1803. return nullptr;
  1804. }
  1805. _has_bits_[0] &= ~0x00000002u;
  1806. return user_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1807. }
  1808. inline void Rabbitmq_parameter::set_allocated_user(std::string* user) {
  1809. if (user != nullptr) {
  1810. _has_bits_[0] |= 0x00000002u;
  1811. } else {
  1812. _has_bits_[0] &= ~0x00000002u;
  1813. }
  1814. user_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), user,
  1815. GetArena());
  1816. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_parameter.user)
  1817. }
  1818. inline std::string* Rabbitmq_parameter::unsafe_arena_release_user() {
  1819. // @@protoc_insertion_point(field_unsafe_arena_release:Rabbitmq_proto.Rabbitmq_parameter.user)
  1820. GOOGLE_DCHECK(GetArena() != nullptr);
  1821. _has_bits_[0] &= ~0x00000002u;
  1822. return user_.UnsafeArenaRelease(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1823. GetArena());
  1824. }
  1825. inline void Rabbitmq_parameter::unsafe_arena_set_allocated_user(
  1826. std::string* user) {
  1827. GOOGLE_DCHECK(GetArena() != nullptr);
  1828. if (user != nullptr) {
  1829. _has_bits_[0] |= 0x00000002u;
  1830. } else {
  1831. _has_bits_[0] &= ~0x00000002u;
  1832. }
  1833. user_.UnsafeArenaSetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1834. user, GetArena());
  1835. // @@protoc_insertion_point(field_unsafe_arena_set_allocated:Rabbitmq_proto.Rabbitmq_parameter.user)
  1836. }
  1837. // optional string password = 4;
  1838. inline bool Rabbitmq_parameter::_internal_has_password() const {
  1839. bool value = (_has_bits_[0] & 0x00000004u) != 0;
  1840. return value;
  1841. }
  1842. inline bool Rabbitmq_parameter::has_password() const {
  1843. return _internal_has_password();
  1844. }
  1845. inline void Rabbitmq_parameter::clear_password() {
  1846. password_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1847. _has_bits_[0] &= ~0x00000004u;
  1848. }
  1849. inline const std::string& Rabbitmq_parameter::password() const {
  1850. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter.password)
  1851. return _internal_password();
  1852. }
  1853. inline void Rabbitmq_parameter::set_password(const std::string& value) {
  1854. _internal_set_password(value);
  1855. // @@protoc_insertion_point(field_set:Rabbitmq_proto.Rabbitmq_parameter.password)
  1856. }
  1857. inline std::string* Rabbitmq_parameter::mutable_password() {
  1858. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_parameter.password)
  1859. return _internal_mutable_password();
  1860. }
  1861. inline const std::string& Rabbitmq_parameter::_internal_password() const {
  1862. return password_.Get();
  1863. }
  1864. inline void Rabbitmq_parameter::_internal_set_password(const std::string& value) {
  1865. _has_bits_[0] |= 0x00000004u;
  1866. password_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value, GetArena());
  1867. }
  1868. inline void Rabbitmq_parameter::set_password(std::string&& value) {
  1869. _has_bits_[0] |= 0x00000004u;
  1870. password_.Set(
  1871. &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value), GetArena());
  1872. // @@protoc_insertion_point(field_set_rvalue:Rabbitmq_proto.Rabbitmq_parameter.password)
  1873. }
  1874. inline void Rabbitmq_parameter::set_password(const char* value) {
  1875. GOOGLE_DCHECK(value != nullptr);
  1876. _has_bits_[0] |= 0x00000004u;
  1877. password_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value),
  1878. GetArena());
  1879. // @@protoc_insertion_point(field_set_char:Rabbitmq_proto.Rabbitmq_parameter.password)
  1880. }
  1881. inline void Rabbitmq_parameter::set_password(const char* value,
  1882. size_t size) {
  1883. _has_bits_[0] |= 0x00000004u;
  1884. password_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(
  1885. reinterpret_cast<const char*>(value), size), GetArena());
  1886. // @@protoc_insertion_point(field_set_pointer:Rabbitmq_proto.Rabbitmq_parameter.password)
  1887. }
  1888. inline std::string* Rabbitmq_parameter::_internal_mutable_password() {
  1889. _has_bits_[0] |= 0x00000004u;
  1890. return password_.Mutable(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1891. }
  1892. inline std::string* Rabbitmq_parameter::release_password() {
  1893. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_parameter.password)
  1894. if (!_internal_has_password()) {
  1895. return nullptr;
  1896. }
  1897. _has_bits_[0] &= ~0x00000004u;
  1898. return password_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
  1899. }
  1900. inline void Rabbitmq_parameter::set_allocated_password(std::string* password) {
  1901. if (password != nullptr) {
  1902. _has_bits_[0] |= 0x00000004u;
  1903. } else {
  1904. _has_bits_[0] &= ~0x00000004u;
  1905. }
  1906. password_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), password,
  1907. GetArena());
  1908. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_parameter.password)
  1909. }
  1910. inline std::string* Rabbitmq_parameter::unsafe_arena_release_password() {
  1911. // @@protoc_insertion_point(field_unsafe_arena_release:Rabbitmq_proto.Rabbitmq_parameter.password)
  1912. GOOGLE_DCHECK(GetArena() != nullptr);
  1913. _has_bits_[0] &= ~0x00000004u;
  1914. return password_.UnsafeArenaRelease(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1915. GetArena());
  1916. }
  1917. inline void Rabbitmq_parameter::unsafe_arena_set_allocated_password(
  1918. std::string* password) {
  1919. GOOGLE_DCHECK(GetArena() != nullptr);
  1920. if (password != nullptr) {
  1921. _has_bits_[0] |= 0x00000004u;
  1922. } else {
  1923. _has_bits_[0] &= ~0x00000004u;
  1924. }
  1925. password_.UnsafeArenaSetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
  1926. password, GetArena());
  1927. // @@protoc_insertion_point(field_unsafe_arena_set_allocated:Rabbitmq_proto.Rabbitmq_parameter.password)
  1928. }
  1929. // repeated .Rabbitmq_proto.Rabbitmq_channel_queue_consume rabbitmq_reciever_vector = 5;
  1930. inline int Rabbitmq_parameter::_internal_rabbitmq_reciever_vector_size() const {
  1931. return rabbitmq_reciever_vector_.size();
  1932. }
  1933. inline int Rabbitmq_parameter::rabbitmq_reciever_vector_size() const {
  1934. return _internal_rabbitmq_reciever_vector_size();
  1935. }
  1936. inline void Rabbitmq_parameter::clear_rabbitmq_reciever_vector() {
  1937. rabbitmq_reciever_vector_.Clear();
  1938. }
  1939. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::mutable_rabbitmq_reciever_vector(int index) {
  1940. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_reciever_vector)
  1941. return rabbitmq_reciever_vector_.Mutable(index);
  1942. }
  1943. inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >*
  1944. Rabbitmq_parameter::mutable_rabbitmq_reciever_vector() {
  1945. // @@protoc_insertion_point(field_mutable_list:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_reciever_vector)
  1946. return &rabbitmq_reciever_vector_;
  1947. }
  1948. inline const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& Rabbitmq_parameter::_internal_rabbitmq_reciever_vector(int index) const {
  1949. return rabbitmq_reciever_vector_.Get(index);
  1950. }
  1951. inline const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& Rabbitmq_parameter::rabbitmq_reciever_vector(int index) const {
  1952. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_reciever_vector)
  1953. return _internal_rabbitmq_reciever_vector(index);
  1954. }
  1955. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::_internal_add_rabbitmq_reciever_vector() {
  1956. return rabbitmq_reciever_vector_.Add();
  1957. }
  1958. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::add_rabbitmq_reciever_vector() {
  1959. // @@protoc_insertion_point(field_add:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_reciever_vector)
  1960. return _internal_add_rabbitmq_reciever_vector();
  1961. }
  1962. inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >&
  1963. Rabbitmq_parameter::rabbitmq_reciever_vector() const {
  1964. // @@protoc_insertion_point(field_list:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_reciever_vector)
  1965. return rabbitmq_reciever_vector_;
  1966. }
  1967. // repeated .Rabbitmq_proto.Rabbitmq_channel_queue_consume rabbitmq_sender_request_vector = 6;
  1968. inline int Rabbitmq_parameter::_internal_rabbitmq_sender_request_vector_size() const {
  1969. return rabbitmq_sender_request_vector_.size();
  1970. }
  1971. inline int Rabbitmq_parameter::rabbitmq_sender_request_vector_size() const {
  1972. return _internal_rabbitmq_sender_request_vector_size();
  1973. }
  1974. inline void Rabbitmq_parameter::clear_rabbitmq_sender_request_vector() {
  1975. rabbitmq_sender_request_vector_.Clear();
  1976. }
  1977. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::mutable_rabbitmq_sender_request_vector(int index) {
  1978. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_request_vector)
  1979. return rabbitmq_sender_request_vector_.Mutable(index);
  1980. }
  1981. inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >*
  1982. Rabbitmq_parameter::mutable_rabbitmq_sender_request_vector() {
  1983. // @@protoc_insertion_point(field_mutable_list:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_request_vector)
  1984. return &rabbitmq_sender_request_vector_;
  1985. }
  1986. inline const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& Rabbitmq_parameter::_internal_rabbitmq_sender_request_vector(int index) const {
  1987. return rabbitmq_sender_request_vector_.Get(index);
  1988. }
  1989. inline const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& Rabbitmq_parameter::rabbitmq_sender_request_vector(int index) const {
  1990. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_request_vector)
  1991. return _internal_rabbitmq_sender_request_vector(index);
  1992. }
  1993. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::_internal_add_rabbitmq_sender_request_vector() {
  1994. return rabbitmq_sender_request_vector_.Add();
  1995. }
  1996. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::add_rabbitmq_sender_request_vector() {
  1997. // @@protoc_insertion_point(field_add:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_request_vector)
  1998. return _internal_add_rabbitmq_sender_request_vector();
  1999. }
  2000. inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >&
  2001. Rabbitmq_parameter::rabbitmq_sender_request_vector() const {
  2002. // @@protoc_insertion_point(field_list:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_request_vector)
  2003. return rabbitmq_sender_request_vector_;
  2004. }
  2005. // repeated .Rabbitmq_proto.Rabbitmq_channel_queue_consume rabbitmq_sender_status_vector = 7;
  2006. inline int Rabbitmq_parameter::_internal_rabbitmq_sender_status_vector_size() const {
  2007. return rabbitmq_sender_status_vector_.size();
  2008. }
  2009. inline int Rabbitmq_parameter::rabbitmq_sender_status_vector_size() const {
  2010. return _internal_rabbitmq_sender_status_vector_size();
  2011. }
  2012. inline void Rabbitmq_parameter::clear_rabbitmq_sender_status_vector() {
  2013. rabbitmq_sender_status_vector_.Clear();
  2014. }
  2015. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::mutable_rabbitmq_sender_status_vector(int index) {
  2016. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_status_vector)
  2017. return rabbitmq_sender_status_vector_.Mutable(index);
  2018. }
  2019. inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >*
  2020. Rabbitmq_parameter::mutable_rabbitmq_sender_status_vector() {
  2021. // @@protoc_insertion_point(field_mutable_list:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_status_vector)
  2022. return &rabbitmq_sender_status_vector_;
  2023. }
  2024. inline const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& Rabbitmq_parameter::_internal_rabbitmq_sender_status_vector(int index) const {
  2025. return rabbitmq_sender_status_vector_.Get(index);
  2026. }
  2027. inline const ::Rabbitmq_proto::Rabbitmq_channel_queue_consume& Rabbitmq_parameter::rabbitmq_sender_status_vector(int index) const {
  2028. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_status_vector)
  2029. return _internal_rabbitmq_sender_status_vector(index);
  2030. }
  2031. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::_internal_add_rabbitmq_sender_status_vector() {
  2032. return rabbitmq_sender_status_vector_.Add();
  2033. }
  2034. inline ::Rabbitmq_proto::Rabbitmq_channel_queue_consume* Rabbitmq_parameter::add_rabbitmq_sender_status_vector() {
  2035. // @@protoc_insertion_point(field_add:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_status_vector)
  2036. return _internal_add_rabbitmq_sender_status_vector();
  2037. }
  2038. inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::Rabbitmq_proto::Rabbitmq_channel_queue_consume >&
  2039. Rabbitmq_parameter::rabbitmq_sender_status_vector() const {
  2040. // @@protoc_insertion_point(field_list:Rabbitmq_proto.Rabbitmq_parameter.rabbitmq_sender_status_vector)
  2041. return rabbitmq_sender_status_vector_;
  2042. }
  2043. // -------------------------------------------------------------------
  2044. // Rabbitmq_parameter_all
  2045. // optional .Rabbitmq_proto.Rabbitmq_parameter rabbitmq_parameters = 1;
  2046. inline bool Rabbitmq_parameter_all::_internal_has_rabbitmq_parameters() const {
  2047. bool value = (_has_bits_[0] & 0x00000001u) != 0;
  2048. PROTOBUF_ASSUME(!value || rabbitmq_parameters_ != nullptr);
  2049. return value;
  2050. }
  2051. inline bool Rabbitmq_parameter_all::has_rabbitmq_parameters() const {
  2052. return _internal_has_rabbitmq_parameters();
  2053. }
  2054. inline void Rabbitmq_parameter_all::clear_rabbitmq_parameters() {
  2055. if (rabbitmq_parameters_ != nullptr) rabbitmq_parameters_->Clear();
  2056. _has_bits_[0] &= ~0x00000001u;
  2057. }
  2058. inline const ::Rabbitmq_proto::Rabbitmq_parameter& Rabbitmq_parameter_all::_internal_rabbitmq_parameters() const {
  2059. const ::Rabbitmq_proto::Rabbitmq_parameter* p = rabbitmq_parameters_;
  2060. return p != nullptr ? *p : *reinterpret_cast<const ::Rabbitmq_proto::Rabbitmq_parameter*>(
  2061. &::Rabbitmq_proto::_Rabbitmq_parameter_default_instance_);
  2062. }
  2063. inline const ::Rabbitmq_proto::Rabbitmq_parameter& Rabbitmq_parameter_all::rabbitmq_parameters() const {
  2064. // @@protoc_insertion_point(field_get:Rabbitmq_proto.Rabbitmq_parameter_all.rabbitmq_parameters)
  2065. return _internal_rabbitmq_parameters();
  2066. }
  2067. inline void Rabbitmq_parameter_all::unsafe_arena_set_allocated_rabbitmq_parameters(
  2068. ::Rabbitmq_proto::Rabbitmq_parameter* rabbitmq_parameters) {
  2069. if (GetArena() == nullptr) {
  2070. delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(rabbitmq_parameters_);
  2071. }
  2072. rabbitmq_parameters_ = rabbitmq_parameters;
  2073. if (rabbitmq_parameters) {
  2074. _has_bits_[0] |= 0x00000001u;
  2075. } else {
  2076. _has_bits_[0] &= ~0x00000001u;
  2077. }
  2078. // @@protoc_insertion_point(field_unsafe_arena_set_allocated:Rabbitmq_proto.Rabbitmq_parameter_all.rabbitmq_parameters)
  2079. }
  2080. inline ::Rabbitmq_proto::Rabbitmq_parameter* Rabbitmq_parameter_all::release_rabbitmq_parameters() {
  2081. auto temp = unsafe_arena_release_rabbitmq_parameters();
  2082. if (GetArena() != nullptr) {
  2083. temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
  2084. }
  2085. return temp;
  2086. }
  2087. inline ::Rabbitmq_proto::Rabbitmq_parameter* Rabbitmq_parameter_all::unsafe_arena_release_rabbitmq_parameters() {
  2088. // @@protoc_insertion_point(field_release:Rabbitmq_proto.Rabbitmq_parameter_all.rabbitmq_parameters)
  2089. _has_bits_[0] &= ~0x00000001u;
  2090. ::Rabbitmq_proto::Rabbitmq_parameter* temp = rabbitmq_parameters_;
  2091. rabbitmq_parameters_ = nullptr;
  2092. return temp;
  2093. }
  2094. inline ::Rabbitmq_proto::Rabbitmq_parameter* Rabbitmq_parameter_all::_internal_mutable_rabbitmq_parameters() {
  2095. _has_bits_[0] |= 0x00000001u;
  2096. if (rabbitmq_parameters_ == nullptr) {
  2097. auto* p = CreateMaybeMessage<::Rabbitmq_proto::Rabbitmq_parameter>(GetArena());
  2098. rabbitmq_parameters_ = p;
  2099. }
  2100. return rabbitmq_parameters_;
  2101. }
  2102. inline ::Rabbitmq_proto::Rabbitmq_parameter* Rabbitmq_parameter_all::mutable_rabbitmq_parameters() {
  2103. // @@protoc_insertion_point(field_mutable:Rabbitmq_proto.Rabbitmq_parameter_all.rabbitmq_parameters)
  2104. return _internal_mutable_rabbitmq_parameters();
  2105. }
  2106. inline void Rabbitmq_parameter_all::set_allocated_rabbitmq_parameters(::Rabbitmq_proto::Rabbitmq_parameter* rabbitmq_parameters) {
  2107. ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArena();
  2108. if (message_arena == nullptr) {
  2109. delete rabbitmq_parameters_;
  2110. }
  2111. if (rabbitmq_parameters) {
  2112. ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
  2113. ::PROTOBUF_NAMESPACE_ID::Arena::GetArena(rabbitmq_parameters);
  2114. if (message_arena != submessage_arena) {
  2115. rabbitmq_parameters = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
  2116. message_arena, rabbitmq_parameters, submessage_arena);
  2117. }
  2118. _has_bits_[0] |= 0x00000001u;
  2119. } else {
  2120. _has_bits_[0] &= ~0x00000001u;
  2121. }
  2122. rabbitmq_parameters_ = rabbitmq_parameters;
  2123. // @@protoc_insertion_point(field_set_allocated:Rabbitmq_proto.Rabbitmq_parameter_all.rabbitmq_parameters)
  2124. }
  2125. #ifdef __GNUC__
  2126. #pragma GCC diagnostic pop
  2127. #endif // __GNUC__
  2128. // -------------------------------------------------------------------
  2129. // -------------------------------------------------------------------
  2130. // @@protoc_insertion_point(namespace_scope)
  2131. } // namespace Rabbitmq_proto
  2132. // @@protoc_insertion_point(global_scope)
  2133. #include <google/protobuf/port_undef.inc>
  2134. #endif // GOOGLE_PROTOBUF_INCLUDED_GOOGLE_PROTOBUF_INCLUDED_rabbitmq_2eproto