You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2024/02/09 09:58:32 UTC
(camel-spring-boot-examples) branch main updated: Regen and fix compile
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot-examples.git
The following commit(s) were added to refs/heads/main by this push:
new 230bacc Regen and fix compile
230bacc is described below
commit 230bacc6e3d490232d9b62da5aa65767e68ae563
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Feb 9 10:58:22 2024 +0100
Regen and fix compile
---
README.adoc | 4 +++-
.../java/org/apache/camel/example/kafka/avro/KafkaAvroProcessor.java | 2 +-
.../apache/camel/example/kafka/offsetRepository/KafkaProcessor.java | 2 +-
3 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/README.adoc b/README.adoc
index bcc8c13..fca190c 100644
--- a/README.adoc
+++ b/README.adoc
@@ -27,7 +27,7 @@ readme's instructions.
=== Examples
// examples: START
-Number of Examples: 54 (0 deprecated)
+Number of Examples: 55 (0 deprecated)
[width="100%",cols="4,2,4",options="header"]
|===
@@ -113,6 +113,8 @@ Number of Examples: 54 (0 deprecated)
| link:supervising-route-controller/readme.adoc[Supervising Route Controller] (supervising-route-controller) | Management and Monitoring | An example showing how to work with Camel's Supervising Route Controller and Spring Boot
+| link:activemq/readme.adoc[Activemq] (activemq) | Messaging | An example showing how to work with Camel, ActiveMQ openwire and Spring Boot
+
| link:amqp/readme.adoc[Amqp] (amqp) | Messaging | An example showing how to work with Camel, ActiveMQ Amqp and Spring Boot
| link:artemis/readme.adoc[Artemis] (artemis) | Messaging | An example showing how to work with Camel, ActiveMQ Artemis and Spring Boot
diff --git a/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/KafkaAvroProcessor.java b/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/KafkaAvroProcessor.java
index 6c0c0d0..9baa4d8 100644
--- a/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/KafkaAvroProcessor.java
+++ b/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/KafkaAvroProcessor.java
@@ -31,7 +31,7 @@ public class KafkaAvroProcessor implements Processor {
@Override
public void process(Exchange exc) throws Exception {
@SuppressWarnings("unchecked")
- List<RecordMetadata> recordMetaData1 = (List<RecordMetadata>) exc.getIn().getHeader(KafkaConstants.KAFKA_RECORDMETA);
+ List<RecordMetadata> recordMetaData1 = (List<RecordMetadata>) exc.getIn().getHeader(KafkaConstants.KAFKA_RECORD_META);
for (RecordMetadata rd: recordMetaData1) {
LOG.info("producer partition is:" + rd.partition());
LOG.info("producer partition message is:" + rd.toString());
diff --git a/kafka-offsetrepository/src/main/java/org/apache/camel/example/kafka/offsetRepository/KafkaProcessor.java b/kafka-offsetrepository/src/main/java/org/apache/camel/example/kafka/offsetRepository/KafkaProcessor.java
index 71c9f2c..754884d 100644
--- a/kafka-offsetrepository/src/main/java/org/apache/camel/example/kafka/offsetRepository/KafkaProcessor.java
+++ b/kafka-offsetrepository/src/main/java/org/apache/camel/example/kafka/offsetRepository/KafkaProcessor.java
@@ -31,7 +31,7 @@ public class KafkaProcessor implements Processor {
@Override
public void process(Exchange exc) throws Exception {
@SuppressWarnings("unchecked")
- List<RecordMetadata> recordMetaData1 = (List<RecordMetadata>) exc.getIn().getHeader(KafkaConstants.KAFKA_RECORDMETA);
+ List<RecordMetadata> recordMetaData1 = (List<RecordMetadata>) exc.getIn().getHeader(KafkaConstants.KAFKA_RECORD_META);
for (RecordMetadata rd: recordMetaData1) {
LOG.info("producer partition is:" + rd.partition());
}