@Startup @ApplicationScoped public class KieServerIntegration extends Object
Modifier and Type | Field and Description |
---|---|
protected static String |
SERVER_TEMPLATE_KEY |
Constructor and Description |
---|
KieServerIntegration() |
Modifier and Type | Method and Description |
---|---|
List<Object> |
broadcastToKieServers(String serverTemplateId,
Function<org.kie.server.client.KieServicesClient,Object> operation) |
protected void |
buildClientsForServer(org.kie.server.controller.api.model.spec.ServerTemplate serverTemplate) |
void |
createAvailableClients() |
protected org.kie.server.client.KieServicesClient |
createClientForTemplate(org.kie.server.controller.api.model.spec.ServerTemplate serverTemplate,
ClassLoader classLoader,
org.kie.server.client.CredentialsProvider credentialsProvider) |
org.kie.server.client.KieServicesClient |
getAdminServerClient(String serverTemplateId,
String serverInstanceId) |
org.kie.server.client.KieServicesClient |
getAdminServerClientCheckEndpoints(String serverTemplateId) |
protected org.kie.server.client.KieServicesClient |
getClient(String url) |
org.kie.server.client.KieServicesClient |
getServerClient(String serverTemplateId) |
org.kie.server.client.KieServicesClient |
getServerClient(String serverTemplateId,
String containerId) |
protected Map<String,org.kie.server.controller.api.model.runtime.ServerInstanceKey> |
getServerInstancesById() |
protected Map<String,Map<String,org.kie.server.client.KieServicesClient>> |
getServerTemplatesClients() |
protected void |
indexServerInstances(org.kie.server.controller.api.model.spec.ServerTemplate serverTemplate) |
void |
onServerInstanceConnected(org.kie.server.controller.api.model.events.ServerInstanceConnected serverInstanceConnected) |
void |
onServerInstanceDisconnected(org.kie.server.controller.api.model.events.ServerInstanceDisconnected serverInstanceDisconnected) |
void |
onServerTemplateDeleted(org.kie.server.controller.api.model.events.ServerTemplateDeleted serverTemplateDeleted) |
void |
onServerTemplateUpdated(org.kie.server.controller.api.model.events.ServerTemplateUpdated serverTemplateUpdated) |
protected void |
removeServerInstancesFromIndex(String serverTemplateId) |
protected void |
setKieServices(org.kie.api.KieServices kieServices) |
protected void |
setKieServicesClientProviders(List<org.kie.server.controller.impl.client.KieServicesClientProvider> providers) |
void |
stop() |
protected void |
updateOrBuildClient(org.kie.server.client.KieServicesClient client,
org.kie.server.controller.api.model.runtime.ServerInstance serverInstance) |
protected static final String SERVER_TEMPLATE_KEY
@PostConstruct public void createAvailableClients()
@PreDestroy public void stop()
protected void setKieServices(org.kie.api.KieServices kieServices)
public org.kie.server.client.KieServicesClient getServerClient(String serverTemplateId)
public org.kie.server.client.KieServicesClient getServerClient(String serverTemplateId, String containerId)
public org.kie.server.client.KieServicesClient getAdminServerClient(String serverTemplateId, String serverInstanceId)
public org.kie.server.client.KieServicesClient getAdminServerClientCheckEndpoints(String serverTemplateId)
protected void indexServerInstances(org.kie.server.controller.api.model.spec.ServerTemplate serverTemplate)
protected void removeServerInstancesFromIndex(String serverTemplateId)
public void onServerTemplateUpdated(@Observes org.kie.server.controller.api.model.events.ServerTemplateUpdated serverTemplateUpdated)
public void onServerTemplateDeleted(@Observes org.kie.server.controller.api.model.events.ServerTemplateDeleted serverTemplateDeleted)
public void onServerInstanceDisconnected(@Observes org.kie.server.controller.api.model.events.ServerInstanceDisconnected serverInstanceDisconnected)
public void onServerInstanceConnected(@Observes org.kie.server.controller.api.model.events.ServerInstanceConnected serverInstanceConnected)
public List<Object> broadcastToKieServers(String serverTemplateId, Function<org.kie.server.client.KieServicesClient,Object> operation)
protected org.kie.server.client.KieServicesClient getClient(String url)
protected void updateOrBuildClient(org.kie.server.client.KieServicesClient client, org.kie.server.controller.api.model.runtime.ServerInstance serverInstance)
protected void buildClientsForServer(org.kie.server.controller.api.model.spec.ServerTemplate serverTemplate)
protected org.kie.server.client.KieServicesClient createClientForTemplate(org.kie.server.controller.api.model.spec.ServerTemplate serverTemplate, ClassLoader classLoader, org.kie.server.client.CredentialsProvider credentialsProvider)
protected Map<String,Map<String,org.kie.server.client.KieServicesClient>> getServerTemplatesClients()
protected Map<String,org.kie.server.controller.api.model.runtime.ServerInstanceKey> getServerInstancesById()
protected void setKieServicesClientProviders(List<org.kie.server.controller.impl.client.KieServicesClientProvider> providers)
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.