Skip to content

Commit d7d2a7b

Browse files
committed
Fix rqueue-web test: use MessageBroker in JobImpl constructor
RqueueTaskMetricsAggregatorServiceTest was still passing RqueueMessageTemplate where JobImpl now expects MessageBroker. Assisted-By: Claude Code
1 parent b9f2b3a commit d7d2a7b

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

rqueue-web/src/test/java/com/github/sonus21/rqueue/web/service/RqueueTaskMetricsAggregatorServiceTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
import com.github.sonus21.rqueue.config.RqueueWebConfig;
3232
import com.github.sonus21.rqueue.core.Job;
3333
import com.github.sonus21.rqueue.core.RqueueMessage;
34-
import com.github.sonus21.rqueue.core.RqueueMessageTemplate;
34+
import com.github.sonus21.rqueue.core.spi.MessageBroker;
3535
import com.github.sonus21.rqueue.dao.RqueueJobDao;
3636
import com.github.sonus21.rqueue.dao.RqueueQStatsDao;
3737
import com.github.sonus21.rqueue.exception.TimedOutException;
@@ -86,7 +86,7 @@ class RqueueTaskMetricsAggregatorServiceTest extends TestBase {
8686
private RqueueJobDao rqueueJobDao;
8787

8888
@Mock
89-
private RqueueMessageTemplate rqueueMessageTemplate;
89+
private MessageBroker messageBroker;
9090

9191
private RqueueJobMetricsAggregatorService rqueueJobMetricsAggregatorService;
9292

@@ -125,7 +125,7 @@ private RqueueExecutionEvent generateTaskEventWithStatus(MessageStatus status) {
125125
rqueueConfig,
126126
rqueueMessageMetadataService,
127127
rqueueJobDao,
128-
rqueueMessageTemplate,
128+
messageBroker,
129129
rqueueLockManager,
130130
queueDetail,
131131
messageMetadata,

0 commit comments

Comments
 (0)