- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for changed (0.14 sec)
-
internal/event/target/amqp.go
func (target *AMQPTarget) isActive() (bool, error) { ch, _, err := target.channel() if err != nil { return false, err } defer func() { ch.Close() }() return true, nil } func (target *AMQPTarget) channel() (*amqp091.Channel, chan amqp091.Confirmation, error) { var err error var conn *amqp091.Connection var ch *amqp091.Channel isAMQPClosedErr := func(err error) bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0)