Created by Jose Antonio Vazquez
over 7 years ago
|
||
package org.apache.camel.example.jmstofile;import org.apache.camel.CamelContext;import org.apache.camel.builder.RouteBuilder;import org.apache.camel.impl.DefaultCamelContext;public class CamelHelloWorldExample { public static void main(String[] args) throws Exception { CamelContext context = new DefaultCamelContext(); try {// context.addComponent("activemq", ActiveMQComponent.activeMQComponent("vm://localhost?broker.persistent=false")); context.addRoutes(new RouteBuilder() { @Override public void configure() throws Exception { // Copiado sin borrar from("file:C:\\datafiles\\input?noop=true").to("file:C:\\datafiles\\output");// Movido from("file:C:\\datafiles\\input?delete=true").to("file:C:\\datafiles\\output"); // Files Copied from datafiles\input to datafiles\output and Original Files Moved to .camel Subdirectory from("file:C:\\datafiles\\input?").to("file:C:\\datafiles\\output"); // Desde la ruta de Eclipse (Hay que añadirlos al Build Path como Folder Work) from("file:src/data/inbox?noop=true").to("file:src/data/outbox");// Copiar una archivo solofrom("file://C:/datafiles/input/?fileName=MyFile.txt&charset=utf-8&noop=true").to("file://C:/datafiles/output/?fileName=MyFile.txt&charset=utf-8");// fileExist=Ignore : Si existe no los sobreescribe from("file://C:/datafiles/input/?fileName=message1.xml&charset=utf-8&noop=true&fileExist=Ignore") .to("file://C:/datafiles/output/?"); // from("timer://myTimer?period=2000")// .setBody()// .simple("Hello World Camel fired at ${header.firedTime}")// .to("stream:out"); } }); // ProducerTemplate template = context.createProducerTemplate(); context.start(); // template.sendBody("activemq:test.queue", "Hello World"); Thread.sleep(2000); context.stop(); } finally { context.stop(); } }}/ ** */file:// + + ? + fileName= + + & + For example, if the filename is C:\in\MyFile.txt, then the URI would look like one of these (both are valid): file://C:/in/?fileName=MyFile.txt file://C:\\in\\?fileName=MyFile.txt// Copia FTP/** * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */package org.apache.camel.example.ftp;import org.apache.camel.builder.RouteBuilder;import org.apache.camel.component.properties.PropertiesComponent;/** * Client route */public class MyFtpClientRouteBuilder extends RouteBuilder { @Override public void configure() throws Exception { // configure properties component PropertiesComponent pc = getContext().getComponent("properties", PropertiesComponent.class); pc.setLocation("classpath:ftp.properties"); // lets shutdown faster in case of in-flight messages stack up getContext().getShutdownStrategy().setTimeout(10); // Copia todos los xml's desde el origen al destino from("ftp://mingo@localhost:21?password=mingo") .choice() .when(simple("${in.header.CamelFileName} contains '.xml'")) .to("file://C:\\Borrar\\TestFTP"); // use system out so it stand out System.out.println("*********************************************************************************"); System.out.println("Camel will route files from target/upload directory to the FTP server: " + getContext().resolvePropertyPlaceholders("{{ftp.server}}")); System.out.println("You can configure the location of the ftp server in the src/main/resources/ftp.properties file."); System.out.println("If the file upload fails, then the file is moved to the target/error directory."); System.out.println("Use ctrl + c to stop this application."); System.out.println("*********************************************************************************"); }}
Want to create your own Notes for free with GoConqr? Learn more.