public class ConsumerInvocation extends Object
| 构造器和说明 |
|---|
ConsumerInvocation(ConsumerConfig config,
String topic,
NameServerConfig nameServerConfig,
List<ConsumeMessage> messages,
ConsumerInterceptorManager consumerInterceptorManager,
ConsumerInvoker consumerInvoker) |
public ConsumerInvocation(ConsumerConfig config, String topic, NameServerConfig nameServerConfig, List<ConsumeMessage> messages, ConsumerInterceptorManager consumerInterceptorManager, ConsumerInvoker consumerInvoker)
public List<ConsumeReply> invoke()
Copyright © 2020 Joyqueue Community. All rights reserved.