processor

type Error struct {
	Err error
	*Processor
}

type Processor struct {
	Name                 string
	RabbitConn           *amqp.Connection
	RabbitRoutingKey     string
	RabbitChannels       []RabbitChannel
	OutboundMsgChan      chan *models.OutboundMessage
	Config               *config.Configuration
	PubSubProject        string
	PubSubSubscriptionId string
	PubSubClient         *pubsub.Client
	PubSubSubscription   *pubsub.Subscription

	ErrChan chan Error
	Logger  *zap.SugaredLogger
	Context context.Context
	Cancel  context.CancelFunc
	// contains filtered or unexported fields
}

type RabbitChannel interface {
	Close() error
	Tx() error
	TxCommit() error
	TxRollback() error
	NotifyClose(chan *amqp.Error) chan *amqp.Error
	Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
}