Re: Slow FTP

[yogu13]

Hello,

Which version of Apache Camel is being used along with the JDK version.

Regards,
-Yogesh



--
View this message in context: 
http://camel.465427.n5.nabble.com/Slow-FTP-tp5764223p5764240.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Java DSL kick-starting routes, is this possible yet?

[yogu13]

https://git-wip-us.apache.org/repos/asf?p=camel.git;a=blob;f=examples/camel-example-jms-file/src/main/java/org/apache/camel/example/jmstofile/CamelJmsToFileExample.java;h=bf0c708d9a67f7bc5c7a6e2f1e17a90ca7821c01;hb=HEAD

Hope this helps!

Regards,
-Yogesh



--
View this message in context: 
http://camel.465427.n5.nabble.com/Java-DSL-kick-starting-routes-is-this-possible-yet-tp5764227p5764242.html
Sent from the Camel - Users mailing list archive at Nabble.com.

RE: how to send response to the webservice

[chaituu]

thanks for all replies.

as all you said we can resolve this issue by using any of one of these
following patterns.

1)
2)
3)




--
View this message in context: 
http://camel.465427.n5.nabble.com/how-to-send-response-to-the-webservice-after-generated-the-csv-route-tp5764065p5764241.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Slow FTP

[Willem Jiang]

Can you try to setup the FtpClient with a big buffer just like this ?

from("ftp://foo@myserver?password=secret&ftpClient.bufferSize=1000";).to("bean:foo");

--  
Willem Jiang

Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.iteye.com (Chinese)
Twitter: willemjiang  
Weibo: 姜宁willem



On March 16, 2015 at 9:08:44 PM, ulsa (ulrik.sandb...@jayway.com) wrote:
> One of the files on my FTP server is ~200MB. I'm using Camel FTP from an EC2
> instance (Ubuntu 14), and I get a connection reset error on that file after
> 25 minutes. However, when using command line ftp on the same machine, the
> same file takes 38 seconds to download. I have set option
> localWorkDirectory=/var/tmp/camel. Is there any other configuration trick
> that I have missed?
>  
>  
>  
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Slow-FTP-tp5764223.html  
> Sent from the Camel - Users mailing list archive at Nabble.com.
>  

Re: Names of custom MBeans contain hex-number at the end

[Willem Jiang]

The hex-number is the instanceId to avoid the name conflict. 
If you want to get ride of it, you need to make sure the service is a 
StaticService which means you have only one instance per Camel Context.

You can find the below code in the DefaultManagementNamingStrategy.

public ObjectName getObjectNameForService(CamelContext context, Service 
service) throws MalformedObjectNameException {
        StringBuilder buffer = new StringBuilder();
        buffer.append(domainName).append(":");
        buffer.append(KEY_CONTEXT + 
"=").append(getContextId(context)).append(",");
        buffer.append(KEY_TYPE + "=" + TYPE_SERVICE + ",");
        buffer.append(KEY_NAME + 
"=").append(service.getClass().getSimpleName());
        if (!(service instanceof StaticService)) {
            
buffer.append("(").append(ObjectHelper.getIdentityHashCode(service)).append(")");
        }
        return createObjectName(buffer);
    }

--  
Willem Jiang

Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.iteye.com (Chinese)
Twitter: willemjiang  
Weibo: 姜宁willem



On March 17, 2015 at 12:31:06 AM, dermoritz (tantea...@hotmail.com) wrote:
> I created some custom MBeans (implementing Service). they work as they should
> but for some reason their names have some hexadecimal number at the end e.g.
> "JmxController (0x32e652b6)". Is there a way to get rid of this number? What
> does this number mean - only my custom "Services" have such a number?
>  
>  
>  
>  
>  
>  
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Names-of-custom-MBeans-contain-hex-number-at-the-end-tp5764226.html
>   
> Sent from the Camel - Users mailing list archive at Nabble.com.
>  

Re: Concurrent Consumers creating duplicates

[Willem Jiang]

The route looks good to me.
Can you double check the JMS acknowledge setting of JMS connection?


