states

Nov 23, 2022

Changes in this version

+ var RabbitMQConn string

+ type Pub func(msg *pb.ObjectPublicData) error

+ type PublicDataPubSub struct

+ func NewPublicDataPubSub(log *zap.Logger, db *driver.Database, rbmq *amqp.Connection) *PublicDataPubSub

+ func (s *PublicDataPubSub) Channel() *amqp.Channel

+ func (s *PublicDataPubSub) Consumer(col string, msgs <-chan amqp.Delivery)

+ func (s *PublicDataPubSub) PublicDataConsumerInit(ch *amqp.Channel, exchange, subtopic, col string)

+ func (s *PublicDataPubSub) Publisher(ch *amqp.Channel, exchange, subtopic string) Pub

+ func (s *PublicDataPubSub) TopicExchange(ch *amqp.Channel, name string)