set encoder in netty exception
bean id=myencoder
class=org.jboss.netty.handler.codec.string.StringEncoder/
my code like:
ApplicationContext appctx =
new
ClassPathXmlApplicationContext(/org/apache/camel/component/netty/test-codecs.xml);
Object decoder = appctx.getBean(mydecoder);
Object encoder = appctx.getBean(myencoder);
SimpleRegistry registry = new SimpleRegistry();
registry.put(myDecoder, decoder);
registry.put(myEncoder, encoder);
CamelContext context = new DefaultCamelContext(registry);
context.addRoutes(new RouteBuilder() {
public void configure() throws Exception {
from(direct:cpsp)
.process(new MyToProcessor())
.to(netty:tcp://localhost:4096?sync=trueencoder=#myEncoder)
.process(new MyFromProcessor());
}
});
context.start();
Endpoint endpoint = context.getEndpoint(direct:cpsp);
Exchange exchange = endpoint.createExchange();
byte[] data = FileUtil.getInputStreamContent(new
FileInputStream(D:/a.xml));
Producer producer = endpoint.createProducer();
exchange.getIn().setBody(new String(data).trim());
producer.process(exchange);
if (exchange.getException() != null)
throw exchange.getException();
System.out.println(exchange.getOut().getBody());
but exception with:
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to
resolve endpoint:
netty://tcp://localhost:4096?encoder=%23myEncodersync=true due to: Could
not find a suitable setter for property: encoder as there isn't a setter
method with same type: java.lang.String nor type conversion possible: No
type converter available to convert from type: java.lang.String to the
required type: org.jboss.netty.channel.ChannelDownstreamHandler with value
#myEncoder
at
org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:450)
at
org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:47)
at
org.apache.camel.model.RouteDefinition.resolveEndpoint(RouteDefinition.java:180)
at
org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:110)
at
org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:116)
at
org.apache.camel.model.SendDefinition.resolveEndpoint(SendDefinition.java:61)
at
org.apache.camel.model.SendDefinition.createProcessor(SendDefinition.java:55)
at
org.apache.camel.model.ProcessorDefinition.makeProcessor(ProcessorDefinition.java:410)
at
org.apache.camel.model.ProcessorDefinition.addRoutes(ProcessorDefinition.java:181)
at
org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:812)
... 9 more
Caused by: java.lang.IllegalArgumentException: Could not find a suitable
setter for property: encoder as there isn't a setter method with same type:
java.lang.String nor type conversion possible: No type converter available
to convert from type: java.lang.String to the required type:
org.jboss.netty.channel.ChannelDownstreamHandler with value #myEncoder
at
org.apache.camel.util.IntrospectionSupport.setProperty(IntrospectionSupport.java:341)
at
org.apache.camel.util.IntrospectionSupport.setProperties(IntrospectionSupport.java:291)
at
org.apache.camel.util.EndpointHelper.setProperties(EndpointHelper.java:225)
at
org.apache.camel.component.netty.NettyConfiguration.parseURI(NettyConfiguration.java:125)
at
org.apache.camel.component.netty.NettyComponent.createEndpoint(NettyComponent.java:49)
at
org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:75)
at
org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:432)
... 18 more
--
View this message in context:
http://camel.465427.n5.nabble.com/set-encoder-in-netty-exception-tp5130760p5130760.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Typesafe Bean injection in routes using Registry
Hi again Claus, Yes, I also think that this is a neat concept and fits well with the de-Spring-ification that Camel is currently undergoing. I also noted that the registry has the type lookup option, which led me to believe that it could be used from the routes as well. My implementation of the registry SPI is basically a rip of the project I mentioned in the last post: https://github.com/obergner/camelpe/blob/master/impl/src/main/java/net/camelpe/extension/camel/spi/CdiRegistry.java https://github.com/obergner/camelpe/blob/master/impl/src/main/java/net/camelpe/extension/camel/spi/CdiRegistry.java Seems like the author has come a long way of integrating Camel with CDI, using i.e. CDI to scan for type converters, routes contexts etc. My need was much more basic so I opted to only use the registry to reference my business beans for the routes. Perhaps his work could be merged into a camel-cdi component if the author would like to contribute? I can only agree that the bean options are confusing, especially with regards to when the registry is used and when Camel will take care of instantiating classes. This obviously plays a large role if the bean has dependencies and in multi concurrent scenarios (are my objects scoped as singletons/prototypes, etc..). Would love to continue the discussion, thanks for your response! /Billy -- View this message in context: http://camel.465427.n5.nabble.com/Typesafe-Bean-injection-in-routes-using-Registry-tp5092420p5131160.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: set encoder in netty exception
All looks correct to me. May be you have a typo somewhere and myencoder is null.
How does your test-codecs.xml looks like?
Bilgin
On 9 January 2012 08:23, xiangqiuzhao xiangqiuz...@gmail.com wrote:
bean id=myencoder
class=org.jboss.netty.handler.codec.string.StringEncoder/
my code like:
ApplicationContext appctx =
new
ClassPathXmlApplicationContext(/org/apache/camel/component/netty/test-codecs.xml);
Object decoder = appctx.getBean(mydecoder);
Object encoder = appctx.getBean(myencoder);
SimpleRegistry registry = new SimpleRegistry();
registry.put(myDecoder, decoder);
registry.put(myEncoder, encoder);
CamelContext context = new DefaultCamelContext(registry);
context.addRoutes(new RouteBuilder() {
public void configure() throws Exception {
from(direct:cpsp)
.process(new MyToProcessor())
.to(netty:tcp://localhost:4096?sync=trueencoder=#myEncoder)
.process(new MyFromProcessor());
}
});
context.start();
Endpoint endpoint = context.getEndpoint(direct:cpsp);
Exchange exchange = endpoint.createExchange();
byte[] data = FileUtil.getInputStreamContent(new
FileInputStream(D:/a.xml));
Producer producer = endpoint.createProducer();
exchange.getIn().setBody(new String(data).trim());
producer.process(exchange);
if (exchange.getException() != null)
throw exchange.getException();
System.out.println(exchange.getOut().getBody());
but exception with:
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to
resolve endpoint:
netty://tcp://localhost:4096?encoder=%23myEncodersync=true due to: Could
not find a suitable setter for property: encoder as there isn't a setter
method with same type: java.lang.String nor type conversion possible: No
type converter available to convert from type: java.lang.String to the
required type: org.jboss.netty.channel.ChannelDownstreamHandler with value
#myEncoder
at
org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:450)
at
org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:47)
at
org.apache.camel.model.RouteDefinition.resolveEndpoint(RouteDefinition.java:180)
at
org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:110)
at
org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:116)
at
org.apache.camel.model.SendDefinition.resolveEndpoint(SendDefinition.java:61)
at
org.apache.camel.model.SendDefinition.createProcessor(SendDefinition.java:55)
at
org.apache.camel.model.ProcessorDefinition.makeProcessor(ProcessorDefinition.java:410)
at
org.apache.camel.model.ProcessorDefinition.addRoutes(ProcessorDefinition.java:181)
at
org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:812)
... 9 more
Caused by: java.lang.IllegalArgumentException: Could not find a suitable
setter for property: encoder as there isn't a setter method with same type:
java.lang.String nor type conversion possible: No type converter available
to convert from type: java.lang.String to the required type:
org.jboss.netty.channel.ChannelDownstreamHandler with value #myEncoder
at
org.apache.camel.util.IntrospectionSupport.setProperty(IntrospectionSupport.java:341)
at
org.apache.camel.util.IntrospectionSupport.setProperties(IntrospectionSupport.java:291)
at
org.apache.camel.util.EndpointHelper.setProperties(EndpointHelper.java:225)
at
org.apache.camel.component.netty.NettyConfiguration.parseURI(NettyConfiguration.java:125)
at
org.apache.camel.component.netty.NettyComponent.createEndpoint(NettyComponent.java:49)
at
org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:75)
at
org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:432)
... 18 more
--
View this message in context:
http://camel.465427.n5.nabble.com/set-encoder-in-netty-exception-tp5130760p5130760.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: change default table name of jdbc idempotent repository
Hi Christian, thanks for that information. We are running camel from inside ActiveMQ-5.5.1. Will have a look, if it is possible to use the 2.9.1 or 2.10-snapshots. best, christoph 2012/1/7 Christian Müller Only if you can use the Camel 2.9.1-SNAPSHOT or 2.10.0-SNAPSHOT version. I will update the wiki page today or tomorrow to document the changes/improvements which comes with CAMEL-4152. Best, Christian
Re: i am newbie to camel
thanks chris .. please send me some links for tutorials. Actually i want to read an XML from a source and want to parse from processor and after parsing i want to place it in another place(parsed XML) -- View this message in context: http://camel.465427.n5.nabble.com/i-am-newbie-to-camel-tp5127199p5130532.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Adding a startup listener via spring
Hi Claus, I tried the depends-on solution but unfortunately the camel context is started asynchronously after the Spring context is initialized. The behaviour is implemented in class OsgiSpringCamelContext, method onApplicationEvent. Do you think of any other reliable way to define dependencies between camel contexts ? Thanks, metatech Claus Ibsen-2 wrote In Spring XML you should be able to use the depends-on attribute to say that your bean depends on Camel. camelContext id=myCamel ... bean id=foo depends-on=myCamel ... -- View this message in context: http://camel.465427.n5.nabble.com/Adding-a-startup-listener-via-spring-tp4306163p5130769.html Sent from the Camel - Users mailing list archive at Nabble.com.
in netty.why sended 6bytes, but server recved 9bytes
my Encoder:
protected Object encode(
ChannelHandlerContext ctx, Channel channel, Object msg) throws
Exception {
if (!(msg instanceof String)) {
return msg;//(1)
}
System.out.println(IN INCODE: + msg);
buf.writeBytes(data); //6bytes
return buf;//(3)
}
my camelContext:
SimpleRegistry registry = new SimpleRegistry();
registry.put(myEncoder, encoder);
CamelContext context = new DefaultCamelContext(registry);
my routeBuilder:
context.addRoutes(new RouteBuilder() {
public void configure() throws Exception {
from(direct:cpsp)
.process(new MyToProcessor())
.to(netty:tcp://localhost:6789?sync=true)
.process(new MyFromProcessor());
}
});
why my server recved 9bytes??
and how camel know the encoder i put in DefaultCamelContext?
--
View this message in context:
http://camel.465427.n5.nabble.com/in-netty-why-sended-6bytes-but-server-recved-9bytes-tp5131271p5131271.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Xstream marshals to byte array and not String
I mean does the request reply continue to work if the last step of the route is not a .to() but a .xstream() ? It seems not for me -- View this message in context: http://camel.465427.n5.nabble.com/Xstream-marshals-to-byte-array-and-not-String-tp5129211p5131281.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Adding a startup listener via spring
On Mon, Jan 9, 2012 at 9:30 AM, metatech metatec...@gmail.com wrote: Hi Claus, I tried the depends-on solution but unfortunately the camel context is started asynchronously after the Spring context is initialized. The behaviour is implemented in class OsgiSpringCamelContext, method onApplicationEvent. Do you think of any other reliable way to define dependencies between camel contexts ? spring-dm has a option AFAIR where you can tell it to start synchronously. Its an option you need to set in your bundles MANIFEST.MF file. Its documented somewhere in the spring-dm docs. I found some stuff here http://static.springsource.org/osgi/docs/1.2.1/reference/html/app-deploy.html#app-deploy:required-libraries See the create-asynchronously option Thanks, metatech Claus Ibsen-2 wrote In Spring XML you should be able to use the depends-on attribute to say that your bean depends on Camel. camelContext id=myCamel ... bean id=foo depends-on=myCamel ... -- View this message in context: http://camel.465427.n5.nabble.com/Adding-a-startup-listener-via-spring-tp4306163p5130769.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - FuseSource Email: cib...@fusesource.com Web: http://fusesource.com Twitter: davsclaus, fusenews Blog: http://davsclaus.blogspot.com/ Author of Camel in Action: http://www.manning.com/ibsen/
Re: Zookeeper component documentation
On 3 January 2012 16:43, Hartmut Lang hartmut.l...@ericsson.com wrote: Hi, for me it seems that the documentation for the zookeeper component is not correct: http://camel.apache.org/zookeeper.html. The examples for reading from a znode seems more like a writing example. You are right Hartmut, reading should be in the format: from(zookeeper://localhost:39913/camel?repeat=true).to(mock:zookeeper-data); I updated the docs. Thanks for letting us know. Bilgin But maybe i just don't get the point here. Hartmut
Re: set encoder in netty exception
test-codes.xml like : beans bean id=myencoder class=org.jboss.netty.handler.codec.string.StringEncoder/ /beans -- View this message in context: http://camel.465427.n5.nabble.com/set-encoder-in-netty-exception-tp5130760p5131323.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Embedded Web Console in Tomcat
Actually with 2.9.0 you can run the console with Tomcat7 but still not Tomcat6 or another webserver. As far as I know, you can't deploy it in a seperate war, the actual way to do it is with a war overlay (and that bothers me too...). That would be great to deploy it in a seperate instance. We have several Camel applications, each one with its own console : I'd rather prefere only one console where I can add all my Camel applications. 2012/1/8 mgiammarco [via Camel] ml-node+s465427n5129233...@n5.nabble.com Hello, any news about this? I have the same problem: I need web console under tomcat. Is there any workaround? Can I deploy the console in a separate war? Thanks, Mario -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Embedded-Web-Console-in-Tomcat-tp4894690p5129233.html To unsubscribe from Embedded Web Console in Tomcat, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=4894690code=Y2V4YnJheWF0QHNxbGkuY29tfDQ4OTQ2OTB8MTA0MTc4NTM3NQ== . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.InstantMailNamespacebreadcrumbs=instant+emails%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Embedded-Web-Console-in-Tomcat-tp4894690p5131331.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: set encoder in netty exception
Hi
What version of Camel do you use?
And how do you run the app? eg using a maven goal, from Eclipse, or what?
On Mon, Jan 9, 2012 at 9:23 AM, xiangqiuzhao xiangqiuz...@gmail.com wrote:
bean id=myencoder
class=org.jboss.netty.handler.codec.string.StringEncoder/
my code like:
ApplicationContext appctx =
new
ClassPathXmlApplicationContext(/org/apache/camel/component/netty/test-codecs.xml);
Object decoder = appctx.getBean(mydecoder);
Object encoder = appctx.getBean(myencoder);
SimpleRegistry registry = new SimpleRegistry();
registry.put(myDecoder, decoder);
registry.put(myEncoder, encoder);
CamelContext context = new DefaultCamelContext(registry);
context.addRoutes(new RouteBuilder() {
public void configure() throws Exception {
from(direct:cpsp)
.process(new MyToProcessor())
.to(netty:tcp://localhost:4096?sync=trueencoder=#myEncoder)
.process(new MyFromProcessor());
}
});
context.start();
Endpoint endpoint = context.getEndpoint(direct:cpsp);
Exchange exchange = endpoint.createExchange();
byte[] data = FileUtil.getInputStreamContent(new
FileInputStream(D:/a.xml));
Producer producer = endpoint.createProducer();
exchange.getIn().setBody(new String(data).trim());
producer.process(exchange);
if (exchange.getException() != null)
throw exchange.getException();
System.out.println(exchange.getOut().getBody());
but exception with:
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to
resolve endpoint:
netty://tcp://localhost:4096?encoder=%23myEncodersync=true due to: Could
not find a suitable setter for property: encoder as there isn't a setter
method with same type: java.lang.String nor type conversion possible: No
type converter available to convert from type: java.lang.String to the
required type: org.jboss.netty.channel.ChannelDownstreamHandler with value
#myEncoder
at
org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:450)
at
org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:47)
at
org.apache.camel.model.RouteDefinition.resolveEndpoint(RouteDefinition.java:180)
at
org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:110)
at
org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:116)
at
org.apache.camel.model.SendDefinition.resolveEndpoint(SendDefinition.java:61)
at
org.apache.camel.model.SendDefinition.createProcessor(SendDefinition.java:55)
at
org.apache.camel.model.ProcessorDefinition.makeProcessor(ProcessorDefinition.java:410)
at
org.apache.camel.model.ProcessorDefinition.addRoutes(ProcessorDefinition.java:181)
at
org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:812)
... 9 more
Caused by: java.lang.IllegalArgumentException: Could not find a suitable
setter for property: encoder as there isn't a setter method with same type:
java.lang.String nor type conversion possible: No type converter available
to convert from type: java.lang.String to the required type:
org.jboss.netty.channel.ChannelDownstreamHandler with value #myEncoder
at
org.apache.camel.util.IntrospectionSupport.setProperty(IntrospectionSupport.java:341)
at
org.apache.camel.util.IntrospectionSupport.setProperties(IntrospectionSupport.java:291)
at
org.apache.camel.util.EndpointHelper.setProperties(EndpointHelper.java:225)
at
org.apache.camel.component.netty.NettyConfiguration.parseURI(NettyConfiguration.java:125)
at
org.apache.camel.component.netty.NettyComponent.createEndpoint(NettyComponent.java:49)
at
org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:75)
at
org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:432)
... 18 more
--
View this message in context:
http://camel.465427.n5.nabble.com/set-encoder-in-netty-exception-tp5130760p5130760.html
Sent from the Camel - Users mailing list archive at Nabble.com.
--
Claus Ibsen
-
FuseSource
Email: cib...@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/
Re: set encoder in netty exception
Camel version is 2.7.2 and run as a java application (main method) using in eclipse. -- View this message in context: http://camel.465427.n5.nabble.com/set-encoder-in-netty-exception-tp5130760p5131372.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: i am newbie to camel
My colleague Hadrian did a webinar about camel some time ago. The example reads an xml file, parses it, does a choice using xpath and then writes a file again. Should be quite what you try to achieve: http://www.talend.com/webinar/archive/index.php Look for Application Integration / Apache Camel Fundamentals Part 1 The complete source of the example is available from my github account: https://github.com/cschneider/camel-webinar/tree/master/part1/camel-example2-java You can just copy that and use it as a starting point. What the example does not show so much is how parsing the xml works as this is quite hidden in camel. If you can tell me what you want to do with the parsed xml I can perhaps give you some more hints how to achieve it. Christian Am 09.01.2012 07:00, schrieb shaharyar: thanks chris .. please send me some links for tutorials. Actually i want to read an XML from a source and want to parse from processor and after parsing i want to place it in another place(parsed XML) -- View this message in context: http://camel.465427.n5.nabble.com/i-am-newbie-to-camel-tp5127199p5130532.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Christian Schneider http://www.liquid-reality.de Open Source Architect Talend Application Integration Division http://www.talend.com
Re: How to send a templated mail with attachment?
Hi, Do you have any information about plans of 2.9.1 and/or 2.10.0 releases? Regards, Peter Velychko -- View this message in context: http://camel.465427.n5.nabble.com/How-to-send-a-templated-mail-with-attachment-tp5125167p5131386.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: [DISCUSS] Dynamic ScheduledPollConsumer
Hi Do you mean a back-off multiplier. Sounds like a great idea... I have created a Jira request to track this improvement/enhancement request so that the community can take a crack at it. https://issues.apache.org/jira/browse/CAMEL-4876 https://issues.apache.org/jira/browse/CAMEL-4876 Hope this helps. Cheers, Ashwin... - - Ashwin Karpe Apache Camel Committer Sr Principal Consultant FUSESource (a Progress Software Corporation subsidiary) http://fusesource.com Blog: http://opensourceknowledge.blogspot.com - -- View this message in context: http://camel.465427.n5.nabble.com/DISCUSS-Dynamic-ScheduledPollConsumer-tp5129231p5131420.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: [DISCUSS] Dynamic ScheduledPollConsumer
Hi Yeah this is a good idea. We have some logic in Camel in terms of calculating redelivery time. We may be able to leverage that logic for this as well. Then you can configure exponential backoff, and have a max limit as well. Or use the delay pattern syntax etc. On Mon, Jan 9, 2012 at 3:14 PM, Ashwin Karpe aka...@fusesource.com wrote: Hi Do you mean a back-off multiplier. Sounds like a great idea... I have created a Jira request to track this improvement/enhancement request so that the community can take a crack at it. https://issues.apache.org/jira/browse/CAMEL-4876 https://issues.apache.org/jira/browse/CAMEL-4876 Hope this helps. Cheers, Ashwin... - - Ashwin Karpe Apache Camel Committer Sr Principal Consultant FUSESource (a Progress Software Corporation subsidiary) http://fusesource.com Blog: http://opensourceknowledge.blogspot.com - -- View this message in context: http://camel.465427.n5.nabble.com/DISCUSS-Dynamic-ScheduledPollConsumer-tp5129231p5131420.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - FuseSource Email: cib...@fusesource.com Web: http://fusesource.com Twitter: davsclaus, fusenews Blog: http://davsclaus.blogspot.com/ Author of Camel in Action: http://www.manning.com/ibsen/
Re: Unreleased thread, possible in SMPP component
Hi, I am facing the same issue with jsmpp used by camel-smpp. Please, have you already found solution for this? As I am looking inside jsmpp, when it fails to connect during reconnect executorService.shutdown(); is called inside PDUReaderWorker. So threadpool should be released. But it looks like it is not :( -- View this message in context: http://camel.465427.n5.nabble.com/Unreleased-thread-possible-in-SMPP-component-tp4922901p5131453.html Sent from the Camel - Users mailing list archive at Nabble.com.
Using the x509HostnameVerifier option in http4
I'm trying to use the x509HostnameVerifier option in an http4 uri from(jetty:https://0.0.0.0:4433/topython/?matchOnUriPrefix=true;) .to(https4://backend.fake.com:/?bridgeEndpoint=truethrowExceptionOnFailure=falsex509HostnameVerifier=AllowAllHostnameVerifier); but I'm getting an error No bean could be found in the registry for: AllowAllHostnameVerifier of type: org.apache.http.conn.ssl.X509HostnameVerifier Am I doing something wrong? I'm on version 2.9.0 Thanks in advance. -Xavier -- View this message in context: http://camel.465427.n5.nabble.com/Using-the-x509HostnameVerifier-option-in-http4-tp5131544p5131544.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: [DISCUSS] Dynamic ScheduledPollConsumer
Year my thought of like a back-off multiplier, but it didn't have to be that advanced. But with back-off feature it will be much more flexibel. Could be pluggable. preben -- View this message in context: http://camel.465427.n5.nabble.com/DISCUSS-Dynamic-ScheduledPollConsumer-tp5129231p5131565.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: in netty.why sended 6bytes, but server recved 9bytes
sorry, my server recved 14bytes. client in Camel send 230111 string. but server recved 000A05740006323338303131 by hex string why had 8bytes with 000A05740006 ? -- View this message in context: http://camel.465427.n5.nabble.com/in-netty-why-sended-6bytes-but-server-recved-9bytes-tp5131271p5131578.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: in netty.why sended 6bytes, but server recved 9bytes
You use String as payload so it might use UTF-8 as encoding. Your string is not typicall set of bytes, it is set of characters. Make sure first that you write a 6 byte string, not string with 6 characters. Best regards, Lukasz -- Code-House http://code-house.org Wiadomość napisana przez xiangqiuzhao w dniu 2012-01-09, o godz. 16:43: sorry, my server recved 14bytes. client in Camel send 230111 string. but server recved 000A05740006323338303131 by hex string why had 8bytes with 000A05740006 ? -- View this message in context: http://camel.465427.n5.nabble.com/in-netty-why-sended-6bytes-but-server-recved-9bytes-tp5131271p5131578.html Sent from the Camel - Users mailing list archive at Nabble.com.
FTP consumer ignore existing files: configuration option?
Hello, I am using Camel successfully in my project, but have a question concerning the FTP consumer, specifically, with regard to existing files in a watched remote folder. Is there any way of ignoring all files that 'pre-exist' on the server, hopefully, through configuration on the route i.e. ignoreExisting=true or similar? I am only interested in *new* files that get added to the remote folder, not files that already exist when the route is created via the camel context. Many thanks for any pointers (maybe I have missed an obvious config param) Cheerio, Nic -- View this message in context: http://camel.465427.n5.nabble.com/FTP-consumer-ignore-existing-files-configuration-option-tp5131747p5131747.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to send a templated mail with attachment?
We just released Camel 2.9.0 2 weeks ago. We try to build a new minor version (2.10.0) after round about 3 month. You will see Camel 2.9.1 earlier, but it will also takes some more weeks. Best, Christian On Mon, Jan 9, 2012 at 2:58 PM, v_peter v_pe...@ukr.net wrote: Hi, Do you have any information about plans of 2.9.1 and/or 2.10.0 releases? Regards, Peter Velychko -- View this message in context: http://camel.465427.n5.nabble.com/How-to-send-a-templated-mail-with-attachment-tp5125167p5131386.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Using the x509HostnameVerifier option in http4
Hello Xavier! Could you share the Code how you set the host name verifier into the registry? You should do it as below: https://svn.apache.org/repos/asf/camel/trunk/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpsGetTest.java And of course, you can do it also with Spring. The bean id has to be used as value for the 'x509HostnameVerifier' option Best, Christian On Mon, Jan 9, 2012 at 4:28 PM, xverges xver...@gmail.com wrote: I'm trying to use the x509HostnameVerifier option in an http4 uri from(jetty:https://0.0.0.0:4433/topython/?matchOnUriPrefix=true;) .to(https4:// backend.fake.com:/?bridgeEndpoint=truethrowExceptionOnFailure=falsex509HostnameVerifier=AllowAllHostnameVerifier ); but I'm getting an error No bean could be found in the registry for: AllowAllHostnameVerifier of type: org.apache.http.conn.ssl.X509HostnameVerifier Am I doing something wrong? I'm on version 2.9.0 Thanks in advance. -Xavier -- View this message in context: http://camel.465427.n5.nabble.com/Using-the-x509HostnameVerifier-option-in-http4-tp5131544p5131544.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Xstream marshals to byte array and not String
Nobody can help me? Why after I put xstream marshal/unmarshal request-reply has stopped working? 2012/1/9 mgiammarco [via Camel] ml-node+s465427n513128...@n5.nabble.com I mean does the request reply continue to work if the last step of the route is not a .to() but a .xstream() ? It seems not for me -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Xstream-marshals-to-byte-array-and-not-String-tp5129211p5131281.html To unsubscribe from Xstream marshals to byte array and not String, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5129211code=bWdpYW1tYXJjb0BnbWFpbC5jb218NTEyOTIxMXwtMTIyMTI5ODI4 . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.InstantMailNamespacebreadcrumbs=instant+emails%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Xstream-marshals-to-byte-array-and-not-String-tp5129211p5132699.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: in netty.why sended 6bytes, but server recved 9bytes
yes, i'm sure 6bytes only. add 8bytes to the header of netty by default. why? -- View this message in context: http://camel.465427.n5.nabble.com/in-netty-why-sended-6bytes-but-server-recved-9bytes-tp5131271p5132953.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Complex app… 1 context or many?
Thanks everyone for the feedback. --jason On Jan 8, 2012, at 3:20 AM, Christian Müller wrote: For bigger applications we also use multiple contexts and bridge the context via the Camel ActiveMQ component (batch and online requests) or via the Camel VM component (only online requests). By splitting it into smaller parts each context is easier to understand and test. In addition, the development process scales better because each developer has its own service/context/... with defined interfaces. My 0,02 $... Best, Christian On Sun, Jan 8, 2012 at 12:53 AM, Jason Dillon ja...@planet57.com wrote: I'm wondering what the best practice is for a complex application, where many sub-systems (some related, some not) are using camel to process messages, if it is best to have all of them share the same single CamelContext or if its better to have more than one CamelContext to partition the systems? Any advise? --jason
Re: Complex app… 1 context or many?
Wow... a context for a context... brain explodes. I didn't know this was here I'll have a deeper look once my brain is back in one piece ;-) --jason On Jan 8, 2012, at 5:08 AM, Willem Jiang wrote: You can have a look at the camel-context component[1]. It maybe useful for you have a try :) [1]http://camel.apache.org/context.html On 1/8/12 7:53 AM, Jason Dillon wrote: I'm wondering what the best practice is for a complex application, where many sub-systems (some related, some not) are using camel to process messages, if it is best to have all of them share the same single CamelContext or if its better to have more than one CamelContext to partition the systems? Any advise? --jason -- Willem -- FuseSource Web: http://www.fusesource.com Blog:http://willemjiang.blogspot.com (English) http://jnn.javaeye.com (Chinese) Twitter: willemjiang Weibo: willemjiang
Re: i am newbie to camel
thanks alot chris for your kind help actually i just want to get values from that XML and nothing else.XML parsing is not an issue.The real issue was that i want to build a route which pick XML from a folder and then send it to processor and then processor after parsing it (mean getting values from the file) write it into a plain text file and place that file in another folder. Thanks again. -- View this message in context: http://camel.465427.n5.nabble.com/i-am-newbie-to-camel-tp5127199p5133380.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Using the x509HostnameVerifier option in http4
Thanks, Christian. That helped me. I made my life hard by doing some typos and by creating the bean after I tried to use it, but thinks work now. bean id=hostnameVerifier class=org.apache.http.conn.ssl.AllowAllHostnameVerifier / camelContext xmlns=http://camel.apache.org/schema/spring; packagecom.ibm.bcn.xv/package /camelContext Thanks. -Xavier -- View this message in context: http://camel.465427.n5.nabble.com/Using-the-x509HostnameVerifier-option-in-http4-tp5131544p5133564.html Sent from the Camel - Users mailing list archive at Nabble.com.