--  
Willem Jiang

Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.iteye.com (Chinese)
Twitter: willemjiang  
Weibo: 姜宁willem



On March 16, 2015 at 5:56:36 PM, kishore (kishoredevarase...@gmail.com) wrote:
> Here is the WMQRouter. The Ack queue is for a different purpose. we have to
> change the message adding some more data and send the Ack back.
>  
>  
> /public class WMQRouter extends RouteBuilder {
>  
> public static org.apache.log4j.Logger LOG =
> org.apache.log4j.Logger.getLogger(WMQRouter.class);
>  
> public String incomingQueue;
>  
> public String outgoingQueue;
>  
> public String backupFolder;
>  
> public String ackQueue;
>  
> public String getIncomingQueue() {
> return incomingQueue;
> }
>  
> public void setIncomingQueue(String incomingQueue) {
> this.incomingQueue = incomingQueue;
> }
>  
> public String getOutgoingQueue() {
> return outgoingQueue;
> }
>  
> public void setOutgoingQueue(String outgoingQueue) {
> this.outgoingQueue = outgoingQueue;
> }
>  
> public String getBackupFolder() {
> return backupFolder;
> }
>  
> public void setBackupFolder(String backupFolder) {
> this.backupFolder = backupFolder;
> }
>  
> public String getAckQueue() {
> return ackQueue;
> }
>  
> public void setAckQueue(String ackQueue) {
> this.ackQueue = ackQueue;
> }
>  
> /**
> * The configure method is invoked by the Camel to process the message
> * exchanges from the incoming queue and place the processed transaction
> xml
> * to corresponding queues This method also processes the on Exception
> * scenario wherein invoking the Error Handler and places the failure
> * message to the Failure Queue
> */
> @Override
> public void configure() throws Exception {
>  
> String incomingQueue = "websphere:queue:" + getIncomingQueue();
>  
> String outgoingQueue = "websphere:queue:" + getOutgoingQueue();
>  
> String failureQueue = "websphere:queue:" + getAckQueue();
>  
> String backupFolder = "file:" + getBackupFolder();
>  
> FixParseValidator.init();
>  
> FixProcessor fixProcessor = new FixProcessor();
> FIXAckProcessor fixAckProcessor = new FIXAckProcessor();
> FIXErrorHandler fixErrorHandler = new FIXErrorHandler();
>  
> fixAckProcessor.setFixProcessor(fixProcessor);
> fixErrorHandler.setFixProcessor(fixProcessor);
>  
> onException(Exception.class).process(fixErrorHandler);
>  
> onCompletion().process(fixAckProcessor).to(failureQueue);
>  
> from(incomingQueue).to(backupFolder).process(fixProcessor)
> .to(outgoingQueue);
> }
> }
> /
>  
>  
>  
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Concurrent-Consumers-creating-duplicates-tp5764158p5764209.html
>   
> Sent from the Camel - Users mailing list archive at Nabble.com.
>  

CVE-2015-0263 and CVE-2015-0264 - Apache Camel medium disclosure vulnerability

[Christian Mueller]

If you are using Apache Camel to route XML messages, please note that the
security advisories CVE-2015-0263 and CVE-2015-0264 may affect you.

Please study these critical security vulnerability carefully!

CVE-2015-0263 [1]
CVE-2015-0264 [2]

You can download the fixed Apache Camel 2.13.x and 2.14.x version from the
Apache mirrors [3] or from the Central Maven repository.

[1]
http://camel.apache.org/security-advisories.data/CVE-2015-0263.txt.asc?version=1&modificationDate=1426539178647&api=v2
[2]
http://camel.apache.org/security-advisories.data/CVE-2015-0264.txt.asc?version=1&modificationDate=1426539191142&api=v2
[3] http://camel.apache.org/download

On behalf of the Camel PMC,
Christian Mueller
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

Re: Camel route - autostartup - no endpoint found

[ychawla]

I tried injecting a Camel Context into the Route Policy, but it looks like
the route isn't yet created so it can't be deleted:

