RE: Camel-ahc-ws netty runtime problems

Thanks Claus! I wasn't aware of the *-starter packages for Camel. Much appreciated for the pointer. Moving to the 'camel-ahc-ws-starter' package and adjusting all other camel* packages I now get a different exception. Any help/pointers are appreciated. Thanks

Re: Question on multicast to pipelines

Hi Brad, yes that's the definition of multicast but the documentation also suggests that pipelines are supposed to be implicitly derived from a vararg to(...) statement. In any case I don't understand how the multicast could leak into a vararg pipeline(...). It really feels like a bug to me, but

Re: Question on multicast to pipelines

Hi Darius, that's correct, I'm expecting the START message to enter the pipelines from their heads. On Fri, 28 Oct 2016 at 20:43, DariusX wrote: > It isn't clear what you want as the expected output. > From your example, it seems that you have two "pipelines" and you

Re: smb cannot connect to server

Hi, Looking into the source of the jcifs library (where the exception originates) it seems that the root cause of the exception is a UnknownHostException. See the FAQ for the jcifs library (https://jcifs.samba.org/FAQ.html#ukhost). Is the server address resolvable over DNS you can try changing

Re: Alternative to Spring Boot websocket/stomp support in OSGI

I'm not sure exactly what you're looking for here but will give it a shot. If you use a it should do what you are after. amq:queue::${header.destinationVariable} I don't know if that destinationVariable is what is in the header or if you send another name. But effectively that EIP is used to

Re: Problem: Concatenate the different input(from different route) using aggreagationStrategy

Sorry... I see what you are doing. Which is line 19? On Fri, Oct 28, 2016 at 3:32 PM, Steve973 wrote: > There is no way that you can aggregate like that. Both messages need to > be sent to the same endpoint, and they need to have some sort of > aggregation id in order for

Re: Problem: Concatenate the different input(from different route) using aggreagationStrategy

There is no way that you can aggregate like that. Both messages need to be sent to the same endpoint, and they need to have some sort of aggregation id in order for the aggregation to know which messages to combine. Let me know if this is unclear or if you need more information. On Thu, Oct 27,

Alternative to Spring Boot websocket/stomp support in OSGI

Spring boot offers the capability to develop interactive web apps using websockets communication with a browser based client (JavaScript UI). The stomp protocol is used on websockets and then mapped to activemq queues or topics, allowing server side components to interact with a web client

Re: Question on multicast to pipelines

The multicast sends the same message to all the to or pipeline elements it finds in its definition. That's why it is a "multicast". What is it you are trying to accomplish here and don't focus so much on the mechanics of doing it. Without knowing what your business case/problem definition is

Re: Question on multicast to pipelines

It isn't clear what you want as the expected output. >From your example, it seems that you have two "pipelines" and you want to multicast to send the message down both pipelines. But, that's probably not what you really want. -- View this message in context:

Using metrics publisher with camel-hysterix

Can someone let me know if it is possible to use metrics-publisher with camel-hysterix ? My intention is to publish metrics to Graphite. I am using camel

smb cannot connect to server

Camel: 2.16.3, camel-jcifs: 2.15.0 (latest) I am using jCIFS and attempting to connect to a remote share in a different domain. I can connect to this share without issue using Windows Explorer (Win 7) and the UNC path. I can also connect through Linux using smbclient (SuSE 11,

camel 2.18.0 rabbitmq component fails under Karaf

trying to install camel-rabbitmq under Karaf 4.0.6 fails unable to resolve com.rabbitmq.client. Was working fine in 2.17.3 Any ideas or help? ka...@sis.gt.common()> feature:install camel-rabbitmq Error executing command: Unable to resolve root: missing requirement [root] osgi.identity;

Re: Setting TTL on Netty4 multicast endpoint

Hi, I think it should be "IP_MULTICAST_TTL" https://github.com/netty/netty/blob/4.1/transport/src/main/java/io/netty/channel/ChannelOption.java#L122 But note that the ChannelOptions are no longer string literal unlike netty3... hopefully something like following would work if

Re: Setting TTL on Netty4 multicast endpoint

Aha, many thanks Tomo. I'll raise the issue in JIRA. Following the update, do you know what I'd replace the 'XXX' with in the 'option.XXX' option to update the multicast TTL? Regards, Rob -- View this message in context:

Re: Setting TTL on Netty4 multicast endpoint

Hi, I just took a look at this one, it seems camel-netty4 doesn't yet implement option.XXX https://github.com/apache/camel/blob/master/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java#L417-L424 Would you file a JIRA for it? Thanks, Tomo On 10/27/2016

Re: Is GenericFileOperationFailedException handled differently than other exceptions?

Hi again, Let me rephrase: My problem is that GenericFileOperationFailedException goes directly to the dead letter channel and and completely bypass redelivery. I don't have any onException statements which reset maximumRedeliveries to 0. Is this excepted behavior? (In my earlier post I

Question on multicast to pipelines

Hi all, I had some trouble figuring out how to multicast to some pipelines. I eventually found a [working] definition, but I also expected other forms to work such as: .multicast().aggregationStrategy(AggregationStrategies.groupedExchange()) .pipeline("A", "B") .pipeline("C", "D")

Re: JpaConsumer endpoint not showing up in hawtio.

Hi Are you creating the endpoint instance yourself eg do you do JpaEndpoint jpaEventoPieza = new JpaEndpoint(); Its likely related to this fact if you create the endpoint instance yourself. Also try upgrading Camel to a newer release. On Thu, Oct 27, 2016 at 2:38 PM, raulsperoni

Re: help with WARN messages in camel 2.18.0

Essentially you can ignore those WARNs but you can also configure what Camel should do with the TypeConverterExists option. See for example this unit test https://github.com/apache/camel/blob/master/camel-core/src/test/java/org/apache/camel/impl/TypeConverterRegistryTest.java On Thu, Oct 27,

Re: camel 2.18.0 file component filter example

Hi You can try look in the unit tests of camel-core as there is likely some unit tests covering this functionality. On Thu, Oct 27, 2016 at 1:08 PM, gustavo.maurizio wrote: > Can someone please provide an example of the new file2 filterFile and > filterDirectory usage with

Re: Camel-ahc-ws netty runtime problems

When using Spring Boot and Camel 2.18 onwards you should use the -starter components, eg camel-ahc-ws-starter and so on. On Tue, Oct 25, 2016 at 8:21 PM, Ingram, Stuart wrote: > Using the following dependencies > > compile('org.apache.camel:camel-jackson:2.18.0') >

Re: Losing mi sanity on pipeline testing

Hi Quinn, Thanks that's correct, but really I was looking for a way to test the construct timer+broadcast+pipelines+merged_processor. Shoving the datasets to fake the remotes inside the pipelines made sense. Anyway, I'll see if I have time to get back to this setup sometime later. Right now I'm

Re: apache camel returns statusCode:500

Hi Avnish, Thanks for your replying. I finally found the problem is the json format I passed to the server is incorrect...Then it works now. Thanks, Meng -- View this message in context: http://camel.465427.n5.nabble.com/apache-camel-returns-statusCode-500-tp578p5789367.html Sent from

Re: Problem: Concatenate the different input(from different route) using aggreagationStrategy

I change to .aggregate(simple("${body}"), new JoinReplyAggregationStrategy()), now no exceptions, but only returns the second exchange from route 2. No original payload comes in to aggregate -- View this message in context:

Problem: Concatenate the different input(from different route) using aggreagationStrategy

Hi, I now design three route to process my input message and want to concatenate them using my aggregation strategy.Here is my design: payload ->route1:"direct:start", do multicast to route 2("direct:a") and route 3("direct:b") in route 2("direct:a"), do multicast to 8 servers, and use