Thanks for the comments from all of you, now we have to analyze all of this
and possibly refactor our code, based on your feedback. Thanks for help,
Greg
W dniu 13 lutego 2012 10:13 użytkownik Ioannis Canellos
napisał:
> Grezgorz,
>
> Allow me to clarify that I did not mean that you are "overusi
You should use the options of decoders and encoders.
The netty endpoint doesn't support the option of encoder and decoder.
On Tue Feb 14 12:46:27 2012, xiangqiuzhao wrote:
I change the URI with
.to("netty:tcp://localhost:6789?encoder=#myEncoder&decoder=#myDecoder&sync=true").
but the same excep
Samruben
I highly recommend the "camel on action" book it is enlightning to say the
least.
On Tuesday, February 14, 2012, Claus Ibsen wrote:
> On Tue, Feb 14, 2012 at 8:36 AM, Samruben wrote:
>> Thank you for your reply.
>>
>> I have gone through it. Is there any demo example implemented this
Hi
I have seen some simplerouterfromxml java file in the link
http://svn.apache.org/viewvc/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jaxb/SpringLoadRouteFromXmlTest.java?view=markup&pathrev=1040085
whether I need to do the same thing or its for older version?
// load ro
You need to enable the stream cache[1], as the stream is consumed when
.
[1]http://camel.apache.org/stream-caching.html
On Tue Feb 14 14:33:49 2012, Lars wrote:
Hi,
I'm using Camel 2.9.0 and try to aggregate the content of xml-files in a
directory into a zip-file. When I try to open the zip it
hi Forum,
I'm trying to do a simple route, consuming from a JMS queue and handling
several messages in parallel by some Bean.
It's a simple
route. camel-context.xml is attached.
Well, it does not work...
The queue has several messages in it, debugging in eclipse I see some JMS
Consumers, but on
Willem
Shouldn't ZipDataFormat.marshal() method [1] better make use of
TypeConverter's mandatoryConvertTo() method instead of convertTo() to
avoid such NPE as an ugly side effect when the conversion fails.
This "manadatory conversion behaviour" is already available by it's
unmarshal() method.
WD
Hi
Did you have a change to set the activemq endpoint option of
concurrentConsumers like this?
On Tue Feb 14 18:21:14 2012, shlomi java wrote:
hi Forum,
I'm trying to do a simple route, consuming from a JMS queue and
handling several messages in parallel by some Bean.
It's a simple exec
i had look at http://camel.apache.org/netty.html, and described as "Registry
based Options".
so it's a mistake?
--
View this message in context:
http://camel.465427.n5.nabble.com/about-netty-encoder-and-encoders-tp5479417p5482422.html
Sent from the Camel - Users mailing list archive at Nabble.co
Hi
No it's NOT a mistake of yours, as both encoder/encoders as well as
decoder/decoders are ALL supported, see [1] which supports these!
Question: does your encoder extends
org.jboss.netty.channel.ChannelDownStreamHandler and your decoder extends
org.jboss.netty.channel.ChannelUpStreamHandler.
C
Hi,
I have seen the documentation of the resequencer EIP (
http://camel.apache.org/resequencer.html) and examples are based on direct
source.
Is it applicable when using a JMS source and transaction ?
I would say no since messages would be dispatched sequentially (waiting
commit to dispatch the
Thanks!
By configuring stream cache I got rid of NPE.
But the zip-file is still unreadable.
Best regards
Lars Stuevold
--
View this message in context:
http://camel.465427.n5.nabble.com/Zipping-the-content-of-several-files-into-one-file-tp5481638p5482567.html
Sent from the Camel - Users maili
+1 for the change.
It makes sense.
Willem
On Feb 14, 2012, at 8:43 PM, Babak Vahdat wrote:
> Willem
>
> Shouldn't ZipDataFormat.marshal() method [1] better make use of
> TypeConverter's mandatoryConvertTo() method instead of convertTo() to
> avoid such NPE as an ugly side effect when the conver
*Solved!* sort of...
The problem was that the JMS queue got filled with messages *before* any
consumer was available.
When the consumers were finally started, by initiating the to:activemq
endpoint, all existing messages in the JMS queue were assigned to a *single
consumer!*
That caused the _app
Hi,
Can you just change the ftp endpoint to a normal file endpoint ?
I'm not sure if the issue is related to it.
On Tue Feb 14 22:23:01 2012, Lars wrote:
Thanks!
By configuring stream cache I got rid of NPE.
But the zip-file is still unreadable.
Best regards
Lars Stuevold
--
View this messa
> You may get some idea by checking out the code of StreamComponent.
> But you still need to find a way to tell the StreamConsumer to pick up the
> Stream when your callback API is called.
I will stick with my custom glue code as it is more readable and
maintainable for my client's team.
Thanks f
the class LengthDecoder and MessageEncoder code:
public class LengthDecoder extends FrameDecoder {
private static final transient Logger LOG =
LoggerFactory.getLogger(LengthDecoder.class);
@Override
protected Object decode(
ChannelHandlerContext ctx, Channel channel,
Done: http://svn.apache.org/viewvc?view=revision&revision=1243995
Babak
--
View this message in context:
http://camel.465427.n5.nabble.com/Zipping-the-content-of-several-files-into-one-file-tp5481638p5482800.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Hello,
I am trying to implement a camel solution for a pretty simple requirement.
Its about a monitoring system with jms. Here is what it looks like:
1. a process writes jms messages with an xml body in an activemq queue. The
xml body contains the monitoring data to be evaluated.
2. in a pre defi
Hi
That's indeed possible even if you make use of the *transactional* JMS.
I already verified it using one of the Camel's own unit tests (you could
also give it a try as well if you want).
I changed [1] as the following (note the newly introduced transacted() DSL):
from("activemq:queue:in1").tr
I think you should consider reading from the queue directly, and remove
the timing piece from the design altogether. The beauty in this
approach, is that it will be processing closer to realtime, and it will
aggregate only when you need to aggregate.. in 3s batches. If you only
get one messag
And if you want to increase the performance (because of the transactional
overhead) consider the usage of:
cacheLevelName=CACHE_CONSUMER
option as already described [1], and in case you want to run the test I've
already mentioned by my previous post it would be [2].
[1] http://camel.apache.org/j
Thanks, i will do some tests.
Hervé
On 2/14/12, Babak Vahdat wrote:
> And if you want to increase the performance (because of the transactional
> overhead) consider the usage of:
>
> cacheLevelName=CACHE_CONSUMER
>
> option as already described [1], and in case you want to run the test I've
> al
Hi
You make use of Camel 2.7.2 which means you're suffering from the ticket [1]
not being resolved by your used version, so consider an upgrade if possible.
Just a side note:
As you own one *single* encoder and *one* single decoder just make use of
encoder/decoder parameters and remove the encode
Hi
I am new user to camel.
My requirement is the JAXB object which is in the method in java should
directly be used to trigger off the flow defined in the XML (router).JAXB
object should be passed as-is by reference to the xml flow(contains router
information).
Could you provide me some examp
I'm taking on a task of converting bean that we use along a camel route into an
actual camel component. I have everything working and wired up (simple
processor component) but have one problem. We use Spring to create a bean that
we use to interface with various external systems and I want to
Hi Matt,
Thanks a lot for the quick answer.
I guess, I found a solution. As you proposed, without the timer component.
The aggregator component has a property called "completionInterval". In the
documentation for this property it says:
"/A repeating period in millis by which the aggregator will co
Hi
I am new user to camel.
I have a project created using JAXB. My requirement is, when the method in a
service is called, JAXB object inside the calling method should directly be
used to trigger off the flow defined in the XML (router).JAXB object should
be passed as-is by reference to the xml f
Hi, i have done some tests.
It seems that the Stream Resequencing as in fact a "size" when using JMS
This "batch size" is completely linked to the Prefetch size.
If you need more messages than the prefetch size, the resequencer
can't do its job. (I have run the test with 1010 messages as it is a
Good deal, let us know how it goes. Just to clarify-- i was suggesting
adding a completionSize in ADDITION to the completionInterval. Its a
"belt and suspenders" type approach.
On 2/14/12 12:12 PM, weggyboy wrote:
Hi Matt,
Thanks a lot for the quick answer.
I guess, I found a solution. As y
Set the prefetch size to 0 and in case not already done check this:
http://activemq.apache.org/i-do-not-receive-messages-in-my-second-consumer.html
Babak
--
View this message in context:
http://camel.465427.n5.nabble.com/Resequencer-EIP-tp5482502p5483660.html
Sent from the Camel - Users mailing
Hello,
I am trying to build a application with several camel routes which re use
many common routes internally.
Hence, I am trying to segregate the routes in several different Route
Builder classes and then connecting the routes where needed.
For eg, all routes pertaining to sending emails go int
Well, I haven't gotten a satisfactory response to this inquiry. Really
looks like a bug to me. Any Camel contributors care to comment?
Thanks,
Jim
On 2/6/2012 2:22 PM, Jim Newsham wrote:
The MEP is InOut ("request/reply"). There are two participants, a
consumer and a producer. We need
Please don't send the mail twice by asking for an example.
I think lots of people already provide you some throughts.
Can you take some time to try them all ?
On Wed Feb 15 02:53:03 2012, Samruben wrote:
Hi
I am new user to camel.
I have a project created using JAXB. My requirement is, when t
Camel supposes to look up the bean reference from the registry (name as
the key and bean instance as the value) which could be provided by the
Spring Application context.
If you want to inject a bean instance into the camel endpoint, you can
use EndpointHelper#setReferenceProperties() to do this
Thanks a lot for the response!
The scheduler is partially working now --
1. Camel keep running all the time, scheduler NOT forced to shut down
because of Camel routes stopped.
2. Scheduler started and did add the job using the trigger -- see below
logging output
But the job never get invoked, loo
Hi I have added two doubts within same topic. Thats the mistake i did. People
provided me some solutions for loading routers from xml. I did it. Now i
need to pass jaxb object to the xml flow.
--
View this message in context:
http://camel.465427.n5.nabble.com/loading-xml-file-tp5483420p5484849
Hi I have added two doubts within same topic. Thats the mistake i did. People
provided me some solutions for loading routers from xml. I did it. Now i
need to pass jaxb object to the xml flow.
--
View this message in context:
http://camel.465427.n5.nabble.com/loading-xml-file-tp5483420p5484851
Hi,
I have deleted much of the "crap" and converted to file endpoint ( see
below). However the produced zip-file is still unreadable. However, if I
convert to gzip marshalling the file is readable. What is wrong with the zip
marshalling?
http://camel.apache.org/schema/spring";>
39 matches
Mail list logo
