public final class PulsarUtils extends Object
static Queue<org.apache.pulsar.client.api.Consumer<byte[]>>
stopConsumers(Queue<org.apache.pulsar.client.api.Consumer<byte[]>> consumers)
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public static Queue<org.apache.pulsar.client.api.Consumer<byte[]>> stopConsumers(Queue<org.apache.pulsar.client.api.Consumer<byte[]>> consumers) throws org.apache.pulsar.client.api.PulsarClientException
org.apache.pulsar.client.api.PulsarClientException
Apache Camel