workflowpluginbroker

Apr 22, 2026

Changes in this version

type Broker

+ Publish func(subject string, data []byte) error

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ Subscribe func(subject string, handler func([]byte)) error

+ SubscribeDurable func(subject, consumerName string, handler func([]byte)) error

+ SubscribeWithSubject func(subject string, handler func(subject string, data []byte)) error

Mar 16, 2026

Changes in this version

+ type Broker = internal.Broker

+ func NewBrokerPlugin(name string, cfg map[string]any) Broker