Skip to content

Commit e48da7a

Browse files
committed
refactor: remove duplicate metrics aggregator service from rqueue-web
Clean up duplicate RqueueJobMetricsAggregatorService from rqueue-web/src/main/java after moving the interface to rqueue-core/metrics as RqueueMetricsAggregatorService. Move the test RqueueTaskMetricsAggregatorServiceTest from rqueue-web to rqueue-core/src/test/java/com/github/sonus21/rqueue/metrics/, updating package declarations and class references to use the renamed RqueueMetricsAggregatorService. This ensures a single source of truth for the metrics aggregator interface in the core module. Assisted-By: Claude Code
1 parent ae30092 commit e48da7a

2 files changed

Lines changed: 3 additions & 341 deletions

File tree

rqueue-web/src/test/java/com/github/sonus21/rqueue/web/service/RqueueTaskMetricsAggregatorServiceTest.java renamed to rqueue-core/src/test/java/com/github/sonus21/rqueue/metrics/RqueueTaskMetricsAggregatorServiceTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
*
1515
*/
1616

17-
package com.github.sonus21.rqueue.web.service;
17+
package com.github.sonus21.rqueue.metrics;
1818

1919
import static org.junit.jupiter.api.Assertions.assertEquals;
2020
import static org.junit.jupiter.api.Assertions.assertNotNull;
@@ -88,12 +88,12 @@ class RqueueTaskMetricsAggregatorServiceTest extends TestBase {
8888
@Mock
8989
private MessageBroker messageBroker;
9090

91-
private RqueueJobMetricsAggregatorService rqueueJobMetricsAggregatorService;
91+
private RqueueMetricsAggregatorService rqueueJobMetricsAggregatorService;
9292

9393
@BeforeEach
9494
public void initService() throws IllegalAccessException {
9595
MockitoAnnotations.openMocks(this);
96-
rqueueJobMetricsAggregatorService = new RqueueJobMetricsAggregatorService(
96+
rqueueJobMetricsAggregatorService = new RqueueMetricsAggregatorService(
9797
rqueueConfig, rqueueWebConfig, rqueueLockManager, rqueueQStatsDao);
9898
doReturn(true).when(rqueueWebConfig).isCollectListenerStats();
9999
doReturn(1).when(rqueueWebConfig).getStatsAggregatorThreadCount();

rqueue-web/src/main/java/com/github/sonus21/rqueue/web/service/RqueueJobMetricsAggregatorService.java

Lines changed: 0 additions & 338 deletions
This file was deleted.

0 commit comments

Comments
 (0)