mrabbitmq

Documentation

Index

• type RabbitMQConnection
  • func (rc *RabbitMQConnection) Connect() error
  • func (rc *RabbitMQConnection) GetNewConnect() (*amqp.Channel, error)

Types

type RabbitMQConnection

type RabbitMQConnection struct {
	ConnectionStringSource string
	Queue                  string
	Exchange               string
	Key                    string
	Host                   string
	Port                   string
	User                   string
	Pass                   string
	Channel                *amqp.Channel
	Logger                 mlog.Logger
	Connected              bool
}

RabbitMQConnection is a hub which deal with rabbitmq connections.

func (*RabbitMQConnection) Connect

func (rc *RabbitMQConnection) Connect() error

Connect keeps a singleton connection with rabbitmq.

func (*RabbitMQConnection) GetNewConnect

func (rc *RabbitMQConnection) GetNewConnect() (*amqp.Channel, error)

GetNewConnect returns a pointer to the rabbitmq connection, initializing it if necessary.