| | |
|---|
| | | import com.ks.lucky.pojo.DTO.ActivityMQMsg; |
|---|
| | | import com.ks.lucky.remote.service.LuckyActivityOpenService; |
|---|
| | | import com.ks.lucky.service.impl.LuckyActivityManager; |
|---|
| | | import com.ks.lucky.util.mq.CMQConsumeRunner; |
|---|
| | | import com.ks.lucky.util.mq.CMQManager; |
|---|
| | | import com.ks.lucky.utils.mq.CMQConsumeRunner; |
|---|
| | | import org.yeshi.utils.mq.JobThreadExecutorServiceImpl; |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import java.util.Iterator; |
|---|
| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void start() { |
|---|
| | | while (true) { |
|---|
| | | new JobThreadExecutorServiceImpl().run(new Runnable() { |
|---|
| | | @Override |
|---|
| | | public void run() { |
|---|
| | | Map<String, ActivityMQMsg> map = CMQManager.getInstance().consumeActivityMsg(16); |
|---|
| | | if (map != null) { |
|---|
| | | for (Iterator<String> its = map.keySet().iterator(); its.hasNext(); ) { |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
