channelprovider

Documentation

Index

• type ChannelProvider
  • func NewChannelProvider(logger *gologger.CustomLogger, username string, password string) *ChannelProvider
  • func NewChannelProviderWithServers(logger *gologger.CustomLogger, rabbitMqServers []string, username string, ...) *ChannelProvider
  • func (cp *ChannelProvider) GetChannel() (*amqp.Channel, error)

Types

type ChannelProvider

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

ChannelProvider is container for logger and connection pool, has method to get channel.

func NewChannelProvider

func NewChannelProvider(logger *gologger.CustomLogger, username string, password string) *ChannelProvider

NewChannelProvider gives you a new channel provider. It takes the list of servers from "rabbitmq" in config

func NewChannelProviderWithServers

func NewChannelProviderWithServers(logger *gologger.CustomLogger, rabbitMqServers []string, username string, password string) *ChannelProvider

NewChannelProviderWithServers gives you a new channel provider. You have to pass a list of rabbitmq servers.

func (*ChannelProvider) GetChannel

func (cp *ChannelProvider) GetChannel() (*amqp.Channel, error)

GetChannel creates and returns a channel