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

Method PublishMsgAsync

jetstream/jetstream.go:101–101  ·  view source on GitHub ↗

PublishMsgAsync performs a publish to a stream and returns [PubAckFuture] interface, not blocking while waiting for an acknowledgement. It accepts subject name (which must be bound to a stream) and nats.Message. PublishMsgAsync does not guarantee that the message has been received by the server. It

(msg *nats.Msg, opts ...PublishOpt)

Source from the content-addressed store, hash-verified

99 // sent to the server and thus messages can be stored in the stream
100 // out of order in case of retries.
101 PublishMsgAsync(msg *nats.Msg, opts ...PublishOpt) (PubAckFuture, error)
102
103 // PublishAsyncPending returns the number of async publishes outstanding
104 // for this context. An outstanding publish is one that has been

Callers 3

PutMethod · 0.65
TestPublishMsgAsyncFunction · 0.65

Implementers 2

jsjs.go
jetStreamjetstream/jetstream.go

Calls

no outgoing calls

Tested by 2

TestPublishMsgAsyncFunction · 0.52