Re: Stop component "direct-vm" from another OSGI camelContext

I conducted a series of experiments. Normal JUnit, without OSGI. Creates 2 Camel Context. The first contains The second contains not a single RouteBuilder. Create only ProducerTemplate and send body. JUnit shows stable performance. Go to the Apache Karaf. The first component can be built on

Re: Stop component "direct-vm" from another OSGI camelContext

I did not see the problem. It is clear the list "direct-vm". How to use camel-scr affects the "direct-vm"? -- View this message in context: http://camel.465427.n5.nabble.com/Stop-component-direct-vm-from-another-OSGI-camelContext-tp5794194p5794330.html Sent from the Camel - Users mailing list

Re: Stop component "direct-vm" from another OSGI camelContext

Thanks Claus. I looked implementation camel-scr. I found there Here the problem lies elsewhere. DirectVmComponent erases data endpoints list For this purpose, it uses the counter First CamelContext adds new endpoint (consumer) "direct-vm". Create new component (DirectVmComponent). The counter

Re: Stop component "direct-vm" from another OSGI camelContext

Opened error on this topic https://issues.apache.org/jira/browse/CAMEL-10880 -- View this message in context: http://camel.465427.n5.nabble.com/Stop-component-direct-vm-from-another-OSGI-camelContext-tp5794194p5794280.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Stop component "direct-vm" from another OSGI camelContext

Got a call stack is a list of all the cleaning system "dicect-vm" In the mode "debug" error caught a third call karaf shell command. -- View this message in context: http://camel.465427.n5.nabble.com/Stop-component-direct-vm-from-another-OSGI-camelContext-tp5794194p5794273.html Sent from

Re: Stop component "direct-vm" from another OSGI camelContext

I added to the code Camel Karaf commands work. First time doing team No errors. For the second time running the command. An error. Routing code The second time I launch the command Indicates that all works. Why error occurs DirectVmConsumerNotAvailableException? -- View this message in

Re: Stop component "direct-vm" from another OSGI camelContext

Command context-list extend class CamelControllerImpl. This class find OSGi services Used OsgiDefaultCamelContext class is not a service. Why do his service? Where is it written that it is necessary to register it as a service? Where can I see an example of how this is done?

Re: Stop component "direct-vm" from another OSGI camelContext

I use Apache Karaf 4.0.7. Camel karf commands do not work. Or when I did not think to stop running components. First OSGI bundle use dynamic OSGi components. The class is an analogue of the standard Bundle activator. Second OSGI bundle use Karaf Shell annotation. First OSGI bundle defines

Re: Stop component "direct-vm" from another OSGI camelContext

In the first OSGI bundle is multiple camel routes. Camel karaf command do not work camel:context-list camel:component-list camel:route-list I stop and will start component (OSGI bundle stop and start). Fires once. After 5-6 seconds, I repeat. Again, it does not work. The first way should not

Stop component "direct-vm" from another OSGI camelContext

