mqutil

Documentation

Index

• type Engine
  • func New(e *gin.Engine) *Engine
  • func (e *Engine) Capture(channel, topic string, handler gin.HandlerFunc)
• type Listener

Types

type Engine

type Engine struct {
	Gin       *gin.Engine
	Listeners []Listener
}

Engine stores the Gin engine and the message queue listeners.

func New

func New(e *gin.Engine) *Engine

New creates the new message queue handler engine.

func (*Engine) Capture

func (e *Engine) Capture(channel, topic string, handler gin.HandlerFunc)

Capture subscribes to a channel and capturing the incoming messages with the specified topic.

type Listener

type Listener struct {
	Method  string
	Path    string
	Channel string
	Topic   string
	Handler gin.HandlerFunc
}

Listener listens and processes the specified incoming messages.