internalAddGeneratedFile( ' �& #apache/rocketmq/v2/definition.protoapache.rocketmq.v2google/protobuf/duration.proto"T FilterExpression, type

(2.apache.rocketmq.v2.FilterType expression
( "�
RetryPolicy max_attempts

(E exponential_backoff
(2&.apache.rocketmq.v2.ExponentialBackoffHC customized_backoff
(2%.apache.rocketmq.v2.CustomizedBackoffHB strategy"| ExponentialBackoff* initial

(2.google.protobuf.Duration& max
(2.google.protobuf.Duration multiplier
("< CustomizedBackoff\' next
(2.google.protobuf.Duration"4 Resource resource_namespace

(  name
( "z SubscriptionEntry+ topic

(2.apache.rocketmq.v2.Resource8 expression
(2$.apache.rocketmq.v2.FilterExpression"% Address host

(  port
("n Endpoints1 scheme

(2!.apache.rocketmq.v2.AddressScheme. addresses (2.apache.rocketmq.v2.Address"T Broker name

(  id
(0 endpoints
(2.apache.rocketmq.v2.Endpoints"�
MessageQueue+ topic

(2.apache.rocketmq.v2.Resource id
(2 permission
(2.apache.rocketmq.v2.Permission* broker
(2.apache.rocketmq.v2.Broker= accept_message_types (2.apache.rocketmq.v2.MessageType"H Digest, type

(2.apache.rocketmq.v2.DigestType checksum
( "� SystemProperties tag

( H�

 keys (  message_id
( / body_digest
(2.apache.rocketmq.v2.Digest3 body_encoding
(2.apache.rocketmq.v2.Encoding5 message_type
(2.apache.rocketmq.v2.MessageType2 born_timestamp
(2.google.protobuf.Timestamp born_host
( 8 store_timestamp
(2.google.protobuf.TimestampH
�

 store_host
( ; delivery_timestamp
(2.google.protobuf.TimestampH�

 receipt_handle
( H�

 queue_id
( queue_offset
(H�

: invisible_duration
(2.google.protobuf.DurationH�

 delivery_attempt
(H�

 message_group
( H�

 trace_context
( H�

N &orphaned_transaction_recovery_duration
(2.google.protobuf.DurationH �

B _tagB _store_timestampB _delivery_timestampB _receipt_handleB _queue_offsetB _invisible_durationB _delivery_attemptB _message_groupB _trace_contextB) \'_orphaned_transaction_recovery_duration"� Message+ topic

(2.apache.rocketmq.v2.ResourceH user_properties (2/.apache.rocketmq.v2.Message.UserPropertiesEntry? system_properties
(2$.apache.rocketmq.v2.SystemProperties body
(5 UserPropertiesEntry key

(  value
( :8
"E Assignment7 message_queue

(2 .apache.rocketmq.v2.MessageQueue"A Status& code

(2.apache.rocketmq.v2.Code message
( "i UA. language

(2.apache.rocketmq.v2.Language version
(  platform
(  hostname
( *Y TransactionResolution& "TRANSACTION_RESOLUTION_UNSPECIFIED COMMIT
 ROLLBACK*W TransactionSource SOURCE_UNSPECIFIED SOURCE_CLIENT
 SOURCE_SERVER_CHECK*W Permission PERMISSION_UNSPECIFIED NONE
 READ WRITE READ_WRITE*; FilterType FILTER_TYPE_UNSPECIFIED TAG
 SQL*T AddressScheme ADDRESS_SCHEME_UNSPECIFIED IPv4
 IPv6 DOMAIN_NAME*] MessageType MESSAGE_TYPE_UNSPECIFIED NORMAL
 FIFO DELAY TRANSACTION*G DigestType DIGEST_TYPE_UNSPECIFIED CRC32
 MD5 SHA1*_ ClientType CLIENT_TYPE_UNSPECIFIED PRODUCER
 PUSH_CONSUMER SIMPLE_CONSUMER*< Encoding ENCODING_UNSPECIFIED IDENTITY
 GZIP*� Code CODE_UNSPECIFIED OK��
 MULTIPLE_RESULTS��
 BAD_REQUEST�� ILLEGAL_ACCESS_POINT�� ILLEGAL_TOPIC¸ ILLEGAL_CONSUMER_GROUPø ILLEGAL_MESSAGE_TAGĸ ILLEGAL_MESSAGE_KEYŸ ILLEGAL_MESSAGE_GROUPƸ" ILLEGAL_MESSAGE_PROPERTY_KEYǸ INVALID_TRANSACTION_IDȸ ILLEGAL_MESSAGE_IDɸ ILLEGAL_FILTER_EXPRESSIONʸ ILLEGAL_INVISIBLE_TIME˸ ILLEGAL_DELIVERY_TIME̸ INVALID_RECEIPT_HANDLE͸) #MESSAGE_PROPERTY_CONFLICT_WITH_TYPEθ UNRECOGNIZED_CLIENT_TYPEϸ MESSAGE_CORRUPTEDи CLIENT_ID_REQUIREDѸ UNAUTHORIZED�� PAYMENT_REQUIRED�� FORBIDDEN� NOT_FOUNDл MESSAGE_NOT_FOUNDѻ TOPIC_NOT_FOUNDһ CONSUMER_GROUP_NOT_FOUNDӻ REQUEST_TIMEOUT� PAYLOAD_TOO_LARGE�� MESSAGE_BODY_TOO_LARGE�� PRECONDITION_FAILED�� TOO_MANY_REQUESTS��% REQUEST_HEADER_FIELDS_TOO_LARGE��" MESSAGE_PROPERTIES_TOO_LARGE�� INTERNAL_ERRORІ INTERNAL_SERVER_ERRORц HA_NOT_AVAILABLE҆ NOT_IMPLEMENTED�� PROXY_TIMEOUT�� MASTER_PERSISTENCE_TIMEOUT� SLAVE_PERSISTENCE_TIMEOUT� UNSUPPORTEDĊ VERSION_UNSUPPORTEDŊ% VERIFY_FIFO_MESSAGE_UNSUPPORTEDƊ FAILED_TO_CONSUME_MESSAGE��*Z Language LANGUAGE_UNSPECIFIED JAVA
 CPP DOT_NET GOLANG RUSTB; apache.rocketmq.v2BMQDomainP
�

�

�Apache.Rocketmq.V2bproto3' , true); static::$is_initialized = true; } }