Regen and fix compile

apache · Feb 9, 2024 · 230bacc · 230bacc
1 parent 8e2dbdc
commit 230bacc
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git 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
@@ -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/...ository/src/main/java/org/apache/camel/example/kafka/offsetRepository/KafkaProcessor.java b/...ository/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());
         }