Skip to content

Commit 51bf7b9

Browse files
committed
chore: check queueWorker to implement the worker interface
Signed-off-by: Bo-Yi Wu <[email protected]>
1 parent 7378dbc commit 51bf7b9

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

worker.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@ type Worker interface {
1111
BeforeRun() error
1212
Run(chan struct{}) error
1313
AfterRun() error
14-
1514
Shutdown() error
1615
Queue(job QueuedMessage) error
1716
Capacity() int
@@ -23,7 +22,10 @@ type QueuedMessage interface {
2322
Bytes() []byte
2423
}
2524

26-
var _ Worker = (*emptyWorker)(nil)
25+
var (
26+
_ Worker = (*emptyWorker)(nil)
27+
_ Worker = (*queueWorker)(nil)
28+
)
2729

2830
type emptyWorker struct{}
2931

0 commit comments

Comments
 (0)