Skip to content

Commit 0458aa1

Browse files
committed
refactor: move inner class to the end of the class
Signed-off-by: Chaedong Im <[email protected]>
1 parent 27d7eb7 commit 0458aa1

File tree

1 file changed

+12
-12
lines changed

1 file changed

+12
-12
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/FilteringMessageListenerAdapter.java

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -41,18 +41,6 @@ public class FilteringMessageListenerAdapter<K, V>
4141
extends AbstractFilteringMessageListener<K, V, MessageListener<K, V>>
4242
implements AcknowledgingConsumerAwareMessageListener<K, V>, FilteringAware<K, V> {
4343

44-
private static class FilterResult<K, V> {
45-
46-
final ConsumerRecord<K, V> record;
47-
48-
final boolean wasFiltered;
49-
50-
FilterResult(ConsumerRecord<K, V> record, boolean wasFiltered) {
51-
this.record = record;
52-
this.wasFiltered = wasFiltered;
53-
}
54-
55-
}
5644

5745
private final boolean ackDiscarded;
5846

@@ -142,4 +130,16 @@ public void onMessage(ConsumerRecord<K, V> data, @Nullable Consumer<?, ?> consum
142130
onMessage(data, null, consumer);
143131
}
144132

133+
private static class FilterResult<K, V> {
134+
135+
final ConsumerRecord<K, V> record;
136+
137+
final boolean wasFiltered;
138+
139+
FilterResult(ConsumerRecord<K, V> record, boolean wasFiltered) {
140+
this.record = record;
141+
this.wasFiltered = wasFiltered;
142+
}
143+
144+
}
145145
}

0 commit comments

Comments
 (0)