Skip to content

Commit e4002a8

Browse files
author
Roman Lovakov
committed
Correct setting kafka graceful-shutdown property for dev and test profiles
1 parent 9ac65b1 commit e4002a8

File tree

1 file changed

+1
-8
lines changed

1 file changed

+1
-8
lines changed

extensions/smallrye-reactive-messaging-kafka/deployment/src/main/java/io/quarkus/smallrye/reactivemessaging/kafka/deployment/SmallRyeReactiveMessagingKafkaProcessor.java

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -201,14 +201,7 @@ public void defaultChannelConfiguration(
201201

202202
if (launchMode.getLaunchMode().isDevOrTest()) {
203203
if (!buildTimeConfig.enableGracefulShutdownInDevAndTestMode()) {
204-
List<AnnotationInstance> incomings = discoveryState.findRepeatableAnnotationsOnMethods(DotNames.INCOMING);
205-
List<AnnotationInstance> outgoings = discoveryState.findRepeatableAnnotationsOnMethods(DotNames.OUTGOING);
206-
List<AnnotationInstance> channels = discoveryState.findAnnotationsOnInjectionPoints(DotNames.CHANNEL);
207-
List<AnnotationInstance> annotations = new ArrayList<>();
208-
annotations.addAll(incomings);
209-
annotations.addAll(outgoings);
210-
annotations.addAll(channels);
211-
for (AnnotationInstance annotation : annotations) {
204+
for (AnnotationInstance annotation : discoveryState.findRepeatableAnnotationsOnMethods(DotNames.INCOMING)) {
212205
String channelName = annotation.value().asString();
213206
if (!discoveryState.isKafkaConnector(channelsManagedByConnectors, true, channelName)) {
214207
continue;

0 commit comments

Comments
 (0)