Camel AMQ - SSL and XA

[dpravin]

Hello,We have AMQ connection factory classes for SSL and XA separately.
However I did not find any connection factory class that supports both XA
and SSL. Appreciate if anyone has come across this requirement and have a
solution for it.Regards,Pravin



--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-AMQ-SSL-and-XA-tp5783462.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How to stop a dynamic route

[Daniel P22]

Ranx explain to you, I have a route A, in that route you are going to put a
file with ammdd date format. 

Then Im going to create a dinamic route in the Camel Context using that
date, this route is what you see in the example, I just wanna from the smb
endpoint the files according that date.

When finish the batch, stop and remove the route. I just wanna execute once. 

I use delay=6  because I want this code to run.

*The Stop Code *


if(context.getRouteStatus("sap-xrt-connect-interface-receive-" +
fileNameOnly).isStarted()){  // Se verifica si se inicio la ruta 

int CamelBatchValidator = 0; 
do{ 

Thread.sleep(1); // Se realiza la verificacion cada 10
segundos si la interfaz culmino su procesamiento 

if (CamelBatchComplete=="true"){ 

 Thread.sleep(2); // Tiempo adicional para verificar que
todo ha culminado 

 context.stopRoute("sap-xrt-connect-interface-receive-" +
fileNameOnly); 
  
 Thread.sleep(1); 
  
 context.removeRoute("sap-xrt-connect-interface-receive-" +
fileNameOnly); 
  
 CamelBatchValidator=1; 
 CamelBatchComplete = null; 
}else{ 

//Si la ruta esta vacia o hay error al conectar , esto hara
que entre en el IF de arriba y elimine la ruta 
if(CamelBatchComplete == null){ 

CamelBatchComplete="true"; 
} 

} 


}while(CamelBatchValidator==0);


Thanks



--
View this message in context: 
http://camel.465427.n5.nabble.com/How-to-stop-a-dynamic-route-tp5783385p5783460.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: XML Configuration with Spring boot

[Pontus Ullgren]

Hi,

For beans you can place your beans in a separate spring xml in
src/main/resources and import it in your FatJarRouter using the @Import(..)
annotation.


@SpringBootApplication
@ImportResource( "beans.xml" )
public class MyFatJarRouter extends FatJarRouter {
...

// Pontus

On Sat, 4 Jun 2016 at 00:03 J-  wrote:

> Hi,
>
> When using camel with spring-boot with xml config, can you only use
>  and  xml components?
>
> Is it possible to do other configuration in xml when using spring-boot?
> For example  or  inside the xml?
>
> I know this has been asked before a long time ago, but now that it's a few
> years later, is there any preference/benefits of using xml over java.
>
> Our lead wants us to switch back to using xml instead of java, and so far
> the xml is far more difficult to write.
>
> Thanks,
>
> -J
>

XML Configuration with Spring boot

[J-]

Hi,

When using camel with spring-boot with xml config, can you only use  and 
 xml components?

Is it possible to do other configuration in xml when using spring-boot? For 
example  or  inside the xml?

I know this has been asked before a long time ago, but now that it's a few 
years later, is there any preference/benefits of using xml over java.  

Our lead wants us to switch back to using xml instead of java, and so far the 
xml is far more difficult to write.

Thanks,

-J

Re: File Consumer Exchange

[Brad Johnson]

Yeah, as Hans points out the "noop" will leave the file and not even create
an exchange so you don't have to filter for it downstream.  If you are
polling you can set an idempotent flag on the file reader to ensure that it
doesn't re-read a file it has already processed.

On Fri, Jun 3, 2016 at 1:01 AM, Hans Orbaan  wrote:

> Hi,
>
> You can use the "no operation" functionality. See noop=true @
> http://camel.apache.org/file2.html
>
>
> -Oorspronkelijk bericht-
> Van: bwest [mailto:bwesterfi...@gmail.com]
> Verzonden: Friday 3 June 2016 1:19
> Aan: users@camel.apache.org
> Onderwerp: File Consumer Exchange
>
> Can I ignore an exchange that's been picked up by a file consumer?  In
> other words, I don't want the file to be moved or deleted.  I'd like to
> remain in the directory for other subsequent polls.
>
> Thanks!
>
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/File-Consumer-Exchange-tp5783404.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Re: Throttling per activemq consumer

[Brad Johnson]

Just speaking to the throttler and not the JMS group, you've set this at 1
message every 30 seconds.  Somehow I suspect that isn't what you want.
Are all the messages you are consuming on the activemq:queue:test or is
that already split/filttered based on the JMSXGroupID?  If that queue is
the one that has all your messages on it with a variety of headers then you
will only ever get one message very 30 seconds regardless of what you've
set downstream.

But that's hard to say when the posted code is just a single snippet.

On Fri, Jun 3, 2016 at 5:11 AM, hasikada  wrote:

> Let's say have I have multiple activemq consumers
> (jms.concurrentConsumers=20), I use message groups, so incomming messages
> has JMSXGroupID header set and I would like to enable throttling per
> message
> group in Camel.
>
>  from("activemq:queue:test")
>   .throttle(1).timePeriodMillis(3L)
>   .to("mock:result");
>
> I would expect that first activemq consumer throttles incomming messages
> from assigned message group, while second consumer throttles messages from
> another group in parallel.
> But the first throttling consumer blocks second one. The second consumer is
> not able to process a message until the throttling time period 30sec of
> first one expires.
>
> How to proceed the message groups in parallel and enable delay between the
> messages within same message group?
>
> Thank you
>
> Adam
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Throttling-per-activemq-consumer-tp5783432.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

RE: Q about how to help the file2 component to do a better job

[Tobias Schöneberg]

Hello Souciance,
and thx for your reply.
I stepped through the code and it really looked like I need to register my own 
Converter which can then make the conversion the way I want it, 
i.e. without relying on the system's default encoding to make any sense.

If you are interested, this is how the Converter looks: 
https://github.com/metasfresh/metasfresh/blob/master/de.metas.edi.esb.camel/src/main/java/de/metas/edi/esb/route/exports/ReaderTypeConverter.java

It can convert byte[] and ByteArrayInputStream.
I found the info i needed at https://camel.apache.org/type-converter.html 
(mostly in section "Encoding support for byte[] and String Conversion").

However, I'm still not 100% sure I didn't miss something..I would have expected 
that this stuff was "somehow" already there, and i would just have had to set 
the Exchange.CHARSET_NAME..
Probably I'm just spoiled by camel ;-).

Best regards
Tobias

-Original Message-
From: souciance [mailto:souciance.eqdam.ras...@gmail.com] 
Sent: Donnerstag, 2. Juni 2016 10:33
To: users@camel.apache.org
Subject: Re: Q about how to help the file2 component to do a better job

Not sure if this helps but I had to go from a file with stream to third party 
library which wanted a Reader and I used this:

//enforce UTF-8 encoding where stream is an InputStream stream = new 
ByteArrayInputStream(exchange.getIn().getBody().toString().
getBytes("UTF-8"));

Then go from the stream to Reader..

On Thu, Jun 2, 2016 at 10:19 AM, Tobias Schöneberg [via Camel] <
ml-node+s465427n5783381...@n5.nabble.com> wrote:

> Hi,
>
> we are using servicemix and I had a problem which was related to the 
> time when that servicemix's JVM started.
> Aparently, it started before the operating system's locale was set to 
> something UTF-8ish.
> I solved it (fingers crossed) by making sure that the system property 
> "file.encoding" is explicitly set to "UTF-8"
>
> This is the related background/documentation, i hope it sufficiently 
> explains what the problem was about:
>
> # If the camel file component needs to write an InputStream to a file 
> # and has to use  a given encoding # and doesn't have enough info to 
> do anything sophisticated, # then it creates a reader for the task, 
> using "new InputStreamReader(is)".
> # This reader uses the "default charset" to interpret the stream.
> # Depending on when the JVM was started, the default charset might be
> ANSI_X3.4-1968 a.k.a. US-Ascii.
> # Now, when we create EDI files, the smooks' SmooksDataFormat creates 
> a String and then writes it out as a UTF-8 encoded byte stream.
> # When this stream is read as US-Ascii, then all its nice Umlauts are 
> turned into "??"s.
> # To prevent this, we explicitly set the default encoding to UTF-8 for 
> the servicemix-JVM.
>
> .. and this is the code from FileOperations.storeFile() 
> (camel-2.16.1), which creates the InputStreamReader from the the 
> exchange's body
>
> 
> if (charset != null) {
> // charset configured so we must use a reader so we can write with 
> encoding
> Reader in =
> exchange.getContext().getTypeConverter().tryConvertTo(Reader.class,
> exchange, exchange.getIn().getBody());
> if (in == null) {
> // okay no direct reader conversion, so use an input stream 
> (which a lot can be converted as)
> InputStream is =
> exchange.getIn().getMandatoryBody(InputStream.class);
> in = new InputStreamReader(is);
> }
> // buffer the reader
> in = IOHelper.buffered(in);
> writeFileByReaderWithCharset(in, file, charset); } else { 
>
> Now to my question:
> Could you point me to a best practice in my route (i'm specifying it 
> via
> java-fluent) to tell camel "something", so that the tryConvertTo() 
> method succeeds in creating an UTF-8-based reader?
> E.g. by setting some propery or something?
>
> It would relief us from worrying about that system property on the 
> systems we deploy this component to.
>
> Best regards
> Tobi
>
>
>
> --
> If you reply to this email, your message will be added to the 
> discussion
> below:
>
> http://camel.465427.n5.nabble.com/Q-about-how-to-help-the-file2-compon
> ent-to-do-a-better-job-tp5783381.html
> To start a new topic under Camel - Users, email
> ml-node+s465427n465428...@n5.nabble.com
> To unsubscribe from Camel - Users, click here 
>  bscribe_by_code&node=465428&code=c291Y2lhbmNlLmVxZGFtLnJhc2h0aUBnbWFpb
> C5jb218NDY1NDI4fDE1MzI5MTE2NTY=>
> .
> NAML
>  o_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namesp
> aces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.vi
> ew.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%
> 3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%2
> 1nabble%3Aemail.naml>
>




--
View this message in context: 
http://camel.465427.n5.nabble.com/Q-a

Re: How to stop a dynamic route

[Brad Johnson]

I can't read the format of the code but as Quinn pointed out you can use
the control bus but I have to ask what is the purpose/reason for shutting
the route down?  Are you just running the batch once or are you re-enabling
it at some other time?

Just from what I can see this looks like it is going to pull the file every
60 seconds regardless of whether you've previously processed it or not and
the only difference is you won't process it a second time.  But it appears
that you'll continually re-read that file. Unfortunately I'm more familiar
with Blueprint XML and not the route builder semantics.  If I understand
the issue I it seems you want to get a file and the disable the route/smb
so it doesn't re-read the same file?

from("smb://"+ inputXrtSmbDomain +";"+ inputXrtSmbUser +"@"+
inputXrtSmbServer +"/"+ inputXrtSmbFolder +"?password="+ inputXrtSmbPassword
+ "&delete=false&delay=6")

If I'm reading this correctly then every 60 seconds this is going to fire
up and read whatever files are in that directory and not delete when it has
finished processing.  I've never used the JCIFS endpoint so may be off base
there.   That isn't an initialDelay and a better name for the flag would
have been something like "period" or "poll".  It is going to go off every
60 seconds.  Is your file getting moved to a .camel directory when it is
finished processing?

If you just want to make sure it doesn't process files that have already
been processed then use the idempotent flag.  Then this route will poll
every 60 seconds and pick up whatever new files it finds but ignore
processing anything that it has already seen.

Without knowing the exact business problem at hand it's hard to be
definitive.

On Fri, Jun 3, 2016 at 10:13 AM, Quinn Stevenson <
qu...@pronoia-solutions.com> wrote:

> You could use the control bus to stop the route (
> http://camel.apache.org/controlbus.html <
> http://camel.apache.org/controlbus.html> )
>
> > On Jun 2, 2016, at 5:06 AM, Daniel Pompa  wrote:
> >
> > If you see, I have a do-while monitoring the value of the var
> > CamelBatchComplete, then when is true, stop and remove the route from
> Camel
> > Context. I don't like this.
> >
> > My question is, there a better way to stop and remove the route when the
> > Batch finish? Using the RouteBuilder for example.
> >
> > Thanks.
> >
> >
> >
> > --
> > View this message in context:
> http://camel.465427.n5.nabble.com/How-to-stop-a-dynamic-route-tp5783385p5783389.html
> > Sent from the Camel - Users mailing list archive at Nabble.com.
>
>

Re: Problem transfer from SMB to FTP OutMemory Java Heap Space

[Brad Johnson]

Were you able to bump the heap space in Fuse.  The bin directory with
fuse/karaf sh or bat file is where that is located.  I believe the heap
used to be small by default because OSGi/karaf were and are used in small
devices.  However Fuse isn't.

Unfortunately I don't know smb/JFCIS.  I know in similar circumstances with
FTP or files I will use either a flag of streaming or chunked splitter to
make sure the endpoint isn't loading everything into memory.  In this case
I don't know the mechanics of SMB.  Is it actually streaming the file to
you and your camel route and then you are pushing it to the FTP location?

Try breaking the problem down.  Temporarily replace your push to FTP with a
write to a local file.  Do you run into the problem still?  If not, switch
it and run it from the local file to your FTP server.  Do you run into the
problem that way?

On Fri, Jun 3, 2016 at 9:42 AM, Daniel P22  wrote:

> Thanks Hans and Pontus, let me try this of mount a share.
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Problem-transfer-from-SMB-to-FTP-OutMemory-Java-Heap-Space-tp5783383p5783453.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Re: How to stop a dynamic route

[Quinn Stevenson]

You could use the control bus to stop the route ( 
http://camel.apache.org/controlbus.html 
 )

> On Jun 2, 2016, at 5:06 AM, Daniel Pompa  wrote:
> 
> If you see, I have a do-while monitoring the value of the var
> CamelBatchComplete, then when is true, stop and remove the route from Camel
> Context. I don't like this.
> 
> My question is, there a better way to stop and remove the route when the
> Batch finish? Using the RouteBuilder for example.
> 
> Thanks.
> 
> 
> 
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/How-to-stop-a-dynamic-route-tp5783385p5783389.html
> Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Problem transfer from SMB to FTP OutMemory Java Heap Space

[Daniel P22]

Thanks Hans and Pontus, let me try this of mount a share.



--
View this message in context: 
http://camel.465427.n5.nabble.com/Problem-transfer-from-SMB-to-FTP-OutMemory-Java-Heap-Space-tp5783383p5783453.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Problem transfer from SMB to FTP OutMemory Java Heap Space

[Pontus Ullgren]

Strange I have run applications where I transfer files up to 300MB without
problems using camel-jcifs.
Feel free to log a jira (
https://camel-extra.atlassian.net/projects/CAMEX/issues) with your findings.

However I do agree that if you use case is such that you can mount the
shares (either on windows or using smbmount on linux) then using the
file:// transport is probably a more stable and tested way to go.
Also if you are running from a Windows machine I do belive using file://
witth a UNC path is also possible. Provided that the user your JVM is
running as has access to the share.

Best regards
Pontus Ullgren



On Fri, 3 Jun 2016 at 15:17 Hans Orbaan  wrote:

> Hi,
>
> You should mount your share and use the file:// component to avoid out of
> memory errors. There is something wrong with camel-jcifs. It will go out of
> memory (threads I guess, not memory, but system resources) will retrieving
> a file.
> This already happens from 5 MB or more we found. Could not really locate
> the issue though.
>
> With kind regards,
>
> Hans Orbaan
>
>
> -Oorspronkelijk bericht-
> Van: Pontus Ullgren [mailto:ullg...@gmail.com]
> Verzonden: Friday 3 June 2016 13:15
> Aan: users@camel.apache.org
> Onderwerp: Re: Problem transfer from SMB to FTP OutMemory Java Heap Space
>
> localWorkDirectory is a directory on the server where your camel route run
> (in Fuse as you say),
>
> localWorkDirectory is also supported in camel-jcifs (
> http://camel.apache.org/jcifs.html).
>
>
> // Pontus
>
> On Fri, 3 Jun 2016 at 08:12 Daniel Pompa  wrote:
>
> > Hi Pontus, sorry Im new in Fuse. The Camel version is 2.12.0
> >
> > how I can defined the heap size to the Java Process?
> >
> > I add localWorkDirectory into the URI, but fail again, this
> > localWorkDirectory is a directory in Fuse or in the smb server? I put
> > in the localWorkDirectory  in smb.
> >
> > I saw localWorkDirectory is just for FTP.
> >
> > Thanks.
> >
> >
> >
> > --
> > View this message in context:
> > http://camel.465427.n5.nabble.com/Problem-transfer-from-SMB-to-FTP-Out
> > Memory-Java-Heap-Space-tp5783383p5783388.html
> > Sent from the Camel - Users mailing list archive at Nabble.com.
> >
>

RE: IBM MQ to Active MQ migration

[Steve Huston]

IBM MQ -> ActiveMQ is a separate activity from using camel, or are you already 
using camel with IBM MQ?

-teve

> -Original Message-
> From: tanay94 [mailto:tanay.jos...@gmail.com]
> Sent: Friday, June 03, 2016 2:15 AM
> To: users@camel.apache.org
> Subject: IBM MQ to Active MQ migration
> 
> I want to migrate applications from IBM MQ to Active MQ. I would prefer
> using camel. Since I am new to this technology, I would appreciate if
> someone helps me to build it from scratch.
> 
> 
> 
> --
> View this message in context: http://camel.465427.n5.nabble.com/IBM-MQ-
> to-Active-MQ-migration-tp5783408.html
> Sent from the Camel - Users mailing list archive at Nabble.com.

RE: Problem transfer from SMB to FTP OutMemory Java Heap Space

[Hans Orbaan]

Hi,

You should mount your share and use the file:// component to avoid out of 
memory errors. There is something wrong with camel-jcifs. It will go out of 
memory (threads I guess, not memory, but system resources) will retrieving a 
file.
This already happens from 5 MB or more we found. Could not really locate the 
issue though.

With kind regards,

Hans Orbaan


-Oorspronkelijk bericht-
Van: Pontus Ullgren [mailto:ullg...@gmail.com] 
Verzonden: Friday 3 June 2016 13:15
Aan: users@camel.apache.org
Onderwerp: Re: Problem transfer from SMB to FTP OutMemory Java Heap Space

localWorkDirectory is a directory on the server where your camel route run (in 
Fuse as you say),

localWorkDirectory is also supported in camel-jcifs ( 
http://camel.apache.org/jcifs.html).


// Pontus

On Fri, 3 Jun 2016 at 08:12 Daniel Pompa  wrote:

> Hi Pontus, sorry Im new in Fuse. The Camel version is 2.12.0
>
> how I can defined the heap size to the Java Process?
>
> I add localWorkDirectory into the URI, but fail again, this 
> localWorkDirectory is a directory in Fuse or in the smb server? I put 
> in the localWorkDirectory  in smb.
>
> I saw localWorkDirectory is just for FTP.
>
> Thanks.
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Problem-transfer-from-SMB-to-FTP-Out
> Memory-Java-Heap-Space-tp5783383p5783388.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Re: Camel blueprint: Unable to load class org.apache.camel.builder.LoggingErrorHandler

[Alex Soto]

That worked, thanks!

Best regards,
Alex soto


> On Jun 2, 2016, at 11:20 PM, Quinn Stevenson  
> wrote:
> 
>> org.apache.camel.builder.LoggingErrorHandler

Jakcom Smart Ring R3---best quality, lowest prices

[Joanne]

Introducing what you want-Jakcom Smart Ring

Main feature of our Smart Ring :

1.Replace ""door key"" ,""Payment Card"" or other""IC""/""ID""card;   
2.Improve human health and prevent disease;
3.Unlock phone ,Quick start phone's program,Share informations,Private 
notebook,etc;
4.No need to charge and waterproof;
5.Full U.S. sizes optional;
6.Made by Liquid Tungsten and Epoxy Crystal Ceramic ,Fashionable design 
elements."

Would you mind visiting our website, we will show you more video of our 
products.

w w w . J A K C O M . c o m

"And please give me some requirments ,then i will offer the best quotation to 
you.thank you.
Jakcom Technology Company
Winston
Marketing Consultant 
Thanks & Regards









































































Mail server information (DKIM) DomainKeys Identified Mail: 
"5vbaaj61e2na5iall9hssidswfc0cbny13hw0rqxfcwad72r3b4gsabqtzlsupb9l5lircvx2eba5kxruenkqqb81wlnq8kvzhsfpbbvj6knupymsvajsujvhexsd2fjwqx4nfqjlh8nqvis7hyru9un5juz3wbvhiaar54ynxzm6qqto1vrkgxskjuhqssduj5oqv4kcgscb1jn7mfvm30mganj9cndm0grnre0dyi6brt9qqnkff8sfou32um5cxhvjon0gpzurxhn3jme8mlceb0pfodehle4rhiodlld0ojkdvhdcqtmdcswjnyhidontqa0ba4yivb7oanmgt8b0yhfistg2qnblq00zyjgdp75jhapitepbjfbidtpujzztvqdypzyeby7yu0taqhdbfaqyxbgxfzfey0dtgbdvrxow4csgnegoeybwnufa9bu0xcxgvnxdgz7vpyhfzyd34yer6feipxgfxgzhck2z41wcyzuri7mloeldkq2drqx69ku0axt1ymrltxjz8pmr1gtat7nc6iyzpqdg2wp0diegzuw1btfmlcj4h3y8blc48mliy8zz7igfkedysfyijxfu5lcj1vtxaxugqkkag5ju7mfehx63ms7m7yxp2o2fcvrexhpqkxn5uppzimce6ek8lq5zrway3ghirstqfgxsyogeupdhcq10gvcuanfxwafnprof1coqcqb7tfollekczocxexsok1ccpmb96hcwqiwcm2fs8wzugfxzfhaqsoy6z4cg9207dvj3dqrlqdzynalspjkkley1qmxpgwlqnpanjypozjvyaf063ynjunilpcgmeqe0qblzlmnxbfgx9cgg3k9whsezqum4hmmemsfviwjv2b4restu0o5jplkjo9tw3hqv6rgopkn3lzkt6fbga6bgunogidden0a7ebd01jizc9ybfuxkprfpxhdiaswtrtxlnrlxkdcfizcdv"

Re: Problem transfer from SMB to FTP OutMemory Java Heap Space

[Pontus Ullgren]

localWorkDirectory is a directory on the server where your camel route run
(in Fuse as you say),

localWorkDirectory is also supported in camel-jcifs (
http://camel.apache.org/jcifs.html).


// Pontus

On Fri, 3 Jun 2016 at 08:12 Daniel Pompa  wrote:

> Hi Pontus, sorry Im new in Fuse. The Camel version is 2.12.0
>
> how I can defined the heap size to the Java Process?
>
> I add localWorkDirectory into the URI, but fail again, this
> localWorkDirectory is a directory in Fuse or in the smb server? I put in
> the
> localWorkDirectory  in smb.
>
> I saw localWorkDirectory is just for FTP.
>
> Thanks.
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Problem-transfer-from-SMB-to-FTP-OutMemory-Java-Heap-Space-tp5783383p5783388.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Throttling per activemq consumer

[hasikada]

Let's say have I have multiple activemq consumers
(jms.concurrentConsumers=20), I use message groups, so incomming messages
has JMSXGroupID header set and I would like to enable throttling per message
group in Camel.

 from("activemq:queue:test")
  .throttle(1).timePeriodMillis(3L)
  .to("mock:result");

I would expect that first activemq consumer throttles incomming messages
from assigned message group, while second consumer throttles messages from
another group in parallel.
But the first throttling consumer blocks second one. The second consumer is
not able to process a message until the throttling time period 30sec of
first one expires.

How to proceed the message groups in parallel and enable delay between the
messages within same message group?

Thank you

Adam



--
View this message in context: 
http://camel.465427.n5.nabble.com/Throttling-per-activemq-consumer-tp5783432.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: IBM MQ to Active MQ migration

[souciance]

Best help is to start reading the documentation, break the problem in
smaller parts, and try it out and then come back with specific questions.

On Fri, Jun 3, 2016 at 8:15 AM, tanay94 [via Camel] <
ml-node+s465427n5783408...@n5.nabble.com> wrote:

> I want to migrate applications from IBM MQ to Active MQ. I would prefer
> using camel. Since I am new to this technology, I would appreciate if
> someone helps me to build it from scratch.
>
> --
> If you reply to this email, your message will be added to the discussion
> below:
>
> http://camel.465427.n5.nabble.com/IBM-MQ-to-Active-MQ-migration-tp5783408.html
> To start a new topic under Camel - Users, email
> ml-node+s465427n465428...@n5.nabble.com
> To unsubscribe from Camel - Users, click here
> 
> .
> NAML
> 
>




--
View this message in context: 
http://camel.465427.n5.nabble.com/IBM-MQ-to-Active-MQ-migration-tp5783408p5783411.html
Sent from the Camel - Users mailing list archive at Nabble.com.