There are two OSGI bundle. First OSGI bundle from("direct-vm:makeDoc") .bean(loacalBean, "make"); Second OSGI bundle void execute(String entityGuid) { SimpleRegistry registry = new SimpleRegistry(); BundleContext bundleContext =

Re: File Expression Language & date format

Excuse me. Maybe I did not quite understand spoken. Or someone does not quite understand. On page http://camel.apache.org/file-language.html file:modified - Refers to the file last modified returned as a Date type. Writing idempotentKey=${file:name}-${file:size}-${file:modified}

File Expression Language & date format

Do you think that a complete rejection of the parameters "idempotent" corrects errors? https://issues.apache.org/jira/browse/CAMEL-6574 https://issues.apache.org/jira/browse/CAMEL-6936 Enjoying http://camel.apache.org/file2.html idempotentKey=${file:name}-${file:size} Good. Enjoying

understand the work with thread pools

Please help to understand the work with thread pools. System Log The first 2 lines are clear. I do not understand the last line. The process is not performed in the thread pool, while the main stream. Regards, Alexey. -- View this message in context:

Re: Error in Karaf: Unknown protocol: mvn

In the file camel-core-2.17.1.jar, internal file META-INF/MANIFEST.MF have row Ignore-Package: com.googlecode.concurrentlinkedhashmap but this package use in class org.apache.camel.util.LRUCache. It's errror for OSGi. Add this package to parameter Import-Package, or change usage classes

Error in Karaf: Unknown protocol: mvn

Explain why the assembly 2.17.1 by May August 2016, the class org.apache.camel.util.LRUCache differs from https://github.com/apache/camel/blob/master/camel-core/src/main/java/org/apache/camel/util/LRUCache.java ? Last Update 1f48a57 on 31 Mar @davsclaus davsclaus CAMEL-8602: Java 8:

Re: OSGi CamelHttpTransportServlet error

Clause, did not help the registration system component "servlet 2". The system still will take a component called "servlet". I think it is necessary to replace In this case bothers me a little higher in the condition statement "if". I found a solution: Call method endpointProperty. You're

Re: OSGi CamelHttpTransportServlet error

Thank you, Claus Ibsen-2. I will try to register the component Servlet Component with the new name "servlet2". The fact that I use only one servlet in one CamelRoute. I think it will be interesting. Make several restConfiguration for different servlet. The idea is that you can make a few

OSGi CamelHttpTransportServlet error

I use two different OSGi component. Each writing I see an error It turns out that the two OSGi components must not only be different version of the component, but also the name of the servlet. This is clearly a mistake. The second error I give unique names to each servlet. I see an error

Re: OSGi CamelHttpTransportServlet error

>From route builder component("servlet") use ServletComponent. How to specify the correct servletName? -- View this message in context: http://camel.465427.n5.nabble.com/OSGi-CamelHttpTransportServlet-error-tp5774062p5774094.html Sent from the Camel - Users mailing list archive at

Re: OSGi CamelHttpTransportServlet error

One OSGi bundle can be regarded as a WAR or EAR module in the JavaEE server. I'm talking about the fact that in different modules can not use servlets with the same name. The fact that the component camel-servlet comprises a static cache And he's one for all the modules. Something similar can be

Re: Camel Container Deployment - Best Practice

I use a bunch of Apache Karaf and Apache Camel. At the beginning of the road I used OSGi Blueprint. Over time, the Blueprint gave up and switched to Dynamic Services. Spring DS - a type of OSGi Blueprint. It was quite a compelling reason authors abandon basic Spring DS in OSGi. This is the main

Re: Propose change eagerMaxMessagesPerPoll in file/ftp consumers

I tried to implement a mechanism to limit the list of files. If the system is switched to the third depth of the file system, it is necessary to process all the files and subdirectories. For this purpose, it is necessary to register the new component. An example implementation is shown below

Propose change eagerMaxMessagesPerPoll in file/ftp consumers

I propose to extend the value eagerMaxMessagesPerPoll in file/ftp consumers. eagerMaxMessagesPerPoll = true eagerMaxMessagesPerPoll = false eagerMaxMessagesPerPoll = reach eagerMaxMessagesPerPoll = overcome The values ​​of reach and overcome give a chance to correct sorting of files in a single

Re: Data Corruption in SFTP in Parallel Multicast branches

Try replacing the Multicast on the Recipient List with parallelProcessing=true. Multicast: The Multicast allows to route the same message to a number of endpoints and process them in a different way. Recipient List: The recipients will receive a copy of the same Exchange. -- View this

Camel rest DSL and OSGI

I had a problem similar to http://camel.465427.n5.nabble.com/Problem-with-Camel-rest-in-OSGi-td5758649.html Read Wiki https://cwiki.apache.org/confluence/display/CAMEL/Rest+DSL The Camel Rest component to use for the REST transport, such as restlet, spark-rest. If no component has been explicit

Re: Camel rest DSL and OSGI

We had to repeat the feat, as described in the file https://github.com/apache/camel/blob/master/examples/camel-example-servlet-rest-blueprint/src/main/resources/OSGI-INF/blueprint/camel.xml And this is called then Camel will lookup if there is a Camel component that integrates with the Rest DSL.

Re: camel-ftp 2.15.1 return ftp error code 421

An exemplary work plan Ftp consumer. As we can see, at the beginning of a connection to the server. FTPClient establishes a new connection for a list of files in each directory. At the end of the first connection is switched off. Why hold the first connection? Another question. Some

Re: camel-ftp 2.15.1 return ftp error code 421

Yes, I tried to find an answer to the question why the process ceases to take files from ftp server. The most simple - revert to the old assembly Camel. Lo and behold, the files were taken. But just a couple of days. Server file number increased by several hundred. The system stops to pick up the

Re: camel-ftp 2.15.1 return ftp error code 421

It looks like quite a different matter. On the server, there is a restriction session. After 10 minutes, the server connection tearing. No problem in download speed of large files. Disconnection is the fault of the strategy routePolicyStopTime. But it's not scary. The main problem is to read a

Re: Karaf with Camel 2.15.1, CXF 3.0.4 - which Spring versions can be used?

File etc/org.apache.karaf.features.cfg Note line -- View this message in context: http://camel.465427.n5.nabble.com/Karaf-with-Camel-2-15-1-CXF-3-0-4-which-Spring-versions-can-be-used-tp5765283p5765369.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: camel-ftp 2.15.1 return ftp error code 421

A short excerpt from karaf.log.xxx file -- View this message in context: http://camel.465427.n5.nabble.com/camel-ftp-2-15-1-return-ftp-error-code-421-tp5765272p5765368.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: camel-ftp 2.15.1 return ftp error code 421

Honestly. 2.15.0 On this effect is much less than 2.15.1. I used to CronScheduledRoutePolicy ftpDocReadRoutePolicy = new CronScheduledRoutePolicy(); ftpDocReadRoutePolicy.setRouteStartTime(routePolicyStartTime); ftpDocReadRoutePolicy.setRouteStopTime(routePolicyStopTime);

camel-ftp 2.15.1 return ftp error code 421

On the new version of Apache Camel 2.15.1 started to happen strange errors. On this version 2.15.0 there is no error. -- View this message in context: http://camel.465427.n5.nabble.com/camel-ftp-2-15-1-return-ftp-error-code-421-tp5765272.html Sent from the Camel - Users mailing list archive

Re: camel-ftp 2.15.1 return ftp error code 421

Imagine that your FTP directory shows the C:\Program Files on Windows or /usr/lib on Linux. There is a very large number of files. Files can not be deleted. Process periodically scans all files in all folders, filters, and sorts. Uses a database table to store the names of files previously treated

Re: parallelProcessing with multicast

An incident that is necessary to call a method .end() from(...) .filter() .to(myprocess) .to(mock.out) .end(); Your account is perceived as from(...) .filter() .to(myprocess) .end() .to(mock.out); -- View this message in context:

Re: Annotations are not working in RouteBuilder

Specifically decided to test it out. Below shows a working example. CamelContext camelContext; LocalRouteBuilder builder = new LocalRouteBuilder(); new DefaultCamelBeanPostProcessor(camelContext).postProcessBeforeInitialization(builder, builder); camelContext.addRoutes(builder); Why could not

Re: Annotations are not working in RouteBuilder

Part http://camel.apache.org/bean-integration.html Spring component scanning mechanism and a camelContext is used or a CamelBeanPostProcessor then we process a number of Camel annotations to do various things such as injecting resources or producing, consuming or routing messages. CamelContext

Annotations are not working in RouteBuilder

Hi Strange error. How to test BlueprintPropertyInjectRoute use @PropertyInject. If you are using OSGi Blueprint, annotations work. Write SimpleRegistry registry = new SimpleRegistry(); registry.put(serviceProperties, properties); CamelContext camelContext = new

Re: camel-catalog 2.15.0 and karaf 2.4.1

I'll wait for the new assembly 2.15.1. Still hawtio and correct. The new Camel shows no counter calls in Route Diagram. Version 2.14.0 show counter calls and changed. Aleksey -- View this message in context:

Re: Camel distributed transactions/XA without full J2EE container?

You are not faced with the problem of access to GitHUB. Recently, in Russia, this resource was not available for several days. This multi-million developers have lost access to their projects. Well, that someone wrote for GitHUB system blocking parts of sections for whole regions (countries). God

OSGI Apache Aries Transaction

Hi Working on the project, encountered an error emergency closing the connection. The database connection is closed to rollback the entire transaction. I registered an error https://issues.apache.org/jira/browse/ARIES-1279 Description contains many quotations from the trace log. In the comments

Re: OSGI Apache Aries Transaction

I changed the error message. I think that this is a very serious mistake. Added test. When the database returns an error, distributed transaction falls during the rollback. Do you think that this behavior is transaction management system correct? I wondered whether I should leave in OSGI project

Re: Camel distributed transactions/XA without full J2EE container?

Hi Please read my opinion on account of Aries Transaction. See http://camel.465427.n5.nabble.com/OSGI-Apache-Aries-Transaction-td5760310.html https://issues.apache.org/jira/browse/ARIES-1279 Another author: https://issues.jboss.org/browse/ENTESB-2244 On the topic of the question. In

context stoping to many time

Help to understand the following information karaf@root camel:route-list ContextRoute Status ---- -- camel-exchange-oos-dict-read route-exchangeDictRead

Re: How to clean '.camel' directories?

Hi Willem. I would like to delete files whose modification date was more than one month. Apache Camel 2.13.0. FileConsumer skip path '.camel' How to make FileConsumer read files in these directories? Parameter noop = true does not affect. Parameter move = other are not affected. --

How to clean '.camel' directories?

The process works on a schedule. Recursively searches the directory. Found files are processed and fall into a subdirectory named '.camel'. path_a path_b path_b_a .camel path_b_b .camel path_c path_c_a .camel path_c_b .camel Camel route:

Re: zip file best practices

I never used to separate files in zip archive. I use a component splitter to read nested XML files. Example use in spring DSL: http://stackoverflow.com/questions/20294005/using-zipsplitter-in-apache-camel-spring-dsl Copy/paste and add comments bean id=zipSplitter

RE: Http4 Set Header Content-Type not passing through to the HTTP Request

Look http://camel.apache.org/http4.html Section: Message Headers. Aleksey -- View this message in context: http://camel.465427.n5.nabble.com/Http4-Set-Header-Content-Type-not-passing-through-to-the-HTTP-Request-tp5746414p5746464.html Sent from the Camel - Users mailing list archive at

Re: zip file best practices

ZipSplitter uses the input stream from the archive file (message body). Sends output stream for each attached file. One should not expect from him GenericFile Nothing complicated. -- View this message in context: http://camel.465427.n5.nabble.com/zip-file-best-practices-tp5713437p5746434.html

Re: Camel main class in osgi bundle

Consider an example. Example project in the attachment file. For reasons of clarity, the project no services and no Apache Camel. Build project: Note the last warning. Remove method getB. Build project. Last warning not exists. myapp.tar.gz

Re: Camel main class in osgi bundle

Hi, Christian My sample code: blueprint error code: Move class A from package myapp to package myapp.imp.camel.processes Create Java DSL RouteBuilder -- View this message in context: http://camel.465427.n5.nabble.com/Camel-main-class-in-osgi-bundle-tp5746113p5746246.html Sent from

RE: Camel main class in osgi bundle

1. Blueprint requires the presence of all the objects (beans) in the public OSGi part. 2. These objects can create objects from the private OSGi part. 3. Objects must not contain public methods taking or transmitting other objects from the private part. The last point is very difficult to

Re: Camel FTP consumer + socketFactory not work correctly

Hi, Willem Thanks for the correction of an error. Exactly the same error there FtpsEndpoint. Aleksey -- View this message in context: http://camel.465427.n5.nabble.com/Camel-FTP-consumer-socketFactory-not-work-correctly-tp5744716p5745005.html Sent from the Camel - Users mailing list archive

Re: Camel FTP consumer + socketFactory not work correctly

Hi Add JUnit test for remove paramenters from FtpClient FromFtpClientSoTimeout3Test.java http://camel.465427.n5.nabble.com/file/n5744955/FromFtpClientSoTimeout3Test.java Aleksey -- View this message in context:

Re: Camel FTP consumer + socketFactory not work correctly

Cause of the error. Method retrieves the value of the parameter and removes it from the list. The following method call will not find these parameters. Parameters were destroyed in the first call. Example FtpsEndpoint.java, line 163. / / And we want to keep data timeout so we can log

Camel FTP consumer + socketFactory not work correctly

Hi Camel FTP consumer + socketFactory not work correctly There is a real FTP server with authorization . ftp://free:free @ ftp.zakupki.gov.ru: 21 / The company stands proxy squid. Use HTTP Basic authentication. Work with FTP being timer . read.routePolicy.startTime = 0 2/ 5 *** ?

Re: Camel FTP consumer + socketFactory not work correctly

Forgot to specify. Camel 2.12.2 source code ProxySoketFactory: https://github.com/alexey-su/camel-ftpext/tree/master/src/main/java/org/apache/commons/net/proxy https://github.com/alexey-su/camel-ftpext/tree/master/src/main/java/org/apache/commons/net/proxy Aleksey -- View this message in

Re: Camel FTP consumer + socketFactory not work correctly

Exploring the magazine saw different objects -- first start 12:07:01,016 | TRACE | ... | FtpOperations | ponent.file.remote.FtpOperations 71 | 115 - org.apache.camel.camel-ftp - 2.12.2 | Connecting using FTPClient: org.apache.commons.net.ftp.FTPClient@32b02753 -- second start 12:12:44,090 |

where the news camel 2.12.2?

Hi Question on the topic. In http://search.maven.org/ already have version 2.12.2. org.apache.camelcamel 2.12.2 all (48)23-Nov-2013 The official website of http://camel.apache.org/ no news. Aleksey -- View this message in context:

Re: Propose add annotation @BeanInject

Claus Ibsen. Thank you. Aleksey -- View this message in context: http://camel.465427.n5.nabble.com/Propose-add-annotation-BeanInject-tp5742782p5743334.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Propose add annotation @BeanInject

Hi Continue my idea of ​​using annotations. Annotations EJB 3.0 is much easier to read than the xml description of EJB 2.0. Annotations easier to read than the jndi lookup from the era of EJB 2.0. Checking the data type is during the execution of the code. Annotations are checked when lifting

Re: Propose add annotation @BeanInject

Hi Each framework has its own set of annotations to insert objects. 1) OSGI bluprint have annotation @Bean 2) Spring have annotation @Autowire 3) CDI Weld and Guice have annotation @Inject 4) EJB have annotations @EJB and @Resource This zoo annotations are not universal. I'm not looking Varant

