diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/controller/RocketmqRecordController.java b/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/controller/RocketmqRecordController.java new file mode 100644 index 000000000..e69de29bb diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/entity/RocketmqRecord.java b/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/entity/RocketmqRecord.java new file mode 100644 index 000000000..e69de29bb diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/mapper/RocketmqRecordMapper.java b/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/mapper/RocketmqRecordMapper.java new file mode 100644 index 000000000..e69de29bb diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/mapper/xml/RocketmqRecordMapper.xml b/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/mapper/xml/RocketmqRecordMapper.xml new file mode 100644 index 000000000..e69de29bb diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/service/RocketmqRecordService.java b/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/service/RocketmqRecordService.java new file mode 100644 index 000000000..e69de29bb diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/service/impl/RocketmqRecordServiceImpl.java b/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/service/impl/RocketmqRecordServiceImpl.java new file mode 100644 index 000000000..e69de29bb diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQConsumerConfiguration.java b/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQConsumerConfiguration.java new file mode 100644 index 000000000..a0fbf99eb --- /dev/null +++ b/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQConsumerConfiguration.java @@ -0,0 +1,2 @@ +package com.fuint.common.config;public class MQConsumerConfiguration { +} diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQProducerConfiguration.java b/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQProducerConfiguration.java new file mode 100644 index 000000000..d94e3eaed --- /dev/null +++ b/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQProducerConfiguration.java @@ -0,0 +1,2 @@ +package com.fuint.common.config;public class MQProducerConfiguration { +} diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/RedissonConfig.java b/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/RedissonConfig.java new file mode 100644 index 000000000..4b8964338 --- /dev/null +++ b/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/RedissonConfig.java @@ -0,0 +1,2 @@ +package com.fuint.common.config;public class RedissonConfig { +} diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/DistributedLockUtil.java b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/DistributedLockUtil.java new file mode 100644 index 000000000..37de0baac --- /dev/null +++ b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/DistributedLockUtil.java @@ -0,0 +1,2 @@ +package com.fuint.common.util;public class DistributedLockUtil { +} diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RedisLock.java b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RedisLock.java new file mode 100644 index 000000000..c49e465d9 --- /dev/null +++ b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RedisLock.java @@ -0,0 +1,2 @@ +package com.fuint.common.util;public class RedisLock { +} diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketSendCallbackListener.java b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketSendCallbackListener.java new file mode 100644 index 000000000..54439479b --- /dev/null +++ b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketSendCallbackListener.java @@ -0,0 +1,29 @@ +package com.ruoyi.rocket.utils; + +import com.alibaba.fastjson.JSONObject; +import lombok.extern.slf4j.Slf4j; +import org.apache.rocketmq.client.producer.SendCallback; +import org.apache.rocketmq.client.producer.SendResult; + +/** + * rocketmq异步回调监听 + */ +@Slf4j +public class SendCallbackListener implements SendCallback { + + private int id; + + public SendCallbackListener(int id) { + this.id = id; + } + + @Override + public void onSuccess(SendResult sendResult) { + log.info("CallBackListener on success11111111 : " + JSONObject.toJSONString(sendResult)); + } + + @Override + public void onException(Throwable throwable) { + log.error("CallBackListener on exception : ", throwable); + } +} \ No newline at end of file diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketUtil.java b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketUtil.java new file mode 100644 index 000000000..880c10233 --- /dev/null +++ b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketUtil.java @@ -0,0 +1,2 @@ +package com.fuint.common.util;public class RocketUtil { +} diff --git a/fuintBackend/fuint-application/src/test/java/aes.java b/fuintBackend/fuint-application/src/test/java/aes.java new file mode 100644 index 000000000..fadccbf89 --- /dev/null +++ b/fuintBackend/fuint-application/src/test/java/aes.java @@ -0,0 +1,2 @@ +package PACKAGE_NAME;public class aes { +}