endpoints

Documentation

Index

• type Endpoint
• type RabbitMQEndpoint
  • func (endpoint *RabbitMQEndpoint) Close() error
  • func (endpoint *RabbitMQEndpoint) Connect(config confighandler.Config) error

Types

type Endpoint

type Endpoint interface {
	Connect() error
	Close() error
}

Endpoint defines the the behavior of an endpoint

type RabbitMQEndpoint

type RabbitMQEndpoint struct {
	Connection *amqp.Connection
	Channel    *amqp.Channel
}

RabbitMQEndpoint defines the struct used by a RabbitMQ endpoint

func (*RabbitMQEndpoint) Close

func (endpoint *RabbitMQEndpoint) Close() error

Close takes case of closing connection to the RabbitMQ broker

func (*RabbitMQEndpoint) Connect

func (endpoint *RabbitMQEndpoint) Connect(config confighandler.Config) error

Connect exeuctes a connectiong to a RabbitMQ instance with specified values in confighandler.Config Writes the connection and open channel to communicate with Rabbit