Re: Need help in java.net.ConnectException: Connection refused

2012-06-15 Thread Babak Vahdat
Ah now I see the problem. The onException clause of yours  will not help at
all as Camel does NOT see / get the java.net.ConnectException thrown here. I
don't see any possible way of achieving what you're looking for! 

However in general there's a org.springframework.util.ErrorHandler which is
so to say the DMLC error handler/callback where you could provide your own
using:

JmsEndpoint.setErrorHandler()

Or:

JmsConfiguration.setErrorHandler()

Inside Java Code or Spring config but in this concrete case even using
ErrorHandler would not help. Following the code snippet from DMLC where the
exception is catched:

protected void refreshConnectionUntilSuccessful() {
while (isRunning()) {
try {
if (sharedConnectionEnabled()) {
refreshSharedConnection();
}
else {
Connection con = createConnection();
JmsUtils.closeConnection(con);
}
logger.info(Successfully refreshed JMS 
Connection);
break;
}
catch (Exception ex) {
StringBuilder msg = new StringBuilder();
msg.append(Could not refresh JMS Connection 
for destination ');

msg.append(getDestinationDescription()).append(' - retrying in );
msg.append(this.recoveryInterval).append( ms. 
Cause: );
msg.append(ex instanceof JMSException ?
JmsUtils.buildExceptionMessage((JMSException) ex) : ex.getMessage());
if (logger.isDebugEnabled()) {
logger.warn(msg, ex);
}
else {
logger.warn(msg);
}
}
sleepInbetweenRecoveryAttempts();
}
}



That said maybe there're STILL a way of achieving what you need which others
in the forum could have in their mind, however I doubt that.

Babak

--
View this message in context: 
http://camel.465427.n5.nabble.com/Need-help-in-java-net-ConnectException-Connection-refused-tp5714476p5714525.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: Need help in java.net.ConnectException: Connection refused

2012-06-15 Thread Babak Vahdat
Maybe this could be one possible way:

Using plain Java Socket API write a bean which only does try to connect on
localhost port 61616 inside your Camel route and rethrows the exception if
java.net.ConnectException with the message Connection refused is thrown so
that your onException clause get's kicked in.

Babak

--
View this message in context: 
http://camel.465427.n5.nabble.com/Need-help-in-java-net-ConnectException-Connection-refused-tp5714476p5714526.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: copy of Exchange during Multicast

2012-06-15 Thread kenhans
Thanks, Henryk, I really appreciate your answer. 

I can see that the FilterProcessor do
exchange.setProperty(Exchange.FILTER_MATCHED, matches);
and I also see that the GroupedExchangeAggregationStrategy puts the Exchange
in it's list of answer.properties. 

I also set headers/properties myself (in bold below).

But I am still not able to access any of those headers in the
filterMatchCheckRouter as stated below. The headers are just not there in
the exchange sent to filterMatchCheckRouter.

Could Spring mess up things? Or am I missing out on something here? Is my
config wrong?

ProcessorDefinition processorDefinition =
from(incomingQueue).routeId(ProducerRoute).shutdownRoute(ShutdownRoute.Defer).shutdownRunningTask(ShutdownRunningTask.CompleteAllTasks).convertBodyTo(Document.class);
MulticastDefinition multicastDefinition = processorDefinition.multicast(*new
GroupedExchangeAggregationStrategy()*);
for (Producer producer : producers) { 
  multicastDefinition 
  .filter().method(producer, filter)  
  *.process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
  exchange.getIn().setHeader(KEY1, value1);
  exchange.setProperty(KEY2, value2);
}}) *
  .bean(producer, createEvent) 
  .to(EndPointUri.INCOMING_EVENT_QUEUE); 
} 
multicastDefinition.to(direct:filterMatchCheckRouter);


--
View this message in context: 
http://camel.465427.n5.nabble.com/copy-of-Exchange-during-Multicast-tp5714477p5714528.html
Sent from the Camel - Users mailing list archive at Nabble.com.


csv bindy with multiline values

2012-06-15 Thread pvunckx
Hello,

I'm using the bindy component to convert csv - java objects.
Everything is working super fine.
But now I'm running my camel route agains a new csv file with the following
line:

23;09/901/13855;M JANSSENS JAN
   M JANSSENS J
   JANSSENS;BO;185.100.096;185.100.096;streetname;45;4396;city;BE;geschrapt

The 3th field is a multiline value.

