amqp

Documentation

Overview

Package amqp defines version 1 implementation of amqp

Index

• func CreateListener(inChan chan<- *channel.DataChan, address string)
• func CreateNewStatusListener(inChan chan<- *channel.DataChan, address string, ...)
• func CreateSender(inChan chan<- *channel.DataChan, address string)
• func DeleteListener(inChan chan<- *channel.DataChan, address string)
• func DeleteSender(inChan chan<- *channel.DataChan, address string)
• func NewReceiver(hostName string, port int, address string) (*amqp1.Protocol, error)
• func NewSender(hostName string, port int, address string) (*amqp1.Protocol, error)
• type AMQP
  • func GetAMQPInstance(amqpHost string, dataIn <-chan *channel.DataChan, ...) (*AMQP, error)
  • func (a *AMQP) Start(wg *sync.WaitGroup)

Functions

func CreateListener

func CreateListener(inChan chan<- *channel.DataChan, address string)

CreateListener send subscription address information on a channel to create its listener object

func CreateNewStatusListener

func CreateNewStatusListener(inChan chan<- *channel.DataChan, address string,
	onReceiveOverrideFn func(e cloudevents.Event, dataChan *channel.DataChan) error,
	processEventFn func(e interface{}) error)

CreateNewStatusListener send status address information on a channel to create its listener object

func CreateSender

func CreateSender(inChan chan<- *channel.DataChan, address string)

CreateSender send publisher address information on a channel to create it's sender object

func DeleteListener

func DeleteListener(inChan chan<- *channel.DataChan, address string)

DeleteListener send subscription address information on a channel to delete its listener object

func DeleteSender

func DeleteSender(inChan chan<- *channel.DataChan, address string)

DeleteSender send publisher address information on a channel to delete its sender object

func NewReceiver

func NewReceiver(hostName string, port int, address string) (*amqp1.Protocol, error)

NewReceiver create new receiver independent of the framework

func NewSender

func NewSender(hostName string, port int, address string) (*amqp1.Protocol, error)

NewSender - create new sender independent of the framework

Types

type AMQP

type AMQP struct {
	Router *amqp1.Router
}

AMQP exposes amqp api methods

func GetAMQPInstance

func GetAMQPInstance(amqpHost string, dataIn <-chan *channel.DataChan, dataOut chan<- *channel.DataChan, closeCh <-chan struct{}, amqInitTimeout time.Duration) (*AMQP, error)

GetAMQPInstance get event instance

func (*AMQP) Start

func (a *AMQP) Start(wg *sync.WaitGroup)

Start start amqp processors