Start consuming from key servers
()
| 66 | |
| 67 | // Start consuming from key servers |
| 68 | func (t *KeyChangeConsumer) Start() error { |
| 69 | return jetstream.JetStreamConsumer( |
| 70 | t.ctx, t.jetstream, t.topic, t.durable, t.onMessage, |
| 71 | nats.DeliverAll(), nats.ManualAck(), |
| 72 | ) |
| 73 | } |
| 74 | |
| 75 | // onMessage is called in response to a message received on the |
| 76 | // key change events topic from the key server. |