Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func OpenConsumeLog ¶ added in v1.0.7
func OpenConsumeLog() optionFunc
func WithLogger ¶ added in v1.0.7
Types ¶
type Client ¶ added in v1.0.7
type Client struct {
// contains filtered or unexported fields
}
type ConsumeParams ¶ added in v1.0.7
type ConsumeParams struct { Context context.Context Queue string AutoAck bool Exclusive bool NoLocal bool NoWait bool Args amqp.Table MultipleAck bool Consumer queue.Consumer }
params := ConsumeParams{ queue: "queue_name", AutoAck: false, Exclusive: false, NoLocal: false, NoWait: false, Args: nil, Consumer: queue.Consumer, }
type ProduceMessage ¶ added in v1.0.7
type ProduceMessage struct { Exchange string // exchange Key string // routing key Mandatory bool // set true, when no queue match Basic.Return Immediate bool // set false, not dependent consumers // amqp.Publishing{ // DeliveryMode: amqp.Persistent, // ContentType: "text/plain", // Body: m, // }) Message amqp.Publishing OpenConfirm bool }
Click to show internal directories.
Click to hide internal directories.