|
@@ -1,27 +1,5 @@
|
|
|
package com.uas.search.console.b2b.jms;
|
|
|
|
|
|
-import java.util.HashSet;
|
|
|
-import java.util.Map;
|
|
|
-import java.util.Properties;
|
|
|
-import java.util.concurrent.ConcurrentHashMap;
|
|
|
-
|
|
|
-import javax.jms.JMSException;
|
|
|
-import javax.jms.Message;
|
|
|
-import javax.jms.MessageConsumer;
|
|
|
-import javax.jms.MessageListener;
|
|
|
-import javax.jms.Queue;
|
|
|
-import javax.jms.QueueConnection;
|
|
|
-import javax.jms.QueueConnectionFactory;
|
|
|
-import javax.jms.Session;
|
|
|
-
|
|
|
-import org.apache.commons.lang.NullArgumentException;
|
|
|
-import org.slf4j.Logger;
|
|
|
-import org.slf4j.LoggerFactory;
|
|
|
-import org.springframework.beans.factory.InitializingBean;
|
|
|
-import org.springframework.beans.factory.annotation.Autowired;
|
|
|
-import org.springframework.stereotype.Service;
|
|
|
-import org.springframework.util.CollectionUtils;
|
|
|
-
|
|
|
import com.alibaba.druid.pool.DruidDataSource;
|
|
|
import com.alibaba.fastjson.JSONException;
|
|
|
import com.uas.search.console.b2b.DruidDBConfiguration;
|
|
@@ -29,10 +7,21 @@ import com.uas.search.console.b2b.model.ParsedQueueMessage;
|
|
|
import com.uas.search.console.b2b.service.IndexService;
|
|
|
import com.uas.search.console.b2b.util.SearchConstants;
|
|
|
import com.uas.search.console.b2b.util.SearchConstants.DataSourceQualifier;
|
|
|
-
|
|
|
+import com.uas.search.util.CollectionUtils;
|
|
|
import oracle.jms.AQjmsAdtMessage;
|
|
|
import oracle.jms.AQjmsFactory;
|
|
|
import oracle.jms.AQjmsSession;
|
|
|
+import org.slf4j.Logger;
|
|
|
+import org.slf4j.LoggerFactory;
|
|
|
+import org.springframework.beans.factory.InitializingBean;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+
|
|
|
+import javax.jms.*;
|
|
|
+import java.util.HashSet;
|
|
|
+import java.util.Map;
|
|
|
+import java.util.Properties;
|
|
|
+import java.util.concurrent.ConcurrentHashMap;
|
|
|
|
|
|
/**
|
|
|
* 对数据库的消息队列进行实时监听
|
|
@@ -219,7 +208,7 @@ public class AQListener implements InitializingBean {
|
|
|
*/
|
|
|
public boolean isRunning(DataSourceQualifier dataSourceQualifier) {
|
|
|
if (dataSourceQualifier == null) {
|
|
|
- throw new NullArgumentException("dataSourceQualifier");
|
|
|
+ throw new IllegalArgumentException("dataSourceQualifier 为空");
|
|
|
}
|
|
|
MessageConsumer consumer = consumers.get(dataSourceQualifier);
|
|
|
return consumer != null;
|