When parsing this line I'm getting the following error:
/Some fields are missing (optional or mandatory), line: 1/

Is there a solution for those records?

Thx 
Pieter



--
View this message in context: 
http://camel.465427.n5.nabble.com/csv-bindy-with-multiline-values-tp5714530.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: CXFRS URL Matrix Parameters seemingly stripped away

2012-06-15 Thread desysemia
Both,

Thanks for your input.

With regards to checking that my camel-cxfrs consumer is correct.  All
other components of the URL are matched and passed through correctly, e.g.
PathSegments and QueryParameters.  What could be configured incorrectly an
still allow this to happen?


D.
On Fri, Jun 15, 2012 at 3:07 AM, Willem.Jiang [via Camel] 
ml-node+s465427n5714517...@n5.nabble.com wrote:

 Hi,

 As Sergey just said, the metrix parameters are got from the request URI
 which means it has nothing to do with the server address that your
 camel-cxfrs consumer is using.
 Even you define the server address with the values option, if the
 client request doesn't has these values you will not get it.
 Please check if the request to the camel-cxfrs consumer is right.

 On Fri Jun 15 00:19:15 2012, Sergey Beryozkin wrote:

  Hi
  On 14/06/12 16:59, desysemia wrote:
  This is my first time posting here, so a big hello from me!
 
  Let me start off by stating I'm quite new to Camel and CXF so the
  issue I'm
  seeing might well just be my own doing.
 
  I'm currently running FuseESB/ServiceMix 3.6/4.4.1 including Camel
  version
  2.8.0.
 
  The short version:
 
  is that the PathSegment.getMatrixParameters method returns an empty
  collection if the resource is accessed through the URL made available
  through the rsServer endpoint, but as expected when accessed through
 the
  rsClient endpoint. But therefore as I understand it not therefore
  using the
  Camel route at all.
 
  So to me somewhere along the line Camel/CXF is stripping of the matrix
  parameters, thoughts?
 
 
  In CXF alone, HTTPServletRequest.getRequestURI() is used in CXF
  AbstractHTTPDestination to capture the relative path including the
  matrix parameters if any, for the subsequent match to succeed.
 
  I've confirmed locally that matrix parameters are correctly captured
  with the nearly identical test resource method signature.
 
  Perhaps in your case CXF Message.REQUEST_URI property is set by CXF
  Camel differently which may be causing the loss of the parameters
 
  Cheers, Sergey
 
  The long version:
 
  So here goes with the scenario;
 
  I have a Camel route defined using the rsServer and rsClient
  endpoints, and
  I have a resource class implemented and used by both endpoints with a
  single
  JAXRS annotated method as such;
 
  @GET
  @Path ( object/{context}/{version} )
  public String getObject ( @PathParam ( context ) PathSegment context,
  @PathParam ( version ) float version );
 
  This is invoked through the rsServer endpoint URL like so;
 
  http://localhost:9000/test/object/id;key1=value1;key2=value2/1.0
 
  Then calling the getMatrixParameters method on the 'context' parameter
  returns an empty collection.
 
  However if this is invoked through the rsClient endpoint URL like so;
 
  http://localhost:9001/test/object/id;key1=value1;key2=value2/1.0
 
  Then calling the getMatrixParameters method on the 'context' parameter
  returns a collection containing the two key/value pairs as described.
 
  Hopefully someone out there can point me in the right direction here?
 
  Thanks in advance.
 
  D.
 
 
  --
  View this message in context:
 
 http://camel.465427.n5.nabble.com/CXFRS-URL-Matrix-Parameters-seemingly-stripped-away-tp5714486.html
 
  Sent from the Camel - Users mailing list archive at Nabble.com.
 
 



 --
 Willem
 --
 FuseSource
 Web: http://www.fusesource.com
 Blog:http://willemjiang.blogspot.com (English)
  http://jnn.javaeye.com (Chinese)
 Twitter: willemjiang
 Weibo: willemjiang



 --
  If you reply to this email, your message will be added to the discussion
 below:

 http://camel.465427.n5.nabble.com/CXFRS-URL-Matrix-Parameters-seemingly-stripped-away-tp5714486p5714517.html
  To unsubscribe from CXFRS URL Matrix Parameters seemingly stripped away, 
 click
 herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5714486code=c3lzZW1pYS5kYXJyZW4uZXZlcmxleUBnbWFpbC5jb218NTcxNDQ4NnwtMTEzMjY3NjUyOA==
 .
 NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml



--
View this message in context: 
http://camel.465427.n5.nabble.com/CXFRS-URL-Matrix-Parameters-seemingly-stripped-away-tp5714486p5714531.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Exception not propagated in Splitter-Aggregator EIP

2012-06-15 Thread priya
I have route like this:

errorHandler(transactionErrorHandler().maximumRedeliveries(0));

from(seda:fileInput)
  .onException(IllegalArgumentException.class).maximumRedeliveries(0)   
.log( idExpr + Error occured during processing of Data)
  .end()
.transacted()
.split(myFileSplitterExp(inFile))
   .streaming()
  .stopOnException()
  .bean(myBean)
.aggregate(header(HeaderConstant.JOB_ID), new
MyStringBuilderAggregationStrategy())   
.completionSize(10)
.completionTimeout(2000)
.completionPredicate(
header(Exchange.SPLIT_COMPLETE).isEqualTo(Boolean.TRUE))
.to(direct:updateDB);



with aggregationStrategy defined as:

private class MyStringBuilderAggregationStrategy implements
AggregationStrategy {
@Override
public Exchange aggregate(final Exchange oldExchange, final 
Exchange
newExchange) {
final DataSet newBody = 
newExchange.getIn().getBody(DataSet.class);
List DataSetlist = null;
if(newExchange != null  newExchange.getException()!=null )
{
log.info(exception caught*** + 
newExchange.getException());
}else if (oldExchange != null  oldExchange.getException()!= 
null)
{
log.info(exception caught in oldExc*** + 
oldExchange.getException());
}else
log.info(no exception );


if (oldExchange == null) {
list = new ArrayListDataSet();
list.add(newBody);
newExchange.getIn().setBody(list);
return newExchange;
} else {
list = oldExchange.getIn().getBody(List.class);
list.add(newBody);
return oldExchange;
}}}
The problem is We are unable to get hold of exception in 
MyStringBuilderAggregationStrategy, in case some exception occurs in myBean
for some invalid record.

Exchange.getEception() is null as against the example in Chpater 8 of the
book.

Also with stopOnException() though we are able to stop further processing of
Exchange messages and rollback  the Batch records inserted before the
errornous Exchange using errorHandler(transactionErrorHandler()).But, since
we are unable to catch the exception on this errornous Batch(subExchange of
parent exchange) we are unable to dump the records which were aggregated
before the error of the same errornous Batch and it goes for further
processing to (direct:updateDB) endpoint which is DB insertion.



--
View this message in context: 
http://camel.465427.n5.nabble.com/Exception-not-propagated-in-Splitter-Aggregator-EIP-tp5714533.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: Overwrite blueprint properties in camel blueprint tests

2012-06-15 Thread Michael Süess

Hi


i am a little bit confused...


I looked at the jira feature (which is resolved)

CAMEL-5349: Make it easy to provider override properties from unit tests

with the comment

Updated docs. See the using property placeholder docs for details.


i found the new section in the docu
http://camel.apache.org/using-propertyplaceholder.html:

Available as of Camel 2.10
When Testing with Camel and using the Properties component, you may want 
to be able to provide the properties to be used from directly within the 
unit test source code.
This is now possible from Camel 2.10 onwards, as the Camel test kits, eg 
CamelTestSupport class offers the following methods

useOverridePropertiesWithPropertiesComponent
ignoreMissingLocationWithPropertiesComponent
So for example in your unit test classes, you can override the 
useOverridePropertiesWithPropertiesComponent method and return a 
java.util.Properties that contains the properties which should be 
preferred to be used.

Providing properties from within unit test source
// override this method to provide our custom properties we use in this 
unit test

@Override
protected Properties useOverridePropertiesWithPropertiesComponent() {
Properties extra = new Properties();
extra.put(destination, mock:extra);
extra.put(greeting, Bye);
return extra;
}
This can be done from any of the Camel Test kits, such as camel-test, 
camel-test-spring, and camel-test-blueprint.
The ignoreMissingLocationWithPropertiesComponent can be used to instruct 
Camel to ignore any locations which was not discoverable, for example if 
you run the unit test, in an environment that does not have access to 
the location of the properties.