@Override
protected void doStart() throws Exception {
LOG.info("In custom do start");

boolean removed = camelContext.removeRoute("myServiceRoute");

LOG.info("Removed route" + removed);
}

Any other ideas?  Is it possible to conditionally import a route context
based on a Spring profile?

Thanks,
Yogesh



--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-route-autostartup-no-endpoint-found-tp5764230p5764231.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Camel route - autostartup - no endpoint found

[ychawla]

Hello All,
I have a route with autoStartup set to 'false'.  However, Camel will still
try to resolve the endpoint in the 'from' URI on the route.  For example:





However, I don't have 'myCXFServiceEndpoint' defined because the Spring
profile that I am using does not define that bean.  There is a JIRA right
now to not pre-warm/start the route:

https://issues.apache.org/jira/browse/CAMEL-5695

which is discussed in this thread:

http://camel.465427.n5.nabble.com/autoStartup-and-Endpoints-td5718204.html

I was thinking that I could use the route policy that is referenced in this
thread, however, the exception is thrown before I can get at the route.  For
example, overriding this method doesn't have any effect:

@Override
public void onInit(Route route)
{
LOG.info("Route Init for" + route.getId());
}

Is there any technique that I can use to tell Camel that when I set
autoStartup to 'false' that I don't want it to try to resolve the 'from'
endpoint?  I can't think of any tricks offhand and am not able to do so with
a route policy.  I do have CamelContext autostartup to false and am manually
only starting the routes that I will be using.

Any help is most appreciated!

Thanks,
Yogesh






--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-route-autostartup-no-endpoint-found-tp5764230.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Possibility of jdbc component when performing a select to return a map

[Antoine DESSAIGNE]

Hi,

No, it's not possible. In order to be unique in your Map it has to know
which fields are part of key (assuming that you retrieve them all).

If you have camel-groovy in your project you can do the following:
to("jdbc:something").setBody(new
GroovyExpression("request.body.collectEntries {[(it.COLUMN_A): it]}"))

Otherwise you'll have to use a custom processor.

Hope this helps,

Antoine.


2015-03-16 17:43 GMT+01:00 angelo.rlcosta :

> HI Guys,
>
> i'm using jdbc component to perform a selectList. I've noticed that
> according to the impl it returns a List> data =
> extractResultSetData(rs);
>
> Is there any type of transformation i can perform to have data like
> Map> so instead of a List i have a Map where
> the key is for example List[i].COLUMN_A and then the inner map the same as
> the Map in the List.
>
> Thanks in advance,
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Possibility-of-jdbc-component-when-performing-a-select-to-return-a-map-tp5764228.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Possibility of jdbc component when performing a select to return a map

[angelo.rlcosta]

HI Guys,

i'm using jdbc component to perform a selectList. I've noticed that
according to the impl it returns a List> data =
extractResultSetData(rs);

Is there any type of transformation i can perform to have data like
Map> so instead of a List i have a Map where
the key is for example List[i].COLUMN_A and then the inner map the same as
the Map in the List.

Thanks in advance,




--
View this message in context: 
http://camel.465427.n5.nabble.com/Possibility-of-jdbc-component-when-performing-a-select-to-return-a-map-tp5764228.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Java DSL kick-starting routes, is this possible yet?

[mikes300]

I can kick-start a route (for example by a file or message/q or timer input)
automatically in Spring and read in a couple posts that doing this via a
pure Java DSL implementation was possible but still find no evidence of it.

Is this possible yet does anyone know?  Or if anyone has gotten something
like that actually working without using Spring?

Thanks!



--
View this message in context: 
http://camel.465427.n5.nabble.com/Java-DSL-kick-starting-routes-is-this-possible-yet-tp5764227.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Names of custom MBeans contain hex-number at the end

[dermoritz]

I created some custom MBeans (implementing Service). they work as they should
but for some reason their names have some hexadecimal number at the end e.g.
"JmxController (0x32e652b6)". Is there a way to get rid of this number? What
does this number mean - only my custom "Services" have such a number?






