public class CamelKieServerExtension extends Object implements org.kie.server.services.api.KieServerExtension
Modifier and Type | Field and Description |
---|---|
protected org.apache.camel.impl.DefaultCamelContext |
camelContext |
protected CamelContextBuilder |
camelContextBuilder |
protected Map<String,org.apache.camel.impl.DefaultCamelContext> |
camelContexts |
static String |
EXTENSION_NAME |
protected boolean |
managedCamel |
Constructor and Description |
---|
CamelKieServerExtension() |
CamelKieServerExtension(CamelContextBuilder camelContextBuilder) |
CamelKieServerExtension(org.apache.camel.impl.DefaultCamelContext camelContext) |
CamelKieServerExtension(org.apache.camel.impl.DefaultCamelContext camelContext,
CamelContextBuilder camelContextBuilder) |
Modifier and Type | Method and Description |
---|---|
protected void |
annotateKJarRoutes(org.apache.camel.model.RoutesDefinition routes,
String deploymentId) |
protected org.apache.camel.CamelContext |
buildDeploymentContext(String identifier,
ClassLoader classloader) |
protected org.apache.camel.CamelContext |
buildGlobalContext() |
void |
createContainer(String id,
org.kie.server.services.api.KieContainerInstance kieContainerInstance,
Map<String,Object> parameters) |
void |
destroy(org.kie.server.services.impl.KieServerImpl kieServer,
org.kie.server.services.api.KieServerRegistry registry) |
protected CamelContextBuilder |
discoverCamelContextBuilder() |
void |
disposeContainer(String id,
org.kie.server.services.api.KieContainerInstance kieContainerInstance,
Map<String,Object> parameters) |
<T> T |
getAppComponents(Class<T> serviceType) |
List<Object> |
getAppComponents(org.kie.server.services.api.SupportedTransports type) |
org.apache.camel.impl.DefaultCamelContext |
getCamelContext() |
CamelContextBuilder |
getCamelContextBuilder() |
String |
getExtensionName() |
String |
getImplementedCapability() |
List<Object> |
getServices() |
Integer |
getStartOrder() |
void |
init(org.kie.server.services.impl.KieServerImpl kieServer,
org.kie.server.services.api.KieServerRegistry registry) |
boolean |
isActive() |
boolean |
isInitialized() |
boolean |
isUpdateContainerAllowed(String id,
org.kie.server.services.api.KieContainerInstance kieContainerInstance,
Map<String,Object> parameters) |
void |
serverStarted() |
String |
toString() |
void |
updateContainer(String id,
org.kie.server.services.api.KieContainerInstance kieContainerInstance,
Map<String,Object> parameters) |
public static final String EXTENSION_NAME
protected org.apache.camel.impl.DefaultCamelContext camelContext
protected boolean managedCamel
protected CamelContextBuilder camelContextBuilder
public CamelKieServerExtension()
public CamelKieServerExtension(CamelContextBuilder camelContextBuilder)
public CamelKieServerExtension(org.apache.camel.impl.DefaultCamelContext camelContext)
public CamelKieServerExtension(org.apache.camel.impl.DefaultCamelContext camelContext, CamelContextBuilder camelContextBuilder)
public boolean isInitialized()
isInitialized
in interface org.kie.server.services.api.KieServerExtension
public boolean isActive()
isActive
in interface org.kie.server.services.api.KieServerExtension
public void init(org.kie.server.services.impl.KieServerImpl kieServer, org.kie.server.services.api.KieServerRegistry registry)
init
in interface org.kie.server.services.api.KieServerExtension
public void destroy(org.kie.server.services.impl.KieServerImpl kieServer, org.kie.server.services.api.KieServerRegistry registry)
destroy
in interface org.kie.server.services.api.KieServerExtension
public void createContainer(String id, org.kie.server.services.api.KieContainerInstance kieContainerInstance, Map<String,Object> parameters)
createContainer
in interface org.kie.server.services.api.KieServerExtension
public void updateContainer(String id, org.kie.server.services.api.KieContainerInstance kieContainerInstance, Map<String,Object> parameters)
updateContainer
in interface org.kie.server.services.api.KieServerExtension
public boolean isUpdateContainerAllowed(String id, org.kie.server.services.api.KieContainerInstance kieContainerInstance, Map<String,Object> parameters)
isUpdateContainerAllowed
in interface org.kie.server.services.api.KieServerExtension
public void disposeContainer(String id, org.kie.server.services.api.KieContainerInstance kieContainerInstance, Map<String,Object> parameters)
disposeContainer
in interface org.kie.server.services.api.KieServerExtension
public List<Object> getAppComponents(org.kie.server.services.api.SupportedTransports type)
getAppComponents
in interface org.kie.server.services.api.KieServerExtension
public <T> T getAppComponents(Class<T> serviceType)
getAppComponents
in interface org.kie.server.services.api.KieServerExtension
public String getImplementedCapability()
getImplementedCapability
in interface org.kie.server.services.api.KieServerExtension
public List<Object> getServices()
getServices
in interface org.kie.server.services.api.KieServerExtension
public String getExtensionName()
getExtensionName
in interface org.kie.server.services.api.KieServerExtension
public Integer getStartOrder()
getStartOrder
in interface org.kie.server.services.api.KieServerExtension
public void serverStarted()
serverStarted
in interface org.kie.server.services.api.KieServerExtension
public org.apache.camel.impl.DefaultCamelContext getCamelContext()
public CamelContextBuilder getCamelContextBuilder()
protected void annotateKJarRoutes(org.apache.camel.model.RoutesDefinition routes, String deploymentId)
protected org.apache.camel.CamelContext buildGlobalContext()
protected org.apache.camel.CamelContext buildDeploymentContext(String identifier, ClassLoader classloader)
protected CamelContextBuilder discoverCamelContextBuilder()
Apache Camel