rabbit

Documentation

Index

• type Client
  • func NewClient(connection string, exchange string, exchangeKind string, exchangeDurable bool, ...) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) Consume() (chan core.Message, error)
  • func (c *Client) Produce(message core.Message) error
• type ZapLogger
  • func (l ZapLogger) Tracef(msg string, args ...interface{})

Types

type Client

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

func NewClient

func NewClient(
	connection string,
	exchange string,
	exchangeKind string,
	exchangeDurable bool,
	routingKeys []string,
	logger *zap.SugaredLogger,
) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

Close, closed the client connection and execute cleanup operations

func (*Client) Consume

func (c *Client) Consume() (chan core.Message, error)

func (*Client) Produce

func (c *Client) Produce(message core.Message) error

type ZapLogger

type ZapLogger struct {
	*zap.SugaredLogger
}

func (ZapLogger) Tracef

func (l ZapLogger) Tracef(msg string, args ...interface{})