gorabbitmq

Feb 23, 2021

Changes in this version

+ type ActionFunc func(string)

Feb 22, 2021

Changes in this version

+ func Server(connection Connection, queueSetting QueueSetting, ...)

Feb 22, 2021

Changes in this version

+ func Client(body string, connection Connection, queueSetting QueueSetting, ...) (errorResponse error)

Feb 9, 2021

Changes in this version

+ type AMQPChannel struct

+ func (channel *AMQPChannel) Close() error

+ func (channel *AMQPChannel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (<-chan amqp.Delivery, error)

+ func (channel *AMQPChannel) IsClosed() bool

+ type AMQPConnection struct

+ func Dial(url string) (*AMQPConnection, error)

+ func (connection *AMQPConnection) Channel() (*AMQPChannel, error)

Feb 5, 2021

Changes in this version

+ func RPCServer(connection Connection, queueSetting QueueSetting, qosSetting QosSetting, ...)

+ type QosSetting struct

+ Global bool

+ PrefetchCount int

+ PrefetchSize int

+ type RouteFunc func(string) string

Feb 4, 2021

Changes in this version

+ func RPCClient(body string, connection Connection, queueSetting QueueSetting, ...) (response string, errorResponse error)

+ type Connection struct

+ Host string

+ Password string

+ Port string

+ Username string

+ VirtualHost string

+ type ConsumeSetting struct

+ Args map[string]interface{}

+ AutoAck bool

+ Consumer string

+ Exclusive bool

+ NoLocal bool

+ NoWait bool

+ type OtherSetting struct

+ Expiration string

+ Immediate bool

+ Mandatory bool

+ RoutingKey string

+ Timeout time.Duration

+ type QueueSetting struct

+ Args map[string]interface{}

+ AutoDelete bool

+ Durable bool

+ Exclusive bool

+ Name string

+ NoWait bool