service

Documentation

Index

• type RabbitMQService
  • func (r *RabbitMQService) Connect(serverURL string) (err error)
  • func (r *RabbitMQService) CreateMsgDaemon(ctx context.Context) (daemon booting.Daemon, err error)

Types

type RabbitMQService

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

func (*RabbitMQService) Connect

func (r *RabbitMQService) Connect(serverURL string) (err error)

func (*RabbitMQService) CreateMsgDaemon

func (r *RabbitMQService) CreateMsgDaemon(ctx context.Context) (daemon booting.Daemon, err error)