任何人都可以解释如何处理 JMS-Session 超时。在我的应用程序中,我正在使用 Hornetq,它在一段时间后工作正常,错误会出现(JMS-Session 超时)请帮助我。 公共(public) HornetQProducer() {
try {
ic = getInitialContext();
cf = (ConnectionFactory) ic.lookup("/ConnectionFactory");
queue = new HornetQQueue("ExampleQueue");
connection = cf.createConnection();
logger.info("Connection object of HornetQ <<<>>>>>>>" + connection);
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
messageProducer = session.createProducer(queue);
connection.start();
logger.info("Message Producer HornetQ....." + messageProducer);
} catch (NamingException e) {
e.printStackTrace();
} catch (JMSException e) {
e.printStackTrace();
}
}
谢谢
最佳答案
尝试像这样在 HornetQ 配置文件中配置连接工厂。
<connection-factory name="NettyConnectionFactory">
<xa>false</xa>
<connectors>
<connector-ref connector-name="netty"/>
</connectors>
<entries>
<entry name="/ConnectionFactory"/>
</entries>
<retry-interval>1000</retry-interval>
<retry-interval-multiplier>1.0</retry-interval-multiplier>
<reconnect-attempts>1</reconnect-attempts>
</connection-factory>
要处理 JMS 超时,请尝试使用 JMSException。
关于java - 如何使用 HornetQ 处理 JMS-Session 超时?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/9801144/