如何使用 quarkus 和 apache camel 将队列发送到 weblogic 服务器?

问题描述 投票:0回答:0

我在 pom.xml 中使用依赖项

<dependency>
    <groupId>org.amqphub.quarkus</groupId>
    <artifactId>quarkus-qpid-jms</artifactId>
</dependency>

我的 yml 属性文件

quarkus:
   qpid-jms: amqp:url:port
   username: username
   password: password

我有一堂课

import javax.enterprise.context.ApplicationScoped;
import javax.inject.Inject;
import javax.jms.ConnectionFactory;
import javax.jms.JMSContext;
import javax.jms.JMSRuntimeException;
import javax.jms.Session;
import org.apache.camel.Exchange;
import org.apache.camel.Proccesor;

@ApplicationScoped
public class JMSProducer implements Processor {
    @Inject
    ConnectionFactory connectionFactory;

    @Override
    public void process(Exchange exchange) throws Exception {
        try (JMSContext context = connectionFactory.createContext(Session.AUTO_ACKNOWLEDGE)){
            context.createProducer().send(context.createQueue("my_queue"), exchange.getMessage().getBody(String.class));
        } catch (JMSRuntimeException ex) {}
    }
}

在此之后,我在我的 apache 骆驼路线的过程中将这个类称为 bean。

我对这些问题很陌生,希望你能帮助我。

java apache-camel jms weblogic quarkus
© www.soinside.com 2019 - 2024. All rights reserved.