dispatch

Oct 14, 2026

Changes in this version

type Dispatcher

+ func (d *Dispatcher) RegisterHandlerWithOptions(handlerFunc interface{}, opts HandlerOptions) HandlerIdentifier

+ type HandlerOptions struct

+ UnwrappedPanics bool

May 4, 2021

Changes in this version

+ var ErrQueueNotFound = errors.New("one or more queues not found")

type Dispatcher

+ func (d *Dispatcher) UnregisterAllHandlers()

May 15, 2020

Changes in this version

+ type Config struct

+ PanicHandler PanicHandler

type Dispatcher

+ func NewDispatcherWithConfig(cfg Config) *Dispatcher

+ type PanicHandler func(v interface{})

Mar 21, 2020

Changes in this version

+ type ConsumerCodePanic struct

+ func (ucp ConsumerCodePanic) String() string

+ func (ucp ConsumerCodePanic) Value() interface{}

May 18, 2018

Changes in this version

type Dispatcher

+ func (d *Dispatcher) UnregisterHandler(identifier HandlerIdentifier)

+ type HandlerIdentifier *int

Sep 11, 2017

Changes in this version

+ type Dispatcher struct

+ func (d *Dispatcher) AddQueues(queues ...chan interface{})

+ func (d *Dispatcher) Dispatch(object interface{})

+ func (d *Dispatcher) RegisterHandler(handler interface{})

+ func (d *Dispatcher) RemoveAllQueues()

+ func (d *Dispatcher) RemoveQueues(queues ...chan interface{}) error

+ func (d *Dispatcher) SyncAllQueues()

+ func (d *Dispatcher) SyncQueues(queues ...chan interface{}) error