package spec.proto.extension.v1.delay_queue

Get desktop application:
View/edit binary Protocol Buffers messages

DelayQueue is a special kind of message queue, which lets you postpone the delivery of new messages to consumers. For example, you can invoke this API and tell the message queue "please send this message to the consumers after 5 minutes".

• rpc PublishDelayMessage (DelayMessageRequest, DelayMessageResponse)

  delay_queue.proto:14

  Publish a delay message

  message DelayMessageRequest

  delay_queue.proto:19

  DelayMessageRequest is the message to publish

  • string component_name = 1

    Required. The name of the DelayQueue component

  • string topic = 2

    Required. The pubsub topic

  • bytes data = 3

    Required. The data which will be published to topic.

  • string data_content_type = 4

    The content type for the data (optional).

  • int32 delay_in_seconds = 5

    The length of time, in seconds, for which the delivery of this messages is delayed. Default: 0.

  • map<string, string> metadata = 6

    The metadata passing to pub components metadata property: - key : the key of the message.

  message DelayMessageResponse

  delay_queue.proto:45

  DelayMessageResponse is the response

  • string message_id = 1

    The message identifier