|
@ -1,6 +1,6 @@
|
|
|
package com.yihu.jw.base.activemq;
|
|
|
|
|
|
import com.yihu.utils.context.SpringContextUtils;
|
|
|
import com.yihu.jw.lang.SpringContext;
|
|
|
import org.apache.activemq.ActiveMQConnectionFactory;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
@ -37,7 +37,7 @@ public class ConsumerRunner implements Runnable, ExceptionListener {
|
|
|
|
|
|
private void init() {
|
|
|
try {
|
|
|
ActiveMQConnectionFactory connectionFactory = SpringContextUtils.getService(ActiveMQConnectionFactory.class);
|
|
|
ActiveMQConnectionFactory connectionFactory = SpringContext.getService(ActiveMQConnectionFactory.class);
|
|
|
// Create a Connection
|
|
|
connection = connectionFactory.createQueueConnection();
|
|
|
connection.start();
|
|
@ -55,7 +55,7 @@ public class ConsumerRunner implements Runnable, ExceptionListener {
|
|
|
}
|
|
|
|
|
|
private void recover() throws JMSException {
|
|
|
ActiveMQConnectionFactory connectionFactory = SpringContextUtils.getService(ActiveMQConnectionFactory.class);
|
|
|
ActiveMQConnectionFactory connectionFactory = SpringContext.getService(ActiveMQConnectionFactory.class);
|
|
|
// Create a Connection
|
|
|
connection = connectionFactory.createQueueConnection();
|
|
|
connection.start();
|