but i couldn't find the mentioned method in the camel maven 
2.10-SNAPSHOT (be the way, i tried to download the 2.10 windows and 
source distros, both links 
[http://www.apache.org/dyn/closer.cgi/camel/apache-camel/2.10.0/apache-camel-2.10.0.zip 
and 
http://www.apache.org/dyn/closer.cgi/camel/apache-camel/2.10.0/apache-camel-2.10.0-src.zip] 
are broken!)


Thx for any help...


On 09.06.2012 14:45, Claus Ibsen wrote:

Hi

I logged a ticket to make this easier
https://issues.apache.org/jira/browse/CAMEL-5349


On Fri, May 25, 2012 at 9:22 AM, Michael Süessmichael.sue...@basis06.chwrote:


Hi


Yes, this solves the problem of restarting the route after a config change
in karaf/servicemix.

But my problem is how to set the properties in a junit test using
CamelBlueprintTestSupport.

- where to put my config file?
- or can i set the properties programmatically in the junit test class?



On 25.05.2012 05:20, alexey-s wrote:


Hi

Change cm namespace form
   xmlns:cm=http://aries.apache.**org/blueprint/xmlns/blueprint-**
cm/v1.0.0http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0
to
   xmlns:cm=http://aries.apache.**org/blueprint/xmlns/blueprint-**
cm/v1.1.0http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0
and change lile from
cm:property-placeholder persistent-id=foo
to
cm:property-placeholder persistent-id=foo update-strategy=reload

After change config file $KARAF_HOME/etc/foo.cfg, blueprint restart all
camel route in this bundle.


Aleksey

--
View this message in context: http://camel.465427.n5.nabble.**
com/Overwrite-blueprint-**properties-in-camel-blueprint-**
tests-tp5710948p5713531.htmlhttp://camel.465427.n5.nabble.com/Overwrite-blueprint-properties-in-camel-blueprint-tests-tp5710948p5713531.html
Sent from the Camel - Users mailing list archive at Nabble.com.





--
Michael Sueess   Senior Software Engineer

basis06 AG, Birkenweg 61, CH-3013 Bern - Fon +41 31 311 32 22
http://www.basis06.ch - source of smart business

Keine News verpassen? 
http://www.basis06.ch/**newsletter-registration.htmlhttp://www.basis06.ch/newsletter-registration.html
Schon gebloggt? http://blog.basis06.ch









Re: XPath namespaces in Spring DSL?

2012-06-15 Thread Andreas A.
Yeah I found and applied the example from the book.

This works as long as there is actually a prefix in the xml. When there's
only a default namespace the XPath-qeury returns nothing. It doesn't throw
an exception like it normally would if the path was incorrect.

--
View this message in context: 
http://camel.465427.n5.nabble.com/XPath-namespaces-in-Spring-DSL-tp4556826p5714537.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: XPath namespaces in Spring DSL?

2012-06-15 Thread Claus Ibsen
On Fri, Jun 15, 2012 at 1:58 PM, Andreas A. andreasasm...@gmail.com wrote:

 Yeah I found and applied the example from the book.

 This works as long as there is actually a prefix in the xml. When there's
 only a default namespace the XPath-qeury returns nothing. It doesn't throw
 an exception like it normally would if the path was incorrect.


There is something about local() in the xpath expression you can use I
think.
To kinda refer to a local namepsace or something like that.

People on this forum have posted and talked about this in the past.

And I guess you can possible google something about that.


 --
 View this message in context:
 http://camel.465427.n5.nabble.com/XPath-namespaces-in-Spring-DSL-tp4556826p5714537.html
 Sent from the Camel - Users mailing list archive at Nabble.com.




-- 
Claus Ibsen
-
FuseSource
Email: cib...@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen


RE: jms to http

2012-06-15 Thread pchakinala
Hi Wilem,

Thank you for the response. 

Usecase: Need to implement Async Service. So we have used jms queue
(Camel-jms) and camel-http  components.

  Httpclient -- camel-http (from
uri=jetty:http://0.0.0.0:8192/mib401Asyncreq//)- jms queue provider --- 
queue consumer ---http  target (http) service

If I don’t use bridgeEndpoint  found below exception.
java.lang.IllegalArgumentException: Invalid uri:
/mib401Asyncreq/mib401Asyncreq/. If you are forwarding/bridging http
endpoints, then enable the bridgeEndpoint option on the endpoint:
Endpoint[http://localhost:8080/jsp-examples/checkbox/nipr.jsp]

If I use bridgeEndpoint found below exception: 
Obesered URL value is changing in the run time and adding first route uri

First route or incoming endpoint :  from
uri=jetty:http://0.0.0.0:8192/mib401Asyncreq//
To uri: to
uri=http://localhost:8080/jsp-examples/checkbox/nipr.jsp?bridgeEndpoint=true/
 

Changing uri dynamically like below:

| 100 - org.apache.camel.camel-http - 2.8.3 | Executing http POST
method: http://localhost:8080/jsp-examples/checkbox/nipr.jsp/mib401Asyncreq/

I attached log files and beans xml for your reference. Please suggest me why
the url value is replacing in runtime.

Is this the right way to implement httpJms Bridge? Please suggest
http://camel.465427.n5.nabble.com/file/n5714542/beans.xml.txt beans.xml.txt 
http://camel.465427.n5.nabble.com/file/n5714542/servicemix_log_with_bridgeEndpoint.log
servicemix_log_with_bridgeEndpoint.log 
http://camel.465427.n5.nabble.com/file/n5714542/servicemix_log_without_bridgeEndpoint.log
servicemix_log_without_bridgeEndpoint.log 

--
View this message in context: 
http://camel.465427.n5.nabble.com/jms-to-http-tp5714372p5714542.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: Need help in java.net.ConnectException: Connection refused

2012-06-15 Thread vargjohn
Hi Babak,

I wrote some code using Socket API and tried to connect to activemq within
the camel route and it worked but the onException() clause is not getting
called. but now i do not see the exception java.net.ConnectException:
Connection refused when my web application is started and the activemq is
down. Thank you very much for the solution.

But when i shutdown the activemq in the middle while my application is
running, i keep getting the java.net.ConnectException: Connection refused,
is there any method to rerun the camel route again or some other method.

Thanks  Regards,
John

--
View this message in context: 
http://camel.465427.n5.nabble.com/Need-help-in-java-net-ConnectException-Connection-refused-tp5714476p5714545.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: recipient list sending to multiple Camel Processors

2012-06-15 Thread Tyler Durvik
All of my processor information are stored in a database.  When I
start my system I want to build my routes by creating instances of my
processors as defined in a database.  So once I begin to receive data
I can route through my processors based on the data received.  The
problem I see is I get NoSuchEndpoint exceptions thrown.  I am not
sure how to solve this exception.


On Fri, Jun 15, 2012 at 12:34 AM, Claus Ibsen claus.ib...@gmail.com wrote:
 On Thu, Jun 14, 2012 at 9:58 PM, Tyler Durvik phangb...@gmail.com wrote:

 Yes.  I want to dynamically build recipient list, but all the
 destinations will be camel processor.  I see examples where you parse
 a header using a comma (,), or a java.util.List of strings but not
 processors.  I am trying to build the list dynamically inside a bean.


 If you enlist your processors in the registry, eg if you use Spring XML,
 then define them as bean, then you can refer to them using the bean
 component

 return bean:foo,bean:bar


 bean id=foo class=com.mycompany.MyFooProcessor/




 On Thu, Jun 14, 2012 at 3:50 PM, Vincent Nonnenmacher
 vincent.nonnenmac...@gmail.com wrote:
  you means this http://camel.apache.org/recipient-list.html is not what
  you're looking for ?
 
 
  On Thu, Jun 14, 2012 at 9:08 PM, Tyler Durvik phangb...@gmail.com
 wrote:
 
  Is it possible to send a message to a group of Camel processors using
  a recipient list ?  I have looked through the documentation and cannot
  find an example of this.
 




 --
 Claus Ibsen
 -
 FuseSource
 Email: cib...@fusesource.com
 Web: http://fusesource.com
 Twitter: davsclaus, fusenews
 Blog: http://davsclaus.com
 Author of Camel in Action: http://www.manning.com/ibsen


Re: Camel Component - Consumer Threading Question

2012-06-15 Thread gilboy
Thanks for the response.

I was just thinking about this a little further. If an exception occurs in
my consumer, I really just need to restart the consumer not the whole route. 

If I take this approach, i.e. 

class CustomConsumer extends DefaultConsumer implements Runnable{ 
.. 

public void run(){ 

   try{ 

   } catch (Exception exc){ 
  doStop(); 
  doStart(); 
   } 

. 
}

By only restarting the consumer I will not need to worry about inflight
exchanges, right?

Is it bad practise to restart a consumer in isolation?

Thanks
Joe

--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-Component-Consumer-Threading-Question-tp5714233p5714559.html
Sent from the Camel - Users mailing list archive at Nabble.com.


running ActiveMQ with camel from maven

2012-06-15 Thread Mark Webb
I usually use the command mvn camel:run to execute my camel
routes..etc in my development environment.  I have included ActiveMQ
support for my camel routing and would like to start an ActiveMQ
broker as part of my Camel routes when they start up.  Is there a way
to do this from maven or should I just embed a broker in my main
class?

I ran across this link -
http://activemq.apache.org/maven2-activemq-broker-plugin.html, but it
seems quite dated.


Thanks,
Mark


Re: keep track of JMSMessageID with InOnly exchange

2012-06-15 Thread dmhatre
Hi there,
So did you guys found out the way how to implement this.
I tried the patch but i get the following error:
Also pasting my configuration and java code. Please help.

java.lang.UnsupportedOperationException: JMSCC0029: A destination must be
specified when sending from this producer.
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
Method)[:1.6.0_32]
at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39)[:1.6.0_32]
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27)[:1.6.0_32]
at
java.lang.reflect.Constructor.newInstance(Constructor.java:513)[:1.6.0_32]
at
com.ibm.msg.client.commonservices.j2se.NLSServices.createException(NLSServices.java:313)[com.ibm.mqjms.jar:7.0.1.0
- k000-L090724]
at
com.ibm.msg.client.commonservices.nls.NLSServices.createException(NLSServices.java:390)[com.ibm.mqjms.jar:7.0.1.0
- k000-L090724]
at
com.ibm.msg.client.jms.internal.JmsErrorUtils.createException(JmsErrorUtils.java:104)[com.ibm.mqjms.jar:7.0.1.0
- k000-L090724]
at
com.ibm.msg.client.jms.internal.JmsMessageProducerImpl.checkNotUnidentifiedProducer(JmsMessageProducerImpl.java:1058)[com.ibm.mqjms.jar:7.0.1.0
- k000-L090724]
at
com.ibm.msg.client.jms.internal.JmsMessageProducerImpl.send_(JmsMessageProducerImpl.java:725)[com.ibm.mqjms.jar:7.0.1.0
- k000-L090724]
at
com.ibm.msg.client.jms.internal.JmsMessageProducerImpl.send(JmsMessageProducerImpl.java:406)[com.ibm.mqjms.jar:7.0.1.0
- k000-L090724]
at
com.ibm.mq.jms.MQMessageProducer.send(MQMessageProducer.java:299)[com.ibm.mqjms.jar:7.0.1.0
- k000-L090724]
at
org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:592)[spring-jms-3.0.7.RELEASE.jar:3.0.7.RELEASE]
at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.doSend(JmsConfiguration.java:274)[file:/C:/workspace/OceanviewEAI/bin/:]
at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.doSendToDestination(JmsConfiguration.java:213)[file:/C:/workspace/OceanviewEAI/bin/:]
at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.access$1(JmsConfiguration.java:203)[file:/C:/workspace/OceanviewEAI/bin/:]
at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate$2.doInJms(JmsConfiguration.java:179)[file:/C:/workspace/OceanviewEAI/bin/:]
at
org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:466)[spring-jms-3.0.7.RELEASE.jar:3.0.7.RELEASE]
at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.java:177)[file:/C:/workspace/OceanviewEAI/bin/:]
at
org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:375)[file:/C:/workspace/OceanviewEAI/bin/:]
at
org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.java:313)[file:/C:/workspace/OceanviewEAI/bin/:]
at
org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:111)[file:/C:/workspace/OceanviewEAI/bin/:]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.2.jar:2.9.2]
at
org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:115)[camel-core-2.9.2.jar:2.9.2]
at
org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:285)[camel-core-2.9.2.jar:2.9.2]
at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:110)[camel-core-2.9.2.jar:2.9.2]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.2.jar:2.9.2]
at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.9.2.jar:2.9.2]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.2.jar:2.9.2]
at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:71)[camel-core-2.9.2.jar:2.9.2]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.2.jar:2.9.2]
at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.9.2.jar:2.9.2]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.2.jar:2.9.2]
at
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)[camel-core-2.9.2.jar:2.9.2]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.2.jar:2.9.2]
at
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:333)[camel-core-2.9.2.jar:2.9.2]
at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:223)[camel-core-2.9.2.jar:2.9.2]