public class KieEndpoint
extends org.apache.camel.impl.DefaultEndpoint
Modifier and Type | Class and Description |
---|---|
static class |
KieEndpoint.Action
An ENUM to define which action should be executed by the
producer into this end point
|
Constructor and Description |
---|
KieEndpoint(String endpointUri,
String remaining,
KieComponent component) |
Modifier and Type | Method and Description |
---|---|
protected void |
configure(KieComponent component,
String uri) |
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Exchange |
createExchange(Object pojo) |
org.apache.camel.Producer |
createProducer() |
KieEndpoint.Action |
getAction() |
String |
getChannel() |
ClassLoader |
getClassLoader(org.kie.api.runtime.CommandExecutor exec) |
org.kie.api.runtime.CommandExecutor |
getCommandExecutor(String name) |
String |
getDataFormat() |
String |
getEntryPoint() |
org.kie.api.runtime.CommandExecutor |
getExecutor() |
String |
getKsessionId() |
static String |
getKsessionId(String uri) |
String |
getLookup(String body) |
boolean |
isSingleton() |
void |
setAction(KieEndpoint.Action action) |
void |
setAction(String action) |
void |
setChannel(String channel) |
void |
setDataFormat(String dataFormatName) |
void |
setEntryPoint(String entryPoint) |
void |
setKsessionId(String ksession) |
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 static final Pattern P
public KieEndpoint(String endpointUri, String remaining, KieComponent component) throws URISyntaxException
URISyntaxException
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public String getKsessionId()
public void setKsessionId(String ksession)
public org.kie.api.runtime.CommandExecutor getExecutor()
protected void configure(KieComponent component, String uri)
public String getDataFormat()
public void setDataFormat(String dataFormatName)
public org.kie.api.runtime.CommandExecutor getCommandExecutor(String name)
public ClassLoader getClassLoader(org.kie.api.runtime.CommandExecutor exec)
public KieEndpoint.Action getAction()
public void setAction(KieEndpoint.Action action)
public void setAction(String action)
public String getEntryPoint()
public void setEntryPoint(String entryPoint)
public String getChannel()
public void setChannel(String channel)
public org.apache.camel.Exchange createExchange(Object pojo)
Copyright © 2013–2016 JBoss by Red Hat. All rights reserved.