mmq

Jul 7, 2023

Changes in this version

type MMQ

+ JsonMarshal func(v interface{}) ([]byte, error)

+ JsonUnmarshal func(data []byte, v interface{}) error

type Settings

+ JsonMarshal func(v interface{}) ([]byte, error)

+ JsonUnmarshal func(data []byte, v interface{}) error

Jul 1, 2023

Changes in this version

type Context

+ func (ctx *Context) Next() error

+ func (ctx *Context) WorkerId() int

type MMQ

+ func (m *MMQ) ConsumeMultiply(name string, workers int, handler ...Handler)

+ func (m *MMQ) Use(handler Handler)

Jun 20, 2023

Changes in this version

type MMQ

+ func (m *MMQ) RequestJSON(name string, body interface{}, response interface{}) error

Jun 19, 2023

Changes in this version

type Context

+ func (ctx *Context) AppId() string

+ func (ctx *Context) Body() []byte

+ func (ctx *Context) ConsumerTag() string

+ func (ctx *Context) ContentType() string

+ func (ctx *Context) CorrelationId() string

+ func (ctx *Context) DeliveryTag() uint64

+ func (ctx *Context) MessageCount() uint32

+ func (ctx *Context) MessageId() string

+ func (ctx *Context) Redelivered() bool

+ func (ctx *Context) ReplyTo() string

+ func (ctx *Context) Timestamp() time.Time

+ func (ctx *Context) Type() string

+ func (ctx *Context) UserId() string

type MMQ

+ func (m *MMQ) PurgeExchange(name string, ifUnused, noWait bool) error

+ func (m *MMQ) PurgeQueue(name string, noWait bool) error

Jun 18, 2023

Changes in this version

type Context

+ func (ctx *Context) ReplyJSON(data interface{}) error

+ type JSON map[string]interface

Jun 18, 2023

Changes in this version

type Context

+ func (ctx *Context) Bind(data interface{}) error

+ func (ctx *Context) Reply(data []byte) error

type MMQ

+ func (m *MMQ) BindQueue(name, routingKey, exchange string, noWait bool, args amqp091.Table) error

+ func (m *MMQ) Queue(name, routingKey, exchange string)

+ func (m *MMQ) Reconnect()

+ func (m *MMQ) Request(name string, body []byte) (data []byte, err error)

+ type Settings struct

+ AutoReconnect bool

+ ConnectionUrl string

+ PublishTimeout int

Apr 8, 2023

Changes in this version

type MMQ

+ func (m *MMQ) RPCCall(q, e string, message []byte, headers amqp.Table) ([]byte, error)

Apr 8, 2023

Changes in this version

type Queue

+ Durable bool

Apr 8, 2023

Changes in this version

+ type Context struct

+ App *MMQ

+ Channel *amqp.Channel

+ Delivery amqp.Delivery

+ func (m *Context) Ack(multiple bool) error

+ func (m *Context) Nack(multiple, requeue bool) error

+ func (m *Context) Reject(requeue bool) error

+ func (m *Context) SendResponse(message interface{}, headers amqp.Table) error

+ type ExchageType int

+ const ExchangeTypeDirect

+ const ExchangeTypeFanout

+ const ExchangeTypeTopic

+ type Exchange struct

+ Durable bool

+ Name string

+ Type ExchageType

+ type Handler func(ctx *Context)

+ type MMQ struct

+ func New(connection string) *MMQ

+ func (m *MMQ) Close()

+ func (m *MMQ) Connect() (err error)

+ func (m *MMQ) Consume(q string, handler Handler)

+ func (m *MMQ) DeclareExchange(name string, exchangeType ExchageType, durable bool)

+ func (m *MMQ) DeclareExchanges(exchanges ...Exchange)

+ func (m *MMQ) DeclareQueue(name, exchange, routingKey string)

+ func (m *MMQ) DeclareQueues(queues ...Queue)

+ func (m *MMQ) GetQueue(name string) *queue.Queue

+ func (m *MMQ) GetQueues() map[string]*queue.Queue

+ func (m *MMQ) Listen()

+ func (m *MMQ) Publish(q, e string, message []byte, headers amqp.Table) error

+ type Queue struct

+ Exchange string

+ Name string

+ RoutingKey string