php/grpc/GPBMetadata/Apache/Rocketmq/V2/Service.php

<?php
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: apache/rocketmq/v2/service.proto

namespace GPBMetadata\Apache\Rocketmq\V2;

class Service
{
    public static $is_initialized = false;

    public static function initOnce() {
        $pool = \Google\Protobuf\Internal\DescriptorPool::getGeneratedPool();

        if (static::$is_initialized == true) {
          return;
        }
        \GPBMetadata\Google\Protobuf\Duration::initOnce();
        \GPBMetadata\Google\Protobuf\Timestamp::initOnce();
        \GPBMetadata\Apache\Rocketmq\V2\Definition::initOnce();
        $pool->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;
    }
}