|
|
@ -28,7 +28,6 @@ type WrappedQueueConfiguration struct { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
type delayedStarter struct { |
|
|
|
type delayedStarter struct { |
|
|
|
lock sync.Mutex |
|
|
|
|
|
|
|
internal Queue |
|
|
|
internal Queue |
|
|
|
underlying Type |
|
|
|
underlying Type |
|
|
|
cfg interface{} |
|
|
|
cfg interface{} |
|
|
@ -89,6 +88,7 @@ func (q *delayedStarter) setInternal(atShutdown func(context.Context, func()), h |
|
|
|
// WrappedQueue wraps a delayed starting queue
|
|
|
|
// WrappedQueue wraps a delayed starting queue
|
|
|
|
type WrappedQueue struct { |
|
|
|
type WrappedQueue struct { |
|
|
|
delayedStarter |
|
|
|
delayedStarter |
|
|
|
|
|
|
|
lock sync.Mutex |
|
|
|
handle HandlerFunc |
|
|
|
handle HandlerFunc |
|
|
|
exemplar interface{} |
|
|
|
exemplar interface{} |
|
|
|
channel chan Data |
|
|
|
channel chan Data |
|
|
|