public class RequestProducer extends Object
Constructor and Description |
---|
RequestProducer(DataDescriptor dataDescriptor,
int maxOutstandingRequests) |
Modifier and Type | Method and Description |
---|---|
void |
produce(Consumer<Message> messageConsumer,
MessageContext context) |
public RequestProducer(DataDescriptor dataDescriptor, int maxOutstandingRequests)
public void produce(Consumer<Message> messageConsumer, MessageContext context)
Copyright © 2016–2021. All rights reserved.