public class ExclusiveConsumerStrategy 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) throws Exception
create
in interface ConsumerCreationStrategy
Exception
Apache Camel