public class RocketmqConsumer
extends java.lang.Object
implements java.io.Closeable
构造器和说明 |
---|
RocketmqConsumer(RocketmqConfig config) |
限定符和类型 | 方法和说明 |
---|---|
void |
close() |
void |
init(CloudProps cloudProps,
CloudEventObserverManger observerManger) |
public RocketmqConsumer(RocketmqConfig config)
public void init(CloudProps cloudProps, CloudEventObserverManger observerManger) throws org.apache.rocketmq.client.apis.ClientException
org.apache.rocketmq.client.apis.ClientException
public void close() throws java.io.IOException
close
在接口中 java.io.Closeable
close
在接口中 java.lang.AutoCloseable
java.io.IOException