@UriEndpoint(firstVersion="2.12.0", scheme="vertx", title="Vert.x", syntax="vertx:address", consumerClass=VertxConsumer.class, label="eventbus,reactive") public class VertxEndpoint extends org.apache.camel.impl.DefaultEndpoint implements org.apache.camel.AsyncEndpoint, org.apache.camel.MultipleConsumersSupport
Constructor and Description |
---|
VertxEndpoint(String uri,
VertxComponent component,
String address) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
String |
getAddress() |
VertxComponent |
getComponent() |
io.vertx.core.eventbus.EventBus |
getEventBus() |
Boolean |
getPubSub() |
io.vertx.core.Vertx |
getVertx() |
boolean |
isMultipleConsumersSupported() |
boolean |
isPubSub() |
boolean |
isSingleton() |
void |
setAddress(String address)
Sets the event bus address used to communicate
|
void |
setPubSub(Boolean pubSub)
Whether to use publish/subscribe instead of point to point when sending to a vertx endpoint.
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, 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
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public VertxEndpoint(String uri, VertxComponent component, String address)
public VertxComponent getComponent()
getComponent
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
Exception
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
public boolean isMultipleConsumersSupported()
isMultipleConsumersSupported
in interface org.apache.camel.MultipleConsumersSupport
public io.vertx.core.eventbus.EventBus getEventBus()
public io.vertx.core.Vertx getVertx()
public String getAddress()
public void setAddress(String address)
public boolean isPubSub()
public Boolean getPubSub()
public void setPubSub(Boolean pubSub)
Apache Camel