FAQ
I am sending messages through a Camel route in ActiveMQ. My message
reaches the end of the processing chain, and at the last processor I
call exchange.setOut( newly created DefaultMessage ). When I look at
the admin page for ActiveMQ, the topic shows that there is a message
to be dequeued. It even says that there is a consumer connected to
that topic, which is a GUI tool I wrote. The GUI tool makes a call to
Consumer.setMessageListener. So why are the messages not making their
way to my GUI tool? I am stumped as to why the messages sit in the
topic and never leave if there is a listener for that topic.

Of course the first thought is, is the Connection started? Yeah I
verified that. In fact I can send messages to the topic via the
web-based admin tool for ActiveMQ and the GUI receives them.

Thanks for any help you have,
Mark

Search Discussions

  • Claus Ibsen at Oct 2, 2010 at 7:07 am
    See this FAQ
    http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
    On Fri, Oct 1, 2010 at 10:37 PM, Mark Webb wrote:
    I am sending messages through a Camel route in ActiveMQ.  My message
    reaches the end of the processing chain, and at the last processor I
    call exchange.setOut( newly created DefaultMessage ).  When I look at
    the admin page for ActiveMQ, the topic shows that there is a message
    to be dequeued.  It even says that there is a consumer connected to
    that topic, which is a GUI tool I wrote.  The GUI tool makes a call to
    Consumer.setMessageListener.  So why are the messages not making their
    way to my GUI tool?  I am stumped as to why the messages sit in the
    topic and never leave if there is a listener for that topic.

    Of course the first thought is, is the Connection started?  Yeah I
    verified that.  In fact I can send messages to the topic via the
    web-based admin tool for ActiveMQ and the GUI receives them.

    Thanks for any help you have,
    Mark


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus
  • Mark Webb at Oct 4, 2010 at 1:57 pm
    Thanks. I have things working now.

    It seems weird to me though that if in a Processor I take a message
    in, transform it into a newly created Message object that I should
    call Exchange.setIn(Message) instead of Exchange.setOut(Message). I
    think of a Processor as taking "in" a message and then sending it
    "out", but it looks like that is not the case. Just need to adjust
    the way I think about things.


    On Sat, Oct 2, 2010 at 3:06 AM, Claus Ibsen wrote:
    See this FAQ
    http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
    On Fri, Oct 1, 2010 at 10:37 PM, Mark Webb wrote:
    I am sending messages through a Camel route in ActiveMQ.  My message
    reaches the end of the processing chain, and at the last processor I
    call exchange.setOut( newly created DefaultMessage ).  When I look at
    the admin page for ActiveMQ, the topic shows that there is a message
    to be dequeued.  It even says that there is a consumer connected to
    that topic, which is a GUI tool I wrote.  The GUI tool makes a call to
    Consumer.setMessageListener.  So why are the messages not making their
    way to my GUI tool?  I am stumped as to why the messages sit in the
    topic and never leave if there is a listener for that topic.

    Of course the first thought is, is the Connection started?  Yeah I
    verified that.  In fact I can send messages to the topic via the
    web-based admin tool for ActiveMQ and the GUI receives them.

    Thanks for any help you have,
    Mark


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus
  • Claus Ibsen at Oct 4, 2010 at 2:02 pm

    On Mon, Oct 4, 2010 at 3:57 PM, Mark Webb wrote:
    Thanks.  I have things working now.

    It seems weird to me though that if in a Processor I take a message
    in, transform it into a newly created Message object that I should
    call Exchange.setIn(Message) instead of Exchange.setOut(Message).  I
    think of a Processor as taking "in" a message and then sending it
    "out", but it looks like that is not the case.  Just need to adjust
    the way I think about things.
    You are not the only one. See this FAQ
    http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
    On Sat, Oct 2, 2010 at 3:06 AM, Claus Ibsen wrote:
    See this FAQ
    http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
    On Fri, Oct 1, 2010 at 10:37 PM, Mark Webb wrote:
    I am sending messages through a Camel route in ActiveMQ.  My message
    reaches the end of the processing chain, and at the last processor I
    call exchange.setOut( newly created DefaultMessage ).  When I look at
    the admin page for ActiveMQ, the topic shows that there is a message
    to be dequeued.  It even says that there is a consumer connected to
    that topic, which is a GUI tool I wrote.  The GUI tool makes a call to
    Consumer.setMessageListener.  So why are the messages not making their
    way to my GUI tool?  I am stumped as to why the messages sit in the
    topic and never leave if there is a listener for that topic.

    Of course the first thought is, is the Connection started?  Yeah I
    verified that.  In fact I can send messages to the topic via the
    web-based admin tool for ActiveMQ and the GUI receives them.

    Thanks for any help you have,
    Mark


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus
  • Hadrian Zbarcea at Oct 4, 2010 at 5:54 pm
    Yeah, there is still a lot of confusion.
    Unfortunately that page is bollocks and I'll have to get it cleaned up.
    Mark, I think you did the right thing actually, in a processor one should *not* modify the in, but produce an out, if needed. It's time to get that clarified!

    My $0.02,
    Hadrian
    On Oct 4, 2010, at 10:01 AM, Claus Ibsen wrote:
    On Mon, Oct 4, 2010 at 3:57 PM, Mark Webb wrote:
    Thanks. I have things working now.

    It seems weird to me though that if in a Processor I take a message
    in, transform it into a newly created Message object that I should
    call Exchange.setIn(Message) instead of Exchange.setOut(Message). I
    think of a Processor as taking "in" a message and then sending it
    "out", but it looks like that is not the case. Just need to adjust
    the way I think about things.
    You are not the only one. See this FAQ
    http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
    On Sat, Oct 2, 2010 at 3:06 AM, Claus Ibsen wrote:
    See this FAQ
    http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
    On Fri, Oct 1, 2010 at 10:37 PM, Mark Webb wrote:
    I am sending messages through a Camel route in ActiveMQ. My message
    reaches the end of the processing chain, and at the last processor I
    call exchange.setOut( newly created DefaultMessage ). When I look at
    the admin page for ActiveMQ, the topic shows that there is a message
    to be dequeued. It even says that there is a consumer connected to
    that topic, which is a GUI tool I wrote. The GUI tool makes a call to
    Consumer.setMessageListener. So why are the messages not making their
    way to my GUI tool? I am stumped as to why the messages sit in the
    topic and never leave if there is a listener for that topic.

    Of course the first thought is, is the Connection started? Yeah I
    verified that. In fact I can send messages to the topic via the
    web-based admin tool for ActiveMQ and the GUI receives them.

    Thanks for any help you have,
    Mark


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus
  • Russell, Brian at Oct 4, 2010 at 6:10 pm
    I have deployed a working quartz cron trigger outside of the camel
    configuration.

    We are in the process of implementing our backend processes using camel.
    So far, this is going well and have not hit any major obstacles -- so
    very pleased.

    I have a new quartz trigger that I am wanting to setup and can easily do
    it outside of camel.

    I am trying to setup the new quartz trigger inside of camel but am not
    quite getting it implemented properly.

    Basically, I want a trigger to fire every few minutes and load a List of
    java objects from the database.

    I want to take this list (assuming the Splitter pattern) and produce a
    message onto a jms queue.

    Are there any similar examples of this that I can reference using the
    Spring Configuration?

    I'm not quite understanding how to return the List of objects from the
    quartz job into the camel route where I can split it out from there.

    Thanks for any guidance.










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.
  • Ashwin Karpe at Oct 4, 2010 at 7:14 pm
  • Russell, Brian at Oct 5, 2010 at 1:58 pm
    Thanks very much. I guess the part that I'm not understanding in this
    is how to get a List<Object> to return from a method where I can then
    split it out based on a quart cron trigger.

    Let me ask it this way -- is the quartz implementation in camel
    literally just the timer part of the process? So that, when it kicks
    off, it pulls from your "from" endpoint to your "to" endpoint?

    So I would have something like the following:

    <endpoint id="quartz_scheduler"
    uri="quartz://quartTrigger?cron=0+0/1+*+*+*+?" />

    <route id="route1">
    <from ref="quartz_scheduler" />
    <to ref="beanReturningListObject">
    <split>
    <simple>body</simple>
    <to ref="map_objects" />
    <to ref="jms_queue" />
    </split>
    </route>

    Is quartz_scheduler just a cron expression or does it actually map to a
    bean? Does quartzTrigger need to be defined as a bean also? In my
    quartz-only implementation, I actually create a custom trigger bean and
    a custom job bean. The job bean in that scenario would execute a
    service layer to get the objects, iterate through them, move them to a
    MapMessage, and drop them on the queue.

    With this, I'm trying to have a quartz job return a List<Object and drop
    each object onto the queue.

    I'm just not quite following how this stream gets mapped together
    through the spring configuration?

    ?


    -----Original Message-----
    From: Ashwin Karpe
    Sent: Monday, October 04, 2010 3:14 PM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?


    Hi,

    Check out the following links

    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup

    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup

    Cheers,

    Ashwin...


    -----
    ---------------------------------------------------------
    Ashwin Karpe
    Apache Camel Committer & Sr Principal Consultant
    FUSESource (a Progress Software Corporation subsidiary)
    http://fusesource.com http://fusesource.com

    Blog: http://opensourceknowledge.blogspot.com
    http://opensourceknowledge.blogspot.com
    ---------------------------------------------------------
    --
    View this message in context:
    http://camel.465427.n5.nabble.com/message-not-getting-delivered-tp307328
    1p3198239.html
    Sent from the Camel - Users mailing list archive at Nabble.com.










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.
  • Claus Ibsen at Oct 5, 2010 at 3:12 pm

    On Tue, Oct 5, 2010 at 3:56 PM, Russell, Brian wrote:
    Thanks very much.  I guess the part that I'm not understanding in this
    is how to get a List<Object> to return from a method where I can then
    split it out based on a quart cron trigger.

    Let me ask it this way -- is the quartz implementation in camel
    literally just the timer part of the process?  So that, when it kicks
    off, it pulls from your "from" endpoint to your "to" endpoint?
    Yes quartz is just the scheduler. You can just use a bean/processor to
    get the List<Object>.

    from(qartz)
    to(beanThatGetTheList)
    ...

    So I would have something like the following:

    <endpoint id="quartz_scheduler"
    uri="quartz://quartTrigger?cron=0+0/1+*+*+*+?" />

    <route id="route1">
    <from ref="quartz_scheduler" />
    <to ref="beanReturningListObject">
    <split>
    <simple>body</simple>
    <to ref="map_objects" />
    <to ref="jms_queue" />
    </split>
    </route>

    Is quartz_scheduler just a cron expression or does it actually map to a
    bean?  Does quartzTrigger need to be defined as a bean also?  In my
    quartz-only implementation, I actually create a custom trigger bean and
    a custom job bean.  The job bean in that scenario would execute a
    service layer to get the objects, iterate through them, move them to a
    MapMessage, and drop them on the queue.

    With this, I'm trying to have a quartz job return a List<Object and drop
    each object onto the queue.

    I'm just not quite following how this stream gets mapped together
    through the spring configuration?

    ?


    -----Original Message-----
    From: Ashwin Karpe
    Sent: Monday, October 04, 2010 3:14 PM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?


    Hi,

    Check out the following links

    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup

    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup

    Cheers,

    Ashwin...


    -----
    ---------------------------------------------------------
    Ashwin Karpe
    Apache Camel Committer & Sr Principal Consultant
    FUSESource (a Progress Software Corporation subsidiary)
    http://fusesource.com http://fusesource.com

    Blog: http://opensourceknowledge.blogspot.com
    http://opensourceknowledge.blogspot.com
    ---------------------------------------------------------
    --
    View this message in context:
    http://camel.465427.n5.nabble.com/message-not-getting-delivered-tp307328
    1p3198239.html
    Sent from the Camel - Users mailing list archive at Nabble.com.










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.




    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus
  • Russell, Brian at Oct 6, 2010 at 12:59 pm
    I did get this working for a single server -- thank you.

    As a follow-up, how can I implement this in a singleton mode across a cluster?

    I need the trigger to only fire on one server in the cluster at a time.

    I have this implemented using quartz outside of the camel context where the clustered timers race to lock a database but only one wins and actually fires.

    However, I am unclear on how this transfers into the camel implementation.

    ?


    -----Original Message-----
    From: Claus Ibsen
    Sent: Tuesday, October 05, 2010 11:12 AM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?
    On Tue, Oct 5, 2010 at 3:56 PM, Russell, Brian wrote:
    Thanks very much.  I guess the part that I'm not understanding in this
    is how to get a List<Object> to return from a method where I can then
    split it out based on a quart cron trigger.

    Let me ask it this way -- is the quartz implementation in camel
    literally just the timer part of the process?  So that, when it kicks
    off, it pulls from your "from" endpoint to your "to" endpoint?
    Yes quartz is just the scheduler. You can just use a bean/processor to
    get the List<Object>.

    from(qartz)
    to(beanThatGetTheList)
    ...

    So I would have something like the following:

    <endpoint id="quartz_scheduler"
    uri="quartz://quartTrigger?cron=0+0/1+*+*+*+?" />

    <route id="route1">
    <from ref="quartz_scheduler" />
    <to ref="beanReturningListObject">
    <split>
    <simple>body</simple>
    <to ref="map_objects" />
    <to ref="jms_queue" />
    </split>
    </route>

    Is quartz_scheduler just a cron expression or does it actually map to a
    bean?  Does quartzTrigger need to be defined as a bean also?  In my
    quartz-only implementation, I actually create a custom trigger bean and
    a custom job bean.  The job bean in that scenario would execute a
    service layer to get the objects, iterate through them, move them to a
    MapMessage, and drop them on the queue.

    With this, I'm trying to have a quartz job return a List<Object and drop
    each object onto the queue.

    I'm just not quite following how this stream gets mapped together
    through the spring configuration?

    ?


    -----Original Message-----
    From: Ashwin Karpe
    Sent: Monday, October 04, 2010 3:14 PM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?


    Hi,

    Check out the following links

    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup

    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup

    Cheers,

    Ashwin...


    -----
    ---------------------------------------------------------
    Ashwin Karpe
    Apache Camel Committer & Sr Principal Consultant
    FUSESource (a Progress Software Corporation subsidiary)
    http://fusesource.com http://fusesource.com

    Blog: http://opensourceknowledge.blogspot.com
    http://opensourceknowledge.blogspot.com
    ---------------------------------------------------------
    --
    View this message in context:
    http://camel.465427.n5.nabble.com/message-not-getting-delivered-tp307328
    1p3198239.html
    Sent from the Camel - Users mailing list archive at Nabble.com.










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.




    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.
  • Hadrian Zbarcea at Oct 6, 2010 at 1:05 pm
    Yes, it is fairly easy. You have to have a way though to communicate across instances in a cluster. So you will need a processor that sets the lock and a filter that will drop the quartz message (trigger event) if not the first.

    I hope this helps.
    Hadrian

    On Oct 6, 2010, at 8:57 AM, Russell, Brian wrote:

    I did get this working for a single server -- thank you.

    As a follow-up, how can I implement this in a singleton mode across a cluster?

    I need the trigger to only fire on one server in the cluster at a time.

    I have this implemented using quartz outside of the camel context where the clustered timers race to lock a database but only one wins and actually fires.

    However, I am unclear on how this transfers into the camel implementation.

    ?


    -----Original Message-----
    From: Claus Ibsen
    Sent: Tuesday, October 05, 2010 11:12 AM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?
    On Tue, Oct 5, 2010 at 3:56 PM, Russell, Brian wrote:
    Thanks very much. I guess the part that I'm not understanding in this
    is how to get a List<Object> to return from a method where I can then
    split it out based on a quart cron trigger.

    Let me ask it this way -- is the quartz implementation in camel
    literally just the timer part of the process? So that, when it kicks
    off, it pulls from your "from" endpoint to your "to" endpoint?
    Yes quartz is just the scheduler. You can just use a bean/processor to
    get the List<Object>.

    from(qartz)
    to(beanThatGetTheList)
    ...

    So I would have something like the following:

    <endpoint id="quartz_scheduler"
    uri="quartz://quartTrigger?cron=0+0/1+*+*+*+?" />

    <route id="route1">
    <from ref="quartz_scheduler" />
    <to ref="beanReturningListObject">
    <split>
    <simple>body</simple>
    <to ref="map_objects" />
    <to ref="jms_queue" />
    </split>
    </route>

    Is quartz_scheduler just a cron expression or does it actually map to a
    bean? Does quartzTrigger need to be defined as a bean also? In my
    quartz-only implementation, I actually create a custom trigger bean and
    a custom job bean. The job bean in that scenario would execute a
    service layer to get the objects, iterate through them, move them to a
    MapMessage, and drop them on the queue.

    With this, I'm trying to have a quartz job return a List<Object and drop
    each object onto the queue.

    I'm just not quite following how this stream gets mapped together
    through the spring configuration?

    ?


    -----Original Message-----
    From: Ashwin Karpe
    Sent: Monday, October 04, 2010 3:14 PM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?


    Hi,

    Check out the following links

    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup

    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup

    Cheers,

    Ashwin...


    -----
    ---------------------------------------------------------
    Ashwin Karpe
    Apache Camel Committer & Sr Principal Consultant
    FUSESource (a Progress Software Corporation subsidiary)
    http://fusesource.com http://fusesource.com

    Blog: http://opensourceknowledge.blogspot.com
    http://opensourceknowledge.blogspot.com
    ---------------------------------------------------------
    --
    View this message in context:
    http://camel.465427.n5.nabble.com/message-not-getting-delivered-tp307328
    1p3198239.html
    Sent from the Camel - Users mailing list archive at Nabble.com.










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.




    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.

  • Russell, Brian at Oct 6, 2010 at 1:17 pm
    That makes sense logically in terms of what is needed, but quartz does
    this by default. In doing this in a straight quartz context, I was able
    to do this through configuration (and setting up the quartz database
    tables).

    Is this type of functionality not implemented yet in camel or do I need
    to write the specific code to to this? Or am I missing something?

    Thanks for your help.


    -----Original Message-----
    From: Hadrian Zbarcea
    Sent: Wednesday, October 06, 2010 9:05 AM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?

    Yes, it is fairly easy. You have to have a way though to communicate
    across instances in a cluster. So you will need a processor that sets
    the lock and a filter that will drop the quartz message (trigger event)
    if not the first.

    I hope this helps.
    Hadrian

    On Oct 6, 2010, at 8:57 AM, Russell, Brian wrote:

    I did get this working for a single server -- thank you.

    As a follow-up, how can I implement this in a singleton mode across a cluster?
    I need the trigger to only fire on one server in the cluster at a time.
    I have this implemented using quartz outside of the camel context
    where the clustered timers race to lock a database but only one wins and
    actually fires.
    However, I am unclear on how this transfers into the camel
    implementation.
    ?


    -----Original Message-----
    From: Claus Ibsen
    Sent: Tuesday, October 05, 2010 11:12 AM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?
    On Tue, Oct 5, 2010 at 3:56 PM, Russell, Brian wrote:
    Thanks very much. I guess the part that I'm not understanding in
    this
    is how to get a List<Object> to return from a method where I can then
    split it out based on a quart cron trigger.

    Let me ask it this way -- is the quartz implementation in camel
    literally just the timer part of the process? So that, when it kicks
    off, it pulls from your "from" endpoint to your "to" endpoint?
    Yes quartz is just the scheduler. You can just use a bean/processor to
    get the List<Object>.

    from(qartz)
    to(beanThatGetTheList)
    ...

    So I would have something like the following:

    <endpoint id="quartz_scheduler"
    uri="quartz://quartTrigger?cron=0+0/1+*+*+*+?" />

    <route id="route1">
    <from ref="quartz_scheduler" />
    <to ref="beanReturningListObject">
    <split>
    <simple>body</simple>
    <to ref="map_objects" />
    <to ref="jms_queue" />
    </split>
    </route>

    Is quartz_scheduler just a cron expression or does it actually map to
    a
    bean? Does quartzTrigger need to be defined as a bean also? In my
    quartz-only implementation, I actually create a custom trigger bean
    and
    a custom job bean. The job bean in that scenario would execute a
    service layer to get the objects, iterate through them, move them to
    a
    MapMessage, and drop them on the queue.

    With this, I'm trying to have a quartz job return a List<Object and
    drop
    each object onto the queue.

    I'm just not quite following how this stream gets mapped together
    through the spring configuration?

    ?


    -----Original Message-----
    From: Ashwin Karpe
    Sent: Monday, October 04, 2010 3:14 PM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?


    Hi,

    Check out the following links
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    >>
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    >>
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    >>
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    >>
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup

    Cheers,

    Ashwin...


    -----
    ---------------------------------------------------------
    Ashwin Karpe
    Apache Camel Committer & Sr Principal Consultant
    FUSESource (a Progress Software Corporation subsidiary)
    http://fusesource.com http://fusesource.com

    Blog: http://opensourceknowledge.blogspot.com
    http://opensourceknowledge.blogspot.com
    ---------------------------------------------------------
    --
    View this message in context:
    http://camel.465427.n5.nabble.com/message-not-getting-delivered-tp307328
    1p3198239.html
    Sent from the Camel - Users mailing list archive at Nabble.com.










    Confidentiality Notice: The information contained in this electronic
    transmission is confidential and may be legally privileged. It is
    intended only for the addressee(s) named above. If you are not an
    intended recipient, be aware that any disclosure, copying, distribution
    or use of the information contained in this transmission is prohibited
    and may be unlawful. If you have received this transmission in error,
    please notify us by telephone (513) 229-5500 or by email
    (postmaster@MedPlus.com). After replying, please erase it from your
    computer system.



    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus










    Confidentiality Notice: The information contained in this electronic
    transmission is confidential and may be legally privileged. It is
    intended only for the addressee(s) named above. If you are not an
    intended recipient, be aware that any disclosure, copying, distribution
    or use of the information contained in this transmission is prohibited
    and may be unlawful. If you have received this transmission in error,
    please notify us by telephone (513) 229-5500 or by email
    (postmaster@MedPlus.com). After replying, please erase it from your
    computer system.










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.
  • Claus Ibsen at Oct 6, 2010 at 1:44 pm

    On Wed, Oct 6, 2010 at 3:15 PM, Russell, Brian wrote:
    That makes sense logically in terms of what is needed, but quartz does
    this by default.  In doing this in a straight quartz context, I was able
    to do this through configuration (and setting up the quartz database
    tables).

    Is this type of functionality not implemented yet in camel or do I need
    to write the specific code to to this?  Or am I missing something?
    No you just need to configure Quartz to be clustered with the DB stuff.

    Then you just configure the QuartzComponent to use your quartz.properties file
    See: http://camel.apache.org/quartz

    Thanks for your help.


    -----Original Message-----
    From: Hadrian Zbarcea
    Sent: Wednesday, October 06, 2010 9:05 AM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?

    Yes, it is fairly easy. You have to have a way though to communicate
    across instances in a cluster. So you will need a processor that sets
    the lock and a filter that will drop the quartz message (trigger event)
    if not the first.

    I hope this helps.
    Hadrian

    On Oct 6, 2010, at 8:57 AM, Russell, Brian wrote:

    I did get this working for a single server -- thank you.

    As a follow-up, how can I implement this in a singleton mode across a cluster?
    I need the trigger to only fire on one server in the cluster at a time.
    I have this implemented using quartz outside of the camel context
    where the clustered timers race to lock a database but only one wins and
    actually fires.
    However, I am unclear on how this transfers into the camel
    implementation.
    ?


    -----Original Message-----
    From: Claus Ibsen
    Sent: Tuesday, October 05, 2010 11:12 AM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?
    On Tue, Oct 5, 2010 at 3:56 PM, Russell, Brian wrote:
    Thanks very much.  I guess the part that I'm not understanding in
    this
    is how to get a List<Object> to return from a method where I can then
    split it out based on a quart cron trigger.

    Let me ask it this way -- is the quartz implementation in camel
    literally just the timer part of the process?  So that, when it kicks
    off, it pulls from your "from" endpoint to your "to" endpoint?
    Yes quartz is just the scheduler. You can just use a bean/processor to
    get the List<Object>.

    from(qartz)
    to(beanThatGetTheList)
    ...

    So I would have something like the following:

    <endpoint id="quartz_scheduler"
    uri="quartz://quartTrigger?cron=0+0/1+*+*+*+?" />

    <route id="route1">
    <from ref="quartz_scheduler" />
    <to ref="beanReturningListObject">
    <split>
    <simple>body</simple>
    <to ref="map_objects" />
    <to ref="jms_queue" />
    </split>
    </route>

    Is quartz_scheduler just a cron expression or does it actually map to
    a
    bean?  Does quartzTrigger need to be defined as a bean also?  In my
    quartz-only implementation, I actually create a custom trigger bean
    and
    a custom job bean.  The job bean in that scenario would execute a
    service layer to get the objects, iterate through them, move them to
    a
    MapMessage, and drop them on the queue.

    With this, I'm trying to have a quartz job return a List<Object and
    drop
    each object onto the queue.

    I'm just not quite following how this stream gets mapped together
    through the spring configuration?

    ?


    -----Original Message-----
    From: Ashwin Karpe
    Sent: Monday, October 04, 2010 3:14 PM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?


    Hi,

    Check out the following links
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup

    Cheers,

    Ashwin...


    -----
    ---------------------------------------------------------
    Ashwin Karpe
    Apache Camel Committer & Sr Principal Consultant
    FUSESource (a Progress Software Corporation subsidiary)
    http://fusesource.com http://fusesource.com

    Blog: http://opensourceknowledge.blogspot.com
    http://opensourceknowledge.blogspot.com
    ---------------------------------------------------------
    --
    View this message in context:
    http://camel.465427.n5.nabble.com/message-not-getting-delivered-tp307328
    1p3198239.html
    Sent from the Camel - Users mailing list archive at Nabble.com.










    Confidentiality Notice: The information contained in this electronic
    transmission is confidential and may be legally privileged. It is
    intended only for the addressee(s) named above. If you are not an
    intended recipient, be aware that any disclosure, copying, distribution
    or use of the information contained in this transmission is prohibited
    and may be unlawful. If you have received this transmission in error,
    please notify us by telephone (513) 229-5500 or by email
    (postmaster@MedPlus.com). After replying, please erase it from your
    computer system.



    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus










    Confidentiality Notice: The information contained in this electronic
    transmission is confidential and may be legally privileged. It is
    intended only for the addressee(s) named above. If you are not an
    intended recipient, be aware that any disclosure, copying, distribution
    or use of the information contained in this transmission is prohibited
    and may be unlawful. If you have received this transmission in error,
    please notify us by telephone (513) 229-5500 or by email
    (postmaster@MedPlus.com). After replying, please erase it from your
    computer system.










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.




    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus
  • Hadrian Zbarcea at Oct 6, 2010 at 1:48 pm
    That's not currently possible afaik using camel quartz configuration. I'd have to try that though to answer for sure.
    Camel works great on cluster deployments with stateless routes. There is a bit more work to do for stateful routes, we'll address in 3.0.

    Maybe somebody on the list did that already and has a solution?

    Hadrian

    On Oct 6, 2010, at 9:15 AM, Russell, Brian wrote:

    That makes sense logically in terms of what is needed, but quartz does
    this by default. In doing this in a straight quartz context, I was able
    to do this through configuration (and setting up the quartz database
    tables).

    Is this type of functionality not implemented yet in camel or do I need
    to write the specific code to to this? Or am I missing something?

    Thanks for your help.


    -----Original Message-----
    From: Hadrian Zbarcea
    Sent: Wednesday, October 06, 2010 9:05 AM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?

    Yes, it is fairly easy. You have to have a way though to communicate
    across instances in a cluster. So you will need a processor that sets
    the lock and a filter that will drop the quartz message (trigger event)
    if not the first.

    I hope this helps.
    Hadrian

    On Oct 6, 2010, at 8:57 AM, Russell, Brian wrote:

    I did get this working for a single server -- thank you.

    As a follow-up, how can I implement this in a singleton mode across a cluster?
    I need the trigger to only fire on one server in the cluster at a time.
    I have this implemented using quartz outside of the camel context
    where the clustered timers race to lock a database but only one wins and
    actually fires.
    However, I am unclear on how this transfers into the camel
    implementation.
    ?


    -----Original Message-----
    From: Claus Ibsen
    Sent: Tuesday, October 05, 2010 11:12 AM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?
    On Tue, Oct 5, 2010 at 3:56 PM, Russell, Brian wrote:
    Thanks very much. I guess the part that I'm not understanding in
    this
    is how to get a List<Object> to return from a method where I can then
    split it out based on a quart cron trigger.

    Let me ask it this way -- is the quartz implementation in camel
    literally just the timer part of the process? So that, when it kicks
    off, it pulls from your "from" endpoint to your "to" endpoint?
    Yes quartz is just the scheduler. You can just use a bean/processor to
    get the List<Object>.

    from(qartz)
    to(beanThatGetTheList)
    ...

    So I would have something like the following:

    <endpoint id="quartz_scheduler"
    uri="quartz://quartTrigger?cron=0+0/1+*+*+*+?" />

    <route id="route1">
    <from ref="quartz_scheduler" />
    <to ref="beanReturningListObject">
    <split>
    <simple>body</simple>
    <to ref="map_objects" />
    <to ref="jms_queue" />
    </split>
    </route>

    Is quartz_scheduler just a cron expression or does it actually map to
    a
    bean? Does quartzTrigger need to be defined as a bean also? In my
    quartz-only implementation, I actually create a custom trigger bean
    and
    a custom job bean. The job bean in that scenario would execute a
    service layer to get the objects, iterate through them, move them to
    a
    MapMessage, and drop them on the queue.

    With this, I'm trying to have a quartz job return a List<Object and
    drop
    each object onto the queue.

    I'm just not quite following how this stream gets mapped together
    through the spring configuration?

    ?


    -----Original Message-----
    From: Ashwin Karpe
    Sent: Monday, October 04, 2010 3:14 PM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?


    Hi,

    Check out the following links
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup

    Cheers,

    Ashwin...


    -----
    ---------------------------------------------------------
    Ashwin Karpe
    Apache Camel Committer & Sr Principal Consultant
    FUSESource (a Progress Software Corporation subsidiary)
    http://fusesource.com http://fusesource.com

    Blog: http://opensourceknowledge.blogspot.com
    http://opensourceknowledge.blogspot.com
    ---------------------------------------------------------
    --
    View this message in context:
    http://camel.465427.n5.nabble.com/message-not-getting-delivered-tp307328
    1p3198239.html
    Sent from the Camel - Users mailing list archive at Nabble.com.










    Confidentiality Notice: The information contained in this electronic
    transmission is confidential and may be legally privileged. It is
    intended only for the addressee(s) named above. If you are not an
    intended recipient, be aware that any disclosure, copying, distribution
    or use of the information contained in this transmission is prohibited
    and may be unlawful. If you have received this transmission in error,
    please notify us by telephone (513) 229-5500 or by email
    (postmaster@MedPlus.com). After replying, please erase it from your
    computer system.



    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus










    Confidentiality Notice: The information contained in this electronic
    transmission is confidential and may be legally privileged. It is
    intended only for the addressee(s) named above. If you are not an
    intended recipient, be aware that any disclosure, copying, distribution
    or use of the information contained in this transmission is prohibited
    and may be unlawful. If you have received this transmission in error,
    please notify us by telephone (513) 229-5500 or by email
    (postmaster@MedPlus.com). After replying, please erase it from your
    computer system.










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.

  • Claus Ibsen at Oct 6, 2010 at 2:27 pm

    On Wed, Oct 6, 2010 at 2:57 PM, Russell, Brian wrote:
    I did get this working for a single server -- thank you.

    As a follow-up, how can I implement this in a singleton mode across a cluster?

    I need the trigger to only fire on one server in the cluster at a time.
    This is what Quartz can do by its own. It can work in a cluster if you
    use the DB, which lets all node race for the shared lock in the shared
    DB. And only one will win and figure the triggers.

    That means only one Camel route should trigger as well.

    There has been a couple of guys around which did this. We found some
    problems with OSGi in Camel 2.3 which we fixed in 2.4.
    You can probably search this forum for those talks.


    I have this implemented using quartz outside of the camel context where the clustered timers race to lock a database but only one wins and actually fires.

    However, I am unclear on how this transfers into the camel implementation.

    ?


    -----Original Message-----
    From: Claus Ibsen
    Sent: Tuesday, October 05, 2010 11:12 AM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?
    On Tue, Oct 5, 2010 at 3:56 PM, Russell, Brian wrote:
    Thanks very much.  I guess the part that I'm not understanding in this
    is how to get a List<Object> to return from a method where I can then
    split it out based on a quart cron trigger.

    Let me ask it this way -- is the quartz implementation in camel
    literally just the timer part of the process?  So that, when it kicks
    off, it pulls from your "from" endpoint to your "to" endpoint?
    Yes quartz is just the scheduler. You can just use a bean/processor to
    get the List<Object>.

    from(qartz)
    to(beanThatGetTheList)
    ...

    So I would have something like the following:

    <endpoint id="quartz_scheduler"
    uri="quartz://quartTrigger?cron=0+0/1+*+*+*+?" />

    <route id="route1">
    <from ref="quartz_scheduler" />
    <to ref="beanReturningListObject">
    <split>
    <simple>body</simple>
    <to ref="map_objects" />
    <to ref="jms_queue" />
    </split>
    </route>

    Is quartz_scheduler just a cron expression or does it actually map to a
    bean?  Does quartzTrigger need to be defined as a bean also?  In my
    quartz-only implementation, I actually create a custom trigger bean and
    a custom job bean.  The job bean in that scenario would execute a
    service layer to get the objects, iterate through them, move them to a
    MapMessage, and drop them on the queue.

    With this, I'm trying to have a quartz job return a List<Object and drop
    each object onto the queue.

    I'm just not quite following how this stream gets mapped together
    through the spring configuration?

    ?


    -----Original Message-----
    From: Ashwin Karpe
    Sent: Monday, October 04, 2010 3:14 PM
    To: users@camel.apache.org
    Subject: Re: Quartz Camel Spring Example?


    Hi,

    Check out the following links

    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/resources/org/apache/camel/component/quartz/SpringQuartzCronRouteTest
    .xml?view=markup

    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup
    https://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/te
    st/java/org/apache/camel/component/quartz/SpringQuartzCronRouteTest.java
    ?view=markup

    Cheers,

    Ashwin...


    -----
    ---------------------------------------------------------
    Ashwin Karpe
    Apache Camel Committer & Sr Principal Consultant
    FUSESource (a Progress Software Corporation subsidiary)
    http://fusesource.com http://fusesource.com

    Blog: http://opensourceknowledge.blogspot.com
    http://opensourceknowledge.blogspot.com
    ---------------------------------------------------------
    --
    View this message in context:
    http://camel.465427.n5.nabble.com/message-not-getting-delivered-tp307328
    1p3198239.html
    Sent from the Camel - Users mailing list archive at Nabble.com.










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.




    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.




    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus
  • Russell, Brian at Oct 6, 2010 at 6:25 pm
    In addition to testing my clustered quartz configuration, I have the
    following question...

    I have a bean returning a java.util.List<CustomPOJO> (see get_list
    below). I then try to use the <simple>body</simple> to route each
    CustomPOJO. See following...

    <route id="route1">
    <from ref="quartz_scheduler" />
    <to ref="get_list" />
    <split>
    <simple>body</simple>
    <to ref="map_object" />
    <to ref="jms_queue" />
    </split>
    </route>

    It's not reaching the "map_object" bean endpoint.

    Should this be working or am I misconfiguring something?

    I am using camel 2.4.

    Thanks.










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.
  • Claus Ibsen at Oct 6, 2010 at 6:57 pm

    On Wed, Oct 6, 2010 at 8:23 PM, Russell, Brian wrote:
    In addition to testing my clustered quartz configuration, I have the
    following question...

    I have a bean returning a java.util.List<CustomPOJO>  (see get_list
    below).  I then try to use the <simple>body</simple> to route each
    CustomPOJO.  See following...

    <route id="route1">
    <from ref="quartz_scheduler" />
    <to ref="get_list" />
    <split>
    <simple>body</simple>
    <to ref="map_object" />
    <to ref="jms_queue" />
    </split>
    </route>

    It's not reaching the "map_object" bean endpoint.

    Should this be working or am I misconfiguring something?

    I am using camel 2.4.
    Can't remember if there was a bug/issue there when doing <simple>body</simple>
    You can try with <simple>${body}</simple>.
    Thanks.










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.




    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus
  • Russell, Brian at Oct 6, 2010 at 7:51 pm
    Thanks Claus. I tried that also and still not working. I verified the List coming out of my bean contains multiple CustomPOJO objects with values.

    I just wanted to make sure I am approaching this the correct way.

    Brian.


    -----Original Message-----
    From: Claus Ibsen
    Sent: Wednesday, October 06, 2010 2:56 PM
    To: users@camel.apache.org
    Subject: Re: Splitter Question
    On Wed, Oct 6, 2010 at 8:23 PM, Russell, Brian wrote:
    In addition to testing my clustered quartz configuration, I have the
    following question...

    I have a bean returning a java.util.List<CustomPOJO>  (see get_list
    below).  I then try to use the <simple>body</simple> to route each
    CustomPOJO.  See following...

    <route id="route1">
    <from ref="quartz_scheduler" />
    <to ref="get_list" />
    <split>
    <simple>body</simple>
    <to ref="map_object" />
    <to ref="jms_queue" />
    </split>
    </route>

    It's not reaching the "map_object" bean endpoint.

    Should this be working or am I misconfiguring something?

    I am using camel 2.4.
    Can't remember if there was a bug/issue there when doing <simple>body</simple>
    You can try with <simple>${body}</simple>.
    Thanks.










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.




    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.
  • Russell, Brian at Oct 6, 2010 at 8:28 pm
    Also, I assume the "map_object" bean would take CustomPOJO as the input parameter -- correct?


    -----Original Message-----
    From: Russell, Brian
    Sent: Wednesday, October 06, 2010 3:51 PM
    To: users@camel.apache.org
    Subject: RE: Splitter Question

    Thanks Claus. I tried that also and still not working. I verified the List coming out of my bean contains multiple CustomPOJO objects with values.

    I just wanted to make sure I am approaching this the correct way.

    Brian.


    -----Original Message-----
    From: Claus Ibsen
    Sent: Wednesday, October 06, 2010 2:56 PM
    To: users@camel.apache.org
    Subject: Re: Splitter Question
    On Wed, Oct 6, 2010 at 8:23 PM, Russell, Brian wrote:
    In addition to testing my clustered quartz configuration, I have the
    following question...

    I have a bean returning a java.util.List<CustomPOJO>  (see get_list
    below).  I then try to use the <simple>body</simple> to route each
    CustomPOJO.  See following...

    <route id="route1">
    <from ref="quartz_scheduler" />
    <to ref="get_list" />
    <split>
    <simple>body</simple>
    <to ref="map_object" />
    <to ref="jms_queue" />
    </split>
    </route>

    It's not reaching the "map_object" bean endpoint.

    Should this be working or am I misconfiguring something?

    I am using camel 2.4.
    Can't remember if there was a bug/issue there when doing <simple>body</simple>
    You can try with <simple>${body}</simple>.
    Thanks.










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.




    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.













    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.
  • Claus Ibsen at Oct 7, 2010 at 7:57 am
    I added an test which works
    http://svn.apache.org/viewvc?rev=1005355&view=rev

    Could you compare and also you can use the Tracer to see whats going on
    http://camel.apache.org/tracer
    On Wed, Oct 6, 2010 at 10:26 PM, Russell, Brian wrote:
    Also, I assume the "map_object" bean would take CustomPOJO as the input parameter -- correct?


    -----Original Message-----
    From: Russell, Brian
    Sent: Wednesday, October 06, 2010 3:51 PM
    To: users@camel.apache.org
    Subject: RE: Splitter Question

    Thanks Claus.  I tried that also and still not working.  I verified the List coming out of my bean contains multiple CustomPOJO objects with values.

    I just wanted to make sure I am approaching this the correct way.

    Brian.


    -----Original Message-----
    From: Claus Ibsen
    Sent: Wednesday, October 06, 2010 2:56 PM
    To: users@camel.apache.org
    Subject: Re: Splitter Question
    On Wed, Oct 6, 2010 at 8:23 PM, Russell, Brian wrote:
    In addition to testing my clustered quartz configuration, I have the
    following question...

    I have a bean returning a java.util.List<CustomPOJO>  (see get_list
    below).  I then try to use the <simple>body</simple> to route each
    CustomPOJO.  See following...

    <route id="route1">
    <from ref="quartz_scheduler" />
    <to ref="get_list" />
    <split>
    <simple>body</simple>
    <to ref="map_object" />
    <to ref="jms_queue" />
    </split>
    </route>

    It's not reaching the "map_object" bean endpoint.

    Should this be working or am I misconfiguring something?

    I am using camel 2.4.
    Can't remember if there was a bug/issue there when doing <simple>body</simple>
    You can try with <simple>${body}</simple>.
    Thanks.










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.




    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus










    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.













    Confidentiality Notice: The information contained in this electronic transmission is confidential and may be legally privileged. It is intended only for the addressee(s) named above. If you are not an intended recipient, be aware that any disclosure, copying, distribution or use of the information contained in this transmission is prohibited and may be unlawful. If you have received this transmission in error, please notify us by telephone (513) 229-5500 or by email (postmaster@MedPlus.com). After replying, please erase it from your computer system.




    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus
  • Mark Webb at Oct 4, 2010 at 7:59 pm
    I agree. But when producing an out I think you need to call
    Exchange.setIn(Message). Seems like when you call
    Exchange.setOut(Message) you are setting up a request-reply scenario
    which is not what I wanted.

    On Mon, Oct 4, 2010 at 1:54 PM, Hadrian Zbarcea wrote:
    Yeah, there is still a lot of confusion.
    Unfortunately that page is bollocks and I'll have to get it cleaned up.
    Mark, I think you did the right thing actually, in a processor one should *not* modify the in, but produce an out, if needed. It's time to get that clarified!

    My $0.02,
    Hadrian
    On Oct 4, 2010, at 10:01 AM, Claus Ibsen wrote:
    On Mon, Oct 4, 2010 at 3:57 PM, Mark Webb wrote:
    Thanks.  I have things working now.

    It seems weird to me though that if in a Processor I take a message
    in, transform it into a newly created Message object that I should
    call Exchange.setIn(Message) instead of Exchange.setOut(Message).  I
    think of a Processor as taking "in" a message and then sending it
    "out", but it looks like that is not the case.  Just need to adjust
    the way I think about things.
    You are not the only one. See this FAQ
    http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
    On Sat, Oct 2, 2010 at 3:06 AM, Claus Ibsen wrote:
    See this FAQ
    http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
    On Fri, Oct 1, 2010 at 10:37 PM, Mark Webb wrote:
    I am sending messages through a Camel route in ActiveMQ.  My message
    reaches the end of the processing chain, and at the last processor I
    call exchange.setOut( newly created DefaultMessage ).  When I look at
    the admin page for ActiveMQ, the topic shows that there is a message
    to be dequeued.  It even says that there is a consumer connected to
    that topic, which is a GUI tool I wrote.  The GUI tool makes a call to
    Consumer.setMessageListener.  So why are the messages not making their
    way to my GUI tool?  I am stumped as to why the messages sit in the
    topic and never leave if there is a listener for that topic.

    Of course the first thought is, is the Connection started?  Yeah I
    verified that.  In fact I can send messages to the topic via the
    web-based admin tool for ActiveMQ and the GUI receives them.

    Thanks for any help you have,
    Mark


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus
  • Hadrian Zbarcea at Oct 7, 2010 at 1:51 pm
    As promised, here's my take [1] on the getIn()/getOut() confusion.
    In a few days, when the dust will settle I'll take what's relevant from the post, and the comments that will follow and update the wiki page.

    I hope that clarifies the issue better,
    Hadrian

    [1] http://camelbot.blogspot.com/2010/10/should-you-getin-or-getout.html

    On Oct 4, 2010, at 3:58 PM, Mark Webb wrote:

    I agree. But when producing an out I think you need to call
    Exchange.setIn(Message). Seems like when you call
    Exchange.setOut(Message) you are setting up a request-reply scenario
    which is not what I wanted.

    On Mon, Oct 4, 2010 at 1:54 PM, Hadrian Zbarcea wrote:
    Yeah, there is still a lot of confusion.
    Unfortunately that page is bollocks and I'll have to get it cleaned up.
    Mark, I think you did the right thing actually, in a processor one should *not* modify the in, but produce an out, if needed. It's time to get that clarified!

    My $0.02,
    Hadrian
    On Oct 4, 2010, at 10:01 AM, Claus Ibsen wrote:
    On Mon, Oct 4, 2010 at 3:57 PM, Mark Webb wrote:
    Thanks. I have things working now.

    It seems weird to me though that if in a Processor I take a message
    in, transform it into a newly created Message object that I should
    call Exchange.setIn(Message) instead of Exchange.setOut(Message). I
    think of a Processor as taking "in" a message and then sending it
    "out", but it looks like that is not the case. Just need to adjust
    the way I think about things.
    You are not the only one. See this FAQ
    http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
    On Sat, Oct 2, 2010 at 3:06 AM, Claus Ibsen wrote:
    See this FAQ
    http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
    On Fri, Oct 1, 2010 at 10:37 PM, Mark Webb wrote:
    I am sending messages through a Camel route in ActiveMQ. My message
    reaches the end of the processing chain, and at the last processor I
    call exchange.setOut( newly created DefaultMessage ). When I look at
    the admin page for ActiveMQ, the topic shows that there is a message
    to be dequeued. It even says that there is a consumer connected to
    that topic, which is a GUI tool I wrote. The GUI tool makes a call to
    Consumer.setMessageListener. So why are the messages not making their
    way to my GUI tool? I am stumped as to why the messages sit in the
    topic and never leave if there is a listener for that topic.

    Of course the first thought is, is the Connection started? Yeah I
    verified that. In fact I can send messages to the topic via the
    web-based admin tool for ActiveMQ and the GUI receives them.

    Thanks for any help you have,
    Mark


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus
  • Claus Ibsen at Oct 8, 2010 at 4:11 pm

    On Thu, Oct 7, 2010 at 3:51 PM, Hadrian Zbarcea wrote:
    As promised, here's my take [1] on the getIn()/getOut() confusion.
    In a few days, when the dust will settle I'll take what's relevant from the post, and the comments that will follow and update the wiki page.

    I hope that clarifies the issue better,
    Hadrian

    [1] http://camelbot.blogspot.com/2010/10/should-you-getin-or-getout.html
    Hadrian this is a nice piece of writing you did. Love to see the
    improved documentation at Apache which should be the result of this.

    Remember to update the javadoc on Exchange as well.

    I would also suggest adding some link or info to the FAQ from the
    "Getting Started" guides somewhere, in case the end user starts
    playing with a Processor, and thus gets exposed to the Exchange and
    the question on the getIn and getOut methods.



    On Oct 4, 2010, at 3:58 PM, Mark Webb wrote:

    I agree. But when producing an out I think you need to call
    Exchange.setIn(Message).  Seems like when you call
    Exchange.setOut(Message) you are setting up a request-reply scenario
    which is not what I wanted.

    On Mon, Oct 4, 2010 at 1:54 PM, Hadrian Zbarcea wrote:
    Yeah, there is still a lot of confusion.
    Unfortunately that page is bollocks and I'll have to get it cleaned up.
    Mark, I think you did the right thing actually, in a processor one should *not* modify the in, but produce an out, if needed. It's time to get that clarified!

    My $0.02,
    Hadrian
    On Oct 4, 2010, at 10:01 AM, Claus Ibsen wrote:
    On Mon, Oct 4, 2010 at 3:57 PM, Mark Webb wrote:
    Thanks.  I have things working now.

    It seems weird to me though that if in a Processor I take a message
    in, transform it into a newly created Message object that I should
    call Exchange.setIn(Message) instead of Exchange.setOut(Message).  I
    think of a Processor as taking "in" a message and then sending it
    "out", but it looks like that is not the case.  Just need to adjust
    the way I think about things.
    You are not the only one. See this FAQ
    http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
    On Sat, Oct 2, 2010 at 3:06 AM, Claus Ibsen wrote:
    See this FAQ
    http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
    On Fri, Oct 1, 2010 at 10:37 PM, Mark Webb wrote:
    I am sending messages through a Camel route in ActiveMQ.  My message
    reaches the end of the processing chain, and at the last processor I
    call exchange.setOut( newly created DefaultMessage ).  When I look at
    the admin page for ActiveMQ, the topic shows that there is a message
    to be dequeued.  It even says that there is a consumer connected to
    that topic, which is a GUI tool I wrote.  The GUI tool makes a call to
    Consumer.setMessageListener.  So why are the messages not making their
    way to my GUI tool?  I am stumped as to why the messages sit in the
    topic and never leave if there is a listener for that topic.

    Of course the first thought is, is the Connection started?  Yeah I
    verified that.  In fact I can send messages to the topic via the
    web-based admin tool for ActiveMQ and the GUI receives them.

    Thanks for any help you have,
    Mark


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus
  • Hadrian Zbarcea at Oct 8, 2010 at 5:54 pm
    Thanks Claus, will do.

    I think there's a lot to do to improve documentation and I want to make that one of my priorities. I hope the whole community will join :).

    Cheers,
    Hadrian

    On Oct 8, 2010, at 12:10 PM, Claus Ibsen wrote:
    On Thu, Oct 7, 2010 at 3:51 PM, Hadrian Zbarcea wrote:
    As promised, here's my take [1] on the getIn()/getOut() confusion.
    In a few days, when the dust will settle I'll take what's relevant from the post, and the comments that will follow and update the wiki page.

    I hope that clarifies the issue better,
    Hadrian

    [1] http://camelbot.blogspot.com/2010/10/should-you-getin-or-getout.html
    Hadrian this is a nice piece of writing you did. Love to see the
    improved documentation at Apache which should be the result of this.

    Remember to update the javadoc on Exchange as well.

    I would also suggest adding some link or info to the FAQ from the
    "Getting Started" guides somewhere, in case the end user starts
    playing with a Processor, and thus gets exposed to the Exchange and
    the question on the getIn and getOut methods.



    On Oct 4, 2010, at 3:58 PM, Mark Webb wrote:

    I agree. But when producing an out I think you need to call
    Exchange.setIn(Message). Seems like when you call
    Exchange.setOut(Message) you are setting up a request-reply scenario
    which is not what I wanted.

    On Mon, Oct 4, 2010 at 1:54 PM, Hadrian Zbarcea wrote:
    Yeah, there is still a lot of confusion.
    Unfortunately that page is bollocks and I'll have to get it cleaned up.
    Mark, I think you did the right thing actually, in a processor one should *not* modify the in, but produce an out, if needed. It's time to get that clarified!

    My $0.02,
    Hadrian
    On Oct 4, 2010, at 10:01 AM, Claus Ibsen wrote:
    On Mon, Oct 4, 2010 at 3:57 PM, Mark Webb wrote:
    Thanks. I have things working now.

    It seems weird to me though that if in a Processor I take a message
    in, transform it into a newly created Message object that I should
    call Exchange.setIn(Message) instead of Exchange.setOut(Message). I
    think of a Processor as taking "in" a message and then sending it
    "out", but it looks like that is not the case. Just need to adjust
    the way I think about things.
    You are not the only one. See this FAQ
    http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
    On Sat, Oct 2, 2010 at 3:06 AM, Claus Ibsen wrote:
    See this FAQ
    http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
    On Fri, Oct 1, 2010 at 10:37 PM, Mark Webb wrote:
    I am sending messages through a Camel route in ActiveMQ. My message
    reaches the end of the processing chain, and at the last processor I
    call exchange.setOut( newly created DefaultMessage ). When I look at
    the admin page for ActiveMQ, the topic shows that there is a message
    to be dequeued. It even says that there is a consumer connected to
    that topic, which is a GUI tool I wrote. The GUI tool makes a call to
    Consumer.setMessageListener. So why are the messages not making their
    way to my GUI tool? I am stumped as to why the messages sit in the
    topic and never leave if there is a listener for that topic.

    Of course the first thought is, is the Connection started? Yeah I
    verified that. In fact I can send messages to the topic via the
    web-based admin tool for ActiveMQ and the GUI receives them.

    Thanks for any help you have,
    Mark


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus

Related Discussions

Discussion Navigation
viewthread | post
Discussion Overview
groupusers @
categoriescamel
postedOct 1, '10 at 8:38p
activeOct 8, '10 at 5:54p
posts24
users5
websitecamel.apache.org

People

Translate

site design / logo © 2022 Grokbase