Java 消息传递：ActiveMQ、Mule、ServiceMix 和 Camel 之间的区别

Java 消息传递：ActiveMQ、Mule、ServiceMix 和 Camel 之间的区别

java
// 发送消息
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("myQueue");
MessageProducer producer = session.createProducer(destination);
TextMessage message = session.createTextMessage("Hello, ActiveMQ!");
producer.send(message);
// 接收消息
MessageConsumer consumer = session.createConsumer(destination);
Message receivedMessage = consumer.receive();
if (receivedMessage instanceof TextMessage) {
    TextMessage textMessage = (TextMessage) receivedMessage;
    System.out.println("Received message: " + textMessage.getText());
}

xml
    
    
    
    
    

xml
    
        
        
    
    
        
        
    

java
public class MyRouteBuilder extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        from("file:inbox")
            .to("jms:queue:orders");
        from("jms:queue:orders")
            .to("http://localhost:8080/processOrder");
    }
}
public class MainApp {
    public static void main(String[] args) throws Exception {
        CamelContext context = new DefaultCamelContext();
        context.addRoutes(new MyRouteBuilder());
        context.start();
        Thread.sleep(5000);
        context.stop();
    }
}