123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873 |
- 2023-02-26 15:52:10.394 [MQTT Call: plane-inspection-9062] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- com.alibaba.fastjson.JSONException: can not cast to JSONObject.
- at com.alibaba.fastjson.JSON.parseObject(JSON.java:244)
- at com.alibaba.fastjson.JSONObject.getJSONObject(JSONObject.java:127)
- at com.keystar.plane.inspection.mqtt.RecognizeMqttHandler.handle(RecognizeMqttHandler.java:46)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: java.lang.ClassCastException: java.lang.Integer cannot be cast to com.alibaba.fastjson.JSONObject
- at com.alibaba.fastjson.JSON.parseObject(JSON.java:242)
- ... 8 common frames omitted
- 2023-02-26 15:52:53.144 [MQTT Ping: plane-inspection-9062] ERROR o.eclipse.paho.client.mqttv3.internal.ClientState - plane-inspection-9062: Timed out as no write activity, keepAlive=5,000,000,000 lastOutboundActivity=714,283,495,491,000 lastInboundActivity=714,285,476,608,000 time=714,298,028,497,900 lastPing=714,283,495,497,700
- 2023-02-26 15:53:19.727 [MQTT Call: plane-inspection-9062] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- com.alibaba.fastjson.JSONException: can not cast to JSONObject.
- at com.alibaba.fastjson.JSON.parseObject(JSON.java:244)
- at com.alibaba.fastjson.JSONObject.getJSONObject(JSONObject.java:127)
- at com.keystar.plane.inspection.mqtt.RecognizeMqttHandler.handle(RecognizeMqttHandler.java:46)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: java.lang.ClassCastException: java.lang.Integer cannot be cast to com.alibaba.fastjson.JSONObject
- at com.alibaba.fastjson.JSON.parseObject(JSON.java:242)
- ... 8 common frames omitted
- 2023-02-26 16:01:06.868 [MQTT Ping: plane-inspection-9062] ERROR o.eclipse.paho.client.mqttv3.internal.ClientState - plane-inspection-9062: Timed out as no write activity, keepAlive=5,000,000,000 lastOutboundActivity=714,391,264,875,800 lastInboundActivity=714,792,957,058,800 time=714,792,957,056,400 lastPing=714,391,264,879,700
- 2023-02-26 16:01:08.277 [MQTT Call: plane-inspection-9062] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- com.alibaba.fastjson.JSONException: can not cast to JSONObject.
- at com.alibaba.fastjson.JSON.parseObject(JSON.java:244)
- at com.alibaba.fastjson.JSONObject.getJSONObject(JSONObject.java:127)
- at com.keystar.plane.inspection.mqtt.RecognizeMqttHandler.handle(RecognizeMqttHandler.java:46)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: java.lang.ClassCastException: java.lang.Integer cannot be cast to com.alibaba.fastjson.JSONObject
- at com.alibaba.fastjson.JSON.parseObject(JSON.java:242)
- ... 8 common frames omitted
- 2023-02-26 16:01:52.548 [MQTT Call: plane-inspection-9062] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'planeMqttHandler': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)
- at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:208)
- at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
- at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:224)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveNamedBean(DefaultListableBeanFactory.java:1119)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveBean(DefaultListableBeanFactory.java:411)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:344)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:337)
- at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1123)
- at com.keystar.mqtt.handler.HandlerContext.getInstance(HandlerContext.java:28)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:38)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- 2023-02-26 16:01:52.560 [MQTT Call: plane-inspection-9062] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
- at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
- at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
- at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
- at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
- at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
- at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
- at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
- at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:235)
- at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
- at java.util.Optional.orElseGet(Optional.java:267)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
- at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
- at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
- ... 19 common frames omitted
- Caused by: java.lang.IllegalStateException: executor not accepting a task
- at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:60)
- at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:200)
- at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:49)
- at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:188)
- at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:174)
- at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:502)
- at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:476)
- at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:415)
- at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:540)
- at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:529)
- at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:101)
- at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1009)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:517)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:428)
- at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:487)
- at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
- at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
- at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
- at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
- at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
- at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
- at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
- ... 1 common frames omitted
- 2023-02-26 16:01:53.048 [MQTT Call: plane-inspection-9062] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
- at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
- at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
- at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
- at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
- at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
- at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
- at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
- at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:235)
- at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
- at java.util.Optional.orElseGet(Optional.java:267)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
- at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
- at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
- ... 19 common frames omitted
- Caused by: java.lang.IllegalStateException: executor not accepting a task
- at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:60)
- at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:200)
- at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:49)
- at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:188)
- at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:174)
- at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:502)
- at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:476)
- at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:415)
- at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:540)
- at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:529)
- at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:101)
- at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1009)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:517)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:428)
- at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:487)
- at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
- at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
- at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
- at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
- at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
- at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
- at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
- ... 1 common frames omitted
- 2023-02-26 16:01:53.563 [MQTT Call: plane-inspection-9062] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'planeMqttHandler': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)
- at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:208)
- at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
- at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:224)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveNamedBean(DefaultListableBeanFactory.java:1119)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveBean(DefaultListableBeanFactory.java:411)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:344)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:337)
- at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1123)
- at com.keystar.mqtt.handler.HandlerContext.getInstance(HandlerContext.java:28)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:38)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- 2023-02-26 16:01:53.578 [MQTT Call: plane-inspection-9062] ERROR i.n.u.concurrent.DefaultPromise.rejectedExecution - Failed to submit a listener notification task. Event loop shut down?
- java.util.concurrent.RejectedExecutionException: event executor terminated
- at io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:846)
- at io.netty.util.concurrent.SingleThreadEventExecutor.offerTask(SingleThreadEventExecutor.java:329)
- at io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:322)
- at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:757)
- at io.netty.util.concurrent.DefaultPromise.safeExecute(DefaultPromise.java:766)
- at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:423)
- at io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:152)
- at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:95)
- at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:30)
- at io.lettuce.core.AbstractRedisClient.initializeChannelAsync0(AbstractRedisClient.java:324)
- at io.lettuce.core.AbstractRedisClient.lambda$initializeChannelAsync$0(AbstractRedisClient.java:295)
- at reactor.core.publisher.LambdaMonoSubscriber.onNext(LambdaMonoSubscriber.java:137)
- at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
- at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
- at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
- at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1515)
- at reactor.core.publisher.MonoCallable.subscribe(MonoCallable.java:61)
- at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
- at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
- at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
- at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
- at reactor.core.publisher.Mono.subscribe(Mono.java:3848)
- at reactor.core.publisher.Mono.subscribeWith(Mono.java:3954)
- at reactor.core.publisher.Mono.subscribe(Mono.java:3842)
- at reactor.core.publisher.Mono.subscribe(Mono.java:3809)
- at reactor.core.publisher.Mono.subscribe(Mono.java:3781)
- at io.lettuce.core.AbstractRedisClient.initializeChannelAsync(AbstractRedisClient.java:290)
- at io.lettuce.core.RedisClient.connectStatefulAsync(RedisClient.java:314)
- at io.lettuce.core.RedisClient.connectStandaloneAsync(RedisClient.java:271)
- at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
- at java.util.Optional.orElseGet(Optional.java:267)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
- at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
- at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
- at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
- at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
- at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
- at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
- at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- 2023-02-26 16:03:03.807 [MQTT Ping: plane-inspection-8395] ERROR o.eclipse.paho.client.mqttv3.internal.ClientState - plane-inspection-8395: Timed out as no activity, keepAlive=5,000,000,000 lastOutboundActivity=714,879,050,235,000 lastInboundActivity=714,879,050,811,200 time=714,887,167,904,100 lastPing=714,879,050,240,900
- 2023-02-26 16:03:03.809 [MQTT Call: plane-inspection-8395] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- com.alibaba.fastjson.JSONException: can not cast to JSONObject.
- at com.alibaba.fastjson.JSON.parseObject(JSON.java:244)
- at com.alibaba.fastjson.JSONObject.getJSONObject(JSONObject.java:127)
- at com.keystar.plane.inspection.mqtt.RecognizeMqttHandler.handle(RecognizeMqttHandler.java:46)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: java.lang.ClassCastException: java.lang.Integer cannot be cast to com.alibaba.fastjson.JSONObject
- at com.alibaba.fastjson.JSON.parseObject(JSON.java:242)
- ... 8 common frames omitted
- 2023-02-26 16:03:53.359 [MQTT Call: plane-inspection-8395] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'planeMqttHandler': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)
- at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:208)
- at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
- at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:224)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveNamedBean(DefaultListableBeanFactory.java:1119)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveBean(DefaultListableBeanFactory.java:411)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:344)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:337)
- at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1123)
- at com.keystar.mqtt.handler.HandlerContext.getInstance(HandlerContext.java:28)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:38)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- 2023-02-26 16:03:53.469 [MQTT Call: plane-inspection-8395] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
- at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
- at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
- at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
- at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
- at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
- at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
- at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
- at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:235)
- at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
- at java.util.Optional.orElseGet(Optional.java:267)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
- at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
- at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
- ... 19 common frames omitted
- Caused by: java.lang.IllegalStateException: executor not accepting a task
- at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:60)
- at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:200)
- at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:49)
- at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:188)
- at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:174)
- at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:502)
- at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:476)
- at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:415)
- at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:540)
- at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:529)
- at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:101)
- at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1009)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:517)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:428)
- at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:487)
- at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
- at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
- at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
- at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
- at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
- at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
- at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
- ... 1 common frames omitted
- 2023-02-26 16:03:53.863 [MQTT Call: plane-inspection-8395] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
- at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
- at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
- at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
- at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
- at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
- at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
- at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
- at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:235)
- at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
- at java.util.Optional.orElseGet(Optional.java:267)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
- at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
- at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
- ... 19 common frames omitted
- Caused by: java.lang.IllegalStateException: executor not accepting a task
- at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:60)
- at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:200)
- at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:49)
- at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:188)
- at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:174)
- at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:502)
- at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:476)
- at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:415)
- at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:540)
- at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:529)
- at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:101)
- at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1009)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:517)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:428)
- at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:487)
- at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
- at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
- at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
- at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
- at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
- at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
- at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
- ... 1 common frames omitted
- 2023-02-26 16:03:54.359 [MQTT Call: plane-inspection-8395] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'planeMqttHandler': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)
- at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:208)
- at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
- at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:224)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveNamedBean(DefaultListableBeanFactory.java:1119)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveBean(DefaultListableBeanFactory.java:411)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:344)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:337)
- at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1123)
- at com.keystar.mqtt.handler.HandlerContext.getInstance(HandlerContext.java:28)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:38)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- 2023-02-26 16:03:54.362 [MQTT Call: plane-inspection-8395] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
- at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
- at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
- at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
- at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
- at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
- at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
- at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
- at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:235)
- at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
- at java.util.Optional.orElseGet(Optional.java:267)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
- at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
- at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
- ... 19 common frames omitted
- Caused by: java.lang.IllegalStateException: executor not accepting a task
- at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:60)
- at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:200)
- at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:49)
- at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:188)
- at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:174)
- at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:502)
- at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:476)
- at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:415)
- at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:540)
- at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:529)
- at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:101)
- at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1009)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:517)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:428)
- at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:487)
- at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
- at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
- at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
- at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
- at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
- at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
- at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
- ... 1 common frames omitted
- 2023-02-26 16:03:54.868 [MQTT Call: plane-inspection-8395] ERROR i.n.u.concurrent.DefaultPromise.rejectedExecution - Failed to submit a listener notification task. Event loop shut down?
- java.util.concurrent.RejectedExecutionException: event executor terminated
- at io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:846)
- at io.netty.util.concurrent.SingleThreadEventExecutor.offerTask(SingleThreadEventExecutor.java:329)
- at io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:322)
- at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:757)
- at io.netty.util.concurrent.DefaultPromise.safeExecute(DefaultPromise.java:766)
- at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:423)
- at io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:152)
- at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:95)
- at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:30)
- at io.lettuce.core.AbstractRedisClient.initializeChannelAsync0(AbstractRedisClient.java:324)
- at io.lettuce.core.AbstractRedisClient.lambda$initializeChannelAsync$0(AbstractRedisClient.java:295)
- at reactor.core.publisher.LambdaMonoSubscriber.onNext(LambdaMonoSubscriber.java:137)
- at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
- at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
- at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
- at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1515)
- at reactor.core.publisher.MonoCallable.subscribe(MonoCallable.java:61)
- at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
- at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
- at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
- at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
- at reactor.core.publisher.Mono.subscribe(Mono.java:3848)
- at reactor.core.publisher.Mono.subscribeWith(Mono.java:3954)
- at reactor.core.publisher.Mono.subscribe(Mono.java:3842)
- at reactor.core.publisher.Mono.subscribe(Mono.java:3809)
- at reactor.core.publisher.Mono.subscribe(Mono.java:3781)
- at io.lettuce.core.AbstractRedisClient.initializeChannelAsync(AbstractRedisClient.java:290)
- at io.lettuce.core.RedisClient.connectStatefulAsync(RedisClient.java:314)
- at io.lettuce.core.RedisClient.connectStandaloneAsync(RedisClient.java:271)
- at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
- at java.util.Optional.orElseGet(Optional.java:267)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
- at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
- at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
- at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
- at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
- at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
- at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
- at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- 2023-02-26 16:04:32.548 [MQTT Ping: plane-inspection-301] ERROR o.eclipse.paho.client.mqttv3.internal.ClientState - plane-inspection-301: Timed out as no write activity, keepAlive=5,000,000,000 lastOutboundActivity=714,986,109,119,700 lastInboundActivity=714,998,634,340,100 time=714,998,634,404,400 lastPing=714,986,109,122,700
- 2023-02-26 16:10:01.061 [MQTT Call: plane-inspection-301] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- java.lang.NullPointerException: null
- at com.keystar.plane.inspection.mqtt.RecognizeMqttHandler.handle(RecognizeMqttHandler.java:53)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- 2023-02-26 16:10:01.605 [MQTT Call: plane-inspection-301] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is java.lang.IllegalStateException: Pool not open
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
- at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
- at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
- at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
- at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
- at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: java.lang.IllegalStateException: Pool not open
- at org.apache.commons.pool2.impl.BaseGenericObjectPool.assertOpen(BaseGenericObjectPool.java:713)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:411)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
- ... 19 common frames omitted
- 2023-02-26 16:10:01.606 [MQTT Call: plane-inspection-301] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'planeMqttHandler': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)
- at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:208)
- at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
- at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:224)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveNamedBean(DefaultListableBeanFactory.java:1119)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveBean(DefaultListableBeanFactory.java:411)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:344)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:337)
- at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1123)
- at com.keystar.mqtt.handler.HandlerContext.getInstance(HandlerContext.java:28)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:38)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- 2023-02-26 16:11:23.920 [MQTT Ping: plane-inspection-6523] ERROR o.eclipse.paho.client.mqttv3.internal.ClientState - plane-inspection-6523: Timed out as no activity, keepAlive=5,000,000,000 lastOutboundActivity=715,403,664,433,100 lastInboundActivity=715,402,750,043,700 time=715,410,008,556,500 lastPing=715,403,664,472,900
- 2023-02-26 16:12:19.989 [MQTT Call: plane-inspection-6523] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'planeMqttHandler': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)
- at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:208)
- at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
- at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:224)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveNamedBean(DefaultListableBeanFactory.java:1119)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveBean(DefaultListableBeanFactory.java:411)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:344)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:337)
- at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1123)
- at com.keystar.mqtt.handler.HandlerContext.getInstance(HandlerContext.java:28)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:38)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- 2023-02-26 16:12:20.000 [MQTT Call: plane-inspection-6523] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
- at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
- at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
- at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
- at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
- at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
- at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
- at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
- at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:235)
- at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
- at java.util.Optional.orElseGet(Optional.java:267)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
- at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
- at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
- ... 19 common frames omitted
- Caused by: java.lang.IllegalStateException: executor not accepting a task
- at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:60)
- at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:200)
- at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:49)
- at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:188)
- at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:174)
- at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:502)
- at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:476)
- at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:415)
- at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:540)
- at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:529)
- at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:101)
- at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1009)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:517)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:428)
- at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:487)
- at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
- at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
- at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
- at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
- at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
- at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
- at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
- ... 1 common frames omitted
- 2023-02-26 16:12:20.479 [MQTT Call: plane-inspection-6523] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
- at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
- at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
- at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
- at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
- at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
- at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
- at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
- at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:235)
- at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
- at java.util.Optional.orElseGet(Optional.java:267)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
- at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
- at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
- ... 19 common frames omitted
- Caused by: java.lang.IllegalStateException: executor not accepting a task
- at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:60)
- at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:200)
- at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:49)
- at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:188)
- at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:174)
- at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:502)
- at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:476)
- at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:415)
- at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:540)
- at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:529)
- at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:101)
- at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1009)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:517)
- at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:428)
- at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:487)
- at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
- at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
- at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
- at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
- at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
- at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
- at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
- ... 1 common frames omitted
- 2023-02-26 16:12:20.978 [MQTT Call: plane-inspection-6523] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
- org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'planeMqttHandler': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)
- at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:208)
- at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
- at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:224)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveNamedBean(DefaultListableBeanFactory.java:1119)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveBean(DefaultListableBeanFactory.java:411)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:344)
- at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:337)
- at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1123)
- at com.keystar.mqtt.handler.HandlerContext.getInstance(HandlerContext.java:28)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:38)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
- 2023-02-26 16:12:20.989 [MQTT Call: plane-inspection-6523] ERROR i.n.u.concurrent.DefaultPromise.rejectedExecution - Failed to submit a listener notification task. Event loop shut down?
- java.util.concurrent.RejectedExecutionException: event executor terminated
- at io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:846)
- at io.netty.util.concurrent.SingleThreadEventExecutor.offerTask(SingleThreadEventExecutor.java:329)
- at io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:322)
- at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:757)
- at io.netty.util.concurrent.DefaultPromise.safeExecute(DefaultPromise.java:766)
- at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:423)
- at io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:152)
- at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:95)
- at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:30)
- at io.lettuce.core.AbstractRedisClient.initializeChannelAsync0(AbstractRedisClient.java:324)
- at io.lettuce.core.AbstractRedisClient.lambda$initializeChannelAsync$0(AbstractRedisClient.java:295)
- at reactor.core.publisher.LambdaMonoSubscriber.onNext(LambdaMonoSubscriber.java:137)
- at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
- at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
- at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
- at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1515)
- at reactor.core.publisher.MonoCallable.subscribe(MonoCallable.java:61)
- at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
- at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
- at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
- at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
- at reactor.core.publisher.Mono.subscribe(Mono.java:3848)
- at reactor.core.publisher.Mono.subscribeWith(Mono.java:3954)
- at reactor.core.publisher.Mono.subscribe(Mono.java:3842)
- at reactor.core.publisher.Mono.subscribe(Mono.java:3809)
- at reactor.core.publisher.Mono.subscribe(Mono.java:3781)
- at io.lettuce.core.AbstractRedisClient.initializeChannelAsync(AbstractRedisClient.java:290)
- at io.lettuce.core.RedisClient.connectStatefulAsync(RedisClient.java:314)
- at io.lettuce.core.RedisClient.connectStandaloneAsync(RedisClient.java:271)
- at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
- at java.util.Optional.orElseGet(Optional.java:267)
- at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
- at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
- at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
- at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
- at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
- at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
- at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
- at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
- at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
- at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
- at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
- at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
- at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
- at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
- at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
- at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
- at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
- at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
- at java.lang.Thread.run(Thread.java:748)
|