我正在使用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 camel路由的一个进程中将这个类称为bean。
我是新手，希望你能帮助我。