messages

Documentation

Index

• type Executor
• type MessageAdapter
  • func NewMessageAdapter(console *zap.Logger, rabbitAdapter queue.Executor, ...) *MessageAdapter
  • func (a *MessageAdapter) ProcessMessage()
  • func (a *MessageAdapter) ReceiveMessages(queue string)
• type Parameter

Types

type Executor

type Executor interface {
	ReceiveMessages(queue string)
	ProcessMessages()
}

type MessageAdapter

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

func NewMessageAdapter

func NewMessageAdapter(console *zap.Logger,
	rabbitAdapter queue.Executor,
	grpcHelloCommand command.Executor,
	validatorService validation.Executor,
) *MessageAdapter

func (*MessageAdapter) ProcessMessage

func (a *MessageAdapter) ProcessMessage()

func (*MessageAdapter) ReceiveMessages

func (a *MessageAdapter) ReceiveMessages(queue string)

type Parameter

type Parameter struct {
	ViewColumn  string
	NameMapping string
	Order       int
}