org.apache.camel.component.vertx
Class VertxEndpoint

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultEndpoint
          extended by org.apache.camel.component.vertx.VertxEndpoint
All Implemented Interfaces:
org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

@UriEndpoint(scheme="vertx",
             consumerClass=VertxConsumer.class)
public class VertxEndpoint
extends org.apache.camel.impl.DefaultEndpoint

A Camel Endpoint for working with vert.x event bus endpoints


Field Summary
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
VertxEndpoint(String uri, VertxComponent component, String address)
           
 
Method Summary
 org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
           
 org.apache.camel.Producer createProducer()
           
 String getAddress()
           
 VertxComponent getComponent()
           
 org.vertx.java.core.eventbus.EventBus getEventBus()
           
 Boolean getPubSub()
           
 org.vertx.java.core.Vertx getVertx()
           
 boolean isPubSub()
           
 boolean isSingleton()
           
 void setAddress(String address)
          Sets the event bus address used to communicate
 void setPubSub(Boolean pubSub)
           
 
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString
 
Methods inherited from class org.apache.camel.support.ServiceSupport
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

VertxEndpoint

public VertxEndpoint(String uri,
                     VertxComponent component,
                     String address)
Method Detail

getComponent

public VertxComponent getComponent()
Overrides:
getComponent in class org.apache.camel.impl.DefaultEndpoint

createProducer

public org.apache.camel.Producer createProducer()
                                         throws Exception
Throws:
Exception

createConsumer

public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
                                         throws Exception
Throws:
Exception

isSingleton

public boolean isSingleton()

getEventBus

public org.vertx.java.core.eventbus.EventBus getEventBus()

getVertx

public org.vertx.java.core.Vertx getVertx()

getAddress

public String getAddress()

isPubSub

public boolean isPubSub()

getPubSub

public Boolean getPubSub()

setPubSub

public void setPubSub(Boolean pubSub)

setAddress

public void setAddress(String address)
Sets the event bus address used to communicate



Apache Camel