Start consuming from the clientapi
()
| 64 | |
| 65 | // Start consuming from the clientapi |
| 66 | func (t *OutputReceiptConsumer) Start() error { |
| 67 | return jetstream.JetStreamConsumer( |
| 68 | t.ctx, t.jetstream, t.topic, t.durable, t.onMessage, |
| 69 | nats.DeliverAll(), nats.ManualAck(), nats.HeadersOnly(), |
| 70 | ) |
| 71 | } |
| 72 | |
| 73 | // onMessage is called in response to a message received on the receipt |
| 74 | // events topic from the client api. |