message_queue

README

Message Queue

RabbitMQ client implementation.

Documentation

Index

• Constants
• func Enable(ctx *commons.RuntimeContext)
• func WrapConnection(runtime *goja.Runtime, config interface{}) goja.Value
• func WrapEmitter(runtime *goja.Runtime, emitter mq_commons.IEmitter) goja.Value
• func WrapListener(runtime *goja.Runtime, listener mq_commons.IListener, mux *sync.Mutex) goja.Value
• type JsMqConnection
• type JsMqEmitter
• type JsMqListener
• type ModuleMessageQueue

Constants

const NAME = "message-queue"

Functions

func Enable

func Enable(ctx *commons.RuntimeContext)

func WrapConnection

func WrapConnection(runtime *goja.Runtime, config interface{}) goja.Value

func WrapEmitter

func WrapEmitter(runtime *goja.Runtime, emitter mq_commons.IEmitter) goja.Value

func WrapListener

func WrapListener(runtime *goja.Runtime, listener mq_commons.IListener, mux *sync.Mutex) goja.Value

Types

type JsMqConnection

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

type JsMqEmitter

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

type JsMqListener

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

type ModuleMessageQueue

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