Examples of org.apache.synapse.deployers.SynapseArtifactDeploymentStore

org.apache.synapse.deployers.SynapseArtifactDeploymentStore
Keeps track of the artifacts deployed with files inside the synapse repository

For hot deployment to properly work we need to, keep track fo not only the artifacts deployed by deployers but also the artifacts deployed from files at the startup as well. Otherwise it is not possible to track the hot update cases. This is introduced as a singleton for the startup to report back for the deployed artifacts at startup apart from the deployers.
@see org.apache.synapse.deployers.AbstractSynapseArtifactDeployer @see org.apache.synapse.config.xml.MultiXMLConfigurationBuilder

     * Get the existing configuration and mark those files not effect on deployers for
     * deletion
     * @param synapseConfig synapse configuration
     */
    private void markConfigurationForSerialization(SynapseConfiguration synapseConfig) {                
        SynapseArtifactDeploymentStore deploymentStore = synapseConfig.getArtifactDeploymentStore();


        for (SequenceMediator seq : synapseConfig.getDefinedSequences().values()) {
            if (seq.getFileName() != null) {
                handleDeployment(new File(rootDirectory, MultiXMLConfigurationBuilder.
                        SEQUENCES_DIR), seq.getFileName(), seq.getName(), deploymentStore);

View Full Code Here

     */
    private void registerDeployer(AxisConfiguration axisConfig, SynapseEnvironment synapseEnvironment)
            throws AxisFault {
        SynapseConfiguration synCfg = synapseEnvironment.getSynapseConfiguration();
        DeploymentEngine deploymentEngine = (DeploymentEngine) axisConfig.getConfigurator();
        SynapseArtifactDeploymentStore deploymentStore = synCfg.getArtifactDeploymentStore();


        String synapseConfigPath = ServiceBusUtils.getSynapseConfigAbsPath(
                synapseEnvironment.getServerContextInformation());
        String templateDirPath = synapseConfigPath
                + File.separator + MultiXMLConfigurationBuilder.TEMPLATES_DIR;


        for (TemplateMediator seqTempl : synCfg.getSequenceTemplates().values()) {
            if (seqTempl.getFileName() != null) {
                deploymentStore.addRestoredArtifact(
                        templateDirPath + File.separator + seqTempl.getFileName());
            }
        }


        for (Template epTempl : synCfg.getEndpointTemplates().values()) {
            if (epTempl.getFileName() != null) {
                deploymentStore.addRestoredArtifact(
                        templateDirPath + File.separator + epTempl.getFileName());
            }
        }
        deploymentEngine.addDeployer(new TemplateDeployer(),
                templateDirPath, ServiceBusConstants.ARTIFACT_EXTENSION);

View Full Code Here

     */
    private void registerDeployer(AxisConfiguration axisConfig, SynapseEnvironment synapseEnvironment)
            throws TenantAwareLoadBalanceEndpointException {
        SynapseConfiguration synCfg = synapseEnvironment.getSynapseConfiguration();
        DeploymentEngine deploymentEngine = (DeploymentEngine) axisConfig.getConfigurator();
        SynapseArtifactDeploymentStore deploymentStore = synCfg.getArtifactDeploymentStore();


        String synapseConfigPath = ServiceBusUtils.getSynapseConfigAbsPath(
                synapseEnvironment.getServerContextInformation());
        String endpointDirPath = synapseConfigPath
                + File.separator + MultiXMLConfigurationBuilder.ENDPOINTS_DIR;


        for (Endpoint ep : synCfg.getDefinedEndpoints().values()) {
            if (ep.getFileName() != null) {
                deploymentStore.addRestoredArtifact(
                        endpointDirPath + File.separator + ep.getFileName());
            }
        }
        deploymentEngine.addDeployer(
                new EndpointDeployer(), endpointDirPath, ServiceBusConstants.ARTIFACT_EXTENSION);

View Full Code Here

     */
    private void registerDeployer(AxisConfiguration axisConfig, SynapseEnvironment synapseEnvironment)
            throws LocalEntryAdminException {
        SynapseConfiguration synCfg = synapseEnvironment.getSynapseConfiguration();
        DeploymentEngine deploymentEngine = (DeploymentEngine) axisConfig.getConfigurator();
        SynapseArtifactDeploymentStore deploymentStore = synCfg.getArtifactDeploymentStore();


        String synapseConfigPath = ServiceBusUtils.getSynapseConfigAbsPath(
                synapseEnvironment.getServerContextInformation());
        String entriesDirPath = synapseConfigPath
                + File.separator + MultiXMLConfigurationBuilder.LOCAL_ENTRY_DIR;


        for (Entry entry : synCfg.getDefinedEntries().values()) {
            if (entry.getFileName() != null) {
                deploymentStore.addRestoredArtifact(
                        entriesDirPath + File.separator + entry.getFileName());
            }
        }
        deploymentEngine.addDeployer(new LocalEntryDeployer(),
                entriesDirPath, ServiceBusConstants.ARTIFACT_EXTENSION);

View Full Code Here

    }


    private void registerDeployer(AxisConfiguration axisConfig, SynapseEnvironment synEnv)
            throws ProxyAdminException {
        DeploymentEngine deploymentEngine = (DeploymentEngine) axisConfig.getConfigurator();
        SynapseArtifactDeploymentStore deploymentStore =
                synEnv.getSynapseConfiguration().getArtifactDeploymentStore();


        String synapseConfigPath = ServiceBusUtils.getSynapseConfigAbsPath(
                synEnv.getServerContextInformation());


        String proxyDirPath = synapseConfigPath
                + File.separator + MultiXMLConfigurationBuilder.PROXY_SERVICES_DIR;


        for (ProxyService proxyService : synEnv.getSynapseConfiguration().getProxyServices()) {
            if (proxyService.getFileName() != null) {
                deploymentStore.addRestoredArtifact(
                        proxyDirPath + File.separator + proxyService.getFileName());
            }
        }
        deploymentEngine.addDeployer(
                new ProxyServiceDeployer(), proxyDirPath, ServiceBusConstants.ARTIFACT_EXTENSION);

View Full Code Here

            throws TenantAwareLoadBalanceEndpointException {
        SynapseConfiguration synCfg = synapseEnvironment
                .getSynapseConfiguration();
        DeploymentEngine deploymentEngine = (DeploymentEngine) axisConfig
                .getConfigurator();
        SynapseArtifactDeploymentStore deploymentStore = synCfg
                .getArtifactDeploymentStore();


        String synapseConfigPath = ServiceBusUtils
                .getSynapseConfigAbsPath(synapseEnvironment
                        .getServerContextInformation());
        String endpointDirPath = synapseConfigPath + File.separator
                + MultiXMLConfigurationBuilder.ENDPOINTS_DIR;


        for (Endpoint ep : synCfg.getDefinedEndpoints().values()) {
            if (ep.getFileName() != null) {
                deploymentStore.addRestoredArtifact(endpointDirPath
                        + File.separator + ep.getFileName());
            }
        }
        deploymentEngine.addDeployer(new EndpointDeployer(), endpointDirPath,
                ServiceBusConstants.ARTIFACT_EXTENSION);

View Full Code Here

0 1

TOP

Related Classes of org.apache.synapse.deployers.SynapseArtifactDeploymentStore

org.apache.stratos.lb.endpoint.internal.LoadBalanceEndpointServiceComponent

org.apache.stratos.load.balancer.internal.LoadBalancerServiceComponent

org.apache.synapse.config.xml.MultiXMLConfigurationSerializer

org.wso2.carbon.endpoint.EndpointServiceComponent

org.wso2.carbon.eventing.eventsource.EventSourceServiceComponent

org.wso2.carbon.localentry.LocalEntryAdminServiceComponent

org.wso2.carbon.mediation.templates.internal.TemplateEditorServiceComponent

org.wso2.carbon.message.processor.MessageProcessorServiceComponent

org.wso2.carbon.message.store.MessageStoreAdminServiceComponent

org.wso2.carbon.priority.executors.PriorityServiceComponent

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.