PublishMsg 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 nats.Message.
(ctx context.Context, msg *nats.Msg, opts ...PublishOpt)
| 77 | // ack from server. It accepts subject name (which must be bound to a |
| 78 | // stream) and nats.Message. |
| 79 | PublishMsg(ctx context.Context, msg *nats.Msg, opts ...PublishOpt) (*PubAck, error) |
| 80 | |
| 81 | // PublishAsync performs a publish to a stream and returns |
| 82 | // [PubAckFuture] interface, not blocking while waiting for an |
no outgoing calls