Method Consume

jetstream/consumer.go:137–137

Consume will continuously receive messages and handle them with the provided callback function. Consume can be configured using PullConsumeOpt options: - Error handling and monitoring can be configured using ConsumeErrHandler option, which provides information about errors encountered during consum

(handler MessageHandler, opts ...PullConsumeOpt)

		// Consume returns a ConsumeContext, which can be used to stop or drain
		// the consumer.
		Consume(handler MessageHandler, opts ...PullConsumeOpt) (ConsumeContext, error)

		// Messages returns MessagesContext, allowing continuous iteration
		// over messages in a stream. Messages can be configured using