consume

Documentation

Index

• type MessageHandler
• type MessageHandlerResult
  • func Ack() MessageHandlerResult
  • func Later(delay time.Duration) MessageHandlerResult
  • func Nack() MessageHandlerResult
• type Option
  • func WithCustomConsumerOptions(f Option) Option

Types

type MessageHandler

type MessageHandler func(ctx context.Context, msg pulsar.Message) MessageHandlerResult

MessageHandler is a function that will be called everytime a message arrives at a consumer.

type MessageHandlerResult

type MessageHandlerResult func(consumer pulsar.Consumer, msg pulsar.Message) error

MessageHandlerResult will be returned by the MessageHandler. The MessageHandlerResult will Ack/Nack the message.

func Ack

func Ack() MessageHandlerResult

Ack should be returned by a MessageHandler whenever the message needs to be acknowledged.

func Later

func Later(delay time.Duration) MessageHandlerResult

Later should be returned by a MessageHandler whenever the message needs to be re-consumed later.

func Nack

func Nack() MessageHandlerResult

Nack should be returned by a MessageHandler whenever the message needs to be NOT acknowledged.

type Option

type Option func(*pulsar.ConsumerOptions)

func WithCustomConsumerOptions

func WithCustomConsumerOptions(f Option) Option