rabbitmq

Documentation

Index

• type HandlerMap
• type Server
  • func GetServer() *Server
  • func NewServer(opts ...options.ConsumerOption) *Server
  • func (s *Server) GetRegisterHandler(queueName string) (rabbitmq.Handler, error)
  • func (s *Server) RegisterHandler(queueName string, h rabbitmq.Handler) error
  • func (s *Server) Start(ctx context.Context) error
  • func (s *Server) Stop(ctx context.Context) error

Types

type HandlerMap

type HandlerMap map[string]rabbitmq.Handler

type Server

type Server struct {
	// contains filtered or unexported fields
}

var (
	// Srv is a global rabbitmq server
	Srv *Server
)

func GetServer

func GetServer() *Server

func NewServer

func NewServer(opts ...options.ConsumerOption) *Server

func (*Server) GetRegisterHandler

func (s *Server) GetRegisterHandler(queueName string) (rabbitmq.Handler, error)

func (*Server) RegisterHandler

func (s *Server) RegisterHandler(queueName string, h rabbitmq.Handler) error

func (*Server) Start

func (s *Server) Start(ctx context.Context) error

func (*Server) Stop

func (s *Server) Stop(ctx context.Context) error