internalAddGeneratedFile( ' �3 apache/rocketmq/v2/service.protoapache.rocketmq.v2google/protobuf/timestamp.proto#apache/rocketmq/v2/definition.proto"r QueryRouteRequest+ topic

(2.apache.rocketmq.v2.Resource0 endpoints
(2.apache.rocketmq.v2.Endpoints"z QueryRouteResponse* status

(2.apache.rocketmq.v2.Status8 message_queues (2 .apache.rocketmq.v2.MessageQueue"C SendMessageRequest- messages
(2.apache.rocketmq.v2.Message"y SendResultEntry* status

(2.apache.rocketmq.v2.Status message_id
(  transaction_id
(  offset
("w SendMessageResponse* status

(2.apache.rocketmq.v2.Status4 entries (2#.apache.rocketmq.v2.SendResultEntry"�
QueryAssignmentRequest+ topic

(2.apache.rocketmq.v2.Resource+ group
(2.apache.rocketmq.v2.Resource0 endpoints
(2.apache.rocketmq.v2.Endpoints"z QueryAssignmentResponse* status

(2.apache.rocketmq.v2.Status3 assignments (2.apache.rocketmq.v2.Assignment"� ReceiveMessageRequest+ group

(2.apache.rocketmq.v2.Resource7 message_queue
(2 .apache.rocketmq.v2.MessageQueue? filter_expression
(2$.apache.rocketmq.v2.FilterExpression batch_size
(: invisible_duration
(2.google.protobuf.DurationH�

 auto_renew
(B _invisible_duration"�
ReceiveMessageResponse, status

(2.apache.rocketmq.v2.StatusH. message
(2.apache.rocketmq.v2.MessageH8 delivery_timestamp
(2.google.protobuf.TimestampHB content"= AckMessageEntry message_id

(  receipt_handle
( "�
AckMessageRequest+ group

(2.apache.rocketmq.v2.Resource+ topic
(2.apache.rocketmq.v2.Resource4 entries (2#.apache.rocketmq.v2.AckMessageEntry"o AckMessageResultEntry message_id

(  receipt_handle
( * status
(2.apache.rocketmq.v2.Status"| AckMessageResponse* status

(2.apache.rocketmq.v2.Status: entries (2).apache.rocketmq.v2.AckMessageResultEntry"�
&ForwardMessageToDeadLetterQueueRequest+ group

(2.apache.rocketmq.v2.Resource+ topic
(2.apache.rocketmq.v2.Resource receipt_handle
(  message_id
(  delivery_attempt
( max_delivery_attempts
("U \'ForwardMessageToDeadLetterQueueResponse* status

(2.apache.rocketmq.v2.Status"�
HeartbeatRequest0 group

(2.apache.rocketmq.v2.ResourceH�

3 client_type
(2.apache.rocketmq.v2.ClientTypeB _group"? HeartbeatResponse* status

(2.apache.rocketmq.v2.Status"�
EndTransactionRequest+ topic

(2.apache.rocketmq.v2.Resource message_id
(  transaction_id
( = resolution
(2).apache.rocketmq.v2.TransactionResolution5 source
(2%.apache.rocketmq.v2.TransactionSource trace_context
( "D EndTransactionResponse* status

(2.apache.rocketmq.v2.Status"- PrintThreadStackTraceCommand nonce

( "Y ThreadStackTrace nonce

(  thread_stack_trace
( H�

B _thread_stack_trace"S VerifyMessageCommand nonce

( , message
(2.apache.rocketmq.v2.Message"$ VerifyMessageResult nonce

( "i !RecoverOrphanedTransactionCommand, message

(2.apache.rocketmq.v2.Message transaction_id
( "p Publishing, topics
(2.apache.rocketmq.v2.Resource max_body_size
( validate_message_type
("� Subscription0 group

(2.apache.rocketmq.v2.ResourceH�

< subscriptions (2%.apache.rocketmq.v2.SubscriptionEntry fifo
(H
�

 receive_batch_size
(H�

< long_polling_timeout
(2.google.protobuf.DurationH�

B _groupB _fifoB _receive_batch_sizeB _long_polling_timeout"Y Metric on

(5 endpoints
(2.apache.rocketmq.v2.EndpointsH�

B _endpoints"� Settings8 client_type

(2.apache.rocketmq.v2.ClientTypeH
�

8 access_point
(2.apache.rocketmq.v2.EndpointsH�

< backoff_policy
(2.apache.rocketmq.v2.RetryPolicyH�

7 request_timeout
(2.google.protobuf.DurationH�

4 publishing
(2.apache.rocketmq.v2.PublishingH8 subscription
(2 .apache.rocketmq.v2.SubscriptionH* user_agent
(2.apache.rocketmq.v2.UA* metric
(2.apache.rocketmq.v2.MetricB pub_subB _client_typeB _access_pointB _backoff_policyB _request_timeout"� TelemetryCommand/ status

(2.apache.rocketmq.v2.StatusH
�

0 settings
(2.apache.rocketmq.v2.SettingsHB thread_stack_trace
(2$.apache.rocketmq.v2.ThreadStackTraceHH verify_message_result
(2\'.apache.rocketmq.v2.VerifyMessageResultHe $recover_orphaned_transaction_command
(25.apache.rocketmq.v2.RecoverOrphanedTransactionCommandH\\ print_thread_stack_trace_command
(20.apache.rocketmq.v2.PrintThreadStackTraceCommandHJ verify_message_command
(2(.apache.rocketmq.v2.VerifyMessageCommandHB commandB _status"\\ NotifyClientTerminationRequest0 group

(2.apache.rocketmq.v2.ResourceH�

B _group"M NotifyClientTerminationResponse* status

(2.apache.rocketmq.v2.Status"�
ChangeInvisibleDurationRequest+ group

(2.apache.rocketmq.v2.Resource+ topic
(2.apache.rocketmq.v2.Resource receipt_handle
( 5 invisible_duration
(2.google.protobuf.Duration message_id
( "e ChangeInvisibleDurationResponse* status

(2.apache.rocketmq.v2.Status receipt_handle
( 2� MessagingService] QueryRoute%.apache.rocketmq.v2.QueryRouteRequest&.apache.rocketmq.v2.QueryRouteResponse"Z Heartbeat$.apache.rocketmq.v2.HeartbeatRequest%.apache.rocketmq.v2.HeartbeatResponse"` SendMessage&.apache.rocketmq.v2.SendMessageRequest\'.apache.rocketmq.v2.SendMessageResponse"l QueryAssignment*.apache.rocketmq.v2.QueryAssignmentRequest+.apache.rocketmq.v2.QueryAssignmentResponse"k ReceiveMessage).apache.rocketmq.v2.ReceiveMessageRequest*.apache.rocketmq.v2.ReceiveMessageResponse"0
] AckMessage%.apache.rocketmq.v2.AckMessageRequest&.apache.rocketmq.v2.AckMessageResponse"�
ForwardMessageToDeadLetterQueue:.apache.rocketmq.v2.ForwardMessageToDeadLetterQueueRequest;.apache.rocketmq.v2.ForwardMessageToDeadLetterQueueResponse"i EndTransaction).apache.rocketmq.v2.EndTransactionRequest*.apache.rocketmq.v2.EndTransactionResponse"] Telemetry$.apache.rocketmq.v2.TelemetryCommand$.apache.rocketmq.v2.TelemetryCommand"(
0
�
NotifyClientTermination2.apache.rocketmq.v2.NotifyClientTerminationRequest3.apache.rocketmq.v2.NotifyClientTerminationResponse"�
ChangeInvisibleDuration2.apache.rocketmq.v2.ChangeInvisibleDurationRequest3.apache.rocketmq.v2.ChangeInvisibleDurationResponse"B< apache.rocketmq.v2B MQServiceP
�

�

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