handler

Documentation

Index

• type AdapterFunc
  • func (a AdapterFunc) Handle(ctx context.Context, msg *stomp.Message) Result
• type HandlerAdapter
• type Middleware
  • func Log(logger log.Logger) Middleware
• type Result
  • func Ack() Result
  • func Requeue(err error) Result
• type ResultHandler
  • func NewHandler(logger log.Logger, adapter HandlerAdapter, middlewares ...Middleware) ResultHandler
  • func (r ResultHandler) Handle(ctx context.Context, delivery *consumer.Delivery)

Types

type AdapterFunc

type AdapterFunc func(ctx context.Context, msg *stomp.Message) Result

func (AdapterFunc) Handle

func (a AdapterFunc) Handle(ctx context.Context, msg *stomp.Message) Result

type HandlerAdapter

type HandlerAdapter interface {
	Handle(ctx context.Context, msg *stomp.Message) Result
}

type Middleware

type Middleware func(next HandlerAdapter) HandlerAdapter

func Log

func Log(logger log.Logger) Middleware

type Result

type Result struct {
	Ack     bool
	Requeue bool
	Err     error
}

func Ack

func Ack() Result

func Requeue

func Requeue(err error) Result

type ResultHandler

type ResultHandler struct {
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(logger log.Logger, adapter HandlerAdapter, middlewares ...Middleware) ResultHandler

func (ResultHandler) Handle

func (r ResultHandler) Handle(ctx context.Context, delivery *consumer.Delivery)