func (t *simpleQueue) Resume(ctx context.Context) error {
	if atomic.CompareAndSwapUint32(&t.isInPause, StatusPaused, StatusDelivering) {
		goglog.Logger.Debugf("queue %s: requesting resume", t.GetType())
		return t.control.RequestResume(ctx)
	}
	return nil
}
// Resume informs that the output is working again - can be called multiple times and is thread safe.
// Should be called after each successfully delivery by the output.
Resume informs that the output is working again - can be called multiple times and is thread safe.
Should be called after each successfully delivery by the output.
// Resume informs that the output is working again - can be called multiple times and is thread safe . // Should be called after each successfully delivery by the output .
func (t *simpleQueue) Resume(ctx context.Context) error {
	if atomic.CompareAndSwapUint32(&t.isInPause, StatusPaused, StatusDelivering) {
		goglog.Logger.Debugf("queue %s: requesting resume", t.GetType())
		return t.control.RequestResume(ctx)
	}
	return nil
}
func ( t * simpleQueue ) Resume ( ctx context . Context ) error { if atomic . CompareAndSwapUint32 ( & t . isInPause , StatusPaused , StatusDelivering ) { goglog . Logger . Debugf ( " " , t . GetType ( ) ) return t . control . RequestResume ( ctx ) } return nil }
Resume informs that the output is working again - can be called multiple times and is thread safe.
Resume informs that the output is working again - can be called multiple times and is thread safe .