--
View this message in context: 
http://camel.465427.n5.nabble.com/Names-of-custom-MBeans-contain-hex-number-at-the-end-tp5764226.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Dynamic MBeans/ dynamically create MBeans in Camel

[dermoritz]

Thanks to this mailing list i know how to create custom mbeans by
implementing Service and adding them to CamelContext.
But is there also such an easy way to create/add dynamic MBeans and or
dynamically create Mbeans - Attributes/Operation and or MBeans are defined
on Runtime?

In my case i read user's properties to setup routes and other stuff. One
propertiy could contain a list of sepcial servers/services (could be 0 or
more entries). I want to deliver one MBean per server entry. 
Probably each server has some additional properties given that could yield
additional/less attributes/operations.

If there is no direct camel way, how to add own (dynamic) MBeans to camel?

Thanks in advance



--
View this message in context: 
http://camel.465427.n5.nabble.com/Dynamic-MBeans-dynamically-create-MBeans-in-Camel-tp5764225.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Slow FTP

[ulsa]

One of the files on my FTP server is ~200MB. I'm using Camel FTP from an EC2
instance (Ubuntu 14), and I get a connection reset error on that file after
25 minutes. However, when using command line ftp on the same machine, the
same file takes 38 seconds to download. I have set option
localWorkDirectory=/var/tmp/camel. Is there any other configuration trick
that I have missed?



--
View this message in context: 
http://camel.465427.n5.nabble.com/Slow-FTP-tp5764223.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Cacehe-Controle header

[richardgroote]

Hello,

We used the below header strategy on the servlet component to allow some
headers.


public class ParameterizedHttpHeaderFilterStrategy extends
DefaultHeaderFilterStrategy {
private final String[] allowedOutHeaders;

public ParameterizedHttpHeaderFilterStrategy(String allowedOutHeaders) {
this.allowedOutHeaders = allowedOutHeaders.split(",");
}

protected void initialize() {
setOutFilter(getParameterizedOutFilter());

setLowerCase(true);

// filter headers begin with "Camel" or "org.apache.camel"
// must ignore case for Http based transports
   
setOutFilterPattern("(?i)(Camel|org\\.apache\\.camel)[\\.|a-z|A-z|0-9]*");
}

protected Set getParameterizedOutFilter() {
Set outFilter = new HashSet();
outFilter.add("content-length");
outFilter.add("content-type");
outFilter.add("host");
// Add the filter for the Generic Message header
// http://www.w3.org/Protocols/rfc2616/rfc2616-sec4.html#sec4.5
outFilter.add("cache-control");
outFilter.add("connection");
outFilter.add("date");
outFilter.add("pragma");
outFilter.add("trailer");
outFilter.add("transfer-encoding");
outFilter.add("upgrade");
outFilter.add("via");
outFilter.add("warning");

for(String allowedOutHeader: allowedOutHeaders){
outFilter.remove(allowedOutHeader.toLowerCase());
}

return outFilter;
}
}


Kind regards,

Richard



--
View this message in context: 
http://camel.465427.n5.nabble.com/Cacehe-Controle-header-tp5764045p5764220.html
Sent from the Camel - Users mailing list archive at Nabble.com.

AW: Dynamic Splitter timeouts

[jhm]

My idea was
- adding an 'id' to the splitter
- later on during runtime (e.g. on an event) get that splitter instance by its 
id and modify its timeout value.

Tried using JavaDSL, but with Camel 2.15.0 I havent any timeout method found ...


Jan

