Versions in this module Expand all Collapse all v1 v1.1.0 Feb 1, 2020 Changes in this version + const RabbitExchangeName + const RabbitQueueName + func DeclareQueue(ch *amqp.Channel) error + type Message struct + GroupID string + MemberID string + Trial int + func (m *Message) ExceededTrialLimit(limit int) bool + func (m *Message) Fields() map[string]interface{} + func (m *Message) Retry()
Go to main page