package com.yeshi.fanli.util.rocketmq;
|
|
import org.springframework.stereotype.Component;
|
|
import com.aliyun.openservices.ons.api.Action;
|
import com.aliyun.openservices.ons.api.ConsumeContext;
|
import com.aliyun.openservices.ons.api.Message;
|
import com.aliyun.openservices.ons.api.MessageListener;
|
|
@Component
|
public class RocketMQMessageListener implements MessageListener {
|
|
public RocketMQMessageListener() {
|
|
}
|
|
@Override
|
public Action consume(Message message, ConsumeContext context) {
|
return null;
|
}
|
}
|