Class KieServerIntegration


  • @Startup
    @ApplicationScoped
    public class KieServerIntegration
    extends Object
    • Constructor Detail

      • KieServerIntegration

        public KieServerIntegration()
    • Method Detail

      • createAvailableClients

        @PostConstruct
        public void createAvailableClients()
      • setKieServices

        protected void setKieServices​(org.kie.api.KieServices kieServices)
      • getServerClient

        public org.kie.server.client.KieServicesClient getServerClient​(String serverTemplateId)
      • getServerClient

        public org.kie.server.client.KieServicesClient getServerClient​(String serverTemplateId,
                                                                       String containerId)
      • getAdminServerClient

        public org.kie.server.client.KieServicesClient getAdminServerClient​(String serverTemplateId,
                                                                            String serverInstanceId)
      • getAdminServerClientCheckEndpoints

        public org.kie.server.client.KieServicesClient getAdminServerClientCheckEndpoints​(String serverTemplateId)
      • indexServerInstances

        protected void indexServerInstances​(org.kie.server.controller.api.model.spec.ServerTemplate serverTemplate)
      • removeServerInstancesFromIndex

        protected void removeServerInstancesFromIndex​(String serverTemplateId)
      • onServerTemplateUpdated

        public void onServerTemplateUpdated​(@Observes
                                            org.kie.server.controller.api.model.events.ServerTemplateUpdated serverTemplateUpdated)
      • onServerTemplateDeleted

        public void onServerTemplateDeleted​(@Observes
                                            org.kie.server.controller.api.model.events.ServerTemplateDeleted serverTemplateDeleted)
      • onServerInstanceDisconnected

        public void onServerInstanceDisconnected​(@Observes
                                                 org.kie.server.controller.api.model.events.ServerInstanceDisconnected serverInstanceDisconnected)
      • onServerInstanceConnected

        public void onServerInstanceConnected​(@Observes
                                              org.kie.server.controller.api.model.events.ServerInstanceConnected serverInstanceConnected)
      • broadcastToKieServers

        public List<Object> broadcastToKieServers​(String serverTemplateId,
                                                  Function<org.kie.server.client.KieServicesClient,​Object> operation)
      • getClient

        protected org.kie.server.client.KieServicesClient getClient​(String url)
      • updateOrBuildClient

        protected void updateOrBuildClient​(org.kie.server.client.KieServicesClient client,
                                           org.kie.server.controller.api.model.runtime.ServerInstance serverInstance)
      • buildClientsForServer

        protected void buildClientsForServer​(org.kie.server.controller.api.model.spec.ServerTemplate serverTemplate)
      • createClientForTemplate

        protected org.kie.server.client.KieServicesClient createClientForTemplate​(org.kie.server.controller.api.model.spec.ServerTemplate serverTemplate,
                                                                                  ClassLoader classLoader,
                                                                                  org.kie.server.client.CredentialsProvider credentialsProvider)
      • getServerTemplatesClients

        protected Map<String,​Map<String,​org.kie.server.client.KieServicesClient>> getServerTemplatesClients()
      • getServerInstancesById

        protected Map<String,​org.kie.server.controller.api.model.runtime.ServerInstanceKey> getServerInstancesById()
      • setKieServicesClientProviders

        protected void setKieServicesClientProviders​(List<org.kie.server.controller.impl.client.KieServicesClientProvider> providers)