Propose add annotation @BeanInject

It's no secret that the OSGI Blueprint implements a proxy object for the service. In the old specification OSGI used references to objects. Very often forget to let go of the service object obtained from the ServiseReference. For this reason, it is desirable to use the links provided in the

RE: Cannot stop inputstream during ftp transfer

I do not understand what the problem is. Within a few years used to. For 20 seconds, the system waits for the successful outcome of the process. After 20 seconds, the process has not stopped. Aborting closing Endpoint. Component throws an exception I/O or NPE. Rollback transaction and original

Re: HTTP Basic Authentication

You'll be surprised. CXF uses the same library Apache HttpComponents. CXF client initially twice sends an HTTP request. The first request without authorization. Second with authorization. For a GET request such behavior is acceptable. For a POST request is very bad. Aleksey -- View this

RE: HTTP Basic Authentication

Rules of the game sets the other side - http server. Two requests are always bad, whether it's on an external authentication server, or proxy server. It is necessary to send a file size of 1 MByte. Length of HTTP request is about 1.3 MByte. Two queries will give 2.6 MByte. Aleksey -- View

Re: how to define/use multiple properties file in a camel route

You can specify multiple resources, separated by commas. property name=location value=prop_a.properties,prop_b.properties,prop_c.properties/ Aleksey -- View this message in context:

