diff --git a/jero-boot/jero-cloud-module/jero-cloud-system-start/src/main/java/com/jero/modules/cloud/lock/DemoLockTest.java b/jero-boot/jero-cloud-module/jero-cloud-system-start/src/main/java/com/jero/modules/cloud/lock/DemoLockTest.java index 0b4c8afb..15c51103 100644 --- a/jero-boot/jero-cloud-module/jero-cloud-system-start/src/main/java/com/jero/modules/cloud/lock/DemoLockTest.java +++ b/jero-boot/jero-cloud-module/jero-cloud-system-start/src/main/java/com/jero/modules/cloud/lock/DemoLockTest.java @@ -1,16 +1,14 @@ package com.jero.modules.cloud.lock; import com.jero.boot.starter.lock.annotation.JLock; -import lombok.extern.slf4j.Slf4j; import com.jero.boot.starter.lock.client.RedissonLockClient; import com.jero.boot.starter.rabbitmq.client.RabbitMqClient; import com.jero.common.base.BaseMap; import com.jero.modules.cloud.constant.CloudConstant; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; -import java.util.HashMap; import java.util.Map; /** @@ -34,7 +32,7 @@ public class DemoLockTest { log.info("执行execute任务开始,休眠三秒"); Thread.sleep(3000); log.info("=======================业务逻辑1============================="); - Map map = new BaseMap(); + Map map = new BaseMap(); map.put("orderId", "BJ0001"); rabbitMqClient.sendMessage(CloudConstant.MQ_JERO_PLACE_ORDER, map); //延迟10秒发送 @@ -44,6 +42,7 @@ public class DemoLockTest { } public DemoLockTest() { + // do other } /**