Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitMQConnection ¶
type RabbitMQConnection struct {
ConnectionStringSource string
Queue string
Host string
Port string
User string
Pass string
Channel *amqp.Channel
Logger log.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.
Click to show internal directories.
Click to hide internal directories.