Re: Camel Splitter slowness problem

Use cache JAXBContext or Marshaller/Unmarshaller in local beans. Sample: private SoftReferenceUnmarshaller refUnmarshaller; private Unmarshaller getUnmarshaller() throws JAXBException { Unmarshaller um = refUnmarshaller != null ? refUnmarshaller.get() : null; if(um == null) {

Re: Issue loading multiple properties files

Hi This error Spring Framework. Camel nothing to do with business. Use in OSGI blueprint: cm:property-placeholder id=placeholder persistent-id=service-pid-id update-strategy=reload ... /cm:property-placeholder camelContext id=... xmlns=http://camel.apache.org/schema/blueprint;

Re: FTP over Proxy

Hi The change is very small DefaultComponent object has a method protected void setProperties (Object bean, Map String, Object parameters) throws Exception It is necessary to repeat this method in DefaultEndpoint. Why is that? Used factory EndpointHelper owes its name to the tune

Re: FTP over Proxy

Good afternoon. Let's go back to the history of the issue. The discussion was offered functionality https://issues.apache.org/jira/browse/CAMEL-3845 Check the description FTPS component in http://camel.apache.org/ftp2.html SFTP component uses this functionality. What prevents the FTP component

Re: Scheduled SFTP consumer

Maybe my example will help. I use RoutePolicy. CronScheduledRoutePolicy ftpDocReadRoutePolicy = new CronScheduledRoutePolicy(); ftpDocReadRoutePolicy.setRouteStartTime(routePolicyStartTime); ftpDocReadRoutePolicy.setRouteStopTime(routePolicyStopTime);

Re: zip file best practices

Can be improved. I thought it would be interesting to the user to remember the name of the zip file. Now ZipItaror not give this information. answer.getHeaders().putAll(inputMessage.getHeaders()); answer.setHeader(zipFileName, current.getName()); answer.setHeader(Exchange.FILE_NAME,

Using transaction process

Hi. In the xml description of the process can be written as reference id=osgiPlatformTransactionManager interface=org.springframework.transaction.PlatformTransactionManager/ bean id=required class=org.apache.camel.spring.spi.SpringTransactionPolicy property name=transactionManager

Re: How to stop the Polling Consumer?

Hi, Claus. http://camel.apache.org/how-can-i-stop-a-route-from-a-route.html Sample stop route after line And in the route we create the thread and call the stopRoute method as shown: is no correct. JavaDoc for method Thread start(): It is never legal to start a thread more than once. In

recipientList and several CamelContext

Hi all. There is a process of loading data from external systems. // first osgi bundle from(direct:loadFile) .id(exchangeCheckUnloadedAttach) .split().method(unloadedAttachSplitter, findUnloadedAttach) .recipientList() .method(dynamicRouter, getVerifyAttachRoutes)

Re: recipientList and several CamelContext

A small mistake. The first process begins from(quartz://core-oos/attach?cron={{exchange.doc.attach.cron}}stateful=true) -- View this message in context: http://camel.465427.n5.nabble.com/recipientList-and-several-CamelContext-tp5735714p5735715.html Sent from the Camel - Users mailing list

Re: recipientList and several CamelContext

I'm change vm component to direct-vm component. See http://camel.apache.org/direct-vm.html It's work! -- View this message in context: http://camel.465427.n5.nabble.com/recipientList-and-several-CamelContext-tp5735714p5735725.html Sent from the Camel - Users mailing list archive at

Camel OSGI and dynamicRoute

Hi I decided to try to call external camel process from another process. If in the first, specify the name of an external process, the process will be run once. If during the specified dynamic route, bean components are run many times. Use Apache Camel 2.10.1 and Apacke Karaf. Example route

Re: [HTTP4] HttpProducer close temporary file in CachedOutputStream

Thank you, Willem. I'm in a catch block forgot to send the resulting error (IOException e) on the top. Aleksey -- View this message in context: http://camel.465427.n5.nabble.com/HTTP4-HttpProducer-close-temporary-file-in-CachedOutputStream-tp5716885p5716907.html Sent from the Camel - Users

[HTTP4] HttpProducer close temporary file in CachedOutputStream

I found a nasty bug. HttpProducer uses a temporary file within the object CachedOutputStream. If the static method doExtractResponseBodyAsStream get an error reading an incoming message, we lose information on the temporary file. I propose to add a block catch (IOException e) to trap the error

Re: initialize camelContext properties

Hi, Willem. I added a ticket CAMEL-5438 --- Aleksey Sushko -- View this message in context: http://camel.465427.n5.nabble.com/initialize-camelContext-properties-tp5715695p5715887.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: initialize camelContext properties

I propose to replace the current structure getCamelContext (). getProprties (). get(my_property) to the new method getCamelContext (). getProperty(my_property) The implementation of this method will produce an automatic substitution values ​​using property placeholders. String getProperty

initialize camelContext properties

Hi I read Using proxy settings outside of URI in http://camel.apache.org/http4.html camelContext properties property key=http.proxyHost value=172.168.18.9/ property key=http.proxyPort value=8080/ /properties /camelContext I read Using Blueprint property placeholder with Camel routes

Re: zip file best practices

You can not get a ZipFile from InputStream. We can only ZipInputStream. When processing files within the zip file, you can not close the stream reader. This is an InputStream for the entire zip file. Enclose an example of processing of xml file inside the zip file. In the example of a very large

Re: Overwrite blueprint properties in camel blueprint tests

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

Re: Dynamic list of consumers for the same route

szh.subs I think so, that the example with two OSGi services will not work. The object will return OsgiDefaultLoadBalancer always only one of the services. In turn, OsgiDefaultLoadBalancer working through proxy OsgiInvocationHandler. If you stop the OSGi bundle with the selected service balancer

Re: Splitting XML but including attribute from parent-document

Hey. Read Splitter https://camel.apache.org/splitter.html Section Using a Pojo to do the splitting, a class MySplitterBean. Change the method signature public List Message splitMessage (Message inMessage) So you will have access to the head of the input message. -- View this message in context:

OSGi JTA and NonXA DataSource

I use a camel running karaf. The data is stored in the database Oracle. From the beginning I used OracleXADataSource. With increasing system performance Oracle Server has often produce errors exceeding the number of connections. For each transaction, JDBC driver creates a new connection to the

Re: How to stop the Polling Consumer?

Hi, thanks for confirmation. File Consumer is the successor of Pool Consumer and Batch Consumer. When you create a File Consumer, uses a pool of 10 threads. The first thread scans and finds the N files. Consumer runs in a loop processing of these files. This is how the Batch Consumer. After the

How to stop the Polling Consumer?

Hi. The process of reading a lot of files in a directory. The content of files stored in the database. The database server generates an error ORA-00257: archiver error. Connect internal only, until freed. It is necessary to correct an error on the database server. It makes no sense to continue

Re: Does the FileConsumer swallow an exception by just only logging it?

Hi. I found the problem on one machine. After the execution of all processes, FileConsumer an error transferring the file to another directory. In my case was not closed input stream of the file. I think that this error should be identified during system testing, and not the pilot operation.

Re: FT2: How do I know the list of file that a Consumer FTP2 is receiving?

Using the shutdown gracefully strategy can lead to a disconnection before the file will be downloaded. The parameter localWorkDirectory helps in this situation. The next iteration of the process will restore the connection and continue to read the file. -- View this message in context:

Re: Copying files from an FTP server using search criteria

Hi I designed their own implementation of the filter directory in the form of the test. It may be useful to you. http://camel.465427.n5.nabble.com/file/n5090214/folder-filter.tar.gz folder-filter.tar.gz -- View this message in context:

Re: NPE when using SEDA queue

Please check with the latest 2.8.3-SNAPSHOT or 2.9.0-SNAPSHOT. A similar bug CAMEL-4605 with NPE was fixed. System has been redesigned GracefulShutdown in terms of stopping consumer. I have a ftp problem has been resolved. -- View this message in context:

Re: Camel ftp read next file after close connection

Thank you for the quick fix. I have yet to set a value of 0 to routeStopGracePeriod. This is not the best solution. I'll wait for a new version and check it out. -- View this message in context:

Performance test ShutdownCompleteAllTasksTest

The test is faster and does not wait for the completion of all processes.. // give it 30 seconds to shutdown context.getShutdownStrategy().setTimeout(30); Run test .../camel/camel-core$ mvn -Dtest=ShutdownCompleteAllTasksTest test --- T E S T

Re: Performance test ShutdownCompleteAllTasksTest

Hi. I got it. I changed the timeout to terminate a process. -- View this message in context: http://camel.465427.n5.nabble.com/Performance-test-ShutdownCompleteAllTasksTest-tp4965388p4965898.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel ftp read next file after close connection

Hi I localized the error. Object DefaultShutdownStrategy$ShutdownTask call ((ShutdownAware) consumer).deferShutdown(shutdownRunningTask) The method of the object GenericFileConsumer always returns false. I redefined the method of the FtpConsumer Now DefaultShutdownStrategy waits until the

Re: Camel ftp read next file after close connection

Hi Add error report https://issues.apache.org/jira/browse/CAMEL-4605 -- View this message in context: http://camel.465427.n5.nabble.com/Camel-ftp-read-next-file-after-close-connection-tp4952369p4957362.html Sent from the Camel - Users mailing list archive at Nabble.com.

  1   2   >