Publish performs a synchronous publish to a stream and waits for ack from server. It accepts subject name (which must be bound to a stream) and message payload.
(ctx context.Context, subj string, data []byte, opts ...PublishOpt)
| 159 | // from server. It accepts subject name (which must be bound to a stream) |
| 160 | // and message payload. |
| 161 | func (js *jetStream) Publish(ctx context.Context, subj string, data []byte, opts ...PublishOpt) (*PubAck, error) { |
| 162 | return js.PublishMsg(ctx, &nats.Msg{Subject: subj, Data: data}, opts...) |
| 163 | } |
| 164 | |
| 165 | // PublishMsg performs a synchronous publish to a stream and waits for |
| 166 | // ack from server. It accepts subject name (which must be bound to a |
nothing calls this directly
no test coverage detected