MessageHandler

Documentation

Index

• func MsgRcv(...)
• func ReceiveIDMsg(span trace.Span, ctx context.Context, msg map[string]any, f *Factory, ...)
• type Factory
  • func GetFactory(cfg Utils.Config) Factory
  • func (f *Factory) GetMessageHandler(queueName string) MessageHandler
  • func (f *Factory) GetWaitingResponseChan(id string, queueName string) (chan MessageResponse, bool)
  • func (f *Factory) SetWaitingResponse(id string, queueName string) chan MessageResponse
• type MessageHandler
  • func (rcv *MessageHandler) CreateConnection(queueName string, con string)
  • func (rcv *MessageHandler) MockSendMsg(message map[string]any, ctx context.Context)
  • func (rcv *MessageHandler) RegisterConsumer() <-chan map[string]any
  • func (rcv *MessageHandler) SendMsg(message map[string]any, ctx context.Context)
• type MessageResponse

Functions

func MsgRcv

func MsgRcv(handler func(span trace.Span, ctx context.Context, msg map[string]any, f *Factory), queueName string, f *Factory, modeID Utils.ReceiveMessageMode)

func ReceiveIDMsg

func ReceiveIDMsg(span trace.Span, ctx context.Context, msg map[string]any, f *Factory, queueName string)

Types

type Factory

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

func GetFactory

func GetFactory(cfg Utils.Config) Factory

func (*Factory) GetMessageHandler

func (f *Factory) GetMessageHandler(queueName string) MessageHandler

func (*Factory) GetWaitingResponseChan

func (f *Factory) GetWaitingResponseChan(id string, queueName string) (chan MessageResponse, bool)

func (*Factory) SetWaitingResponse

func (f *Factory) SetWaitingResponse(id string, queueName string) chan MessageResponse

type MessageHandler

type MessageHandler struct {
	QueueName        string
	ConnectionString string
	ExternalChan     chan map[string]any
	// contains filtered or unexported fields
}

func (*MessageHandler) CreateConnection

func (rcv *MessageHandler) CreateConnection(queueName string, con string)

func (*MessageHandler) MockSendMsg

func (rcv *MessageHandler) MockSendMsg(message map[string]any, ctx context.Context)

func (*MessageHandler) RegisterConsumer

func (rcv *MessageHandler) RegisterConsumer() <-chan map[string]any

func (*MessageHandler) SendMsg

func (rcv *MessageHandler) SendMsg(message map[string]any, ctx context.Context)

type MessageResponse

type MessageResponse struct {
	Span trace.Span
	Ctx  context.Context
	Msg  map[string]any
}