public interface ConsumerCreationStrategy
Modifier and Type | Method and Description |
---|---|
Collection<org.apache.pulsar.client.api.Consumer<byte[]>> |
create(PulsarEndpoint pulsarEndpoint) |
Collection<org.apache.pulsar.client.api.Consumer<byte[]>> create(PulsarEndpoint pulsarEndpoint) throws Exception
Exception
Apache Camel