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

Method Publish

js.go:42–42  ·  js.go::JetStream.Publish

Publish publishes a message to JetStream.

(subj string, data []byte, opts ...PubOpt)

Source from the content-addressed store, hash-verified

40type JetStream interface {
41 // Publish publishes a message to JetStream.
42 Publish(subj string, data []byte, opts ...PubOpt) (*PubAck, error)
43
44 // PublishMsg publishes a Msg to JetStream.
45 PublishMsg(m *Msg, opts ...PubOpt) (*PubAck, error)

Callers 15

ExampleJetStreamContextFunction · 0.95
ackReplyMethod · 0.65
PutMethod · 0.65
chPublishFunction · 0.65
processNextMsgDeliveredMethod · 0.65
RespondMethod · 0.65
ExampleConn_PublishFunction · 0.65
ExampleConn_RequestFunction · 0.65
ExampleSubscription_AutoUnsubscribeFunction · 0.65
ExampleJetStreamFunction · 0.65
ExampleJSOptFunction · 0.65
ExamplePubOptFunction · 0.65

Calls

no outgoing calls

Tested by 15

ExampleJetStreamContextFunction · 0.76
ExampleConn_PublishFunction · 0.52
ExampleConn_RequestFunction · 0.52
ExampleSubscription_AutoUnsubscribeFunction · 0.52
ExampleJetStreamFunction · 0.52
ExampleJSOptFunction · 0.52
ExamplePubOptFunction · 0.52
ExampleAckWaitFunction · 0.52
ExampleMsg_MetadataFunction · 0.52
ExampleAckOptFunction · 0.52
ExamplePullOptFunction · 0.52
ExampleContextFunction · 0.52