rabbitmqchannel

Documentation

Index

• func WaitForConnection(rabbitmq *Rabbitmq)
• type ChannelAdapter
  • func New(done <-chan bool, wg *sync.WaitGroup, config Config) *ChannelAdapter
  • func (ca *ChannelAdapter) GetInputChannel(name string) (chan<- []byte, error)
  • func (ca *ChannelAdapter) GetMode(name string) (channel.Mode, error)
  • func (ca *ChannelAdapter) GetOutputChannel(name string) (<-chan channel.Message, error)
  • func (ca *ChannelAdapter) NewChannel(name string, mode channel.Mode, bufferSize, maxRetryPolicy int) error
• type Config
• type RabbitMQConsumerConnection
• type Rabbitmq

Functions

func WaitForConnection

func WaitForConnection(rabbitmq *Rabbitmq)

Types

type ChannelAdapter

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

func New

func New(done <-chan bool, wg *sync.WaitGroup, config Config) *ChannelAdapter

func (*ChannelAdapter) GetInputChannel

func (ca *ChannelAdapter) GetInputChannel(name string) (chan<- []byte, error)

func (*ChannelAdapter) GetMode

func (ca *ChannelAdapter) GetMode(name string) (channel.Mode, error)

func (*ChannelAdapter) GetOutputChannel

func (ca *ChannelAdapter) GetOutputChannel(name string) (<-chan channel.Message, error)

func (*ChannelAdapter) NewChannel

func (ca *ChannelAdapter) NewChannel(name string, mode channel.Mode, bufferSize, maxRetryPolicy int) error

type Config

type Config struct {
	User            string `koanf:"user"`
	Password        string `koanf:"password"`
	Host            string `koanf:"host"`
	Port            int    `koanf:"port"`
	Vhost           string `koanf:"vhost"`
	ReconnectSecond int    `koanf:"reconnect_second"`
}

type RabbitMQConsumerConnection

type RabbitMQConsumerConnection struct {
	User            string
	Password        string
	Host            string
	Port            int
	Vhost           string
	ReconnectSecond int
}

type Rabbitmq

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