> -Ursprüngliche Nachricht-
> Von: Claus Ibsen [mailto:claus.ib...@gmail.com]
> Gesendet: Montag, 16. März 2015 12:22
> An: users@camel.apache.org
> Betreff: Re: Dynamic Splitter timeouts
> 
> There is no support for dynamic timeout values.
> 
> On Mon, Mar 16, 2015 at 7:38 AM, Gnanaguru S 
> wrote:
> > Hi All,
> >
> > I have a use case where, the requests will have a timeout value.
> Based
> > on this timeout value Splitter should timeout.
> >
> > Splitter processor has the option of timeout, but I doubt whether we
> > can pass dynamic value to that.
> >
> >  parallelProcessing="true"
> > streaming="true" timeout="3000*">
> >  inheritNamespaceTagName="requests" xml="true" />
> > 
> > 
> >
> >
> > Any other ideas ?
> >
> > Regards
> > Guru
> > @tallguru
> >
> >
> >
> > --
> > View this message in context:
> > http://camel.465427.n5.nabble.com/Dynamic-Splitter-timeouts-
> tp5764202.
> > html Sent from the Camel - Users mailing list archive at Nabble.com.
> 
> 
> 
> --
> Claus Ibsen
> -
> Red Hat, Inc.
> Email: cib...@redhat.com
> Twitter: davsclaus
> Blog: http://davsclaus.com
> Author of Camel in Action: http://www.manning.com/ibsen
> hawtio: http://hawt.io/
> fabric8: http://fabric8.io/

Re: Bean invocation .class vs new

[yuncil]

Hey Claus,

thank you I got it now.



--
View this message in context: 
http://camel.465427.n5.nabble.com/Bean-invocation-class-vs-new-tp5764039p5764217.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Sql component lazy loading?

[angelo.rlcosta]

Hi Claus,

Every time i try access ${body[0]} to get the first item returned from the
list from the DB seems a bit slow. Seems like lazy loading is enabled. 

Therefore wanted to try use lazy loading = false somehow to check if its
faster.



--
View this message in context: 
http://camel.465427.n5.nabble.com/Sql-component-lazy-loading-tp5764211p5764216.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Cacehe-Controle header

[Claus Ibsen]

No I dont think so.

But maybe we should think about making that easier to configure on
servlet / jetty and HTTP server like components.


On Thu, Mar 12, 2015 at 4:17 PM, richardgroote  wrote:
> Hello,
>
> For https://issues.apache.org/jira/browse/CAMEL-1975 a lot of headers are
> filtered on the response.
>
> We're using the servlet component and like to set the "cache-control" header
> with values "no-cache, no-store, must-revalidate". Is there a way to do this
> without specifying a custom filter strategy?
>
>
> Kind regards,
>
> Richard
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Cacehe-Controle-header-tp5764045.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
hawtio: http://hawt.io/
fabric8: http://fabric8.io/

Re: Dynamic Splitter timeouts

[Claus Ibsen]

There is no support for dynamic timeout values.

On Mon, Mar 16, 2015 at 7:38 AM, Gnanaguru S  wrote:
> Hi All,
>
> I have a use case where, the requests will have a timeout value. Based on
> this timeout value Splitter should timeout.
>
> Splitter processor has the option of timeout, but I doubt whether we can
> pass dynamic value to that.
>
>  parallelProcessing="true"
> streaming="true" timeout="3000*">
>  inheritNamespaceTagName="requests" xml="true" />
> 
> 
>
>
> Any other ideas ?
>
> Regards
> Guru
> @tallguru
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Dynamic-Splitter-timeouts-tp5764202.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
hawtio: http://hawt.io/
fabric8: http://fabric8.io/

Re: Sql component lazy loading?

[Claus Ibsen]

Hi

What do you mean by lazy loading?

On Mon, Mar 16, 2015 at 12:01 PM, angelo.rlcosta
 wrote:
> Hi guys, does anyone know if sql component has an option to disable lazy
> loading?
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Sql-component-lazy-loading-tp5764211.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
hawtio: http://hawt.io/
fabric8: http://fabric8.io/

Sql component lazy loading?

[angelo.rlcosta]

Hi guys, does anyone know if sql component has an option to disable lazy
loading?



--
View this message in context: 
http://camel.465427.n5.nabble.com/Sql-component-lazy-loading-tp5764211.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: CXF-RS get but no response

[Sergey Beryozkin]

