mrabbitmq

Documentation

Index

• type ConsumerRabbitMQRepository
  • func NewConsumerRabbitMQ(c *mrabbitmq.RabbitMQConnection) *ConsumerRabbitMQRepository
  • func (crmq *ConsumerRabbitMQRepository) ConsumerDefault(response chan string)
• type ProducerRabbitMQRepository
  • func NewProducerRabbitMQ(c *mrabbitmq.RabbitMQConnection) *ProducerRabbitMQRepository
  • func (prmq *ProducerRabbitMQRepository) ProducerDefault(message string) (*string, error)

Types

type ConsumerRabbitMQRepository

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

ConsumerRabbitMQRepository is a rabbitmq implementation of the consumer

func NewConsumerRabbitMQ

func NewConsumerRabbitMQ(c *mrabbitmq.RabbitMQConnection) *ConsumerRabbitMQRepository

NewConsumerRabbitMQ returns a new instance of ConsumerRabbitMQRepository using the given rabbitmq connection.

func (*ConsumerRabbitMQRepository) ConsumerDefault

func (crmq *ConsumerRabbitMQRepository) ConsumerDefault(response chan string)

type ProducerRabbitMQRepository

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

ProducerRabbitMQRepository is a rabbitmq implementation of the producer

func NewProducerRabbitMQ

func NewProducerRabbitMQ(c *mrabbitmq.RabbitMQConnection) *ProducerRabbitMQRepository

NewProducerRabbitMQ returns a new instance of ProducerRabbitMQRepository using the given rabbitmq connection.

func (*ProducerRabbitMQRepository) ProducerDefault

func (prmq *ProducerRabbitMQRepository) ProducerDefault(message string) (*string, error)