ファイルをキューに入れるApache Camel

Question

私はフォルダからファイルを読み込んでキューに置く必要があります。

import java.io.File; 

import org.apache.camel.CamelContext; 
import org.apache.camel.Exchange; 
import org.apache.camel.LoggingLevel; 
import org.apache.camel.Processor; 
import org.apache.camel.builder.RouteBuilder; 
import org.apache.camel.impl.DefaultCamelContext; 

public class FileMove{ 
    public static void main(final String[] arguments) { 
     final CamelContext camelContext = new DefaultCamelContext(); 
     try { 
      camelContext.addRoutes(new RouteBuilder() { 
       @Override 
       public void configure() throws Exception { 

        from("file://E:/TestingWatch1/input?preMove=staging&move=.completed&scheduler=quartz2&scheduler.cron=00+*/1+*+1/1+*+?+*") 
          .routeId("testRoute").process(new Processor() { 
           @Override 
           public void process(Exchange msg) throws Exception { 
            File file = msg.getIn().getBody(File.class); 
            String file1 = msg.getIn().getBody(String.class); 
            System.out.println("" + file + file1); 

           } 

          }). 
          to("file://E:/TestingWatch1/output"); 
       } 
      }); 
      camelContext.start(); 
      // Thread.sleep(10*60*1000); 
      // camelContext.stop(); 
     } catch (Exception ex) { 
      ex.printStackTrace(); 
     } 
    } 
} 

私はファイルを読み、内容を提出することが、私はキューにそれを配置する必要があります。ここでは

は、私が持っているコードです。

Java DSLを使用してファイルまたはファイルの内容をキューに移動するにはどうすればよいですか？

Answer 1

おかげで、私は解決策を見つけた：ここでは、コード

import java.io.File; 

import javax.jms.ConnectionFactory; 

import org.apache.activemq.ActiveMQConnection; 
import org.apache.activemq.ActiveMQConnectionFactory; 
import org.apache.camel.CamelContext; 
import org.apache.camel.Exchange; 
import org.apache.camel.LoggingLevel; 
import org.apache.camel.Processor; 
import org.apache.camel.builder.RouteBuilder; 
import org.apache.camel.component.jms.JmsComponent; 
import org.apache.camel.impl.DefaultCamelContext; 

public class CopyTest { 
    public static void main(final String[] arguments) { 
     final CamelContext camelContext = new DefaultCamelContext(); 
     ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "admin", 
       ActiveMQConnection.DEFAULT_BROKER_URL); 
     camelContext.addComponent("test-jms", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory)); 
     try { 
      camelContext.addRoutes(new RouteBuilder() { 
       @Override 
       public void configure() throws Exception { 

        from("file://E:/TestingWatch1/input?preMove=staging&move=.completed&scheduler=quartz2&scheduler.cron=00+*/1+*+1/1+*+?+*") 
          .routeId("testRoute").process(new Processor() { 
           @Override 
           public void process(Exchange msg) throws Exception { 
            File file = msg.getIn().getBody(File.class); 
            String file1 = msg.getIn().getBody(String.class); 
            System.out.println("" + file + file1); 

           } 

          }).to("test-jms:queue:testMQDestination"). 
          to("file://E:/TestingWatch1/output"); 
       } 
      }); 
      camelContext.start(); 
      // Thread.sleep(10*60*1000); 
      // camelContext.stop(); 
     } catch (Exception ex) { 
      ex.printStackTrace(); 
     } 
    } 
}