public class SharedConsumerStrategy extends Object implements ConsumerCreationStrategy
Modifier and Type | Method and Description |
---|---|
Collection<org.apache.pulsar.client.api.Consumer<byte[]>> |
create(PulsarEndpoint pulsarEndpoint) |
public Collection<org.apache.pulsar.client.api.Consumer<byte[]>> create(PulsarEndpoint pulsarEndpoint)
create
in interface ConsumerCreationStrategy
Apache Camel