cadmin/server/internal/queues/types.go

package queues

import "github.com/nats-io/nats.go"

type SubStrategy interface {
	Handle(m *nats.Msg) (err error)
}