|
|
@@ -51,8 +51,8 @@ public class IotSubscribe { |
|
|
|
|
|
|
|
// 执行单元线程池 |
|
|
|
private final static ExecutorService executorService = new ThreadPoolExecutor( |
|
|
|
Runtime.getRuntime().availableProcessors() - 1, |
|
|
|
(Runtime.getRuntime().availableProcessors() -1)* 2, 60, TimeUnit.SECONDS, |
|
|
|
Runtime.getRuntime().availableProcessors() - 2, |
|
|
|
(Runtime.getRuntime().availableProcessors() -2)* 2, 60, TimeUnit.SECONDS, |
|
|
|
new LinkedBlockingQueue<>(50000)); |
|
|
|
// Jms连接侦听 |
|
|
|
private static JmsConnectionListener myJmsConnectionListener = new IotJmsConnectionListener(); |
|
|
|