consumer_transport

Documentation

Index

• type ConsumerTransport
  • func NewConsumerTransport() ConsumerTransport
• type RabbitmqConsumerTransport
  • func NewRabbitmqConsumerTransport() RabbitmqConsumerTransport
  • func (self *RabbitmqConsumerTransport) CreateDispatcherMessage(encodedMsg []byte) (dispatcher_message.Message, error)
  • func (self *RabbitmqConsumerTransport) Destroy()
  • func (self *RabbitmqConsumerTransport) GetError() error
  • func (self *RabbitmqConsumerTransport) Listen(messageChannel chan dispatcher_message.Message)

Types

type ConsumerTransport

type ConsumerTransport interface {
	Listen(messageChannel chan dispatcher_message.Message)
	Destroy()
	CreateDispatcherMessage(encodedMsg []byte) (dispatcher_message.Message, error)
}

func NewConsumerTransport

func NewConsumerTransport() ConsumerTransport

type RabbitmqConsumerTransport

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

func NewRabbitmqConsumerTransport

func NewRabbitmqConsumerTransport() RabbitmqConsumerTransport

func (*RabbitmqConsumerTransport) CreateDispatcherMessage

func (self *RabbitmqConsumerTransport) CreateDispatcherMessage(encodedMsg []byte) (dispatcher_message.Message, error)

func (*RabbitmqConsumerTransport) Destroy

func (self *RabbitmqConsumerTransport) Destroy()

func (*RabbitmqConsumerTransport) GetError

func (self *RabbitmqConsumerTransport) GetError() error

func (*RabbitmqConsumerTransport) Listen

func (self *RabbitmqConsumerTransport) Listen(messageChannel chan dispatcher_message.Message)