subject:"ActiveMQ Broker Camel Component and wildcards"

Re: ActiveMQ Broker Camel Component and wildcards

2016-04-29 Thread Tim Bain

Sorry, I've never used them nor looked for examples, but maybe someone else
has.
On Apr 29, 2016 7:02 AM, "Quinn Stevenson" 
wrote:

> Thank You Tim -
>
> Is there an example of an interceptor somewhere in the code base I can use
> as a reference to get started on this?
>
> BTW - I did it working with the Camel Broker Component by switching from
>  to .  I’m not sure why that made a difference,
> but it did.
>
> > On Apr 28, 2016, at 10:53 PM, Tim Bain  wrote:
> >
> > I think you want to be using interceptors (
> > http://activemq.apache.org/interceptors.html), not consuming from a
> queue
> > and then publishing back to the same queue.  I've always believed that
> > embedded Camel routes couldn't be inserted into the middle of accepting a
> > message (which is what you really want), but interceptors should be able
> to
> > do that.
> >
> > Tim
> >
> > On Thu, Apr 28, 2016 at 12:49 PM, Quinn Stevenson <
> > qu...@pronoia-solutions.com> wrote:
> >
> >> I’m trying to use the ActiveMQ Broker Camel Component to add some JMS
> user
> >> properties to messages as they arrive at the broker.  I’m using a
> wildcard
> >> on the from so I can apply the same logic to a set of topics or queues,
> but
> >> I can’t seem to send the message back to the original queue.
> >>
> >> Without wildcards, it works fine - something like this:
> >> http://www.springframework.org/schema/beans;
> >>   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
> >>   xsi:schemaLocation="
> >>http://camel.apache.org/schema/spring
> >> http://camel.apache.org/schema/spring/camel-spring.xsd
> >>http://www.springframework.org/schema/beans
> >> http://www.springframework.org/schema/beans/spring-beans.xsd;>
> >>
> >>http://camel.apache.org/schema/spring;>
> >>
> >>
> >>
> >>MyHeaderValue
> >>
> >>
> >>
> >>
> >>
> >>
> >> 
> >>
> >> However when I put in the wildcards, I get and IllegalStateException.
> The
> >> configuration I’m trying looks like this
> >> http://www.springframework.org/schema/beans;
> >>   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
> >>   xsi:schemaLocation="
> >>http://camel.apache.org/schema/spring
> >> http://camel.apache.org/schema/spring/camel-spring.xsd
> >>http://www.springframework.org/schema/beans
> >> http://www.springframework.org/schema/beans/spring-beans.xsd;>
> >>
> >>http://camel.apache.org/schema/spring;>
> >>
> >>
> >>
> >>MyHeaderValue
> >>
> >>
> >>broker://${header[JMSDestination]}
> >>
> >>
> >>
> >>
> >>
> >> 
> >>
> >> And here’s the exception I get
> >>
> >> 2016-04-28 12:47:43,721 | ERROR | Failed delivery for (MessageId:
> >> ID-macpro-local-53588-1461869253207-0-2 on ExchangeId:
> >> ID-macpro-local-53588-1461869253207-0-3). Exhausted after delivery
> attempt:
> >> 1 caught: java.lang.IllegalStateException: Not the original message from
> >> the broker Message: Enter some text here for the message body...
> >>
> >> Message History
> >>
> >>
> ---
> >> RouteId  ProcessorId  Processor
> >>Elapsed (ms)
> >> [in-audit-to-file  ] [in-audit-to-file  ] [broker://queue:in.adt.*
> >>   ] [23]
> >> [in-audit-to-file  ] [setHeader1] [setHeader[MyCustomHeader]
> >>   ] [ 3]
> >> [in-audit-to-file  ] [recipientList1]
> >> [recipientList[simple{broker://${header[JMSDestination]}}]
> >>   ] [18]
> >>
> >> Exchange
> >>
> >>
> ---
> >> Exchange[
> >>Id  ID-macpro-local-53588-1461869253207-0-3
> >>ExchangePattern InOnly
> >>Headers
> >> {breadcrumbId=ID:macpro.local-53587-1461869252118-4:1:1:1:1,
> >> CamelRedelivered=false, CamelRedeliveryCounter=0, JMSCorrelationID=,
> >> JMSCorrelationIDAsBytes=, JMSDeliveryMode=1,
> >> JMSDestination=queue://in.adt.epic, JMSExpiration=0,
> >> JMSMessageID=ID:macpro.local-53587-1461869252118-4:1:1:1:1,
> JMSPriority=0,
> >> JMSRedelivered=false, JMSReplyTo=null, JMSTimestamp=1461869263684,
> >> JMSType=, JMSXGroupID=null, JMSXUserID=null,
> MyCustomHeader=MyHeaderValue}
> >>BodyTypeString
> >>BodyEnter some text here for the message body...
> >> ]
> >>
> >> Stacktrace
> >>
> ---
> >> |

Re: ActiveMQ Broker Camel Component and wildcards

2016-04-29 Thread Quinn Stevenson

Thank You Tim -

Is there an example of an interceptor somewhere in the code base I can use as a 
reference to get started on this?

BTW - I did it working with the Camel Broker Component by switching from 
 to .  I’m not sure why that made a difference, but 
it did.

> On Apr 28, 2016, at 10:53 PM, Tim Bain  wrote:
> 
> I think you want to be using interceptors (
> http://activemq.apache.org/interceptors.html), not consuming from a queue
> and then publishing back to the same queue.  I've always believed that
> embedded Camel routes couldn't be inserted into the middle of accepting a
> message (which is what you really want), but interceptors should be able to
> do that.
> 
> Tim
> 
> On Thu, Apr 28, 2016 at 12:49 PM, Quinn Stevenson <
> qu...@pronoia-solutions.com> wrote:
> 
>> I’m trying to use the ActiveMQ Broker Camel Component to add some JMS user
>> properties to messages as they arrive at the broker.  I’m using a wildcard
>> on the from so I can apply the same logic to a set of topics or queues, but
>> I can’t seem to send the message back to the original queue.
>> 
>> Without wildcards, it works fine - something like this:
>> http://www.springframework.org/schema/beans;
>>   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
>>   xsi:schemaLocation="
>>http://camel.apache.org/schema/spring
>> http://camel.apache.org/schema/spring/camel-spring.xsd
>>http://www.springframework.org/schema/beans
>> http://www.springframework.org/schema/beans/spring-beans.xsd;>
>> 
>>http://camel.apache.org/schema/spring;>
>>
>>
>>
>>MyHeaderValue
>>
>>
>>
>> 
>>
>> 
>> 
>> 
>> However when I put in the wildcards, I get and IllegalStateException.  The
>> configuration I’m trying looks like this
>> http://www.springframework.org/schema/beans;
>>   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
>>   xsi:schemaLocation="
>>http://camel.apache.org/schema/spring
>> http://camel.apache.org/schema/spring/camel-spring.xsd
>>http://www.springframework.org/schema/beans
>> http://www.springframework.org/schema/beans/spring-beans.xsd;>
>> 
>>http://camel.apache.org/schema/spring;>
>>
>>
>>
>>MyHeaderValue
>>
>>
>>broker://${header[JMSDestination]}
>>
>>
>> 
>>
>> 
>> 
>> 
>> And here’s the exception I get
>> 
>> 2016-04-28 12:47:43,721 | ERROR | Failed delivery for (MessageId:
>> ID-macpro-local-53588-1461869253207-0-2 on ExchangeId:
>> ID-macpro-local-53588-1461869253207-0-3). Exhausted after delivery attempt:
>> 1 caught: java.lang.IllegalStateException: Not the original message from
>> the broker Message: Enter some text here for the message body...
>> 
>> Message History
>> 
>> ---
>> RouteId  ProcessorId  Processor
>>Elapsed (ms)
>> [in-audit-to-file  ] [in-audit-to-file  ] [broker://queue:in.adt.*
>>   ] [23]
>> [in-audit-to-file  ] [setHeader1] [setHeader[MyCustomHeader]
>>   ] [ 3]
>> [in-audit-to-file  ] [recipientList1]
>> [recipientList[simple{broker://${header[JMSDestination]}}]
>>   ] [18]
>> 
>> Exchange
>> 
>> ---
>> Exchange[
>>Id  ID-macpro-local-53588-1461869253207-0-3
>>ExchangePattern InOnly
>>Headers
>> {breadcrumbId=ID:macpro.local-53587-1461869252118-4:1:1:1:1,
>> CamelRedelivered=false, CamelRedeliveryCounter=0, JMSCorrelationID=,
>> JMSCorrelationIDAsBytes=, JMSDeliveryMode=1,
>> JMSDestination=queue://in.adt.epic, JMSExpiration=0,
>> JMSMessageID=ID:macpro.local-53587-1461869252118-4:1:1:1:1, JMSPriority=0,
>> JMSRedelivered=false, JMSReplyTo=null, JMSTimestamp=1461869263684,
>> JMSType=, JMSXGroupID=null, JMSXUserID=null, MyCustomHeader=MyHeaderValue}
>>BodyTypeString
>>BodyEnter some text here for the message body...
>> ]
>> 
>> Stacktrace
>> ---
>> | org.apache.camel.processor.DefaultErrorHandler | ActiveMQ VMTransport:
>> vm://localhost#1
>> java.lang.IllegalStateException: Not the original message from the broker
>> Message: Enter some text here for the message body...
>>at
>> org.apache.activemq.camel.component.broker.BrokerProducer.checkOriginalMessage(BrokerProducer.java:95)[activemq-camel-5.13.2.jar:5.13.2]
>>at
>>

Re: ActiveMQ Broker Camel Component and wildcards

2016-04-28 Thread Tim Bain

I think you want to be using interceptors (
http://activemq.apache.org/interceptors.html), not consuming from a queue
and then publishing back to the same queue.  I've always believed that
embedded Camel routes couldn't be inserted into the middle of accepting a
message (which is what you really want), but interceptors should be able to
do that.

Tim

On Thu, Apr 28, 2016 at 12:49 PM, Quinn Stevenson <
qu...@pronoia-solutions.com> wrote:

> I’m trying to use the ActiveMQ Broker Camel Component to add some JMS user
> properties to messages as they arrive at the broker.  I’m using a wildcard
> on the from so I can apply the same logic to a set of topics or queues, but
> I can’t seem to send the message back to the original queue.
>
> Without wildcards, it works fine - something like this:
> http://www.springframework.org/schema/beans;
>xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
>xsi:schemaLocation="
> http://camel.apache.org/schema/spring
> http://camel.apache.org/schema/spring/camel-spring.xsd
> http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans.xsd;>
>
> http://camel.apache.org/schema/spring;>
> 
> 
> 
> MyHeaderValue
> 
> 
> 
>
> 
>
> 
>
> However when I put in the wildcards, I get and IllegalStateException.  The
> configuration I’m trying looks like this
> http://www.springframework.org/schema/beans;
>xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
>xsi:schemaLocation="
> http://camel.apache.org/schema/spring
> http://camel.apache.org/schema/spring/camel-spring.xsd
> http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans.xsd;>
>
> http://camel.apache.org/schema/spring;>
> 
> 
> 
> MyHeaderValue
> 
> 
> broker://${header[JMSDestination]}
> 
> 
>
> 
>
> 
>
> And here’s the exception I get
>
> 2016-04-28 12:47:43,721 | ERROR | Failed delivery for (MessageId:
> ID-macpro-local-53588-1461869253207-0-2 on ExchangeId:
> ID-macpro-local-53588-1461869253207-0-3). Exhausted after delivery attempt:
> 1 caught: java.lang.IllegalStateException: Not the original message from
> the broker Message: Enter some text here for the message body...
>
> Message History
>
> ---
> RouteId  ProcessorId  Processor
> Elapsed (ms)
> [in-audit-to-file  ] [in-audit-to-file  ] [broker://queue:in.adt.*
>] [23]
> [in-audit-to-file  ] [setHeader1] [setHeader[MyCustomHeader]
>] [ 3]
> [in-audit-to-file  ] [recipientList1]
> [recipientList[simple{broker://${header[JMSDestination]}}]
>] [18]
>
> Exchange
>
> ---
> Exchange[
> Id  ID-macpro-local-53588-1461869253207-0-3
> ExchangePattern InOnly
> Headers
>  {breadcrumbId=ID:macpro.local-53587-1461869252118-4:1:1:1:1,
> CamelRedelivered=false, CamelRedeliveryCounter=0, JMSCorrelationID=,
> JMSCorrelationIDAsBytes=, JMSDeliveryMode=1,
> JMSDestination=queue://in.adt.epic, JMSExpiration=0,
> JMSMessageID=ID:macpro.local-53587-1461869252118-4:1:1:1:1, JMSPriority=0,
> JMSRedelivered=false, JMSReplyTo=null, JMSTimestamp=1461869263684,
> JMSType=, JMSXGroupID=null, JMSXUserID=null, MyCustomHeader=MyHeaderValue}
> BodyTypeString
> BodyEnter some text here for the message body...
> ]
>
> Stacktrace
> ---
> | org.apache.camel.processor.DefaultErrorHandler | ActiveMQ VMTransport:
> vm://localhost#1
> java.lang.IllegalStateException: Not the original message from the broker
> Message: Enter some text here for the message body...
> at
> org.apache.activemq.camel.component.broker.BrokerProducer.checkOriginalMessage(BrokerProducer.java:95)[activemq-camel-5.13.2.jar:5.13.2]
> at
> org.apache.activemq.camel.component.broker.BrokerProducer.getMessage(BrokerProducer.java:73)[activemq-camel-5.13.2.jar:5.13.2]
> at
> org.apache.activemq.camel.component.broker.BrokerProducer.processInOnly(BrokerProducer.java:55)[activemq-camel-5.13.2.jar:5.13.2]
> at
> org.apache.activemq.camel.component.broker.BrokerProducer.process(BrokerProducer.java:43)[activemq-camel-5.13.2.jar:5.13.2]
> at
>

ActiveMQ Broker Camel Component and wildcards

2016-04-28 Thread Quinn Stevenson

I’m trying to use the ActiveMQ Broker Camel Component to add some JMS user 
properties to messages as they arrive at the broker.  I’m using a wildcard on 
the from so I can apply the same logic to a set of topics or queues, but I 
can’t seem to send the message back to the original queue.

Without wildcards, it works fine - something like this:
http://www.springframework.org/schema/beans;
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
   xsi:schemaLocation="
http://camel.apache.org/schema/spring 
http://camel.apache.org/schema/spring/camel-spring.xsd
http://www.springframework.org/schema/beans 
http://www.springframework.org/schema/beans/spring-beans.xsd;>

http://camel.apache.org/schema/spring;>



MyHeaderValue








However when I put in the wildcards, I get and IllegalStateException.  The 
configuration I’m trying looks like this
http://www.springframework.org/schema/beans;
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
   xsi:schemaLocation="
http://camel.apache.org/schema/spring 
http://camel.apache.org/schema/spring/camel-spring.xsd
http://www.springframework.org/schema/beans 
http://www.springframework.org/schema/beans/spring-beans.xsd;>

http://camel.apache.org/schema/spring;>



MyHeaderValue


broker://${header[JMSDestination]}







And here’s the exception I get

2016-04-28 12:47:43,721 | ERROR | Failed delivery for (MessageId: 
ID-macpro-local-53588-1461869253207-0-2 on ExchangeId: 
ID-macpro-local-53588-1461869253207-0-3). Exhausted after delivery attempt: 1 
caught: java.lang.IllegalStateException: Not the original message from the 
broker Message: Enter some text here for the message body...

Message History
---
RouteId  ProcessorId  Processor 
   Elapsed (ms)
[in-audit-to-file  ] [in-audit-to-file  ] [broker://queue:in.adt.*  
 ] [23]
[in-audit-to-file  ] [setHeader1] [setHeader[MyCustomHeader]
 ] [ 3]
[in-audit-to-file  ] [recipientList1] 
[recipientList[simple{broker://${header[JMSDestination]}}] 
] [18]

Exchange
---
Exchange[
Id  ID-macpro-local-53588-1461869253207-0-3
ExchangePattern InOnly
Headers 
{breadcrumbId=ID:macpro.local-53587-1461869252118-4:1:1:1:1, 
CamelRedelivered=false, CamelRedeliveryCounter=0, JMSCorrelationID=, 
JMSCorrelationIDAsBytes=, JMSDeliveryMode=1, 
JMSDestination=queue://in.adt.epic, JMSExpiration=0, 
JMSMessageID=ID:macpro.local-53587-1461869252118-4:1:1:1:1, JMSPriority=0, 
JMSRedelivered=false, JMSReplyTo=null, JMSTimestamp=1461869263684, JMSType=, 
JMSXGroupID=null, JMSXUserID=null, MyCustomHeader=MyHeaderValue}
BodyTypeString
BodyEnter some text here for the message body...
]

Stacktrace
---
 | org.apache.camel.processor.DefaultErrorHandler | ActiveMQ VMTransport: 
vm://localhost#1
java.lang.IllegalStateException: Not the original message from the broker 
Message: Enter some text here for the message body...
at 
org.apache.activemq.camel.component.broker.BrokerProducer.checkOriginalMessage(BrokerProducer.java:95)[activemq-camel-5.13.2.jar:5.13.2]
at 
org.apache.activemq.camel.component.broker.BrokerProducer.getMessage(BrokerProducer.java:73)[activemq-camel-5.13.2.jar:5.13.2]
at 
org.apache.activemq.camel.component.broker.BrokerProducer.processInOnly(BrokerProducer.java:55)[activemq-camel-5.13.2.jar:5.13.2]
at 
org.apache.activemq.camel.component.broker.BrokerProducer.process(BrokerProducer.java:43)[activemq-camel-5.13.2.jar:5.13.2]
at 
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460)[camel-core-2.16.2.jar:2.16.2]
at 
org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)[camel-core-2.16.2.jar:2.16.2]
at 
org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:668)[camel-core-2.16.2.jar:2.16.2]
at 
org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:596)[camel-core-2.16.2.jar:2.16.2]
at

Re: ActiveMQ Broker Camel Component and wildcards

Re: ActiveMQ Broker Camel Component and wildcards

Re: ActiveMQ Broker Camel Component and wildcards

ActiveMQ Broker Camel Component and wildcards

4 matches

Site Navigation

Mail list logo

Footer information