On Tue, May 6, 2014 at 7:07 PM, Charles Moulliard wrote:
> s optional, what did you plan to return to your client
> calling your TCP Server exposed by nett
There is a situation when my application is failed to get response
from a third party, the client must also get the same condition.
--
Hi All
Is it possible to make response to be optional in Netty component?
The following routes still make all the response sent back to its
clients, regardless the body is.
${body} == 'intan'
Thanks
--
~The best men are men who
k patterns.
>
> *Robert Simmons Jr. MSc. - Lead Java Architect @ EA*
> *Author of: Hardcore Java (2003) and Maintainable Java (2012)*
> *LinkedIn: **http://www.linkedin.com/pub/robert-simmons/40/852/a39
> <http://www.linkedin.com/pub/robert-simmons/40/852/a39>*
>
>
> On Wed,
OK. I really get your point. Great answer!
Thanks
On Wed, Apr 30, 2014 at 5:18 PM, Jens Breitenstein wrote:
> onder if performance is really a problem? An object makes handling of your
> business logic in all your camel processors far easier (a map, a business
> related class) in contrast to rep
testream there is no
> overhead passing this message through the camel routes (in one vm).
>
> Can you provide more info maybe I simply did not get it?
>
> Jens
>
> Von meinem iPhone gesendet
>
>> Am 30.04.2014 um 08:34 schrieb Muhammad Ichsan :
>>
>> Hi
&g
Hi
I'm thinking about creating a common message which will hold all data
during all business invocations across different system in Camel (of
course with translation for vary systems).
In my first thought, I'm going to use a simple one like Map. The the
payload is simple to use in processor. I ca
My question is: is it true that CachingConnectionFactory causes problem in
Camel OSGi environment?
On Jan 3, 2014 7:21 PM, "Claus Ibsen" wrote:
> On Fri, Jan 3, 2014 at 1:18 PM, Muhammad Ichsan wrote:
> > I'm using org.springframework.jms.connection.CachingConnecti
t; http://camel.apache.org/activemq
>
> On Fri, Jan 3, 2014 at 12:07 PM, Muhammad Ichsan wrote:
>> I have routes defined in an OSGi bundle. The routes use activemq
>> component to process data. To be exact, I have camel listen into 3
>> different queue with concurrency = 10
I have routes defined in an OSGi bundle. The routes use activemq
component to process data. To be exact, I have camel listen into 3
different queue with concurrency = 10.
As I started it in servicemix (apache-servicemix-4.4.0-fuse-00-27), I
see in the Active MQ Web console that the queues are cons
I want to preserve headers of Exchange when sending to other queue. Is
it possible?
public void receiveAndForward(Exchange x) {
timer.schedule(new TimerTask() { sendTo(x, "otherQ"); }, 3000);
}
So that I can read headers of x in the following route
< read x header />
--
~The
I set up many ActiveMQ brokers using this:
How to configure Camel to connect to the cluster? Because ports the
brokers listen to is vary (not fixed). I'm new to clustering.
Thanks
--
~The best men are men who benefit to others
http://michsan.web.id 一緒に勉強しましょう！
Yang berkualitas memang beda ra
Hi
I'm using Camel in FUSE 4.3.1 and
I have implemented the converter. But the problem intermitent. I got
this: javax.jms.JMSException: Failed to build body from content.
Serializable class not available to broker. Reason:
java.lang.ClassNotFoundException id.web.michsan.InternalMsg. Strangely
tha
Hi
Does anyone know why this happens?
org.apache.camel.RuntimeCamelException:
java.lang.IllegalAccessException: Class
org.apache.camel.component.bean.MethodInfo can not access a member of
class id.web.michsan.xt.route.CommonEndpointRouteBuilder$1 with
modifiers "public"
Thanks
--
~The best men
On Thu, May 5, 2011 at 1:14 PM, Muhammad Ichsan wrote:
> Using above DSL, it did work. But it does not for the following
On Wed, May 4, 2011 at 8:47 PM, Muhammad Ichsan wrote:
> On Wed, May 4, 2011 at 7:26 PM, Claus Ibsen wrote:
>> Read the documentation
> from(xxx)
> .inOut().to("activemq:queue:foo")
> .threads(5)
> .to(yyy)
> .to(zzz);
>
On Wed, May 4, 2011 at 7:26 PM, Claus Ibsen wrote:
> Read the documentation
>
> See request/reply over JMS
> http://camel.apache.org/jms
Thank you so much Claus! This is what I've been looking for.
from(xxx)
.inOut().to("activemq:queue:foo")
.threads(5)
.to(yyy)
.to(zzz);
I'll try this
--
~Th
On Wed, May 4, 2011 at 6:27 PM, Muhammad Ichsan wrote:
> 2011/5/4 Claus Ibsen :
>> Hi
>>
It's still in sequence manner, even for this code:
ExecutorService executor = Executors.newFixedThreadPool(10);
// When: 18 messages are sent
2011/5/4 Claus Ibsen :
> Hi
>
> Its a bit hard to follow your question?
>
> Concurrency all starts with consumers. So if you have a single thread
> that sends a message to "direct:casemx" then there is only a single
> thread processing in that given route.
This is how I send the message:
Dear All
I found another problem in Camel. Given context file (the java bean
code is self-explainable):
2011/5/4 Claus Ibsen :
> Hi
>
> I created an unit test based on our routes and it works fine
> http://svn.apache.org/viewvc?rev=1099342&view=rev
So, why it's not working with Spring? Is it Camel's bug related to Spring?
--
~The best men are men who benefit to others
http://michsan.web.id 一緒に勉強し
On Wed, May 4, 2011 at 11:27 AM, boday wrote:
> here are a few links that might help...
>
Thanks!
But, how about time limitation? I need to make sure that when sending
100 messages in concurrency 20 into a 5s processor, camel can process
20 messages in 5s.
--
~The best men are men who benefit
Dear All
I want to load testing my camel so that I know if my configuration -
e.g. concurrentConsumers=10 - can process a 10 messages at one time
concurrently. How to do this? Is there any real example? Thanks
--
~The best men are men who benefit to others
http://michsan.web.id 一緒に勉強しましょう！
Yang
On Tue, May 3, 2011 at 10:00 PM, Claus Straube wrote:
> ok - I see the problem. Try this instead:
>
> public void configure() throws Exception {
>
> from("direct:foo")
> .inOut("activemq:queue:a", "activemq:queue:b")
As far as I know, queue will be used by
On Tue, May 3, 2011 at 6:55 PM, Claus Straube wrote:
The problem is not when using "direct", but when using "activemq"
I'm using:
2.6.0
3.0.5.RELEASE
5.4.2
It's still happening in 2.7.1
If you need my code to review, this is the complete artifact
On Tue, May 3, 2011 at 3:49 PM, Claus Straube wrote:
> Hi Muhammad,
Ichsan please :D
>
> I think the error must be in your iMessageUtil class. This route works as
> you would expect:
IMHO, I think it's a bug in Camel. Please look at my testing arti
Dear All,
Is it possible to use inOut in routingSlip? In the following context,
the destination is visited asynchronously instead of - my expectation
- synchronously. Why this happens?
http://camel.apache.org/schema/spring";>
On Thu, Oct 14, 2010 at 4:06 PM, Willem Jiang wrote:
>> So, Camel will use the same instance across Camel routes?
>>
>> I failed to replace the message into getIn().setBody() with the
>> message clone. It triggers time out exception. May be it's because I'm
>> not quite understand about inOut tri
On Thu, Oct 14, 2010 at 3:23 PM, Willem Jiang wrote:
> st create a new copy of internalMessage in the modify method and set it to
> the message body after the modification ?
So, Camel will use the same instance across Camel routes?
I failed to replace the message into getIn().setBody() with the
Dear Camel Experts
I have an object which becomes the main message to be transported
across camel routes. So, I don't use String or other simple object.
That's why I have to use converter.
@Converter
public class InternalMessageConverter {
@Converter
public static InputStream toT
2010/8/31 Claus Ibsen
> Read chapter 7 in the Camel book how to do request/reply over JMS.
>
> The 2nd route (amq:input) will "detect" the JMSReplyTo header
> automatic and automatic return back the reply. So you don't have to do
> that manually.
> Just at the end of the routing the message is se
Dear All
I want to know if this is possible
How to implement communicator then?
Thanks
--
~The best men are men who benefit to others
http://michsan.web.id 一緒に勉強しましょう！
Yang berkualitas memang beda rasanya!
http://rizqi-cookies.com
On Tue, Aug 31, 2010 at 2:32 PM, Willem Jiang wrote:
> Muhammad Ichsan wrote:
>
>>
>> Thanks for your reply. Here I've just attached my complete code to make it
>> easier to analyze. This is strange.
>>
>> I can't see any code from your mail.
>
On Tue, Aug 31, 2010 at 2:07 PM, Willem Jiang wrote:
> Hi,
>
> Can you just insert a processor after the "activemq:mm01.rin" endpoint?
> Maybe something is wrong with your internalViewer bean.
>
Thanks for your reply. Here I've just attached my complete code to make it
easier to analyze. This is
Dear All
I have problem related to inOut in my attachment. The problem is that,
Exchange.getIn().getBody() is null after inOut invocation. This problem
doesn't occur if I do not have any after activemq:mm01.rin
Thanks for your guidance.
--
~The best men are men who benefit
I have the following routes: http://pastebin.ca/1929016
If the link is broken, see the following:
The problem is, if I uncomment the XML comment 'Problem cause', the route
will be error. Unpredicted behaviour occurs. Why this happens?
This bean:interMessa
2010/7/16 Guillaume Nodet :
> Have a look at http://camel.apache.org/using-osgi-blueprint-with-camel.html
> Let me know if you need more informations.
Actually, I've tried this. But, there was problem with Spring. Some
kind of collision between 2.5.0SEC02 and 3.0.3RELEASE. It's really
complicated.
On Wed, Jul 14, 2010 at 8:41 PM, Willem.Jiang wrote:
>
> Maybe you can consider to put the activemq-broker file into your unit test
> test resource directory.
No, it's not working. It still complains about missing
[spring:file:etc/activemq-broker.xml]. If you want to see how I
produce this error,
Is Camel Blueprint ready for FUSE ESB 4.2.0 container? I want to
deploy my Camel-enabled app in blueprint way inside the container. If
it's not, I will use Spring way instead. If it is, how to make it
work? What features or bundles should be inactive or uninstalled.
Thanks
--
~The best men are
On Fri, Jul 9, 2010 at 7:48 PM, Willem Jiang wrote:
> Hi,
>
> Can you try to put the file into the WorkingDirectory of your Pax Exam?
> You can set this option from the static "configure" method.
I did set working directory as
http://fusesource.com/docs/esb/4.2/deploy_osgi/BestPractices-PaxExam.h
How to test my Camel application using Pax Exam? I need to test across
bundles which requires Active MQ ("uri=activemq:blahblah") using OSGi.
I tried to load the activemq-broker feature but failed. It needs
/etc/active-broker.xml configuration. I don't know where to put the
file and how.
Sorry if
Hi All
Does Anyone know how to prevent problem in your Camel application
during development phase, like CPU eating and raising Java Heap Space
that cause my Camel App dropped? I want to recreate my Camel App so
that the problem vanished. I hate restarting my app daily. I really
appreciate if you c
2010/5/19 Claus Ibsen :
> On Wed, May 19, 2010 at 6:43 AM, Muhammad Ichsan wrote:
>> 2010/5/18 Claus Ibsen :
>>> Try without ?replyTo=out
>>
>
> Do something simpler and then add to the route.
> For example using only JMS, mock etc. to have a simple test start
2010/5/18 Claus Ibsen :
> Try without ?replyTo=out
Not working
--
~The best men are men who benefit to others
http://michsan.web.id 一緒に勉強しましょう！
Yang berkualitas memang beda rasanya!
http://rizqi-cookies.com
Dear All
I have the following routes:
// To test in out pattern
from("direct:input").setExchangePattern(ExchangePattern.InOut).to("activemq:in?replyTo=out").to("mock:result");
from("activemq:in").to("bean:con?method=toExternalMessageRequest").to("bean:biller?meth
On Tue, May 18, 2010 at 6:51 PM, Muhammad Ichsan wrote:
> Dear All
>
> I have the following routes:
>
> from("direct:input").to("activemq:in?replyTo=out").to("mock:result");
>
Sorry. My mistake. I should use public class for both message clas
Dear All
I have the following routes:
from("direct:input").to("activemq:in?replyTo=out").to("mock:result");
// This receive InternalMessage object and send to a biller (the
biller bean receive ExternalMessage object)
from("activemq:in").to("bean:con?method=toExternalMessageRequest").to("bean:bil
On Thu, Apr 22, 2010 at 8:24 PM, Claus Ibsen wrote:
> Hi
>
> I dont tink the tar have the -test source code.
>
> You can view that online at
>
> https://svn.apache.org/repos/asf/camel/trunk/components/camel-mina/src/test/
>
Thanks, this URL is enough for me. But the test class needs some
modific
Dear All
I want to create a component which also use its own uri. How to unit test
the component? I see nothing about testing components (e.g. camel-mina) in
the source apache-camel-2.2.0-src.tar.gz
--
~The best men are men who benefit to others
http://michsan.web.id
On Fri, Apr 2, 2010 at 2:47 AM, Ashwin Karpe wrote:
>
> Hi,
>
> Yes, they will connect to each other since the URL points to the same host
> and port over TCP.
There is no point doing this. There is a never ending loop when doing
this. I've tried myself.
On Thu, Apr 1, 2010 at 7:13 PM, Ashwin Karpe wrote:
>
> Hi,
>
> You cannot do it the way you have detailed. The endpoint in the from()
> clause will create a TCP Listener and bind to a socket (aka server).
>
> You could do the following and accomplish your objective
>
> In Client
> --
>
Dear All,
I tried to use mina endpoints. I see that mina endpoints which is used
in will act as servers and the ones which is used in will
act as clients.
Actually, I need mina endpoints which more or less defined as the
following code:
Is it possible?
Thanks!
--
~The best men are men w
Dear All
I have strange problem in Camel. I use routingSlip like the following:
...
...
There was no problem before in flowing in a 4-endpoint routing slip.
But now, the third of the endpoints is visited 30s-38s since last
endpoint is visited. What are the possible causes?
This are the d
Hi All
Based on the following routes:
Is it possible to use the tag there?
Thanks
--
~The best men are men who benefit to others
http://michsan.web.id
Yang berkualitas memang beda rasanya!
http://rizqi-cookies.com
Dear all
I have a route which is called by like the following:
my.Exception
true
5000
On Thu, Feb 11, 2010 at 1:14 AM, Muhammad Ichsan wrote:
> Dear All,
>
> Please see http://pastebin.com/m4c32d43e
Revised: http://pastebin.com/m456bef74
--
~The best men are men who benefit to others
http://michsan.web.id
Yang berkualitas memang beda rasanya!
http://rizqi-cookies.com
Dear All,
Please see http://pastebin.com/m4c32d43e
The problem is, why I always get timeout. I always get "OMG! Timeout
in inOut poc.itm.invoker.in". I see nothing's wrong here.
Thanks
--
~The best men are men who benefit to others
http://michsan.web.id
Yang berkualitas memang beda rasanya!
h
Dear All
I've been searching about how to use threads in Camel. But I found
nothing which answer my problem. This is one of my routes:
.
Dear All
I have to questions:
1. How to specify concurrent consumers for queue:oth in
Because, "concurrentConsumers=50" only applies to queue:inh (as I
see in activemq webadmin console which states only one consumer
listening to queue:oth) I'm considering this is one of the culprits
Dear All
I'm using Camel, ActiveMQ and ServiceMix
Is it possible to achieve average 100 transaction per second (stable
response time, not rising one). What are things to consider? I've add
concurrentConsumers=100 but the response time is still rising. I'm
glad if you could give me any links for r
Dear All,
I have a class which send a request message and also read a response
message through socket. I want to add it into my camel. What's the
best option? I'm considering implement this (to be invoked through
bean):
/**
@return String The response
*/
public String executeMessage(String request
60 matches
Mail list logo
