Re: Camel 2.14/Netty: How to add ByteArrayDecoder to ServerChannelPipeline?
There are quit different change between the Netty3.x and Netty4.x. That is why we create a new camel component camel-netty4[1] for it. So I think you can just need to change the camel-netty to camel-netty4 and use the scheme netty4 in your camel route. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-2-14-Netty-How-to-add-ByteArrayDecoder-to-ServerChannelPipeline-tp5768638p5768761.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Issue using multiple services broadcast via JettyComponent
FYI, The stack over flow issue was addressed by CAMEL-8036. As we setup the security handler directly on the server, it is impossible to set up two different security handler on the camel jetty endpoints which share the same Jetty component(Jetty server). -- View this message in context: http://camel.465427.n5.nabble.com/Issue-using-multiple-services-broadcast-via-JettyComponent-tp5757958p5767690.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: camel-ftp 2.15.1 return ftp error code 421
I think you may need to find another way to pull the sub directory instead of pulling root directory directly. -- View this message in context: http://camel.465427.n5.nabble.com/camel-ftp-2-15-1-return-ftp-error-code-421-tp5765272p5765843.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: camel-ftp 2.15.1 return ftp error code 421
The first connection is used to check if the ftp server is still alive before starting to pull the directory. If the RemoteFileConsumer cannot connect to the server, it just return the pulling process and wait for another pulling. -- View this message in context: http://camel.465427.n5.nabble.com/camel-ftp-2-15-1-return-ftp-error-code-421-tp5765272p5765842.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: [REST DSL] Camel 2.14.1-SNAPSHOT : How to configure SSL on jetty component ?
Hi, Did you try to setup the JettyComponent first just like this? JettyEndpoint doesn't support to set the sslSocketConnectors. If you want to set the sslContextParameters you need to set it just like this -- View this message in context: http://camel.465427.n5.nabble.com/REST-DSL-Camel-2-14-1-SNAPSHOT-How-to-configure-SSL-on-jetty-component-tp5760328p5760395.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Looking for simple http request example with cxfrs in java
Hi The stack track is not based on the code that you showed. Please make sure you setup the rsClientProxy bean rightly just like this[1] [1]https://camel.apache.org/cxfrs.html#CXFRS-HowtoconfiguretheRESTendpointinCamel Willem -- View this message in context: http://camel.465427.n5.nabble.com/Looking-for-simple-http-request-example-with-cxfrs-in-java-tp5754949p5755022.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: HTTP re-sending
Hi, You can take a look at the onException DSL[1]. You can redirect the exchange to a resending route if you want to resend message. [1]http://camel.apache.org/exception-clause.html -- View this message in context: http://camel.465427.n5.nabble.com/HTTP-re-sending-tp5754474p5754482.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Chunking issue with http producer
Hi Bernard, You are right, the patch has nothing to do with if the http endpoint is bridge endpoint or not. I created a JIRA[1] to keep track of this useful feature. [1]https://issues.apache.org/jira/browse/CAMEL-7638 Regards, Willem -- View this message in context: http://camel.465427.n5.nabble.com/Chunking-issue-with-http-producer-tp5735075p5754439.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: New to Camel and also needing to come up to speed on Java again
Answer for Q1, you can write a Processor to setup the invocation based on the Web Service request. You can find some example on how to prepare the invocation parameter here[1]. Answer for Q2, camel-mail use the Java mail to talk to the mail server, I think it should be find if the server is Exchange server which provides the stand POP3 service. [1]http://camel.apache.org/cxf#CXF-Howtopreparethemessageforthecamel-cxfendpointinPOJOdataformat -- View this message in context: http://camel.465427.n5.nabble.com/New-to-Camel-and-also-needing-to-come-up-to-speed-on-Java-again-tp5752662p5752681.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: XMLConstants.FEATURE_SECURE_PROCESSING feature setting in jboss-fuse-6.1
Yes, we changed the default setting in Camel-2.12.x to enforce the security the setting by default. You can override the setting just as Grzegorz suggested. -- View this message in context: http://camel.465427.n5.nabble.com/XMLConstants-FEATURE-SECURE-PROCESSING-feature-setting-in-jboss-fuse-6-1-tp5750712p5750720.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel CXF Proxy with WS-Security
If you put the message body into out message, you need to copy the in message headers to the out message header at the same time. camel-cxf cannot take the message headers from the in message and message body from the out message. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-CXF-Proxy-with-WS-Security-tp5749223p5749306.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel CXF Endpoint Performance - Threading
Hi， The AsyncProcessorHelper.proccess() method just provides a sync processing invocation which is based on the Async API. I need to know some detail about your route which makes camel does that change. It looks like you are using direct endpoint to route the message to next camel route, as the direct endpoint provides the async API and CXF consumer is using async API by default, so I doubt your InquiryRoute may have some endpoint which just can call the sync process API. You can use seda endpoint to replace direct endpoint to decouple the threads from the InquiryCxfRoute and InquiryRoute. Regards, Willem -- View this message in context: http://camel.465427.n5.nabble.com/Camel-CXF-Endpoint-Performance-Threading-tp5748984p5749074.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: JMS Message Expiration period
timeToLive is the uri option, you can set it on the jms endpoint which you want to route the message from camel route to jms broker. Willem -- View this message in context: http://camel.465427.n5.nabble.com/JMS-Message-Expiration-period-tp5749032p5749075.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: JavaFX + Spring + Camel + Maven
Thanks for sharing the solution with us. Do you to need wrap up a new application jar for JavaFX to use? Why does the camel-spring.jar be used directly? -- View this message in context: http://camel.465427.n5.nabble.com/JavaFX-Spring-Camel-Maven-tp5749039p5749076.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: camel-cxf , return complex type object problem
Hi, For the CXF invocation, it need to return not only the invocation result, but also some out parameters, so we use a Array or List to story these results. If you just set the body with a simple object, camel-cxf can wrap it into a List, but if you put a list as a return object, camel will not wrap it. If you want to return a List object, you need to put the List object into an array or a List. Willem -- View this message in context: http://camel.465427.n5.nabble.com/camel-cxf-return-complex-type-object-problem-tp5746478p5746513.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Unit Testing Question
Can you double check the camel jars in your class path to see if there is another version of camel jar in your class path? BTW, can you tell us which ClassDef is not found? -- View this message in context: http://camel.465427.n5.nabble.com/Unit-Testing-Question-tp5745966p5746476.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How can I call a web service with no parameters via a producerTemplate?
You set a wrong url, please remove the option of dataFormat=MESSAGE because you just invocation the web service with a string instead of SOAP message output stream. -- View this message in context: http://camel.465427.n5.nabble.com/How-can-I-call-a-web-service-with-no-parameters-via-a-producerTemplate-tp4806257p5745618.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Message properties missing after Camel - rabbitmq routing
The correlation_id and reply_to header are removed in removeHeaders pattern=rabbitmq.*/ You can find more information about the rabbitmq.* header here[1] [1]https://github.com/apache/camel/blob/master/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java -- View this message in context: http://camel.465427.n5.nabble.com/Message-properties-missing-after-Camel-rabbitmq-routing-tp5745254p5745491.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: SOAP Web service Calling using camel.
Current camel-cxf doesn't support the JaxWsDynamicClientFactory out of box, so you need to generate the SEI yourself before calling the service. -- View this message in context: http://camel.465427.n5.nabble.com/SOAP-Web-service-Calling-using-camel-tp5745180p5745372.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: problems with route cxf - netty ( netty as tcp socket server)
Here is a thread[1] in the stackoverflow which calls about it. [1]http://stackoverflow.com/questions/20421767/problems-with-mina-netty-tcp-endpoint-in-camel-tcp-socket-server-endpoint/ -- View this message in context: http://camel.465427.n5.nabble.com/problems-with-route-cxf-netty-netty-as-tcp-socket-server-tp5744294p5744701.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: XQuery (camel-saxon)
XQuery suppose to set the result type like this
from(direct:start).xquery(concat('mock:foo.', /person/@city),
String.class);
The default result type is DOM.class.
--
View this message in context:
http://camel.465427.n5.nabble.com/XQuery-camel-saxon-tp5743206p5743251.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: splitting xml failed when running on tomcat
As you are using splitter you have to aggregator to put the response together. -- View this message in context: http://camel.465427.n5.nabble.com/splitting-xml-failed-when-running-on-tomcat-tp5740407p5740482.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Messages disappear if fabric endpoint resolves to null / blank
You should get an exception if the fabric registry entry is not exist. Can you double check the log to see if Camel throws the exception out? -- View this message in context: http://camel.465427.n5.nabble.com/Messages-disappear-if-fabric-endpoint-resolves-to-null-blank-tp5733683p5737512.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Reference OSGI Blueprint java.util.Properties service in Blueprint Camel property placeholder
Hi I just have some time to revisit this issue and found you'd better to leverage the configure admin service which suppose to related the bundle when the configuration is changed. It will more powerful then you just pass the properties through the OSGi service. Willem -- View this message in context: http://camel.465427.n5.nabble.com/Reference-OSGI-Blueprint-java-util-Properties-service-in-Blueprint-Camel-property-placeholder-tp5726985p5732991.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Appending/Not Appending paths
Hi, If you don't want the path1/path2 to be added, you can set the bridgeEndpoint option to be false, otherwise you should et the option to be true. Willem -- View this message in context: http://camel.465427.n5.nabble.com/Appending-Not-Appending-paths-tp5732231p5732241.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: cxf producer needs a break?
camel-cxf is using the asyn invocation by default, if you add the synchronous=true , it will use the synchronous invocation instead. Willem -- View this message in context: http://camel.465427.n5.nabble.com/cxf-producer-needs-a-break-tp5730612p5731050.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: zip file best practices
I just have a chance to check the code, it is not a new component. I think we can treat it as an expression, which can help the splitter to build a Iterator from the uncompressed stream. And it is mainly used with split DSL. Willem -- View this message in context: http://camel.465427.n5.nabble.com/zip-file-best-practices-tp5713437p5729057.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Found a bug in overriding URI using camel-http4 + documentation problem
Hi,
I just went through the unit test, I just found there is some miss
understand between the URI that http4 endpoint use and the URI that the
http4 producer use.
As you know there are more than one component which can send the request to
the HTTP server, such as camel-http, camel-http4 and camel-ahc even
camel-jetty. In came we use URI to specify the endpoint information, so we
use different scheme to let camel pick up right component to use.
But for the http4 producer, it just understand the URI which is start with
http://xxx, so you need to set the URI in the message header like http://xxx
instead of http4:xxx.
And we don't support the change the http request uri for the bridge
endpoint, as the message which is routed form the first endpoint could have
the header with Exchange.HTTP_URI and we don't want this header confuse the
producer.
BTW, I past the Unit test file which I modified here, please check it out.
package org.apache.camel.component.http4;
import java.io.IOException;
import java.io.InputStream;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.Assert;
import org.junit.Ignore;
import org.junit.Test;
public class HttpUriOverrideTest extends CamelTestSupport {
private String direct = direct:abc;
private String oldUri = http4:stackoverflow.com:80;
private String oldUriBridge =
http4:stackoverflow.com:80?bridgeEndpoint=true;
private String newUri = http://www.website.com:80;;
private String newHttp4Uri = http4:www.website.com:80;
private String mock = mock:mock1;
private String oldUriBody = stackoverflow;
private String newUriBody = www.website.com;
/**
* This test success
* @throws Exception
*/
@Test
public void testValidOldUri() throws Exception {
doTestValidWebsite(oldUri);
}
/**
* This test success
* @throws Exception
*/
@Test
public void testValidNewUri() throws Exception {
doTestValidWebsite(newHttp4Uri);
}
/**
* This test success
* @throws Exception
*/
@Test
public void testSimpleTest() throws Exception {
doTestWithSetHeaderHttpUri(oldUri, false);
}
/**
* This test will give the following exception :
* Caused by: java.lang.IllegalArgumentException: Invalid uri:
http4:www.website.com:80.
* If you are forwarding/bridging http endpoints,
* then enable the bridgeEndpoint option on the endpoint:
Endpoint[http4://stackoverflow.com:80]
* @throws Exception
*/
@Test
public void testOverride() throws Exception {
doTestWithSetHeaderHttpUri(oldUri, true);
}
/**
* This test will fails on the Asserts, the body contains the body of
the oldUri (oldUriBody instead of newUriBody)
* @throws Exception
*/
@Test
@Ignore(This test will failed as we don't support to override the http
uri within the bridge endpoint)
public void testOverrideWithBridgeParameter() throws Exception {
doTestWithSetHeaderHttpUri(oldUriBridge, true);
}
public void doTestWithSetHeaderHttpUri(final String oldURI, final
boolean override) throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
if (override) {
from(direct).setHeader(Exchange.HTTP_URI,
constant(newUri)).to(oldURI).to(mock);
} else {
from(direct).to(oldURI).to(mock);
}
}
});
context.start();
getMockEndpoint(mock).expectedMessageCount(1);
context.createProducerTemplate().sendBody(direct, body);
assertMockEndpointsSatisfied();
String body = getMessage((InputStream)
getMockEndpoint(mock).getExchanges().get(0).getIn().getBody());
if (override) {
// Should contain newUriBody
Assert.assertFalse(body.contains(oldUriBody));
Assert.assertTrue(body.contains(newUriBody));
} else {
// Should contain oldUriBody
Assert.assertTrue(body.contains(oldUriBody));
Assert.assertFalse(body.contains(newUriBody));
}
}
public void doTestValidWebsite(final String uri) throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
from(direct).to(uri).to(mock);
}
});
context.start();
getMockEndpoint(mock).expectedMessageCount(1);
context.createProducerTemplate().sendBody(direct, body);
assertMockEndpointsSatisfied();
String body = getMessage((InputStream)
getMockEndpoint(mock).getExchanges().get(0).getIn().getBody());
if (uri.equals(newHttp4Uri)) {
// Should contain newUriBody
Re: Possible bug with multicast shareUnitOfWork
Hi, I can reproduce this kind of error in the trunk by adding a simple unit test as you said. If I remove the shareUnitOfWork setting, the error handler can get expect numbers messages. So I just fill a JIRA CAMEL-6005[1] for it. [1]https://issues.apache.org/jira/browse/CAMEL-6005 Willem -- View this message in context: http://camel.465427.n5.nabble.com/Possible-bug-with-multicast-shareUnitOfWork-tp5726103p5726113.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: camel-ftp error
Hi, You are using camel-ftp-2.10.0.fuse-71-047.jar with the camel-core-2.9.0.fuse-7-061. Please make sure you are using the same version of camel when start the camel context. Willem -- View this message in context: http://camel.465427.n5.nabble.com/camel-ftp-error-tp5724614p5724617.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Call web service from Camel
Hi, From the routes those you showed us, I can see you need go through the camel-cxf wiki[1]. It shows you how to consume or produce the message through the camel-cxf component. [1]http://camel.apache.org/cxf.html Willem -- View this message in context: http://camel.465427.n5.nabble.com/Call-web-service-from-Camel-tp5721952p5721954.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel Bean Component Behaviour in case of an InOut exchange
Hi, How did you send the request to you queue? Did you use ProducerTemplate or just another route ? BTW, you need to consider to use camel 2.10.2 which is latest stable release of Camel. Willem -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Bean-Component-Behaviour-in-case-of-an-InOut-exchange-tp5721888p5721926.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: aggregator question: how do I send reply back to the requestor
Hi, Did you have any chance to take a look at the loan broker example[1]? Basically you just need to setup right aggregation strategy to put the response message together. [1]http://camel.apache.org/loan-broker-example.html Willem -- View this message in context: http://camel.465427.n5.nabble.com/aggregator-question-how-do-I-send-reply-back-to-the-requestor-tp5720377p5721040.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to mock endpoints taking lots of different query parameters values?
Here is the MockComponent that I mentioned, you just need to register it into
the camel context, then you can you get what you need :)
package org.apache.camel.component.mock;
import java.util.HashMap;
import java.util.Map;
import org.apache.camel.Endpoint;
import org.apache.camel.impl.DefaultComponent;
public class MyMockComponent extends DefaultComponent {
private MapString, MockEndpoint endpoints = new HashMapString,
MockEndpoint();;
@Override
protected Endpoint createEndpoint(String uri, String remaining,
MapString, Object parameters) throws Exception {
MockEndpoint endpoint = null;
// deal with the uri which is end with *
if (remaining.endsWith(*)) {
String key = remaining.substring(0, remaining.length() - 1);
if (endpoints.containsKey(key)) {
endpoint = endpoints.get(key);
}
endpoint = new MockEndpoint(uri, this);
endpoints.put(key, endpoint);
}
// check if the remaining is used here
if (endpoints.containsKey(remaining)) {
endpoint = endpoints.get(remaining);
} else {
endpoint = new MockEndpoint(uri, this);
}
return endpoint;
}
}
--
Willem Jiang
Red Hat, Inc.
FuseSource is now part of Red Hat
Web: http://www.fusesource.com | http://www.redhat.com
Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/)
(English)
http://jnn.javaeye.com (http://jnn.javaeye.com/) (Chinese)
Twitter: willemjiang
Weibo: willemjiang
--
View this message in context:
http://camel.465427.n5.nabble.com/How-to-mock-endpoints-taking-lots-of-different-query-parameters-values-tp5719629p5719669.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: CXF component fails to marshal SOAP fault details
In the PAYLOAD dataformat, you need to marshal the SOAP fault detail yourself, like this[1] In the MESSAGE dataformat, you need to marshal the whole SOAP fault yourself, as camel-cxf just redirect the input stream itself. [1]https://svn.apache.org/repos/asf/camel/trunk/camel/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfConsumerPayLoadMarshalFaultTest.java -- Willem Jiang FuseSource Web: http://www.fusesource.com (http://www.fusesource.com/) Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (English) http://jnn.javaeye.com (http://jnn.javaeye.com/) (Chinese) Twitter: willemjiang Weibo: willemjiang -- View this message in context: http://camel.465427.n5.nabble.com/CXF-component-fails-to-marshal-SOAP-fault-details-tp5718686p5718698.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: cxf endpoint with 2004/08 ws-addressing
Hi,
You can set the request context with the below code in your processor before
routing the message the the cxf endpoint.
from(cxf:xxx).process(new Processor() {
public void process(final Exchange exchange) {
MapString, Object requestContext = new HashMapString, Object();
requestContext.put(javax.xml.ws.addressing.context,
http://schemas.xmlsoap.org/ws/2004/08/addressing;);
exchange.getIn().setHeader(Client.REQUEST_CONTEXT, requestContext);
}
}).to(cxf:xxx);
Willem
--
View this message in context:
http://camel.465427.n5.nabble.com/cxf-endpoint-with-2004-08-ws-addressing-tp5715694p5715739.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Graceful shutdown not graceful at all
You are using ThreadPoolTaskExecutor from spring and JmsComponent doesn't manage the TaskExecutor life cycle itself. If you want to shutdown the whole application gracefully, you need to call the ApplicationContext destroy method. -- View this message in context: http://camel.465427.n5.nabble.com/Graceful-shutdown-not-graceful-at-all-tp5709579p5710474.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Error using apache-cxf w. Camel 2.9.1
Just one comment on the camel-cxf behavior change of Camel 2.9.1. CxfProducer create a new client when it is started to avoid the memory leak if the customer create the route dynamically. I'm not sure if it is relates to test code that you have, can you show us the whole test example. Willem -- View this message in context: http://camel.465427.n5.nabble.com/Error-using-apache-cxf-w-Camel-2-9-1-tp5560906p5563188.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: npe in camel 2.9.1 validator
If you put the schema into the test/resources directory, it will not be wrapped into the more jar. You may need to add the test jar dependency like this groupIdcom.example/groupId artifactIdmy-artifact/artifactId typetest-jar/type scopetest/scope Willem -- View this message in context: http://camel.465427.n5.nabble.com/npe-in-camel-2-9-1-validator-tp5540894p5546609.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: camel and spring in a webapp
Hi, Camel does not try to load the annotated Converter from package of 'org.apache.camel.converter' since Camel 2.8.0. Can you check if you wrap the other version of camel into your war ? -- View this message in context: http://camel.465427.n5.nabble.com/camel-and-spring-in-a-webapp-tp5469916p5471412.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Send message to cxf-endpoint with @Produce
Hi, Can I have a look at your SEI class net.myservice.myserviceuserdata.ServiceMyServiceUserData? It looks like CXF client is try to invoke the service with unwrapped parameters. Willem -- View this message in context: http://camel.465427.n5.nabble.com/Send-message-to-cxf-endpoint-with-Produce-tp5453055p5454038.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: GPG encryption in camel 2.8.3
Hi, I think you made a mistake of the route configure code and the processor code. The Java DSL which you used to define the route is just a configuration code, it tell camel to build the route as you want, they are not the processing code which camel uses in the runtime. If you want to camel context call the encryption code of GPG, you can consider to use Bean[1]or implement your customer Processor[2] to do the job at runtime. [1]http://camel.apache.org/bean.html [2]http://camel.apache.org/processor.html Willem -- View this message in context: http://camel.465427.n5.nabble.com/GPG-encryption-in-camel-2-8-3-tp5448999p5449388.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: unmarshalling but not marshalling?
I think we need to take a look at your data format code. -- View this message in context: http://camel.465427.n5.nabble.com/unmarshalling-but-not-marshalling-tp5152663p5156527.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: camel-cxf service publish address problem
As you are using the http jetty transport， when you set the address to be http://0.0.0.0:8890/ProcessPrescriptionOrder;, you should be able to get the wsdl with the url http://localhost:8890/ProcessPrescriptionOrder。 0.0.0.0 just let Jetty to listen to all the network interface. Willem -- View this message in context: http://camel.465427.n5.nabble.com/camel-cxf-service-publish-address-problem-tp4953917p4954099.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Missing detail element in SOAP fault
This issue should be fixed by CAMEL-4570[1] [1] https://issues.apache.org/jira/browse/CAMEL-4570 -- View this message in context: http://camel.465427.n5.nabble.com/Missing-detail-element-in-SOAP-fault-tp4913512p4931073.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Missing detail element in SOAP fault
It looks like you are using the camel-http component to send the request to the server. Can you show us you camel route ? -- View this message in context: http://camel.465427.n5.nabble.com/Missing-detail-element-in-SOAP-fault-tp4913512p4920338.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Bindy CSV marshal does not properly quote values defined by the CsvRecord separator
Hi, After checking the code of BindyCsvFactory, I found the it only support the separator to be char not a string. Maybe we should add some note's on the camel-bindy wiki page. Willem -- View this message in context: http://camel.465427.n5.nabble.com/Bindy-CSV-marshal-does-not-properly-quote-values-defined-by-the-CsvRecord-separator-tp4809017p4809157.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Can't get JAAS working for EJB 3.0(on JBoss) while routing.
I just did some test on the camel-ejb module.[1] It is possible to lookup the spring beans if you just set up the jndi context on the ejb object. you can find the reference here[2]. [1]http://svn.apache.org/viewvc?rev=1170483view=rev [2]https://svn.apache.org/repos/asf/camel/trunk/components/camel-ejb/src/test/resources/org/apache/camel/component/ejb/SpringGreaterCamelEjbTest.xml Willem -- View this message in context: http://camel.465427.n5.nabble.com/Can-t-get-JAAS-working-for-EJB-3-0-on-JBoss-while-routing-tp4801889p4802102.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: WebService problem after adding ...
Which version of CXF are you using? It looks like you have multiple version of CXF jars in your class path. -- View this message in context: http://camel.465427.n5.nabble.com/WebService-problem-after-adding-tp4578410p4581491.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: ServiceMix 4.3.1 and Camel 2.8-SNAPSHOT
Can you not ask the same question across the topics ? It's very annoying and can't help you to get the answer more quickly. Please be patient. -- View this message in context: http://camel.465427.n5.nabble.com/ServiceMix-4-3-1-and-Camel-2-8-SNAPSHOT-tp4553864p4563603.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: I search example where Camel return Web Service
No , you don't need it. CXF supports the build the service module from the interface, so you don't need to provide the WSDL file for the camel-cxf endpoint. -- View this message in context: http://camel.465427.n5.nabble.com/I-search-example-where-Camel-return-Web-Service-tp4557105p4559801.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: are there chinese documents with camel
I wrote some pieces of Chinese articles to introduce some basic concepts of Camel. You can find them in my Chinese blog. [1]http://jnn.iteye.com/category/27938 Willem -- View this message in context: http://camel.465427.n5.nabble.com/are-there-chinese-documents-with-camel-tp4447206p4450530.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: set jms reply to in message header
Hi The header name should be JMSReplyTo. Willem -- View this message in context: http://camel.465427.n5.nabble.com/set-jms-reply-to-in-message-header-tp4420767p4420786.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Multiple persistence-unit
Hi, You can define the different entityManagerFactory for different jpa component instance like this bean id=jpa1 class=org.apache.camel.component.jpa.JpaComponent property name=entityManagerFactory ref=entityManagerFactory1 / /bean bean id=jpa2 class=org.apache.camel.component.jpa.JpaComponent property name=entityManagerFactory ref=entityManagerFactory2 / /bean camelContext id=camel xmlns=http://camel.apache.org/schema/spring; route from uri=direct:start/ to uri=jpa1:/ /route route from uri=jpa2:xxx/ to uri=sedaraw :/ /route /camel:camelContext Willem -- View this message in context: http://camel.465427.n5.nabble.com/Multiple-persistence-unit-tp4335581p4336313.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Cometd component
Hi Instead of using the customer processor, the route can use the convertBodyTo directly. Willem -- View this message in context: http://camel.465427.n5.nabble.com/Cometd-component-tp4299174p4300424.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Strange behavior with simple language in camel route
Hi,
If you want to use the properties component in simple language, the syntax
is liking this
${properties:[locations]:key}
Willem
--
View this message in context:
http://camel.465427.n5.nabble.com/Strange-behavior-with-simple-language-in-camel-route-tp3200894p4300441.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Missing Stack Trace when Handling SOAP Fault from a CXF Endpoint
Just a quick note for CXF server return the stack trace back to the client. If you are using SOAP 11 , CXF can put the stack trace into the fault message if you enable the option faultStackTraceEnabled like this I'm now working on CXF-3445 to make sure this feature can work with SOAP12. [1]https://issues.apache.org/jira/browse/CXF-3445 -- View this message in context: http://camel.465427.n5.nabble.com/Missing-Stack-Trace-when-Handling-SOAP-Fault-from-a-CXF-Endpoint-tp3774168p4287903.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Best Practice fro Thread Safe processor
As Camel has a async process module, you can't know if the processors are called in a single thread. If you are using the thread local to store the states, it may be massed up. My suggestion is store the states information into the Exchange, and Camel will make sure it is processed rightly. Willem -- View this message in context: http://camel.465427.n5.nabble.com/Best-Practice-fro-Thread-Safe-processor-tp4288973p4290075.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: addTypeConverter does not clear misses in BaseTypeConverterRegistry
Hi , Good catch of the issue of misses map. We should updated if a new TypeConverter is added. Please feel free to create a JIRA for it, We love the contribution :) Can you give me more detail about the webstart issue of the AnnotationTypeConverterLoader? What kind of error that you web start client faced, and why suppress the usage of AnnotationTypeConverterLoader can make it work ? Willem Andreas Kuhtz wrote: Hello, I was playing around with adding type converters after the context was started. In my tests I tried to convert an object without any type converter available (returns null which is fine). After that I added a matching type converter (manually) and run the conversion again. Because addTypeConverter does not clear misses map in BaseTypeConverterRegistry subsequent conversions fail. I think the misses map in BaseTypeConverterRegistry should remove the key if a matching type converter is added. My second problem is that it's currently not possible to start camel without the AnnotationTypeConverterLoader added. In case of a webstart based client application this causes startup errors that prevents using camel. I added an attribute to suppress the usage of AnnotationTypeConverterLoader in my local sources and I've prepared a patch for this problem and the problem described above with test case. Should I create a JIRA issue? http://camel.465427.n5.nabble.com/file/n4288871/patch-camel.diff patch-camel.diff Cheers Andi -- View this message in context: http://camel.465427.n5.nabble.com/addTypeConverter-does-not-clear-misses-in-BaseTypeConverterRegistry-tp4288871p4290078.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: camel-example-cxf pom.xml
I just cleaned up the file which name has 2.8-SNAPSHOT in my ~/.m2/ and start to run 'mvn clean install' from examples/camel-example-cxf and can't get the error that you reported again. Willem -- View this message in context: http://camel.465427.n5.nabble.com/camel-example-cxf-pom-xml-tp4268673p4285499.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: spring xml - shutdown strategy timeout
No, CamelContextFactoryBean just lookup the type bean like this. ShutdownStrategy shutdownStrategy = getBeanForType(ShutdownStrategy.class); So the bean id could be anything :) Willem preben wrote: Just create a spring bean : id is important here since it will override camels default shutdown bean I guess. /preben -- View this message in context: http://camel.465427.n5.nabble.com/spring-xml-shutdown-strategy-timeout-tp4256930p4258126.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Documentation for automatic marshalling and unmarshalling
Hi, There is a FallbackTypeConverter[1] will help you do this kind of job of the message body's class is annotated with JAXB annotations. If you put the camel-jaxb into your class path, this fallback type converter will be used by default. If you don't want to use it , you need to convert the message body yourself before the fallback type converter get to work :) [1]https://svn.apache.org/repos/asf/camel/trunk/components/camel-jaxb/src/main/java/org/apache/camel/converter/jaxb/FallbackTypeConverter.java Willem Leonard Axelsson wrote: Hi, At my current gig we have a route roughly like the one below where we send in objects using the ProducerTemplate. Those are marshalled into xml using JAXB (annotations) and then sent on to a JMS queue. jaxb = new JaxbDataFormat(quot;com.entraction.elp.api.messagequot;); from(quot;direct:inquot;) .marshal(jaxb) .to(quot;jms:someQueuequot;) What I found by mistake was that the route worked even if I remove the marshalling step. The object will automatically, it seems, be marshalled. My questions is, is this the right behaviour and if it is, where is this feature documented? Automatic marshalling is nice, but I would like to know for sure that it's intended and not a side effect of something else we do. Regards, /Leo - Leonard Axelsson Agical AB E-mail: leonard.axels...@agical.com Blog: http://xlson.com/ Twitter: xlson -- View this message in context: http://camel.465427.n5.nabble.com/Documentation-for-automatic-marshalling-and-unmarshalling-tp4255275p4258140.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Add a Processor to a route at runtime
Can I know why you want to add Processor into the route? I don't think current Camel provides that kind of API you want. You may consider to use this handy Intercept[1] of Camel instead of add the processor to the route. [1]http://camel.apache.org/intercept.html Willem JacobS wrote: Hi Is it possible to alter an existing running route and add a Processor to some point at the routes sequence using the camel api ? something like : Route route = camelContext.getRoute(routeID); route.suspend(); route.addProcessor(new SomeProcessor()); route.resume(); If it is possible please post a simple example. Thanks, Jacob -- View this message in context: http://camel.465427.n5.nabble.com/Add-a-Processor-to-a-route-at-runtime-tp4257724p4258152.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Newbie question regarding Comet/Jetty
I'm not sure how did you remove the Jetty endpoint?
From the camel route configuration, I can just tell that the Jetty endpoint
is used to accept the request from http://localhost:8081/msgs, just like the
file endpoint does.
If you want to remove the Jetty endpoint, you need remove the this whole
route.
from(jetty:http://localhost:8081/msgs;).
process(new AddSourceProcessor('file3')).
to(seda:logmsgs?size=1concurrentConsumers=5)
Willem
koevet3 wrote:
Hi,
I have stumbled across a blog post recently that shows how to monitor a
file using Camel and display the file content on a browser using Comet
(using Groovy).
Actually a
http://www.andrejkoelewijn.com/wp/2009/10/27/simple-log-console-with-camel-and-cometd/
pretty cool example .
There is something that I don't quite understand in the Camel routing of
this example and I'd like to ask for clarification. This is a snippet from
the code:
==
void configure(){
// inputs
from(stream:file?fileName=/Users/test/dude.logscanStream=truescanStreamDelay=50).
process(new AddSourceProcessor('file1')).
to(seda:logmsgs?size=1concurrentConsumers=5)
from(jetty:http://localhost:8081/msgs;).
process(new AddSourceProcessor('file3')).
to(seda:logmsgs?size=1concurrentConsumers=5)
// output: http://localhost:8082
from(seda:logmsgs?size=1concurrentConsumers=5).
to(cometd://127.0.0.1:8082/service/logs?baseResource=file:webapp)
}
def camelCtx = new DefaultCamelContext()
camelCtx.addRoutes(new SampleRoute());
camelCtx.start();
==
If I remove the Jetty route from the Groovy script it will no longer
run. What is exactly doing the jetty route?
Is it there just to start the jetty server? And why the input endpoint is
set to http://localhost:8081/msgs;?
Thanks
Luciano
--
View this message in context:
http://camel.465427.n5.nabble.com/Newbie-question-regarding-Comet-Jetty-tp4257988p4258156.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to Get SOAP Response from the Last Camel Processor in the Route?
Hi, Which version of Camel are you using? It could be helpful if you post your endProcessor code. Willem -- View this message in context: http://camel.465427.n5.nabble.com/How-to-Get-SOAP-Response-from-the-Last-Camel-Processor-in-the-Route-tp4127850p4165310.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Program never terminates due to simple connection creation
Hi, I can see any route definition in your code, so when you start or stop the camel context , it do nothing on the JMS ConnectionFactory. Because the camel context start or stop just delegates the calls into the Camel service object, which could be a route or an endpoint. Willem -- View this message in context: http://camel.465427.n5.nabble.com/Program-never-terminates-due-to-simple-connection-creation-tp4099499p4165957.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Object routing
Hi, You could use the Direct endpoint to do think kind of job. from(direct:start).to(jms:queue:test); And you can use template to send the object to direct:start, and you can add customer processor between the direct:start and jms:queue:test endpoints. Willem -- View this message in context: http://camel.465427.n5.nabble.com/Object-routing-tp4145397p4166160.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: camel-restlet inside servlet container
I just a have a quick look at camel RestletComponent and camel RestletProducer. You can extends RestletEndpoint and RestletProducer to replay the CamelRestlet one with your RestletServlet. Can you tell me what you want to do in your RestletServlet? Maybe we can find some common processor to add to current RestletProducer. Willem -- View this message in context: http://camel.465427.n5.nabble.com/camel-restlet-inside-servlet-container-tp3868084p4171534.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: response from the exposed cxfendpoint is null
Hi,
I don't know why you call the below code in your processor.
msgList[1].toString()
If your request message only one parameter, the msgList should have only one
element.
If you want to get the result, you should check it in the processor after
.to(cxf:bean);
Willem
TJ wrote:
when i send a request to the route I am not able to see any response from
the webservice.
Is there i am doing something wrong here, is there a different way of
doing it.
msgList[1].toString() throws a array index out of bounds excetion.
from(cxf:bean:releasePOEndpoint).handleFault()
.to(log:incoming?showAll=true)
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
logger.info( cxf:bean:releasePOEndpoint processing exchange in
camel);
Message in = exchange.getIn();
Object[] msgList = exchange.getIn().getBody(Object[].class);
ReleasePurchaseOrderRequestType poRequest
(ReleasePurchaseOrderRequestType)msgList[0];
ReleasePurchaseOrderRequestType poRequest =
(ReleasePurchaseOrderRequestType)msgList[0];
logger.info(#Exchange ouput+msgList[1].toString());
exchange.getOut().setHeader(CxfConstants.OPERATION_NAMESPACE,http://company.com/pehz/wsdl/purchase_order_service.v1_0;);
exchange.getOut().setHeader(CxfConstants.OPERATION_NAME,
releasePurchaseOrder);
exchange.getOut().setBody(in.getBody());
}
})
.to(cxf:bean);
--
View this message in context:
http://camel.465427.n5.nabble.com/response-from-the-exposed-cxfendpoint-is-null-tp3713862p3766359.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: cxf with multiple methods in the interface
Hi ,
You need to do the content base routing according to the operation name.
Here is an example[1] for you.
[1]
https://svn.apache.org/repos/asf/camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfConsumerTest.java
Gabor Dolla wrote:
sorry but half of my message is missing... I tried to send this
We try to use camel and cxf with code-first approach and it works when
we have one only method in the interface.
We can not make it work with multiple methods.
package xxx;
public interface FooBar() {
Result foo(String id) ;
Result2 bar(String id);
}
--
View this message in context:
http://camel.465427.n5.nabble.com/cxf-with-multiple-methods-in-the-interface-tp3411543p3411963.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: InOut exchanges require synchronized clocks?
Hi Bryan, It looks more like a ActiveMQ issue than Camel. Can you send this mail to the us...@activemq.apache.org ? Willem -- View this message in context: http://camel.465427.n5.nabble.com/InOut-exchanges-require-synchronized-clocks-tp3411881p3411964.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Mail component parse mailbox file Spring example?
Hi Bill, I'm not sure what's your mailbox files like. If you can turn the mailbox file into camel-mail URI, I think you will have no trouble to use camel to do the work. Willem -- View this message in context: http://camel.465427.n5.nabble.com/Mail-component-parse-mailbox-file-Spring-example-tp3408199p3411969.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: [PROBLEM] GenericFileOperationFailedException: Cannot rename file
What kind of exception that you service throw? It looks like the File can't be renamed if camel is still using that file. Please subscribe the users@camel.apache.org before you start a new thread in nabble. Willem -- View this message in context: http://camel.465427.n5.nabble.com/PROBLEM-GenericFileOperationFailedException-Cannot-rename-file-tp3409728p3411973.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Problem with multiple CXF services using the same https port
Hi Christian,
I cannot see any code inside the {code}{code} block.
And I didn't get your question.
Willem
--
View this message in context:
http://camel.465427.n5.nabble.com/Problem-with-multiple-CXF-services-using-the-same-https-port-tp3379301p3408939.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Delay() causes unexpected results
Please call the end() after you call the delay() function, then you will get
same result as not using delay() function.
As you know delay is a delegate processor, end() will tell him there is no
other processor it should be delegated to call.
Willem
marbor wrote:
Hi all:
I have a DSL that works as expected, but when I add delay()'s, it doesn't.
Is this a bug or do I not understand the delay() function?
Test Class:
public class ChoiceTesting extends CamelTestSupport {
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
from(direct:start)
.log(Starting testing)
.multicast().stopOnException()
.pipeline()
.log(In the beginning! Body=${body})
.to(direct:dummy)
.choice()
.when(header(KEY).isNotEqualTo(VALUE))
.log(choice 1)
.wireTap(direct:dummy)
//.delay(500)
.choice()
.when(header(KEY).isNotEqualTo(VALUE))
.log(choice 2)
.to(direct:dummy)
//.delay(500)
.choice()
.when(header(KEY).isEqualTo(VALUE))
.log(choice 3)
.throwException(new
RuntimeException(Some Error))
.end()
.end()
.end()
.end()
.to(direct:middle)
.pipeline()
.log(In the end! Body=${body})
.end();
from(direct:middle)
.log(In the middle! Body=${body});
from(direct:dummy)
.setBody().constant(DUMMY);
}
};
}
@Test
public void run() {
template.sendBody(direct:start, X);
}
}
Produces the expected output of:
2011-01-24 15:16:42,891 INFO route1 - Starting testing
2011-01-24 15:16:42,891 INFO route1 - In the beginning! Body=X
2011-01-24 15:16:42,891 INFO route1 - choice 1
2011-01-24 15:16:42,891 INFO route1 - choice 2
2011-01-24 15:16:42,891 INFO route2 - In the middle! Body=X
2011-01-24 15:16:42,891 INFO route1 - In the end! Body=X
But when I uncomment the delay() calls, the output changes to:
2011-01-24 15:23:55,477 INFO route1 - Starting testing
2011-01-24 15:23:55,477 INFO route1 - In the beginning! Body=X
2011-01-24 15:23:55,477 INFO route1 - choice 1
2011-01-24 15:23:55,977 INFO route1 - choice 2
2011-01-24 15:23:56,477 INFO route2 - In the middle! Body=DUMMY
2011-01-24 15:23:56,477 INFO route1 - In the end! Body=DUMMY
I'm using Camel 2.5.0.
Thanks in advance,
Mark
Mark Borner
Java Developer - ZStream Xpress
This email is intended for the named recipient only. It may contain
information which is confidential, commercially sensitive, or
copyright. If you are not the intended recipient you must not
reproduce or distribute any part of the email, disclose its contents,
or take any action in reliance. If you have received this email in
error, please contact the sender and delete the message. It is your
responsibility to scan this email and any attachments for viruses and
other defects. To the extent permitted by law, Zurich and its
associates will not be liable for any loss or damage arising in any
way from this communication including any file attachments. We may
monitor email you send to us, either as a reply to this email or any
email you send to us, to confirm our systems are protected and for
compliance with company policies. Although we take reasonable
precautions to protect the confidentiality of our email systems, we
do not warrant the confidentiality or security of email or
attachments we receive.
--
View this message in context:
http://camel.465427.n5.nabble.com/Delay-causes-unexpected-results-tp3354254p3357308.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: process several instances of one route in parallel
Hi, Can I have a look at your route configure? What's the stack trace when you add threads definition ? I can tell nothing until you answer my upper questions. -- Willem -- FuseSource Web: http://www.fusesource.com Blog:http://willemjiang.blogspot.com (English) http://jnn.javaeye.com (Chinese) Twitter: willemjiang -- View this message in context: http://camel.465427.n5.nabble.com/process-several-instances-of-one-route-in-parallel-tp3275297p3277878.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How much memory usage is acceptable?
Current Camel doesn't have this kind of tools out of box. I'm afraid you need to use other JProfile tools to dig the issue yourself. -- Willem -- FuseSource Web: http://www.fusesource.com Blog:http://willemjiang.blogspot.com (English) http://jnn.javaeye.com (Chinese) Twitter: willemjiang -- View this message in context: http://camel.465427.n5.nabble.com/How-much-memory-usage-is-acceptable-tp3256606p3265080.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel REST
Which version of Camel are you using? Did you deploy the camel application in OSGi platform? Can you try to add below lines into your config ? It which will let CXF load the module explicitly. import resource=classpath:META-INF/cxf/cxf.xml/ import resource=classpath:META-INF/cxf/cxf-extension-soap.xml / import resource=classpath:META-INF/cxf/cxf-extension-http-jetty.xml / Willem -- Open Source Integration: http://www.fusesource.com Blog:http://willemjiang.blogspot.com (English) http://jnn.javaeye.com (Chinese) Twitter: http://twitter.com/willemjiang -- View this message in context: http://camel.465427.n5.nabble.com/Camel-REST-tp3213086p3215823.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Thread.sleep() problem
There is no Thread.sleep() call in the camel-snmp. So I guess you are telling the ScheduledPollConsumer's delay time by setting the delay option from URI. You can find more information about camel-snmp component here[1] [1]http://camel.apache.org/snmp.html Willem ganges_k wrote: Hi, I am using camel to fetch data from switch using camel-snmp component. It is very simple to use and enhance. I have enhanced the snmp4j TableUtils in camel-snmp component. I am facing a problem when we ran our application where the switches are at remote location. I found that it is problem with Thread.sleep(); When i ran the application locally (means both application switches are at same location), i am able to get the data. But when execute the application remotely, i am not able to get the data. For this i have increased the sleep time and getting the data from switches. So, is there any other way to implement this? or do i need to set some maximum sleep time? If you have any documentation link which gives information. Please let me know i will go through it. Thanks in advance. Best Regards, Gangadhar.Katakam -- View this message in context: http://camel.465427.n5.nabble.com/Thread-sleep-problem-tp3211486p3211658.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to handle the SOAP Header
Hi, If you already have a soap message which has the right soap header information , you can just use the camel-http[1] component to invoke the external service. If you want to do other WS* message handling work, or create the SOAP message yourself, you can leverage camel-cxf component. [1]http://camel.apache.org/http.html Willem -- View this message in context: http://camel.465427.n5.nabble.com/How-to-handle-the-SOAP-Header-tp3200457p3206332.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to convert Camel message to soap message
If the camel message body is an inputStream, you can use the javax.xml.soap.MessageFactory to create a SOAPMessage instance for you. Willem -- View this message in context: http://camel.465427.n5.nabble.com/How-to-convert-Camel-message-to-soap-message-tp3205888p3206334.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: configure failover for weblogic jms queue using jndi template
Cool, please post your solution to the mailing list if you find a way to do this job. Willem vvchoy wrote: Hi, Thanks for your suggestion. I also find out that weblogic client (both thin and full jar) does not seem to support the single server recovery scenario (though it supports the failover scenario for multiple redundant servers. I am currently exploring the scenario of bridging between the weblogic server and my application host machine. -- View this message in context: http://camel.465427.n5.nabble.com/configure-failover-for-weblogic-jms-queue-using-jndi-template-tp2834365p3206337.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Some camel questions?
From the stack trace, I can see it's javax.xml.xpath.XPathExpressionException. So I doubt it could be you XPathExpressionException. Willem -- View this message in context: http://camel.465427.n5.nabble.com/Some-camel-questions-tp2806185p2838558.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: CXFRS consumers - is there a better way?
Current cxfbeans doesn't support to configure the provider as you do in the cxf:rsServer. I think we can introduce some kind of spring configuration to it. Please feel free to create a JIRA for it. -- View this message in context: http://camel.465427.n5.nabble.com/CXFRS-consumers-is-there-a-better-way-tp2834502p2835839.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Some camel questions?
which part is not working, and can you show us the stack trace? btw, you mail is appear in the u...@camel.apache.org. Please subscribe the mail list first. -- View this message in context: http://camel.465427.n5.nabble.com/Some-camel-questions-tp2806185p2827116.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: TypeConverters in OSGi
How did you create the camel context? camel-core-osgi is packed into camel-spring as the private package, so you don't need to deploy it into OSGi platform. Willem bstanoje wrote: Hi, since moving to camel-2.4.0 I'm not able to use the TypeConverters inside the OSGi runtime (equinox) any more. What is the camel-core-osgi actually used for, since it's not a valid OSGi bundle? Many thanks and best regards! -- View this message in context: http://camel.465427.n5.nabble.com/TypeConverters-in-OSGi-tp2802220p2805543.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Using Camel-ftp to write file with windows-1252 encoding
Did you try to set the exchange.setProperty(Exchange.CHARSET_NAME, windows-1252) like this? And I need to check your route to see if there is anything that I missed. Willem Roland Villemoes wrote: Hi I am using Camel-2.2.0 and camel-ftp-2.2.0. The issue is that i am using camel-ftp to create file on a windows FTP server and the file must be in windows-1252 :-( My code is running on a Linux server (running apache-servicemix-4.2.0-fuse-01-00). I have tried to set parameter on the endpoint to binary=true and to do someting like: byte[] origStringInBytes=sb.toString().getBytes(UTF-8); String contentInWindows1252 = new String(origStringInBytes, windows-1252); exchange.getOut().setBody(sb.toString()); Anyone having same issue? -- View this message in context: http://camel.465427.n5.nabble.com/Using-Camel-ftp-to-write-file-with-windows-1252-encoding-tp2739750p2805549.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Problem 2 when compiling sample from Camel package
I just create a JIRA[1] and committed a quick fix for it.
Please verify it in Camel 2.5.0-SNAPSHOT.
[1]https://issues.apache.org/activemq/browse/CAMEL-3010
Willem
--
Apache Camel, Apache CXF committer
Open Source Integration http://www.fusesource.com
Blog http://willemjiang.blogspot.com
Tiwtter http://twitter.com/willemjiang
benxs wrote:
I tried to compile a second example from the Camel package.
I setup Java SE 1.6 for this. Anyway it gives an error with
NoClassDefFoundError: org/springframework/asm/ClassVisitor
See below
What does the warning at the top ('includeantruntime' was not set) mean?
Thank you
Ben
C:\Camel\v2.4.0\examples\camel-example-pojo-messagingant
Buildfile: C:\Camel\v2.4.0\examples\camel-example-pojo-messaging\build.xml
build.classes:
[javac] C:\Camel\v2.4.0\examples\common_build.xml:143: warning:
'includeantruntime' was not set, defaulting to build.sysclasspath=last;
set to false for repeatable builds
build.test:
build:
run:
[java] Exception in thread main java.lang.NoClassDefFoundError:
org/springframework/asm/ClassVisitor
[java] at org.springframework.context[
main] MainSupportINFO Apache Camel 2.4.0 starting
[java]
.support.AbstractRefreshableApplicationContext.customizeBeanFactory(AbstractRefreshableApplicationContext.java:218)
[java] at
org.springframework.context.support.AbstractRefreshableApplicationContext.refreshBeanFactory(AbstractRefreshableApplicationContext.java:129)
[java] at
org.springframework.context.support.AbstractApplicationContext.obtainFreshBeanFactory(AbstractApplicationContext.java:467)
[java] at
org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:397)
[java] at
org.springframework.context.support.ClassPathXmlApplicationContext.init(ClassPathXmlApplicationContext.java:139)
[java] at
org.springframework.context.support.ClassPathXmlApplicationContext.init(ClassPathXmlApplicationContext.java:93)
[java] at
org.apache.camel.spring.Main.createDefaultApplicationContext(Main.java:219)
[java] at org.apache.camel.spring.Main.doStart(Main.java:173)
[java] at
org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:56)
[java] at
org.apache.camel.impl.MainSupport.run(MainSupport.java:114)
[java] at
org.apache.camel.impl.MainSupport.run(MainSupport.java:291)
[java] at org.apache.camel.spring.Main.main(Main.java:97)
[java] Caused by: java.lang.ClassNotFoundException:
org.springframework.asm.ClassVisitor
[java] at java.net.URLClassLoader$1.run(URLClassLoader.java:200)
[java] at java.security.AccessController.doPrivileged(Native
Method)
[java] at
java.net.URLClassLoader.findClass(URLClassLoader.java:188)
[java] at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
[java] at
sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
[java] at java.lang.ClassLoader.loadClass(ClassLoader.java:252)
[java] at
java.lang.ClassLoader.loadClassInternal(ClassLoader.java:320)
[java] ... 12 more
[java] [ Thread-0] Main$HangupInterceptor
INFO Received hang up - stopping the main instance.
[java] [ Thread-0] MainSupport
INFO Apache Camel 2.4.0 stopping
BUILD FAILED
C:\Camel\v2.4.0\examples\camel-example-pojo-messaging\build.xml:41: The
following error occurred while executing this line:
C:\Camel\v2.4.0\examples\common_build.xml:185: Java returned: 1
Total time: 1 second
C:\Camel\v2.4.0\examples\camel-example-pojo-messaging
--
View this message in context:
http://camel.465427.n5.nabble.com/Problem-2-when-compiling-sample-from-Camel-package-tp2256111p2256719.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to evaluate an expression/substitute a variable for building URI's at runtime ?
It could be much easier if you implement a DataFormat[1] yourself.
Then you could pass the CONVERT_BODY_TO_RSSURL as the message header and
tell the DataFormat to do the job for you.
[1]https://cwiki.apache.org/CAMEL/data-format.html
Willem
--
Apache Camel, Apache CXF committer
Open Source Integration http://www.fusesource.com
Blog http://willemjiang.blogspot.com
Tiwtter http://twitter.com/willemjiang
hussainpirosha wrote:
Hi ,
How can we evaluate an expression/substitute a variable for building a URI
at runtime. Consider the routes below :
// Route 1: This reads a text file containing RSS URLs and passes each
URL read to an endpoint.
from(file://c:?fileName=listOfRssUrls.txtnoop=true).process(new
Processor()
{
public void process(Exchange exchange) throws Exception {
if(logger.isInfoEnabled())
logger.info(Reading RSS URL's from file);
File rssUrlFile =
exchange.getIn().getBody(File.class);
FileInputStream fis = new
FileInputStream(rssUrlFile);
DataInputStream in = new DataInputStream(fis);
BufferedReader br = new BufferedReader(new
InputStreamReader(in));
String rssUrl = null;
ListString urlLst = new ArrayListString();
StringBuilder listOfRssUrls = new
StringBuilder();
while((rssUrl = br.readLine()) != null) {
urlLst.add(rssUrl);
listOfRssUrls.append(rssUrl).append(;);
}
exchange.getOut().setBody(listOfRssUrls);
if(logger.isInfoEnabled())
logger.info(Read number of URL's
:+urlLst.size());
}
}).split(body(String.class).tokenize(;)).to(direct:processRssUrl);
// Route 2 : This should use the URL passed in route 1 to fetch the RSS
feed. Can we convert the body to String and use it form a URI at runtime ?
or can we access some variable/header property at run time to build the
URI ?
from(direct:processRssUrl).from(rss:{CONVERT_BODY_TO_RSSURL}?splitEntries=trueconsumer.initialDelay=0consumer.delay=2).
filter().
method(feedFilterBean, titleContainsQuery).
process(new SomeProcessor());
Tried to use the
PropertyComponent(org.apache.camel.component.properties.PropertiesComponent)
available in 2.3 version but found that it substitutes the properties
while configuring the routes, not while running them.
Thanks,
Hussain
--
View this message in context:
http://camel.465427.n5.nabble.com/How-to-evaluate-an-expression-substitute-a-variable-for-building-URI-s-at-runtime-tp1618587p1657686.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Reg selective consumer for a Pub-Sub pattern
Camel has the multicast pattern[1], I think you can use it directly. BTW, you need to subscribe the users@camel.apache.org mailing list to get more quicker response. [1]http://camel.apache.org/multicast.html Willem -- Apache Camel, Apache CXF committer Open SOA http://www.fusesource.com Blog http://willemjiang.blogspot.com Tiwtter http://twitter.com/willemjiang sudheer m wrote: I want to publish messages to a group of subscribers. These messages will go so some of the consumers, but not all of them. Please help me with the camel EIP in xml for this. First Publish to One Topic and filter to different topics or queues depending on set of consumers is one of the solution for this. Any other alternative solutions for this? I am a total newbie, plss help. -- View this message in context: http://camel.465427.n5.nabble.com/Reg-selective-consumer-for-a-Pub-Sub-pattern-tp1044987p1046180.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: [CxfBinding] Document Style ?
Can I have a look at your SEI? I mean the OfferService. Does it use JAXWS annotation ? If I remember right CXF will try to use the Document-Literal Wrapped by default. Willem -- Apache Camel, Apache CXF committer Open SOA http://www.fusesource.com Blog http://willemjiang.blogspot.com Tiwtter http://twitter.com/willemjiang -- View this message in context: http://camel.465427.n5.nabble.com/CxfBinding-Document-Style-tp1045363p1045402.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: org.apache.camel.FailedToCreateProducerException Reason: java.lang.ArrayIndexOutOfBoundsException
Hi, Can you try out the latest Camel 2.4 snapshot? As Claus fixed some issues[1] relate to the direct endpoint. [1] https://issues.apache.org/activemq/browse/CAMEL-2854 Willem -- Apache Camel, Apache CXF committer Open SOA http://www.fusesource.com Blog http://willemjiang.blogspot.com Tiwtter http://twitter.com/willemjiang hiba wrote: Hello, please help me with solving the below exception. I got the following exception when i am use camel to put messages in endpoint 'direct://route3'. org.apache.camel.FailedToCreateProducerException: Failed to create Producer for endpoint: Endpoint[direct://route3]. Reason: java.lang.ArrayIndexOutOfBoundsException: 10 at org.apache.camel.impl.ProducerCache.doGetProducer(ProducerCache.java:200) at org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:133) at org.apache.camel.impl.ProducerCache.sendExchange(ProducerCache.java:160) at org.apache.camel.impl.ProducerCache.send(ProducerCache.java:98) at org.apache.camel.impl.DefaultProducerTemplate.send(DefaultProducerTemplate.java:98) at org.apache.camel.impl.DefaultProducerTemplate.sendBodyAndHeaders(DefaultProducerTemplate.java:207) at org.apache.camel.impl.DefaultProducerTemplate.sendBodyAndHeaders(DefaultProducerTemplate.java:203) at com.ettex.rialto.opendmtp.server.messageconsumer.AccountMessageListener.forwardMessageToRoute3(AccountMessageListener.java:135) at com.ettex.rialto.opendmtp.server.messageconsumer.AccountMessageListener.onMessage(AccountMessageListener.java:106) at org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1088) at org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:127) at org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:197) at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122) at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.lang.Thread.run(Unknown Source) Caused by: java.lang.ArrayIndexOutOfBoundsException: 10 at java.util.ArrayList.add(Unknown Source) at org.apache.camel.impl.DefaultCamelContext.addService(DefaultCamelContext.java:642) at org.apache.camel.impl.ProducerCache.doGetProducer(ProducerCache.java:198) ... 16 more I create the producertemplate at the start of the application and i use it to put messages.Could this be the reason? I couldnot figure out the reason for the above exception because, i get this exception sometimes and i could not replicate the scenario. Can please some one expalin me when do usually camel throw this kind of exception. Thanks in Advance Hiba -- View this message in context: http://camel.465427.n5.nabble.com/org-apache-camel-FailedToCreateProducerException-Reason-java-lang-ArrayIndexOutOfBoundsException-tp512608p653052.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: XML VALIDATION with CAMEL
How did you put the message into the activemq:SiebelOutbound2 ?
Can you make sure the message body is not null ?
Willem
--
Apache Camel, Apache CXF committer
Open SOA http://www.fusesource.com
Blog http://willemjiang.blogspot.com
Tiwtter http://twitter.com/willemjiang
ovalerio wrote:
Hi
thanx a lot. I have already tried but no way.
this is my camel.xml configuration file:
camelContext xmlns=http://camel.apache.org/schema/spring;
route id=msginbound trace=true streamCache=true
from uri=activemq:SiebelOutbound2/
doTry
to uri=validator:file:../conf/schema.xsd/
to uri=activemq:valid/
doCatch
exceptionorg.apache.camel.ValidationException/exception
to uri=activemq:invalid/
/doCatch
doFinally
to uri=activemq:finally/
/doFinally
/doTry
/route
/camelContext
i keep opn receiving the text of the message null. I don't have this issue
if i use activemq only (without camel). Any other clue?
Received message of type [class
org.apache.activemq.command.ActiveMQTextMessage] from consumer
[ActiveMQMessageConsumer { value=ID:VPC2K3SRV-2781-1278006762086-2:1:1:1,
started=true }] of session [ActiveMQSession
{id=ID:VPC2K3SRV-2781-1278006762086-2:1:1,started=true}] |
org.springframework.jms.listener.DefaultMessageListenerContainer |
DefaultMessageListenerContainer-1
2010-07-01 19:53:36,034 | DEBUG | Endpoint[activemq://SiebelOutbound2]
consumer receiving JMS message: ActiveMQTextMessage {commandId = 6,
responseRequired = false, messageId =
ID:VPC2K3SRV-1935-1278001989403-0:5:1:1:1, originalDestination = null,
originalTransactionId = null, producerId =
ID:VPC2K3SRV-1935-1278001989403-0:5:1:1, destination =
queue://SiebelOutbound2, transactionId =
TX:ID:VPC2K3SRV-1935-1278001989403-0:5:1, expiration = 0, timestamp =
1278006815162, arrival = 0, brokerInTime = 1278006815172, brokerOutTime =
1278006815943, correlationId = null, replyTo = null, persistent = true,
type = SiebelJMSMessage, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
null, marshalledProperties = null, dataStructure = null, redeliveryCounter
= 0, size = 1028, properties = null, readOnlyProperties = true,
readOnlyBody = true, droppable = false, text = } |
org.apache.camel.component.jms.EndpointMessageListener |
DefaultMessageListenerContainer-1
--
View this message in context:
http://camel.465427.n5.nabble.com/XML-VALIDATION-with-CAMEL-tp510975p653695.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Problems with SMTP
You can't use @Producer inject the template yourself. Here is the mail thread[1] that you can take a look :) [1] http://camel.465427.n5.nabble.com/Best-way-to-retrieve-a-ProducerTemplate-created-in-a-camel-bundle-OSGI-td511695.html#a511695 Willem -- Apache Camel, Apache CXF committer Open SOA http://www.fusesource.com Blog http://willemjiang.blogspot.com Tiwtter http://twitter.com/willemjiang unixployd wrote: Problem is solved. Correctly configured message in Processor using setHeader and setBody. Now it sends successfully. Seems like using @Produce somehow correctly resolves endpoint uri and configures it, but in route case it need to be configured explicitly. -- View this message in context: http://camel.465427.n5.nabble.com/Problems-with-SMTP-tp512137p654358.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Instance is not consuming any messages
How did you setup your activemq connection ? It looks like the connection can't reconnect after long time running. Willem -- Apache Camel, Apache CXF committer Open SOA http://www.fusesource.com Blog http://willemjiang.blogspot.com Tiwtter http://twitter.com/willemjiang Sri wrote: HI, I have create an processor to consume the messages from queue. And I have created 4 instances of these processors to consume the messages. But I realised after some time, say 2 or 3 days , some instances (say 2 ) are not consuming the messages from the respective queue and there are no message even in the log. when I saw it on the server the instances are still runinng ( I mean by ps -ef | grep ). But on the activemq , I can see the consumers number comes down to 2 and the other 2 instances are not consuming any messages. is there any wayto find out why the instances stopped consuming the message even though the processors are still running is the context is dying after sometime?. can context.setAutoStartup(true) will make it work in that case? can any body help me on this? Regards Sri -- View this message in context: http://camel.465427.n5.nabble.com/Instance-is-not-consuming-any-messages-tp512624p655127.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Resequence Stream ConcurrentModificationException
Which version of Camel are you using ? I just assume you are using Camel 2.3.0, as Claus did lots of work on Camel trunk, the stack trace can't match with current trunk code. If I remember right , there is a timer thread to keep try redelivering the exchange, maybe that cause the ConcurrentModificationException. Can try to run your application with Camel 2.4-SNAPSHOT ? If the error still there, you can fill a JIRA and submit a small test case, so we can keep on digging it. Willem -- Apache Camel, Apache CXF committer Open SOA http://www.fusesource.com Blog http://willemjiang.blogspot.com Tiwtter http://twitter.com/willemjiang Ryan R. wrote: I have the following route defined in camel: from(jms:queue:syncTopic).process(new ResequenceProcessorStageOne(syncSession)).throttle(10).resequence(header(messageOrder)).stream().capacity(1000).timeout(100L).unmarshal(format).to(trex); I am getting the below exception whenever I add in the resequencer? Any thoughts as to what may be causing this? Does the jms-component need to be configured to act as a single threaded listener? The reason I have a resequencer hooked up to ActiveMQ is because of the following bug: https://issues.apache.org/activemq/browse/AMQ-2780 [hread 0 - Resequencer Delivery] DefaultErrorHandlerERROR Failed delivery for exchangeId: ID:RSI-KAU-RROLND-4962-1278128211066-0:0:1:1:59. Exhausted after delivery attempt: 1 caught: java.util.ConcurrentModificationException java.util.ConcurrentModificationException at java.util.HashMap$HashIterator.nextEntry(HashMap.java:793) at java.util.HashMap$KeyIterator.next(HashMap.java:828) at org.apache.camel.util.CaseInsensitiveMap.putAll(CaseInsensitiveMap.java:86) at org.apache.camel.component.jms.JmsMessage.copyFrom(JmsMessage.java:77) at org.apache.camel.processor.UnmarshalProcessor.process(UnmarshalProcessor.java:49) at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67) at org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:53) at org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:82) at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:97) at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67) at org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:185) at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:151) at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:89) at org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49) at org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:228) at org.apache.camel.processor.Pipeline.process(Pipeline.java:75) at org.apache.camel.processor.StreamResequencer.sendElement(StreamResequencer.java:165) at org.apache.camel.processor.StreamResequencer.sendElement(StreamResequencer.java:61) at org.apache.camel.processor.resequencer.ResequencerEngine.deliverNext(ResequencerEngine.java:254) at org.apache.camel.processor.resequencer.ResequencerEngine.deliver(ResequencerEngine.java:218) at org.apache.camel.processor.StreamResequencer$Delivery.run(StreamResequencer.java:212) MessageID Out of Order: 59!=58 -- View this message in context: http://camel.465427.n5.nabble.com/Resequence-Stream-ConcurrentModificationException-tp524555p656523.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: JMS Selector - Inconsitent
How did your start the route? Did you set up the transaction option on your activemq component ? Willem -- Apache Camel, Apache CXF committer Open SOA http://www.fusesource.com Blog http://willemjiang.blogspot.com Tiwtter http://twitter.com/willemjiang VikasG wrote: Hi, I wrote the following route to remove/consume a particular message from the queue when header i.e. sender is equal to the provided value. from(activemq:queue: + from +?selector=sender=' + sender + ').to(activemq:queue:Q4); Now, the issues are: 1. Inconsistency while removing messages from queue like sometimes removes all or sometimes 2-3 out of 4 valid messages in queue. 2. Not forwarding messages to other specified queue i.e. Q4. Am i missing something? Please guide. -Vikas -- View this message in context: http://camel.465427.n5.nabble.com/JMS-Selector-Inconsitent-tp512311p512594.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Problems with SMTP
The Builder's configure() method is called when camel context start.
At this time if the there is no message in the test.queue, camel will not
send message to the smtp server.
Did you try to put some message into queue to see if the message is send to
the smtp server ?
Willem
--
Apache Camel, Apache CXF committer
Open SOA http://www.fusesource.com
Blog http://willemjiang.blogspot.com
Tiwtter http://twitter.com/willemjiang
unixployd wrote:
I tried to use Java DSL to configure my route from Active MQ to SMTP.
That is the code:
public void configure() {
String url =
smtp://u...@domain.com?password=passwordto=r...@domain.comdebugMode=true;
from(activemq:queue:test.queue?concurrentConsumers=20).process(new
QueueSmtpProcessor()).to(url);
}
I can't send emails.
But if I use Injection @Produce and create own producer when I get what I
need.
@Produce
ProducerTemplate prod;
public void configure() {
String url =
smtp://u...@domain.com?password=passwordto=r...@domain.comdebugMode=true;
from(activemq:queue:test.queue?concurrentConsumers=20).process(new
QueueSmtpProcessor());
prod.sendBody(body());
System.out.println(Message is sent);
}
Basing on Camel manuals I see that smtp Endpoint should successfully
create Producer and handle all the stuff.
What can be the problem?
--
View this message in context:
http://camel.465427.n5.nabble.com/Problems-with-SMTP-tp512137p512599.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: how to output message into end of the same file that is created by FILE component
You can add this option in your file endpoint fileExist=Append BTW, please take some time to read the wiki page of camel file[1] [1]http://camel.apache.org/file2.html Willem -- Apache Camel, Apache CXF committer Open SOA http://www.fusesource.com Blog http://willemjiang.blogspot.com Tiwtter http://twitter.com/willemjiang StonePeng wrote: my simple use case is from direct:start to file ,but FILE component creates a new file every time. i want to output message from direct:start into end of the same file that is created by FILE component, how to set FILE component? here is my route XML: from uri=direct:start/ to uri=file:outbox?fileName=a.txt/ -- View this message in context: http://camel.465427.n5.nabble.com/how-to-output-message-into-end-of-the-same-file-that-is-created-by-FILE-component-tp509811p512603.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Apache Camel 2.3.0 - required property bundleContext has not been set
Hi, You can't just run the OSGi service with below command mvn -e compile exec:java -PCamelServer You need to deploy your bundle into OSGi plate form, or use some other OSGi test tool like PaxExam to run. Willem -- Apache Camel, Apache CXF committer Open SOA http://www.fusesource.com Blog http://willemjiang.blogspot.com Tiwtter http://twitter.com/willemjiang Mpizo wrote: Hi, I am having trouble setting up OSGI services to run in the Apache Camel Server. I am using Apache Camel 2.3.0. Below is my spring config file, pom.xml and the stacktrace that i am using in my project. Please help. --CAMEL-SERVER.XML-- ?xml version=1.0 encoding=UTF-8? !-- Configures the Camel Context-- beans xmlns=http://www.springframework.org/schema/beans; xmlns:xsi=http://www.w3.org/2001/XMLSchema-instance; xmlns:context=http://www.springframework.org/schema/context; xmlns:camel=http://camel.apache.org/schema/spring; xmlns:amq=http://activemq.apache.org/schema/core; xmlns:osgi=http://www.springframework.org/schema/osgi; xsi:schemaLocation= http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring-2.3.0.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/activemq-core-5.3.2.xsd http://camel.apache.org/schema/osgi http://camel.apache.org/schema/osgi/camel-osgi-2.3.0.xsd http://www.springframework.org/schema/osgi http://www.springframework.org/schema/osgi/spring-osgi.xsd !-- let Spring do its IoC stuff in this package -- context:component-scan base-package=com.reedhousesystems.routing / !-- declare a camel context that scans for classes that is RouteBuilder in the package com.reedhousesystems.routing -- camel:camelContext id=camel camel:packagecom.reedhousesystems.routing/camel:package !-- enable JMX connector so we can connect to the server and browse mbeans -- !-- Camel will log at INFO level the service URI to use for connecting with jconsole -- camel:jmxAgent id=agent createConnector=true / /camel:camelContext !-- This creates an embedded ActiveMQ Broker -- bean id=broker class=org.apache.activemq.xbean.XBeanBrokerService property name=transportConnectorURIs list valuetcp://localhost:61610/value /list /property property name=useJmx value=false/ property name=persistent value=false/ /bean !-- Lets connect the Camel ActiveMQ component to the embedded broker. See http://camel.apache.org/activemq.html for more information. -- bean id=jms class=org.apache.activemq.camel.component.ActiveMQComponent property name=brokerURL value=tcp://localhost:61610 / /bean bean id=genericMessagingService class=com.reedhousesystems.routing.MessageServiceImpl /bean osgi:service ref=genericMessagingService osgi:interfaces valuecom.reedhousesystems.routing.GenericMessagingService/value /osgi:interfaces /osgi:service /beans ---POM.XML--- ?xml version=1.0 encoding=UTF-8? project xmlns=http://maven.apache.org/POM/4.0.0; xmlns:xsi=http://www.w3.org/2001/XMLSchema-instance; xsi:schemaLocation=http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd; modelVersion4.0.0/modelVersion groupIdcom.reedhousesystems/groupId artifactIdjms/artifactId packagingbundle/packaging version0.0.1-SNAPSHOT/version nameA Camel Route/name urlhttp://www.myorganization.org/url descriptionAn example using Spring XML to talk to the JMS server from different kind of client techniques and having AOP aspect to perform audit trails in the Camel Server /description properties camel.osgi.export.pkgorg.apache.camel.example.server.*/camel.osgi.export.pkg camel.osgi.import.additionalorg.apache.activemq.xbean,org.apache.activemq.broker,org.apache.activemq.pool/camel.osgi.import.additional camel-version2.3.0/camel-version activemq-version5.3.2/activemq-version xbean-spring-version3.6/xbean-spring-version