As far as I recall you can not use a cxfrs bean with a "from", one can 
delegate to it with a from:jetty, etc... I believe you need to drop a 
'bean' part...
AFAIK The bean component is useful if you need to invoke on a JAX-RS 
service implementation. You can do it in Camel 2.15.0 directly with a 
cxfrs consumer and a performInvocation option


Cheers, Sergey



On 14/03/15 13:03, garethahealy wrote:

I am just doing a hello world example for a restful service[1] but i don't
get any response, as i would expect. When debugging the test as well, i
never hit the method[2].

I've included some debug[3] but i can't see anything from it.

Any ideas what i am doing wrong?

[1]https://github.com/garethahealy/jboss-fuse-examples/tree/master/ws-restful
[2]https://github.com/garethahealy/jboss-fuse-examples/blob/master/ws-restful/src/main/java/com/garethahealy/ws/restful/services/DefaultHelloWorldService.java#L49
[3]https://gist.github.com/garethahealy/a163900ab1ab700204e4



--
View this message in context: 
http://camel.465427.n5.nabble.com/CXF-RS-get-but-no-response-tp5764141.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Concurrent Consumers creating duplicates

[kishore]

Here is the WMQRouter. The Ack queue is for a different purpose. we have to
change the message adding some more data and send the Ack back.


/public class WMQRouter extends RouteBuilder {

public static org.apache.log4j.Logger LOG =
org.apache.log4j.Logger.getLogger(WMQRouter.class);

public String incomingQueue;

public String outgoingQueue;

public String backupFolder;

public String ackQueue;

public String getIncomingQueue() {
return incomingQueue;
}

public void setIncomingQueue(String incomingQueue) {
this.incomingQueue = incomingQueue;
}

public String getOutgoingQueue() {
return outgoingQueue;
}

public void setOutgoingQueue(String outgoingQueue) {
this.outgoingQueue = outgoingQueue;
}

public String getBackupFolder() {
return backupFolder;
}

public void setBackupFolder(String backupFolder) {
this.backupFolder = backupFolder;
}

public String getAckQueue() {
return ackQueue;
}

public void setAckQueue(String ackQueue) {
this.ackQueue = ackQueue;
}

/**
 * The configure method is invoked by the Camel to process the message
 * exchanges from the incoming queue and place the processed transaction
xml
 * to corresponding queues This method also processes the on Exception
 * scenario wherein invoking the Error Handler and places the failure
 * message to the Failure Queue
 */
@Override
public void configure() throws Exception {

String incomingQueue = "websphere:queue:" + getIncomingQueue();

String outgoingQueue = "websphere:queue:" + getOutgoingQueue();

String failureQueue = "websphere:queue:" + getAckQueue();

String backupFolder = "file:" + getBackupFolder();

FixParseValidator.init();

FixProcessor fixProcessor = new FixProcessor();
FIXAckProcessor fixAckProcessor = new FIXAckProcessor();
FIXErrorHandler fixErrorHandler = new FIXErrorHandler();

fixAckProcessor.setFixProcessor(fixProcessor);
fixErrorHandler.setFixProcessor(fixProcessor);

onException(Exception.class).process(fixErrorHandler);

onCompletion().process(fixAckProcessor).to(failureQueue);

from(incomingQueue).to(backupFolder).process(fixProcessor)
.to(outgoingQueue);
}
}
/



--
View this message in context: 
http://camel.465427.n5.nabble.com/Concurrent-Consumers-creating-duplicates-tp5764158p5764209.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Concurrent Consumers creating duplicates

[Willem Jiang]

I didn’t find the Route definition of wmqRoute, you may need to show us the 
code of 
com.broadridge.adapters.fixadapter.router.WMQRouter.

BWT, why do your route need to specify the “ackQueue”?

--  
Willem Jiang

Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.iteye.com (Chinese)
Twitter: willemjiang  
Weibo: 姜宁willem



