camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Claus Ibsen (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (CAMEL-7339) Transfer exchange in Camel-Kafka
Date Thu, 03 Apr 2014 06:55:16 GMT

    [ https://issues.apache.org/jira/browse/CAMEL-7339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13958579#comment-13958579
] 

Claus Ibsen commented on CAMEL-7339:
------------------------------------

At first glance this patch seem to big and changes too much,

We have some transferExchange logic from camel-core to serialize/de-serialize an exchange
which we use for the components that support transferExchange option. 

The patch should reuse that logic. It's this class
org.apache.camel.impl.DefaultExchangeHolder

And you can find an examples used in these components
./camel-hawtdb/src/main/java/org/apache/camel/component/hawtdb/HawtDBCamelCodec.java:import
org.apache.camel.impl.DefaultExchangeHolder;
./camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java:import
org.apache.camel.impl.DefaultExchangeHolder;
./camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaProducer.java:import
org.apache.camel.impl.DefaultExchangeHolder;
./camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java:import org.apache.camel.impl.DefaultExchangeHolder;
./camel-leveldb/src/main/java/org/apache/camel/component/leveldb/LevelDBCamelCodec.java:import
org.apache.camel.impl.DefaultExchangeHolder;
./camel-mina/src/main/java/org/apache/camel/component/mina/MinaPayloadHelper.java:import org.apache.camel.impl.DefaultExchangeHolder;
./camel-mina2/src/main/java/org/apache/camel/component/mina2/Mina2PayloadHelper.java:import
org.apache.camel.impl.DefaultExchangeHolder;
./camel-netty/src/main/java/org/apache/camel/component/netty/NettyPayloadHelper.java:import
org.apache.camel.impl.DefaultExchangeHolder;
./camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcCamelCodec.java:import
org.apache.camel.impl.DefaultExchangeHolder;


Maybe you can work on a patch that uses the current code base as-is, and adds support for
transferExchange using the logic from camel-core.

> Transfer exchange in Camel-Kafka 
> ---------------------------------
>
>                 Key: CAMEL-7339
>                 URL: https://issues.apache.org/jira/browse/CAMEL-7339
>             Project: Camel
>          Issue Type: Improvement
>          Components: camel-kafka
>    Affects Versions: 2.13.0
>            Reporter: Ioannis Polyzos
>             Fix For: 2.14.0
>
>         Attachments: camel-kafka.diff
>
>
> There is cases that need to transfer the whole exchange through kafka.  I would like
to share a patch for camel-kafka that support transfer exchange along with some more minor
improvements such as more flexible configuration and default values preset.



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Mime
View raw message