rabbitmq

Documentation

Index

• type QueueHandler
  • func NewQueueHandler(job model.MQjob, paramType string) *QueueHandler
  • func (handler *QueueHandler) Listening(msg []byte)
  • func (handler *QueueHandler) LogCall(callLog model.CallLog)
  • func (handler *QueueHandler) LogFailed(msg string)

Types

type QueueHandler

type QueueHandler struct {
	Job model.MQjob
	// contains filtered or unexported fields
}

func NewQueueHandler

func NewQueueHandler(job model.MQjob, paramType string) *QueueHandler

func (*QueueHandler) Listening

func (handler *QueueHandler) Listening(msg []byte)

func (*QueueHandler) LogCall

func (handler *QueueHandler) LogCall(callLog model.CallLog)

func (*QueueHandler) LogFailed

func (handler *QueueHandler) LogFailed(msg string)