rabbitmq

Documentation

Index

• Constants
• type Config
• type GlobalNotifierRabbitmq
  • func (m *GlobalNotifierRabbitmq) Close() error
  • func (m *GlobalNotifierRabbitmq) GetConfig() interface{}
  • func (m *GlobalNotifierRabbitmq) GetGroup() core.ModuleGroup
  • func (m *GlobalNotifierRabbitmq) GetName() string
  • func (m *GlobalNotifierRabbitmq) GetType() core.ModuleType
  • func (m *GlobalNotifierRabbitmq) InitModule(_cfg interface{}) error
  • func (m *GlobalNotifierRabbitmq) InitPipe(w io.Writer, r io.Reader) error
  • func (m *GlobalNotifierRabbitmq) Run(ctx context.Context) error

Constants

const (
	GROUP_NAME  = "global"
	TYPE_NAME   = "notifier"
	MODULE_NAME = "rabbitmq"
)

Types

type Config

type Config struct {
	RabbitMQURL      string
	QueueName        string
	QueueDurable     bool
	QueueAutoDelete  bool
	QueueExclusive   bool
	QueueNoWait      bool
	PublishExchange  string
	PublishKey       string
	PublishMandatory bool
	PublishImmediate bool
	MsgContentType   string
	MsgBody          string
}

Config for GlobalNotifierRabbitmq

type GlobalNotifierRabbitmq

type GlobalNotifierRabbitmq struct {
	core.Module
	// contains filtered or unexported fields
}

func (*GlobalNotifierRabbitmq) Close

func (m *GlobalNotifierRabbitmq) Close() error

func (*GlobalNotifierRabbitmq) GetConfig

func (m *GlobalNotifierRabbitmq) GetConfig() interface{}

func (*GlobalNotifierRabbitmq) GetGroup

func (m *GlobalNotifierRabbitmq) GetGroup() core.ModuleGroup

func (*GlobalNotifierRabbitmq) GetName

func (m *GlobalNotifierRabbitmq) GetName() string

func (*GlobalNotifierRabbitmq) GetType

func (m *GlobalNotifierRabbitmq) GetType() core.ModuleType

func (*GlobalNotifierRabbitmq) InitModule

func (m *GlobalNotifierRabbitmq) InitModule(_cfg interface{}) error

func (*GlobalNotifierRabbitmq) InitPipe

func (m *GlobalNotifierRabbitmq) InitPipe(w io.Writer, r io.Reader) error

func (*GlobalNotifierRabbitmq) Run

func (m *GlobalNotifierRabbitmq) Run(ctx context.Context) error