MCPcopy
hub / github.com/nats-io/nats.go / PublishMsgAsync

Method PublishMsgAsync

js.go:53–53  ·  view source on GitHub ↗

PublishMsgAsync publishes a Msg to JetStream and returns a PubAckFuture. The message should not be changed until the PubAckFuture has been processed.

(m *Msg, opts ...PubOpt)

Source from the content-addressed store, hash-verified

51 // PublishMsgAsync publishes a Msg to JetStream and returns a PubAckFuture.
52 // The message should not be changed until the PubAckFuture has been processed.
53 PublishMsgAsync(m *Msg, opts ...PubOpt) (PubAckFuture, error)
54
55 // PublishAsyncPending returns the number of async publishes outstanding for this context.
56 PublishAsyncPending() int

Callers 4

PutMethod · 0.65

Calls

no outgoing calls