Method InProgress

jetstream/message.go:378–380

InProgress tells the server that this message is being worked on. It resets the redelivery timer on the server.

()

// InProgress tells the server that this message is being worked on. It
// resets the redelivery timer on the server.
func (m *jetStreamMsg) InProgress() error {
	return m.ackReply(context.Background(), ackProgress, false, ackOpts{})
}

// Term tells the server to not redeliver this message, regardless of
// the value of MaxDeliver.