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

Method PublishMsg

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

PublishMsg publishes a Msg to JetStream.

(m *Msg, opts ...PubOpt)

Source from the content-addressed store, hash-verified

43
44 // PublishMsg publishes a Msg to JetStream.
45 PublishMsg(m *Msg, opts ...PubOpt) (*PubAck, error)
46
47 // PublishAsync publishes a message to JetStream and returns a PubAckFuture.
48 // The data should not be changed until the PubAckFuture has been processed.

Callers 15

UpdateMethod · 0.65
DeleteMethod · 0.65
publishMetaFunction · 0.65
RespondMsgMethod · 0.65
ExampleConn_PublishMsgFunction · 0.65
ExampleConn_FlushFunction · 0.65
ExampleConn_FlushTimeoutFunction · 0.65
TestClosedConnectionsFunction · 0.65
TestBasicHeadersFunction · 0.65
TestRequestMsgFunction · 0.65
TestNoHeaderSupportFunction · 0.65
TestMsgHeadersCasePreservingFunction · 0.65

Calls

no outgoing calls

Tested by 15

ExampleConn_PublishMsgFunction · 0.52
ExampleConn_FlushFunction · 0.52
ExampleConn_FlushTimeoutFunction · 0.52
TestClosedConnectionsFunction · 0.52
TestBasicHeadersFunction · 0.52
TestRequestMsgFunction · 0.52
TestNoHeaderSupportFunction · 0.52
TestMsgHeadersCasePreservingFunction · 0.52
TesEncodedConnRequestFunction · 0.52
TestMsg_RespondMsgFunction · 0.52
TestJetStreamPublishFunction · 0.52
TestPurgeStreamFunction · 0.52