|
@@ -146,6 +146,7 @@ public class AcceptanceInboundHandlerAdapter extends ChannelInboundHandlerAdapt
|
|
|
public void onFailure(Throwable ex) {
|
|
|
// 失败业务逻辑
|
|
|
logger.error("发送kafka失败.deviceId:{}, msg:{}", key, msg);
|
|
|
+ singleThreadPool.execute(() -> dataStorage(msg));
|
|
|
}
|
|
|
};
|
|
|
listenableFuture.addCallback(successCallback, failureCallback);
|