MessageBroker

Documentation

Index

• type ConnectionDataRMQ
  • func NewConnectionDataRMQ(host, port, user, password string) *ConnectionDataRMQ
  • func (c *ConnectionDataRMQ) ConnectionString() string
• type IConnectionData
• type RabbitMQBroker
  • func NewRabbitMQBroker(connectionData IConnectionData) (*RabbitMQBroker, error)
  • func (rbmb *RabbitMQBroker) Close()

Types

type ConnectionDataRMQ

type ConnectionDataRMQ struct {
	Host     string
	Port     string
	User     string
	Password string
}

func NewConnectionDataRMQ

func NewConnectionDataRMQ(host, port, user, password string) *ConnectionDataRMQ

func (*ConnectionDataRMQ) ConnectionString

func (c *ConnectionDataRMQ) ConnectionString() string

type IConnectionData

type IConnectionData interface {
	ConnectionString() string
}

type RabbitMQBroker

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

func NewRabbitMQBroker

func NewRabbitMQBroker(connectionData IConnectionData) (*RabbitMQBroker, error)

func (*RabbitMQBroker) Close

func (rbmb *RabbitMQBroker) Close()