On March 16, 2015 at 2:01:59 PM, kishore (kishoredevarase...@gmail.com) wrote:
> Here is my camel-context.xml file
>  
>  
> > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
> xmlns:context="http://www.springframework.org/schema/context";
> xmlns:camel="http://camel.apache.org/schema/spring";
> xsi:schemaLocation="
> http://www.springframework.org/schema/context
> http://www.springframework.org/schema/context/spring-context-3.0.xsd
> http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans.xsd
> http://camel.apache.org/schema/spring
> http://camel.apache.org/schema/spring/camel-spring.xsd";>
>  
>  
> > class="com.broadridge.adapters.fixadapter.router.WMQRouter">
>  
>  
>  
>  
>  
>  
>  
> >  
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
>   
>  
>  
>  
>  
>  
>  
>  
>  
>  
>  
>  
>  
>  
>  
> > class="com.ibm.mq.jms.MQConnectionFactory">
>  
>  
>  
>  
>  
>  
>  
> > class="org.apache.camel.component.jms.JmsConfiguration">
>  
>  
>  
>  
>  
>  
>  
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Concurrent-Consumers-creating-duplicates-tp5764158p5764201.html
>   
> Sent from the Camel - Users mailing list archive at Nabble.com.
>  

Re: Quartz Component quartz.properties in Karaf

[Willem Jiang]

I think you can put the quartz.properties file into your application bundle or 
karaf etc directory.
You can specify quartz.properties file with relative path or absolute path (if 
you like) by calling QuartzComponent.setPropertiesFile() method just like this

context.getComponent("quartz", 
QuartzComponent.class).setPropertiesFile("org/apache/camel/routepolicy/quartz/myquartz.properties");
 

--  
Willem Jiang

Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.iteye.com (Chinese)
Twitter: willemjiang  
Weibo: 姜宁willem



On March 13, 2015 at 11:05:58 PM, Thomas Weinschenk 
(thomas.weinsch...@infoserve.endress.com) wrote:
> Hi all,
>  
> I am trying to configure the quartz scheduler of the Quartz Component via
> the quarzt.properties in Karaf, but I have no glue where to put the file in
> Karaf?
>  
> Regards,
> Thomas
>  
>  
>  
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Quartz-Component-quartz-properties-in-Karaf-tp5764099.html
>   
> Sent from the Camel - Users mailing list archive at Nabble.com.
>  

Manipulate messages for aggregator when there is no message ready to aggregate

[Gnanaguru S]

Hi, 

Lets say I have a splitter which splits a large message into 10 messages and
sends each message to a CXF Web service endpoint. 

Assume only 7 message are responded and 3 messages are still in progress. 

1. I dont want to wait, I want to aggregate 7 successful messages + 3
manipulated messages with a UUID 

Is it possible to create all the 3 messages at a stretch based on a timeout
value ? And that timeout value has to be dynamic. 

So three responses are not received, Can I maipulate 3 responses based on a
timeout value ?

Regards
Guru
@tallguru 




--
View this message in context: 
http://camel.465427.n5.nabble.com/Manipulate-messages-for-aggregator-when-there-is-no-message-ready-to-aggregate-tp5764205.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: how to know how many files Camel Endpoint scanned?

[Nazarii Kukhar]

Hi,

Take a look at this SO question
,
looks like exactly what you are looking for.



On Fri, Mar 13, 2015 at 11:08 AM, ramanarao  wrote:

> I have endpoint which scans the uri(folder).
> and one route which processes the files.
>
> But how to know how many files the endpoint scanned ?...
>
>
> please let me know if this is not clear to you..
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/how-to-know-how-many-files-Camel-Endpoint-scanned-tp5764112.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Dynamic Splitter timeouts

[Gnanaguru S]

Hi All, 

I have a use case where, the requests will have a timeout value. Based on
this timeout value Splitter should timeout. 

Splitter processor has the option of timeout, but I doubt whether we can
pass dynamic value to that. 

timeout="3000*">





Any other ideas ?

Regards
Guru
@tallguru



--
View this message in context: 
http://camel.465427.n5.nabble.com/Dynamic-Splitter-timeouts-tp5764202.html
Sent from the Camel - Users mailing list archive at Nabble.com.