rabbitmq

package
v2.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 3, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Handler

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

func NewHandler

func NewHandler(consumerName string, userName string, password string, host string, port int, options ...Option) *Handler

func (*Handler) Close

func (h *Handler) Close() error

func (*Handler) OnError

func (h *Handler) OnError(cb func(err error)) error

func (*Handler) OnEvent

func (h *Handler) OnEvent(eventName string, callback func([]byte) error, options geb.OnEventOptions) error

func (*Handler) Publish

func (h *Handler) Publish(eventName string, payload []byte) error

func (*Handler) Start

func (h *Handler) Start() error

type Option

type Option func(q *Handler)

func Timeout

func Timeout(duration time.Duration) Option

func VHost

func VHost(vhost string) Option

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL