rabbitmq

package

v0.2.2 Latest Latest Go to latest Published: Apr 4, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func Close()

Close 關閉全域連線

func Consume(queue string, handler func(msg string) error) error

Consume 消費訊息

func DeclareQueue(name string) (amqp.Queue, error)

DeclareQueue 宣告 queue 並存到 map

func Init(url string) error

Init 建立連線與 channel (全域)

func Send(queue string, body string) error

Send 發送訊息 (自動查 map)

This section is empty.