public class OnsConsumerHandler
extends java.lang.Object
implements com.aliyun.openservices.ons.api.MessageListener
构造器和说明 |
---|
OnsConsumerHandler(OnsConfig config,
CloudEventObserverManger observerManger) |
public OnsConsumerHandler(OnsConfig config, CloudEventObserverManger observerManger)
public com.aliyun.openservices.ons.api.Action consume(com.aliyun.openservices.ons.api.Message message, com.aliyun.openservices.ons.api.ConsumeContext consumeContext)
consume
在接口中 com.aliyun.openservices.ons.api.MessageListener
protected boolean onReceive(Event event, java.lang.String topicNew) throws java.lang.Throwable
java.lang.Throwable