public class RocketmqProducer
extends java.lang.Object
implements java.io.Closeable
构造器和说明 |
---|
RocketmqProducer(RocketmqConfig config) |
public RocketmqProducer(RocketmqConfig config)
public boolean publish(CloudProps cloudProps, Event event, java.lang.String topic) 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