Documentation
¶
Index ¶
- Constants
- type Server
- type ServerOption
- func Address(addrs []string) ServerOption
- func Logger(logger log.Logger) ServerOption
- func Subscribe(ctx context.Context, topic string, h broker.Handler, ...) ServerOption
- func SubscribeDurableQueue(ctx context.Context, topic, queue string, h broker.Handler, ...) ServerOption
- func TLSConfig(c *tls.Config) ServerOption
- type SubscribeOption
- type SubscribeOptionMap
- type SubscriberMap
- type Transport
Constants ¶
View Source
const (
KindRabbitMQ transport.Kind = "rabbitmq"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Server ¶
func NewServer ¶
func NewServer(opts ...ServerOption) *Server
func (*Server) RegisterSubscriber ¶
type ServerOption ¶
type ServerOption func(o *Server)
func Address ¶
func Address(addrs []string) ServerOption
func Logger ¶
func Logger(logger log.Logger) ServerOption
func Subscribe ¶
func Subscribe(ctx context.Context, topic string, h broker.Handler, opts ...broker.SubscribeOption) ServerOption
func SubscribeDurableQueue ¶
func SubscribeDurableQueue(ctx context.Context, topic, queue string, h broker.Handler, opts ...broker.SubscribeOption) ServerOption
func TLSConfig ¶
func TLSConfig(c *tls.Config) ServerOption
type SubscribeOption ¶
type SubscribeOption struct {
// contains filtered or unexported fields
}
type SubscribeOptionMap ¶
type SubscribeOptionMap map[string]*SubscribeOption
type SubscriberMap ¶
type SubscriberMap map[string]broker.Subscriber
type Transport ¶
type Transport struct {
// contains filtered or unexported fields
}
Transport is a RabbitMQ transport.
func (*Transport) ReplyHeader ¶
ReplyHeader returns the reply header.
func (*Transport) RequestHeader ¶
RequestHeader returns the request header.
func (*Transport) SelectFilters ¶
SelectFilters returns the client select filters.
Source Files
Click to show internal directories.
Click to hide internal directories.