我在 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。
我对这些问题很陌生,希望你能帮助我。