Re: camel-ejb in JBoss AS7

2013-11-26 Thread simholte
I use Camel-cdi to create my CamelContext in a simple .war file that also exposes a REST endpoint. I then use a CamelProxy to inject data into my Camel route when the REST endpoint is called. This war file and the ejb get packaged up in a .ear file for deployment to AS7. Below is a snippet from

Re: How can trigger scanning a dynamic directory

2013-11-26 Thread Lothar Werzinger
pollEnrich looks like it's exactly what I am looking for. I will try it ASAP. Thanks! On Tue, Nov 26, 2013 at 6:09 PM, Henrique Viecili wrote: > You can use pollEnrich with a file: endpoint. > > Henrique Viecili > > > On 27 November 2013 12:10, Bilgin Ibryam wrote: > > > Hi Lothar, > > > > On

xmljson in DSL without custom format ?

2013-11-26 Thread fliot33
Hi, I'm trying to use have some XML of this string {"info1":886,"infor2": "azesdqsd"} ... ...

Re: camel-ejb in JBoss AS7

2013-11-26 Thread John D. Ament
Sounds like a classloader issue. How are you packaging camel into your app? On Tue, Nov 26, 2013 at 12:15 PM, simholte wrote: > I'm trying to use the Camel EJB component to make a call to an EJB but I'm > having problems calling the bean with anything other then a String. > > My Camel version is

Re: How can trigger scanning a dynamic directory

2013-11-26 Thread Henrique Viecili
You can use pollEnrich with a file: endpoint. Henrique Viecili On 27 November 2013 12:10, Bilgin Ibryam wrote: > Hi Lothar, > > One possible approach would be to have a processor that receives the > notification and creates dynamically a route based on the notification > header to poll the dir

camel-ejb in JBoss AS7

