Versions in this module Expand all Collapse all v1 v1.1.0 Dec 24, 2019 v1.0.1 Apr 25, 2019 Changes in this version + const CREATED + const DATA + const DELETED + const ORGANIZATION + const RESOURCE + const SCHEMA + const UPDATED + type AMQPService struct + Channel *rabbitmq.AMQPChannel + ExchangeType string + ExchnageName string + func NewService(mqConfig *commonCfg.MQConfig) (*AMQPService, func(), error) + func (a *AMQPService) AddObjectHandler(handler ObjectHandler) + func (a *AMQPService) GetExchangeName(exchnageName string) string + func (a *AMQPService) GetExchangeType(exchnageType string) string + func (a *AMQPService) ReceiveObjects() error + func (a *AMQPService) SendObject(e *EventPayload) error + func (a *AMQPService) SetExchangeName(exchnageName string) + func (a *AMQPService) SetExchnageType(exchangeType string) + type EventPayload struct + Data map[string]interface{} + ErrorMessages []string + Event string + ObjectID string + ObjectType string + type ObjectHandler func(amqpChan <-chan amqp.Delivery) + type Service interface + AddObjectHandler func(handler ObjectHandler) + GetExchangeName func(queueName string) string + ReceiveObjects func() error + SendObject func(e *EventPayload) error + SetExchangeName func(exchnageName string)
Go to main page