Re: deleting jms queue
So back to the question about how to delete them :-) On 09/06/2015 07:54, Claus Ibsen wrote: Yes then you should use regular queues. On Tue, Jun 9, 2015 at 8:47 AM, Tim Dudgeon wrote: Well, maybe I'm wrong to call it a temp queue. This is not an InOut pattern. Its InOnly followed (potentially much later) by a response to a "private" queue (specified by JmsReplyTo header) that is InOnly and handled by a different route/consumer. Once processing is complete I need the queue to be deleted. Tim On 09/06/2015 07:07, Claus Ibsen wrote: Hi Afair temp queues are affilianted with the jms session and automatic deleted by the broker when the session is closed - eg AMQ should do this. On Mon, Jun 8, 2015 at 5:31 PM, Tim Dudgeon wrote: I'm using a temp JMS queue to return some results. Once I've finished processing I want to delete the queue. What's the best approach? I'm assuming its best to manually generate the temp queue at the start and then manually delete it when finished. I notice I could use JmsTemporaryQueueEndpoint [1] which I know how to get hold of, and that can give me the javax.jms.TemporaryQueue, which I can then delete(), but how to get a handle on the javax.jms.Session session? Or is there a better way? Thanks Tim [1] http://camel.apache.org/maven/current/camel-jms/apidocs/org/apache/camel/component/jms/JmsTemporaryQueueEndpoint.html [2] http://docs.oracle.com/javaee/7/api/javax/jms/TemporaryQueue.html
Re: Manage CorrelationID using JMS endpoint options
Can you check camel jms docs for option called useMessageIDAsCorrelationID.
Am not sure if this might serve the purpose.
Cheers
Reji
On Tue, Jun 9, 2015 at 10:35 AM, Gnanaguru S wrote:
> Hi All,
>
> I have a camel route, which takes messages from a jms queue and further
> sends it down to a splitter. Further the responses are aggregated and sent
> back to a response queue. (of course response queue is controller by the
> client in this scenario )
>
> In this scenario I had to manually handle client's correlation id, because
> after aggregation the original correlation id will be obvious lost. Can we
> add a jms option to handle this scenario ?
>
> At the moment I am having this logic which manually reverts the original
> correlation id.
>
>
>
> uri="jms:queue:Gateway-Queue?replyToDeliveryPersistent=false" />
>
>
> propertyName="parkedClientCorrelationId">${headers.JMSCorrelationID}
>
>
>
>
>
>
> headerName="JMSCorrelationID">${property.parkedClientCorrelationId}
>
> propertyName="parkedClientCorrelationId" />
>
>
>
>
> Cheers
> Guru
> @tallguru
>
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Manage-CorrelationID-using-JMS-endpoint-options-tp5767995.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
simple language for filters on values of HTTP headers
Hi All,
in a camel route starting with a Jetty endpoint,
I want to enable gzipping if the input sends the http header:
"Accept-Encoding: gzip"
However, the Accept-Encoding may have multiple comma separated values for
different encoding accepted, typical it is
Accept-Encoding: gzip, deflate
As the values are comma separated, I thought about a filter like this to be
fine (xml dsl):
'gzip' in ${header[Accept-Encoding]}
... do gizipping ...
the problem is that it works with a header value of "gzip, deflate" but it
won't work for a header value for example of "compress, deflate, exi, gzip,
identity", because the token split by in operator is ' gzip', (note the
extra space in front of it.
Do you have any suggestion to better handle this "dilemma" :-) ?
FYI I'm reverting to use:
${header[Accept-Encoding]} contains 'gzip'
... do gizipping ...
but using "in" would seem cleaner to me...
Thanks,
Cristiano
XSL stylesheet from database
Hello! Could you show me the most convenient way of using XSL stylesheets loaded from database (or other dynamic sources) with xslt endpoint? I have already noted technique of using http endpoint, but can it be the only way? Thank you in advance! -- View this message in context: http://camel.465427.n5.nabble.com/XSL-stylesheet-from-database-tp5768011.html Sent from the Camel - Users mailing list archive at Nabble.com.
Transactional Client in Camel
Hi, Wanted some clarity on the usage of Transactional Client In situation like below Considering the above route does the transaction span from the getting the message from the inputQueue till the message is posted on to outputQueue ? and would any issue/exception raised during processing trigger rollback of message to the inputqueue ? Please let me know incase any further details are required Regards, -Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/Transactional-Client-in-Camel-tp5768012.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: XSL stylesheet from database
Anything you wanna populate on "to uri=" endpoints can be achieved using recepientList EIP. Check out http://camel.apache.org/how-to-use-a-dynamic-uri-in-to.html Cheers Reji - Reji Mathews Sr. Developer - Middleware Integration / SOA ( Open Source - Apache Camel & Jboss Fuse ESB | Mule ESB ) LinkedIn - http://in.linkedin.com/pub/reji-mathews/31/9a2/40a Twitter - reji_mathews -- View this message in context: http://camel.465427.n5.nabble.com/XSL-stylesheet-from-database-tp5768011p5768014.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: deleting jms queue
Hello, Depends on the support provided by the JMS Provider for deleting... for e.g. in AMQ you can use JMX to delete the queue Regards, -Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/deleting-jms-queue-tp5767981p5768013.html Sent from the Camel - Users mailing list archive at Nabble.com.
RE: JMS MQ performance improvement
Hello, you could try followign things 1. As as transacted is false you can try removing transactionManager which is being set 2. for try setting the cacheLevelName to CACHE_CONSUMER or CACHE_SESSION for higher throughput 3. Enable asyncConsumer if async processing of exchanges is acceptible Regards, -Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/JMS-MQ-performance-improvement-tp5767963p5768016.html Sent from the Camel - Users mailing list archive at Nabble.com.
Is there a tools to convert java dsl to xml ?
hi team,
Is there a tools to convert java dsl to xml ?
Is every java dsl code have a equal xml counterpart?
When I am reading the camel document's , there are many snippets code that
writen by java dsl .
As a new user , sometimes I have to use xml instead of java dsl .
In fact , I want to know how could I convert the below code to xml
from("direct:start")
.setHeader("decisionSlip").method(OrderProcessorBean.class,
"calculateRoute")
.routingSlip("decisionSlip");
thanks.
--
View this message in context:
http://camel.465427.n5.nabble.com/Is-there-a-tools-to-convert-java-dsl-to-xml-tp5768015.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Too many connection in TIME_WAIT when tempfilename is set in the FTP producer URI.
So many connections remain in TIME_WAIT state while configuring a FTP producer route with tempfilename property in FTP producer. I am using *Producertemplate.sendBodyAndHeader(producerURI, Exchange.FILE_NAME, fileName)* to write file to destination. *Producer URI* : ftp:?password=RAW(PASSWORD)&binary=true&*passiveMode=false*&delete=true&pollStrategy=#ConsumerPollStrategy&*disconnect=false*&*tempFileName=/temp/hello.tmp*&initialDelay=10&throwExceptionOnConnectFailed=true&reconnectDelay=10&maximumReconnectAttempts=0&maxMessagesPerPoll=100&readLock=changed&readLockCheckInterval=500&readLockMinLength=1&sendEmptyMessageWhenIdle=true *fileName*: "file.tmp". We are writing ~ 2000 files . First files are written to temp directory then moved to destination. Connections opened for tempfiles are not re used to write temporary files and we run out of connection after writing 1000 files. Route resumes once connections are released. Is there a way we can reuse connection to write temporary files also. -- View this message in context: http://camel.465427.n5.nabble.com/Too-many-connection-in-TIME-WAIT-when-tempfilename-is-set-in-the-FTP-producer-URI-tp5768017.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: XSL stylesheet from database
I might be wrong, but recepientList EIP deals just with dynamic uri
construction (i.e. dynamic endpoint selection, uri parameters setting etc.),
isn't it?
As to my question, I would like to know, is there any way to make xslt
endpoint use xsl stylesheet body (not just filename, but body itself as
String or DOM) not only from file or uri location, but from ${body} of
another endpoint or from some header (like CamelVelocityTemplate), or
something else?..
For now I see the only appropriate way in creating another route started
from http endpoint and returning ${body} with xsl inside...
--
View this message in context:
http://camel.465427.n5.nabble.com/XSL-stylesheet-from-database-tp5768011p5768018.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Queue and database transaction, rollback?
Hi,
I don't understand how this is supposed to work, because it does simply not.
onException(StoreDataException.class)
.useOriginalMessage()
.handled(true)
.to(errorQueue)
.markRollbackOnly()
;
Since it's rollbacking, it rollbacks the message to the incoming queue and
not the errorQueue, which reads it again. Chaos.
How can this be handled better?
I'm deploying in liberty profile, and when I'm committing the message to a
queue I want to commit the sql update as well.
One of my thoughts were using "PROPAGATION_REQUIRES_NEW", so when calling my
bean which calls the database, I'm using that inside an own transaction.
Which will be the only one which rollbacks, and then I can send the message
to the error queue as normal.
But when using "PROPAGATION_REQUIRES_NEW" I get "JtaTransactionManager needs
a JTA TransactionManager for suspending a transaction: specify the
'transactionManager' or 'transactionManagerName' property". I do not get
this error with "PROPAGATION_REQUIRED"
private JmsComponent mqComponentTransacted(InitialContext context, String
connectionFactoryJndiName, String userTransactionJndiName) throws
JMSException, NamingException {
LOG.info("Setting up JmsComponent using jndi lookup");
UserTransaction userTransaction = (UserTransaction)
context.lookup(userTransactionJndiName);
final JtaTransactionManager jtaTransactionManager = new
JtaTransactionManager(userTransaction);
final ConnectionFactory connectionFactory = (ConnectionFactory)
context.lookup(connectionFactoryJndiName);
final JmsComponent jmsComponent =
JmsComponent.jmsComponentTransacted(connectionFactory,
(PlatformTransactionManager) jtaTransactionManager);
jmsComponent.setTransacted(false);
jmsComponent.setCacheLevel(DefaultMessageListenerContainer.CACHE_NONE);
context.bind("userTransaction", userTransaction);
context.bind("transactionManager", jtaTransactionManager);
SpringTransactionPolicy propReq = new SpringTransactionPolicy();
propReq.setTransactionManager((PlatformTransactionManager)
jtaTransactionManager);
propReq.setPropagationBehaviorName("PROPAGATION_REQUIRED");
context.bind("PROPAGATION_REQUIRED", propReq);
SpringTransactionPolicy propReqNew = new SpringTransactionPolicy();
propReqNew.setTransactionManager((PlatformTransactionManager)
jtaTransactionManager);
propReqNew.setPropagationBehaviorName("PROPAGATION_REQUIRES_NEW");
context.bind("PROPAGATION_REQUIRES_NEW", propReqNew);
return jmsComponent;
}
--
View this message in context:
http://camel.465427.n5.nabble.com/Queue-and-database-transaction-rollback-tp5768020.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Queue and database transaction, rollback?
I guess the easiest would be if it could actually just rollback to a defined DLQ, but how? -- View this message in context: http://camel.465427.n5.nabble.com/Queue-and-database-transaction-rollback-tp5768020p5768021.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: https4 2.15.2 not recognizing my httpClientConfigurer endpoint option
I just checked the code of your HttpClientconfigurer, you didn’t set the
httpClientBuilder with the SSLConnectionSocketFactory instance that you just
created.
--
Willem Jiang
Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.iteye.com (Chinese)
Twitter: willemjiang
Weibo: 姜宁willem
On June 6, 2015 at 5:48:31 AM, jspyeatt (john.pye...@singlewire.com) wrote:
> Like several similar posts I've seen I need to allow self-signed certs for
> https4 (2.15.2). Mine isn't working.
>
> I've created an implementation of HttpClientConfigurer that allows any
> host/cert. Below is the implementation of configureHttpClient().
>
> @Override
> public void configureHttpClient(HttpClientBuilder httpClientBuilder) {
> log.debug("configureHttpClient()");
> try {
> SSLContextBuilder builder = new SSLContextBuilder();
> builder.loadTrustMaterial(null, new TrustSelfSignedStrategy() {
> @Override
> * public boolean isTrusted(X509Certificate[] a, String b)
> throws CertificateException {
> log.debug("isTrusted() returns true");
> return true;
> }*
> });
>
> SSLContext sslContext = builder.build();
>
> SSLConnectionSocketFactory sslsf = new
> SSLConnectionSocketFactory(sslContext, new
> TrustEverythingHostnameVerifier());
> } catch (Exception e) {
> log.error(e,e);
> throw new IllegalStateException("Unable to configure
> TrustingHttpClientConfigurer", e);
> }
> }
>
>
> Then in an implementation of CameltestSupport I've overridden
> createRegistry().
> @Override
> protected JndiRegistry createRegistry() throws Exception {
> JndiRegistry jndi = super.createRegistry();
> log.info("createRegistry()");
>
> *jndi.bind("MyConfigurer", new TrustingHttpClientConfigurer());*
> Object o =
> jndi.lookup(TrustingHttpClientConfigurer.HTTP_CLIENT_CONFIGURER);
> log.debug("object type: " + o.getClass().getCanonicalName());
> return jndi;
> }
>
> Then in my createRouteBuilder() it contains...
>
> return new RouteBuilder() {
> public void configure() {
>
> log.debug("CONFIGURE");
> *
> HttpComponent httpComponent = context.getComponent("https4",
> HttpComponent.class);
> httpComponent.setHttpClientConfigurer(new
> TrustingHttpClientConfigurer());
>
> log.info("CCC " +
> context.getRegistry().lookupByName("MyConfigurer"));
>
> from("direct:start").transform(simple("FRED")).to("https4://172.30.253.94:8444/services?httpClientConfigurer=#MyConfigurer";*
>
> }
> };
>
> public void testSimple() throws Exception {
> HttpComponent comp =
> template.getCamelContext().getComponent("https4", HttpComponent.class);
> * log.info("DDD " +
> comp.getHttpClientConfigurer().getClass().getCanonicalName());*
> template.sendBody("direct:start", "FRED");
>
> }
>
> When the test runs I do get
> *DDD com.singlewire.monte.eh.config.TrustingHttpClientConfigurer* which is
> what I would expect.
>
> However test is failing with the obligatory
> javax.net.ssl.SSLHandshakeException. This is what I would expect given that
> the component isn't calling my version of isTrusted(X509Certificate[] a,
> String b) created during TrustingHttpClientConfigurer.configureHttpClient().
> I know this because I never see the debug message indicating that it was
> called.
>
>
> So it's as if during execution of my route the configurator is being
> ignored.
>
> I've tried ?httpClientConfigurer=#MyConfigurer
> I've tried ?httpClientConfigurer=MyConfigurer
>
> I've tried forcing things like this.
> HttpComponent httpComponent = context.getComponent("https4",
> HttpComponent.class);
> httpComponent.setHttpClientConfigurer(new TrustingHttpClientConfigurer());
>
> Nothing seems to work. Any guidance would be greatly appreciated.
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/https4-2-15-2-not-recognizing-my-httpClientConfigurer-endpoint-option-tp5767922.html
>
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
Re: Is there a tools to convert java dsl to xml ?
I also am a new user and tend to like XML. Maybe that will change as I get
used to Camel.
I don't know of any automated way, but you can get edit access to camel and
make the changes yourself:
http://camel.apache.org/how-do-i-edit-the-website.html
Dan
On Tue, Jun 9, 2015 at 3:11 AM, cloud wrote:
> hi team,
>
> Is there a tools to convert java dsl to xml ?
> Is every java dsl code have a equal xml counterpart?
>
> When I am reading the camel document's , there are many snippets code that
> writen by java dsl .
>
> As a new user , sometimes I have to use xml instead of java dsl .
>
> In fact , I want to know how could I convert the below code to xml
>
> from("direct:start")
> .setHeader("decisionSlip").method(OrderProcessorBean.class,
> "calculateRoute")
> .routingSlip("decisionSlip");
>
>
> thanks.
>
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Is-there-a-tools-to-convert-java-dsl-to-xml-tp5768015.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
Re: Is there a tools to convert java dsl to xml ?
I'm the opposite. I avoid XML, and use Java DSL exclusively. I really like
the way it reads, and easy to test using camel test
On Tue, Jun 9, 2015 at 10:48 AM Dan Moore wrote:
> I also am a new user and tend to like XML. Maybe that will change as I get
> used to Camel.
>
> I don't know of any automated way, but you can get edit access to camel and
> make the changes yourself:
> http://camel.apache.org/how-do-i-edit-the-website.html
>
> Dan
>
> On Tue, Jun 9, 2015 at 3:11 AM, cloud wrote:
>
> > hi team,
> >
> > Is there a tools to convert java dsl to xml ?
> > Is every java dsl code have a equal xml counterpart?
> >
> > When I am reading the camel document's , there are many snippets code
> that
> > writen by java dsl .
> >
> > As a new user , sometimes I have to use xml instead of java dsl .
> >
> > In fact , I want to know how could I convert the below code to xml
> >
> > from("direct:start")
> > .setHeader("decisionSlip").method(OrderProcessorBean.class,
> > "calculateRoute")
> > .routingSlip("decisionSlip");
> >
> >
> > thanks.
> >
> >
> >
> >
> >
> > --
> > View this message in context:
> >
> http://camel.465427.n5.nabble.com/Is-there-a-tools-to-convert-java-dsl-to-xml-tp5768015.html
> > Sent from the Camel - Users mailing list archive at Nabble.com.
> >
>
Re: Is there a tools to convert java dsl to xml ?
Hi,
cloud wrote
> Is there a tools to convert java dsl to xml ?
No, although you can see an XML representation of a route defined in any DSL
(Java, XML, Groovy, Scala etc.) by calling a method called dumpRouteAsXml()
when looking at it though JMX.
cloud wrote
> Is every java dsl code have a equal xml counterpart?
>
> When I am reading the camel document's , there are many snippets code that
> writen by java dsl .
>
> As a new user , sometimes I have to use xml instead of java dsl .
Yes it does. A good reference (shameless self-promotion) is the Apache Camel
Developer's Cookbook - it contains examples of every DSL element in both the
Java and XML DSLs.
cloud wrote
> In fact , I want to know how could I convert the below code to xml
>
> from("direct:start")
> .setHeader("decisionSlip").method(OrderProcessorBean.class,
> "calculateRoute")
> .routingSlip("decisionSlip");
decisionSlip
Hope that helps.
Jakub
--
View this message in context:
http://camel.465427.n5.nabble.com/Is-there-a-tools-to-convert-java-dsl-to-xml-tp5768015p5768023.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Is there a tools to convert java dsl to xml ?
I should also say that there is a runtime tool that allows you to see the XML of running routes - HawtIO (http://hawt.io). Jakub -- View this message in context: http://camel.465427.n5.nabble.com/Is-there-a-tools-to-convert-java-dsl-to-xml-tp5768015p5768024.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel Restlet
Hi Reji, contactreji wrote > Suppose I hit the endpoint with * > http://localhost:8181/cars/100?color=red&model=2015 * > with a http GET method, how do I access the * > color=red * > data in camel exchange. where does it get stored? HTTP consumer endpoints such as Jetty (and I am guessing therefore Restlet as well) put the URI parameters directly into exchange headers. So to access the color, all you have to do is something like: Jakub -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Restlet-tp5767988p5768022.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Is there a tools to convert java dsl to xml ?
Hi
At runtime you can output any Camel route as xml, there is api on
camel context or jmx api to do so.
This is what tooling such as the camel commands / hawtio etc uses to
visualize the running routes.
On Tue, Jun 9, 2015 at 11:11 AM, cloud wrote:
> hi team,
>
> Is there a tools to convert java dsl to xml ?
> Is every java dsl code have a equal xml counterpart?
>
> When I am reading the camel document's , there are many snippets code that
> writen by java dsl .
>
> As a new user , sometimes I have to use xml instead of java dsl .
>
> In fact , I want to know how could I convert the below code to xml
>
> from("direct:start")
> .setHeader("decisionSlip").method(OrderProcessorBean.class,
> "calculateRoute")
> .routingSlip("decisionSlip");
>
>
> thanks.
>
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Is-there-a-tools-to-convert-java-dsl-to-xml-tp5768015.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
--
Claus Ibsen
-
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
hawtio: http://hawt.io/
fabric8: http://fabric8.io/
Re: https4 2.15.2 not recognizing my httpClientConfigurer endpoint option
My class that implements HttpClientConfigurer now looks like this from your suggestions: and it still doesn't work. My createRegistry() looks like this: @Override I added a jndi.properties file that looks like this: My uri now looks like this https4://172.30.228.23:8444/InformaCast/RESTServices/V1/Admin/System/ldap/isLdapConfigured?x509HostnameVerifier=*allHostnameVerifier*&httpClientConfigurer=*monteTrustingConfigurer* So I thought I now have all of my ducks in a row. But my sslContext created in configureHttpClient() still isn't calling my isTrusted() method. There must be something I'm still missing for the HttpComponent that isn't matching the uri arguments for x509HostnameVerifier and httpClientConfigurer to my registry. I've done a deep dive into the source code of HttpComponent.java with a debugger. when coming out of createEndpoint() in the source code the endpoint variable appears to at least partially be configured correctly. endpoint.endpointUri="https4://172.30.228.23:8444/InformaCast/RESTServices/V1/Admin/System/ldap/isLdapConfigured?httpClientConfigurer=monteTrustingConfigurer&x509HostnameVerifier=allHostnameVerifier" endpoint.httpClientConfigurer is set to an instance of my class that implements the above configureHttpClient(), TrustingHttpClientConfigurer. endpoint.*component*.httpClientConfigurer is null (which might be OK if it's only used as the default) endpoint.*component*.x509HostnameVerifier is set to BROWSER_COMPATIBLE (this isn't what I want, but again, may just be a default). But I don't see my override value org.apache.http.conn.ssl.AllowAllHostnameVerifier() Now looking at endpoint.camelContext.registry endpoint.camelContext.registry.context.delegate.defaultInitCtx.bindings.0 monteTrustingConfigurer = instance of TrustingHttpClientConfigurer endpoint.camelContext.registry.context.delegate.defaultInitCtx.bindings.1 java.naming.factory.initial = org.apache.camel.util.jndi.CamelInitialContextFactory endpoint.camelContext.registry.context.delegate.defaultInitCtx.bindings.2 allHostnameVerifier = ALLOW_ALL Does anyone see what other little nuggets of knowledge I'm missing? -- View this message in context: http://camel.465427.n5.nabble.com/https4-2-15-2-not-recognizing-my-httpClientConfigurer-endpoint-option-tp5767922p5768038.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel Restlet
Not sure how much this will help, but you can always do this ${headers}.
Which will print all the headers available for you !
Cheers
Guru
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-Restlet-tp5767988p5768043.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: is there a way to change the default properties of a camel component?
One way is to extend the component and the default the configuration value to what you want it to be. Regards, -Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/is-there-a-way-to-change-the-default-properties-of-a-camel-component-tp5767985p5768045.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Transactional Client in Camel
any one used transactions before with jms ? did that span across routes or was limited to the route in which it was started ? Regards, -Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/Transactional-Client-in-Camel-tp5768012p5768044.html Sent from the Camel - Users mailing list archive at Nabble.com.
Camel FTP2 component throws inputstream closed Exception
I am facing issue when I tried to transfer large files through SFTP. 2015-06-04 05:08:19,200 [ax070.abc.com:22//tmp/]] WARN SftpConsumer - Consumer Consumer[sftp://devs...@appax070.target.com:22//tmp/?fileName=sftp_app_wap_trans_test.xlsx&password=xx&stepwise=false&throwExceptionOnConnectFailed=true] failed polling endpoint: Endpoint[sftp://a...@appax070.abc.com:22//tmp/?fileName=sftp_app_wap_trans_test.xlsx&password=xx&stepwise=false&throwExceptionOnConnectFailed=true]. Will try again at next poll. Caused by: [org.apache.camel.component.file.GenericFileOperationFailedException - Cannot connect to sftp://devs...@appax070.target.com:22] org.apache.camel.component.file.GenericFileOperationFailedException: Cannot connect to sftp://a...@appax070.abc.com:22 at org.apache.camel.component.file.remote.SftpOperations.connect(SftpOperations.java:143) at org.apache.camel.component.file.remote.RemoteFileConsumer.connectIfNecessary(RemoteFileConsumer.java:154) at org.apache.camel.component.file.remote.RemoteFileConsumer.recoverableConnectIfNecessary(RemoteFileConsumer.java:145) at org.apache.camel.component.file.remote.RemoteFileConsumer.prePollCheck(RemoteFileConsumer.java:55) at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:106) at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:187) at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:114) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:351) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:781) Caused by: com.jcraft.jsch.JSchException: java.io.IOException: inputstream is closed at com.jcraft.jsch.ChannelSftp.start(ChannelSftp.java:315) at com.jcraft.jsch.Channel.connect(Channel.java:152) at org.apache.camel.component.file.remote.SftpOperations.connect(SftpOperations.java:127) ... 14 more Caused by: java.io.IOException: inputstream is closed at com.jcraft.jsch.ChannelSftp.fill(ChannelSftp.java:2871) at com.jcraft.jsch.ChannelSftp.header(ChannelSftp.java:2895) at com.jcraft.jsch.ChannelSftp.start(ChannelSftp.java:262) ... 16 more Can anyone help on this issue. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-FTP2-component-throws-inputstream-closed-Exception-tp5768036.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Transactional Client in Camel
You can span routes if it happens synchronously (same thread) that is using direct:endpoint between them 10. jun. 2015 07.31 skrev "yogu13" : > any one used transactions before with jms ? did that span across routes or > was limited to the route in which it was started ? > > Regards, > -Yogesh > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/Transactional-Client-in-Camel-tp5768012p5768044.html > Sent from the Camel - Users mailing list archive at Nabble.com. >
Re: is there a way to change the default properties of a camel component?
Hi Sometimes a component allows to configure an option on the component level, that endpoints inherited by default. But its not all components that can do that. And to configure options on components you need to create an instance of it, and configure it the usual java / xml way. On Wed, Jun 10, 2015 at 5:58 AM, yogu13 wrote: > One way is to extend the component and the default the configuration value to > what you want it to be. > > Regards, > -Yogesh > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/is-there-a-way-to-change-the-default-properties-of-a-camel-component-tp5767985p5768045.html > Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen hawtio: http://hawt.io/ fabric8: http://fabric8.io/
