@UriEndpoint(scheme="pulsar",
firstVersion="2.24.0",
title="Apache Pulsar",
syntax="pulsar:uri",
label="messaging")
public class PulsarEndpoint
extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
PulsarEndpoint(String uri,
String path,
PulsarConfiguration pulsarConfiguration,
PulsarComponent component,
org.apache.pulsar.client.api.PulsarClient pulsarClient) |
Modifier and Type | Method and Description |
---|---|
static PulsarEndpoint |
create(String uri,
String path,
PulsarConfiguration pulsarConfiguration,
PulsarComponent component,
org.apache.pulsar.client.api.PulsarClient pulsarClient) |
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Exchange |
createExchange() |
org.apache.camel.Producer |
createProducer() |
PulsarComponent |
getComponent() |
org.apache.pulsar.client.api.PulsarClient |
getPulsarClient() |
PulsarConfiguration |
getPulsarConfiguration() |
String |
getTopicUri() |
boolean |
isSingleton() |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public PulsarEndpoint(String uri, String path, PulsarConfiguration pulsarConfiguration, PulsarComponent component, org.apache.pulsar.client.api.PulsarClient pulsarClient) throws org.apache.pulsar.client.api.PulsarClientException
org.apache.pulsar.client.api.PulsarClientException
public static PulsarEndpoint create(String uri, String path, PulsarConfiguration pulsarConfiguration, PulsarComponent component, org.apache.pulsar.client.api.PulsarClient pulsarClient) throws org.apache.pulsar.client.api.PulsarClientException, IllegalArgumentException
org.apache.pulsar.client.api.PulsarClientException
IllegalArgumentException
public org.apache.camel.Producer createProducer()
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public org.apache.camel.Exchange createExchange()
createExchange
in interface org.apache.camel.Endpoint
createExchange
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.pulsar.client.api.PulsarClient getPulsarClient()
public PulsarConfiguration getPulsarConfiguration()
public String getTopicUri()
public PulsarComponent getComponent()
getComponent
in class org.apache.camel.impl.DefaultEndpoint
Apache Camel