Skip to content

Commit a87d7ae

Browse files
author
smallrye-ci
committed
[RELEASE] - Bump version to 4.25.0
1 parent 5ab30ae commit a87d7ae

File tree

34 files changed

+38
-37
lines changed

34 files changed

+38
-37
lines changed

api/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
<parent>
66
<groupId>io.smallrye.reactive</groupId>
77
<artifactId>smallrye-reactive-messaging</artifactId>
8-
<version>999-SNAPSHOT</version>
8+
<version>4.25.0</version>
99
</parent>
1010

1111
<artifactId>smallrye-reactive-messaging-api</artifactId>

documentation/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
<parent>
88
<groupId>io.smallrye.reactive</groupId>
99
<artifactId>smallrye-reactive-messaging</artifactId>
10-
<version>999-SNAPSHOT</version>
10+
<version>4.25.0</version>
1111
</parent>
1212

1313
<artifactId>documentation</artifactId>

documentation/src/main/java/kafka/inbound/KafkaRecordBatchExample.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,8 @@ public class KafkaRecordBatchExample {
2020
// <code>
2121
@Incoming("prices")
2222
public CompletionStage<Void> consumeMessage(Message<List<Double>> msg) {
23-
IncomingKafkaRecordBatchMetadata<String, Double> batchMetadata = msg.getMetadata(IncomingKafkaRecordBatchMetadata.class).get();
23+
IncomingKafkaRecordBatchMetadata<String, Double> batchMetadata = msg.getMetadata(IncomingKafkaRecordBatchMetadata.class)
24+
.get();
2425
for (ConsumerRecord<String, Double> record : batchMetadata.getRecords()) {
2526
int partition = record.partition();
2627
long offset = record.offset();
@@ -42,7 +43,8 @@ public void consumeRecords(ConsumerRecords<String, Double> records) {
4243

4344
// <batch>
4445
@Incoming("prices")
45-
public void consumeRecords(ConsumerRecords<String, Double> records, IncomingKafkaRecordBatchMetadata<String, Double> metadata) {
46+
public void consumeRecords(ConsumerRecords<String, Double> records,
47+
IncomingKafkaRecordBatchMetadata<String, Double> metadata) {
4648
for (TopicPartition partition : records.partitions()) {
4749
for (ConsumerRecord<String, Double> record : records.records(partition)) {
4850
TracingMetadata tracing = metadata.getMetadataForRecord(record, TracingMetadata.class);

documentation/src/main/java/pulsar/inbound/PulsarMessageBatchExample.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,11 +37,10 @@ public void consumeMessages(org.apache.pulsar.client.api.Messages<Double> messag
3737
}
3838
// </code>
3939

40-
4140
// <batch>
4241
@Incoming("prices")
4342
public void consumeMessages(org.apache.pulsar.client.api.Messages<Double> messages,
44-
PulsarIncomingBatchMessageMetadata metadata) {
43+
PulsarIncomingBatchMessageMetadata metadata) {
4544
for (org.apache.pulsar.client.api.Message<Double> message : messages) {
4645
TracingMetadata tracing = metadata.getMetadataForMessage(message, TracingMetadata.class);
4746
if (tracing != null) {

examples/amqp-quickstart/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
<parent>
66
<groupId>io.smallrye.reactive</groupId>
77
<artifactId>smallrye-reactive-messaging</artifactId>
8-
<version>999-SNAPSHOT</version>
8+
<version>4.25.0</version>
99
<relativePath>../../pom.xml</relativePath>
1010
</parent>
1111

examples/kafka-quickstart-kotlin/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
<parent>
66
<groupId>io.smallrye.reactive</groupId>
77
<artifactId>smallrye-reactive-messaging</artifactId>
8-
<version>999-SNAPSHOT</version>
8+
<version>4.25.0</version>
99
<relativePath>../../pom.xml</relativePath>
1010
</parent>
1111

examples/kafka-quickstart/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
<parent>
66
<groupId>io.smallrye.reactive</groupId>
77
<artifactId>smallrye-reactive-messaging</artifactId>
8-
<version>999-SNAPSHOT</version>
8+
<version>4.25.0</version>
99
<relativePath>../../pom.xml</relativePath>
1010
</parent>
1111

examples/mqtt-quickstart/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
<parent>
66
<groupId>io.smallrye.reactive</groupId>
77
<artifactId>smallrye-reactive-messaging</artifactId>
8-
<version>999-SNAPSHOT</version>
8+
<version>4.25.0</version>
99
<relativePath>../../pom.xml</relativePath>
1010
</parent>
1111

examples/quickstart/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
<parent>
66
<groupId>io.smallrye.reactive</groupId>
77
<artifactId>smallrye-reactive-messaging</artifactId>
8-
<version>999-SNAPSHOT</version>
8+
<version>4.25.0</version>
99
<relativePath>../../pom.xml</relativePath> </parent>
1010

1111
<artifactId>reactive-messaging-quickstart</artifactId>

examples/rabbitmq-quickstart/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
<parent>
66
<groupId>io.smallrye.reactive</groupId>
77
<artifactId>smallrye-reactive-messaging</artifactId>
8-
<version>999-SNAPSHOT</version>
8+
<version>4.25.0</version>
99
<relativePath>../../pom.xml</relativePath>
1010
</parent>
1111

0 commit comments

Comments
 (0)