有人能解释一下如何处理jms会话超时吗?在我的应用程序中使用hornetq,它在一段时间后工作正常,错误将会出现(jms会话超时),请帮助我。
公共大黄蜂生产者{
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。