2013-11-26 Thread simholte
I'm trying to use the Camel EJB component to make a call to an EJB but I'm having problems calling the bean with anything other then a String. My Camel version is 2.12.1 When I expose an EJB like: @Stateless public class ProcessorService { public String process(String argument) {

consume existing(already consumed) files on modifed date or size

2013-11-26 Thread Tobias Hinz
hi, i want my route to re-consume files after the modified date or the file size changed. here is the route: &moveFailed=.error/${file:name.noext}-${date:now:MMddHHmmssSSS}.${file:ext}") .split().tokenize("\n") .choice() .when(simple("${prope

Re: consume existing(already consumed) files on modifed date or size

2013-11-26 Thread Tobias Hinz
eek, something got lost: public void configure() { CsvDataFormat csv = new CsvDataFormat(); csv.setDelimiter("\t"); from("file:///data/csv/test/?charset=ISO8859-1&noop=true&moveFailed=.error/${file:name.noext}-${date:now:MMddHHmmssSSS}.${file:ext}") .sp

Re: How can trigger scanning a dynamic directory

2013-11-26 Thread Bilgin Ibryam
Hi Lothar, One possible approach would be to have a processor that receives the notification and creates dynamically a route based on the notification header to poll the directory. Here is some pseudo code: from(jms) .process(new Processor() {

Re: Message router, multiple values

2013-11-26 Thread Bilgin Ibryam
It is not ideal, but you can achieve the same if you reorganize your route as following $foo1 = 'bar' $foo2 = 'bar' $foo3 = 'bar'

How can trigger scanning a dynamic directory

2013-11-26 Thread Lothar Werzinger
Hi, I would like to create a route that responds to a trigger (e.g. from a queue) and then scans a directory which path is given as a header attribute in the trigger message where I can then route the found files through a set of other components. However if I connect a file component to an input

Re: A simple Aggregator use case

2013-11-26 Thread ChrisS
Thank you for your quick replies. As I was hoping, I was able to build my use case with just minor java coding in AggregationStrategy. I have just added the JIRA request here: https://issues.apache.org/jira/browse/CAMEL-7015 Best regards, CS -- View this message in context: http://camel.46

Re: File Consuming

2013-11-26 Thread Stephan Burkard
Hi I don't know if I understand you correctly. You can use the File2 component (http://camel.apache.org/file2.html) to consume the files and route the generated messages to a simple bean that removes the content you don't want from the message body. Regards Stephan On Tue, Nov 26, 2013 at 12:1

route cxf jaxb webservices -> NoTypeConversionAvailableException

2013-11-26 Thread tapdur
hi all, i desesperate to run a "simple" use case wit camel. http://localhost:9008/wservice/services/wsservice-1.0"; serviceClass="WsServiceImpl" /> http://wservice/v1"; xmlns:data="http://wservice/v1/root";> http://camel.apache.org/

Use of Camel ErrorHandler in transacted routes

2013-11-26 Thread Stephan Burkard
Hi Camel users I have a Camel workflow that spans two asynchronous transacted routes divided by queues. The second one is calling a direct-route that calls another direct-route (see below for detailed example Spring-DSL structure). The reason for the direct routes is that the processing of them mu

XPath with CXF Pojo Endpoint

2013-11-26 Thread jjathman
I have a CXF endpoint that is deserializing the XML received in to a POJO (JAXB objects). This is all working just fine for us. Now we had a new requirement come up to take a fragment of the received XML and audit it in a particular way. What seems like the most ideal solution would be to use the s

Re: Using NMR endpoint in an Transacted route

2013-11-26 Thread Neeraj Mahajan
Charles, Claus Thank you very much for your replies It was a great help and it worked perfectly for me, I have also seen "nmr" documentation and I can see It will use the same thread if we enable the synchronous mode while using the nmr endpoint. I am going to use "nmr" with synchronus mode in m

Re: How to print blank for decimals and long datatype with null value

2013-11-26 Thread Claus Ibsen
Hi I suggest to ask at the beanio user forum if that is possible and how to do that. On Tue, Nov 26, 2013 at 9:29 AM, skumar wrote: > Hi everyone, I have a decimal data type billingFxRate defined > in a pojo class and mapped to a BeanIo file like When the value of this > fie

Re: bean Registry

2013-11-26 Thread Claus Ibsen
If you use spring xml file, then the registry is by default the spring app context. So you can just define your holder bean in the spring xml file And Camel can lookup in spring and find the bean by its id On Tue, Nov 26, 2013 at 3:55 PM, Singh, Surya Prakash wrote: > How do you achieve this

Message router, multiple values

2013-11-26 Thread fliot33
Hi, As per http://camel.apache.org/message-router.html How could I do something like that : $foo1 = 'bar' $foo2 = 'bar' $foo3 = 'bar'

Re: Mutlicasting to dymanic recipient list

2013-11-26 Thread Claus Ibsen
Yeah Camel 2.2 is very old. Is this the version you use? On Tue, Nov 26, 2013 at 1:39 PM, Shiv wrote: > I am able to get it working by combining recipientList and > interceptFromEndpoint features. > > >- this class uses > CamelInterceptedEndpoint to identify where exchange is getti

Re: Using NMR endpoint in an Transacted route

2013-11-26 Thread Claus Ibsen
Sounds good. Ah yeah the synchronous option on the nmr endpoint may also work, as Charles pointed out. But using direct-vm is maybe in the longer run better, as you do not have dependency on ServiceMix, as direct-vm is from camel-core. On Tue, Nov 26, 2013 at 10:57 AM, Neeraj Mahajan wrote: > Th

Re: Using NMR endpoint in an Transacted route

2013-11-26 Thread Neeraj Mahajan
Thank you very much Claus, the application transaction issue is now resolved with the direct-vm component. The good thing is that I am using the 2.10 version of camel from which this component has been introduced. -- View this message in context: http://camel.465427.n5.nabble.com/Using-NMR-end

camel-http client handling 503 error

2013-11-26 Thread pchakinala
Hi, We are using Camel-2.8.3 and SMX -4.4.X. Our usecase flow is like below. Client ---> Camel-http client > Http Service We were able to handle/ catch all the exceptions and observed that when HTTP 503 (service not available) error occurred control is going to custom exception handler

RE: bean Registry

2013-11-26 Thread Singh, Surya Prakash
How do you achieve this when using spring dsl to create a camelcontext? http://camel.apache.org/schema/spring";> Is there a way to inject a SimpleRegistry when creating a CamelContext in spring DSL? What is the namespace for that? Regards, -Original Message- From: Willem jiang [mailt

Re: Mutlicasting to dymanic recipient list

2013-11-26 Thread Shiv
I am able to get it working by combining recipientList and interceptFromEndpoint features. - this class uses CamelInterceptedEndpoint to identify where exchange is getting forwarded and uses that value as Receiver in next step ${in.header.Receiver}

Re: Problem with consuming from endpoint

2013-11-26 Thread trilochan237
Thanks for the quick solution.Its working fine -- View this message in context: http://camel.465427.n5.nabble.com/Problem-with-consuming-from-endpoint-tp5743831p5743850.html Sent from the Camel - Users mailing list archive at Nabble.com.

File Consuming

2013-11-26 Thread Manoranjitham G
Hi, How to remove the file content header and footer(like first line and last line) by using camel. -- View this message in context: http://camel.465427.n5.nabble.com/File-Consuming-tp5743848.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Reading more files from aws-S3 than expected

2013-11-26 Thread Jesper Olsen
Yes, I have specified the prefix. However I have found a workaround to the problem. Since we also developed the application that writes to S3, we changed it to write directly to a bucket, without a prefix. That solves the problem when reading and deleting the files. Kind Regards Jesper Olsen --

Re: Problem with consuming from endpoint

2013-11-26 Thread Dharmendra Patel
replaceproducer.sendBody("direct:step1", "test message"); with producer.asyncSendBody("direct:step1", "test message"); and you don't need to start consumer manually( consumer.start();) as camel does it automatically when ConsumerTemplate is created. -- Forwarded message --

How to print blank for decimals and long datatype with null value

2013-11-26 Thread skumar
Hi everyone, I have a decimal data type billingFxRate defined in a pojo class and mapped to a BeanIo file like When the value of this field is null it prints it as 0.000 in the outbound file.I want when it is blank it should print a space or nothing.I tried to use required=f