Skip to content

Commit 6bdabf4

Browse files
committed
chore(nats): poller fetch-wait fix, producer-mode wiring, copyright sweep
- RqueueMessagePoller now forwards the configured pollingInterval to MessageBroker.pop instead of Duration.ZERO, letting JetStream long-poll rather than spinning $JS.API.CONSUMER.MSG.NEXT requests at full speed. Covered by a new test in RqueueMessageListenerContainerBrokerBranchTest. - RqueueNatsAutoConfig wires RqueueConfig into NatsStreamValidator so producer-only deployments skip durable consumer creation. - StringUtils-based null/empty checks in RqueueNatsAutoConfig. - Copyright headers normalized to 2026 across the NATS-touched files. Assisted-By: Claude Code
1 parent 0dbdda3 commit 6bdabf4

81 files changed

Lines changed: 147 additions & 103 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ ext {
8585

8686
subprojects {
8787
group = "com.github.sonus21"
88-
version = "4.0.0-SK3"
88+
version = "4.0.0-SK5"
8989

9090
dependencies {
9191
// https://mvnrepository.com/artifact/org.springframework/spring-messaging

rqueue-core/src/main/java/com/github/sonus21/rqueue/config/NatsBackendCondition.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2024-2026 Sonu Kumar
2+
* Copyright (c) 2026 Sonu Kumar
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* You may not use this file except in compliance with the License.

rqueue-core/src/main/java/com/github/sonus21/rqueue/config/RedisBackendCondition.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2024-2026 Sonu Kumar
2+
* Copyright (c) 2026 Sonu Kumar
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* You may not use this file except in compliance with the License.

rqueue-core/src/main/java/com/github/sonus21/rqueue/exception/BackendCapabilityException.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2024-2026 Sonu Kumar
2+
* Copyright (c) 2026 Sonu Kumar
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* You may not use this file except in compliance with the License.

rqueue-core/src/main/java/com/github/sonus21/rqueue/listener/RqueueMessagePoller.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,11 @@ abstract class RqueueMessagePoller extends MessageContainerBase {
6161
private List<RqueueMessage> getMessages(QueueDetail queueDetail, int count) {
6262
return rqueueBeanProvider
6363
.getMessageBroker()
64-
.pop(queueDetail, queueDetail.resolvedConsumerName(), count, Duration.ZERO);
64+
.pop(
65+
queueDetail,
66+
queueDetail.resolvedConsumerName(),
67+
count,
68+
Duration.ofMillis(pollingInterval));
6569
}
6670

6771
private void execute(

rqueue-core/src/main/java/com/github/sonus21/rqueue/metrics/RqueueQueueMetricsProvider.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2024-2026 Sonu Kumar
2+
* Copyright (c) 2026 Sonu Kumar
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* You may not use this file except in compliance with the License.

rqueue-core/src/main/java/com/github/sonus21/rqueue/repository/MessageBrowsingRepository.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2024-2026 Sonu Kumar
2+
* Copyright (c) 2026 Sonu Kumar
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* You may not use this file except in compliance with the License.

rqueue-core/src/main/java/com/github/sonus21/rqueue/serdes/RqJacksonSerDes.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2024-2026 Sonu Kumar
2+
* Copyright (c) 2026 Sonu Kumar
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* You may not use this file except in compliance with the License.

rqueue-core/src/main/java/com/github/sonus21/rqueue/serdes/RqueueSerDes.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2024-2026 Sonu Kumar
2+
* Copyright (c) 2026 Sonu Kumar
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* You may not use this file except in compliance with the License.

rqueue-core/src/test/java/com/github/sonus21/rqueue/core/impl/ReactiveRqueueMessageEnqueuerBrokerRoutingTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2024-2026 Sonu Kumar
2+
* Copyright (c) 2026 Sonu Kumar
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* You may not use this file except in compliance with the License.

0 commit comments

Comments
 (0)