Clients - nats : StreamingProducer

NATS StreamingProducer would act as a client allowing to publish messages to the NATS streaming server. StreamingProducer needs the NATS Connection to be initialized.

Constructor

__init

(Connection connection, string clientId, string clusterId, StreamingConfig? streamingConfig)

  • connection Connection
  • An established NATS connection.

  • clientId string ()
  • A unique identifier representing the client.

  • clusterId string test-cluster
  • The ID of the cluster configured in the NATS server.

  • streamingConfig StreamingConfig? ()
  • The configuration related to the NATS streaming connectivity.

Remote Methods

publish

Publishes data to a given subject.

Methods

publish

(string subject, Content data)

returns string | Error

Publishes data to a given subject.

Parameters

  • subject string
  • The subject to send the message to.

  • Return Type

    (string | Error)
  • string value representing the NUID (NATS Unique Identifier) of the published message, if the message gets successfully published and acknowledged by the NATS server OR nats/Error with NUID and message fields in case an error occurs in publishing, the timeout elapses while waiting for the acknowledgement OR nats/Error only with the message field in case an error occurs even before publishing is completed

close

()

returns error

Close the producer.

  • Return Type

    (error)
  • Returns () or the error if unable to complete the close operation.