List of saveItem() Examples

Examples of saveItem()

org.wso2.carbon.mediation.initializer.persistence.MediationPersistenceManager.saveItem()
Save changes made to a particular item of the mediation configuration. Changes are saved to the local file system and if required to the registry as well. Types of supported mediation configuration items are defined in ServiceBusConstants. If the item to be saved should be written to its own configuration file, the file name attribute must be set on the item (in the SynapseConfiguration). Leaving the file name as null will cause the item to be persisted into the top level synapse.xml file. @param name Name/ID of the configuration item @param itemType type of the configuration item

Examples of org.wso2.carbon.mediation.initializer.persistence.MediationPersistenceManager.saveItem()

        synapseConfig.addEndpoint(endpoint.getName(), endpoint);
        synapseConfig.addProxyService(proxy.getName(), proxy);


        MediationPersistenceManager pm = getMediationPersistenceManager();
        pm.saveItem(seq.getName(), ServiceBusConstants.ITEM_TYPE_SEQUENCE);
        pm.saveItem(endpoint.getName(), ServiceBusConstants.ITEM_TYPE_ENDPOINT);
        pm.saveItem(proxy.getName(), ServiceBusConstants.ITEM_TYPE_PROXY_SERVICE);


        hold();


        try {

View Full Code Here

Examples of org.wso2.carbon.mediation.initializer.persistence.MediationPersistenceManager.saveItem()

        synapseConfig.addProxyService(proxy.getName(), proxy);


        MediationPersistenceManager pm = getMediationPersistenceManager();
        pm.saveItem(seq.getName(), ServiceBusConstants.ITEM_TYPE_SEQUENCE);
        pm.saveItem(endpoint.getName(), ServiceBusConstants.ITEM_TYPE_ENDPOINT);
        pm.saveItem(proxy.getName(), ServiceBusConstants.ITEM_TYPE_PROXY_SERVICE);


        hold();


        try {
            File seqFile = new File(path + File.separator +

View Full Code Here

Examples of org.wso2.carbon.mediation.initializer.persistence.MediationPersistenceManager.saveItem()

                messageProcessor.init(getSynapseEnvironment());
                messageProcessor.setFileName(fileName);
                synapseConfiguration.addMessageProcessor(messageProcessor.getName(),
                        messageProcessor);
                MediationPersistenceManager mp = getMediationPersistenceManager();
                mp.saveItem(messageProcessor.getName(), ServiceBusConstants.ITEM_TYPE_MESSAGE_PROCESSOR);


            } else {
                String message = "Unable to create Message Processor ";
                handleException(log, message, null);
            }

View Full Code Here

Examples of org.wso2.carbon.mediation.initializer.persistence.MediationPersistenceManager.saveItem()

                String fileName = ServiceBusUtils.generateFileName(messageProcessor.getName());
                messageProcessor.setFileName(fileName);
                synapseConfiguration.addMessageProcessor(messageProcessor.getName(),
                        messageProcessor);
                MediationPersistenceManager mp = getMediationPersistenceManager();
                mp.saveItem(messageProcessor.getName(),ServiceBusConstants.ITEM_TYPE_MESSAGE_PROCESSOR);
            } else {
                String message = "Unable to Update Message Processor ";
                handleException(log, message, null);
            }

View Full Code Here

Examples of org.wso2.carbon.mediation.initializer.persistence.MediationPersistenceManager.saveItem()

    }


    private void persistTemplate(Template template) throws AxisFault {
       if (template instanceof Template) {
            MediationPersistenceManager pm = getMediationPersistenceManager();
            pm.saveItem(((Template) template).getName(), ServiceBusConstants.ITEM_TYPE_TEMPLATE_ENDPOINTS);
        }
    }




    private void handleException(String message, Throwable cause) throws AxisFault {

View Full Code Here

Examples of org.wso2.carbon.mediation.initializer.persistence.MediationPersistenceManager.saveItem()

        return (String[]) result.getContent();
    }


    private void persistEndpoint(Endpoint ep) throws EndpointAdminException {
        MediationPersistenceManager pm = getMediationPersistenceManager();
        pm.saveItem(ep.getName(), ServiceBusConstants.ITEM_TYPE_ENDPOINT);
    }


    private void assertNameNotEmpty(String endpointName) throws EndpointAdminException {
        if (endpointName == null || "".equals(endpointName.trim())) {
            handleFault("Invalid name : Name is empty.", null);

View Full Code Here

Examples of org.wso2.carbon.mediation.initializer.persistence.MediationPersistenceManager.saveItem()

*/


    private void persistTemplate(Mediator template) throws AxisFault {
       if (template instanceof TemplateMediator) {
            MediationPersistenceManager pm = getMediationPersistenceManager();
            pm.saveItem(((TemplateMediator) template).getName(), ServiceBusConstants.ITEM_TYPE_TEMPLATE);
        }
    }
}

View Full Code Here

Examples of org.wso2.carbon.mediation.initializer.persistence.MediationPersistenceManager.saveItem()

                            getSynapseConfiguration().getProperties());
                    entry.setFileName(ServiceBusUtils.generateFileName(entry.getKey()));
                    getSynapseConfiguration().addEntry(entryKey, entry);
                    MediationPersistenceManager pm
                            = ServiceBusUtils.getMediationPersistenceManager(getAxisConfig());
                    pm.saveItem(entry.getKey(), ServiceBusConstants.ITEM_TYPE_ENTRY);
                }
                if (log.isDebugEnabled()) {
                    log.debug("Local registry entry : " + entryKey + " added to the configuration");
                }
                return true;

View Full Code Here

Examples of org.wso2.carbon.mediation.initializer.persistence.MediationPersistenceManager.saveItem()

                            getSynapseConfiguration().getProperties());
                    getSynapseConfiguration().addEntry(key, entry);
                    entry.setFileName(oldEntry.getFileName());
                    MediationPersistenceManager pm
                            = ServiceBusUtils.getMediationPersistenceManager(getAxisConfig());
                    pm.saveItem(key, ServiceBusConstants.ITEM_TYPE_ENTRY);


                    if (log.isDebugEnabled()) {
                        log.debug("Added local entry : " + key + " into the configuration");
                    }
                }

View Full Code Here

0 1

TOP

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.