extension

Documentation

Index

• func NewExampleExtension(mq *messagequeue.MessageQueue) interfaces.Extension
• type ExmampleExtension
  • func (e *ExmampleExtension) DataHandler(id string, pt string, payload interface{}, ar bool)
  • func (e *ExmampleExtension) Run()

Functions

func NewExampleExtension

func NewExampleExtension(mq *messagequeue.MessageQueue) interfaces.Extension

Types

type ExmampleExtension

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

func (*ExmampleExtension) DataHandler

func (e *ExmampleExtension) DataHandler(id string, pt string, payload interface{}, ar bool)

func (*ExmampleExtension) Run

func (e *ExmampleExtension) Run()