@UriEndpoint(scheme="spring-integration", title="Spring Integration", syntax="spring-integration:defaultChannel", consumerClass=SpringIntegrationConsumer.class, label="spring,eventbus") public class SpringIntegrationEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
SpringIntegrationEndpoint(String endpointUri,
org.springframework.messaging.MessageChannel messageChannel)
Deprecated.
|
SpringIntegrationEndpoint(String uri,
org.springframework.messaging.MessageChannel channel,
org.apache.camel.CamelContext context)
Deprecated.
|
SpringIntegrationEndpoint(String uri,
String channel,
SpringIntegrationComponent component) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
String |
getDefaultChannel() |
String |
getInputChannel() |
org.springframework.messaging.MessageChannel |
getMessageChannel()
Deprecated.
|
String |
getOutputChannel() |
boolean |
isInOut() |
boolean |
isSingleton() |
void |
setDefaultChannel(String defaultChannel)
The default channel name which is used by the Spring Integration Spring context.
|
void |
setInOut(boolean inOut)
The exchange pattern that the Spring integration endpoint should use.
|
void |
setInputChannel(String input)
The Spring integration input channel name that this endpoint wants to consume from Spring integration.
|
void |
setOutputChannel(String output)
The Spring integration output channel name that is used to send messages to Spring integration.
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, 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 SpringIntegrationEndpoint(String uri, String channel, SpringIntegrationComponent component)
@Deprecated public SpringIntegrationEndpoint(String uri, org.springframework.messaging.MessageChannel channel, org.apache.camel.CamelContext context)
@Deprecated public SpringIntegrationEndpoint(String endpointUri, org.springframework.messaging.MessageChannel messageChannel)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public void setInputChannel(String input)
public String getInputChannel()
public void setOutputChannel(String output)
public String getOutputChannel()
public void setDefaultChannel(String defaultChannel)
public String getDefaultChannel()
@Deprecated public org.springframework.messaging.MessageChannel getMessageChannel()
public boolean isSingleton()
public void setInOut(boolean inOut)
public boolean isInOut()
Apache Camel