Examples of addEndpoint()


Examples of org.apache.synapse.config.SynapseConfiguration.addEndpoint()

        synapseConfig.addEntry(entry1.getKey(), entry1);
        synapseConfig.addEntry(entry2.getKey(), entry2);

        Endpoint endpoint = createEndpoint("endpoint");
        initEndpoint(endpoint, entry1.getKey());
        synapseConfig.addEndpoint(endpoint.getName(), endpoint);

        assertDependency(ConfigurationObject.TYPE_ENTRY, entry1.getKey(), endpoint.getName());
        synapseConfig.removeEndpoint(endpoint.getName());
        initEndpoint(endpoint, entry2.getKey());
        synapseConfig.addEndpoint(endpoint.getName(), endpoint);
View Full Code Here

Examples of org.apache.synapse.config.SynapseConfiguration.addEndpoint()

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

        assertDependency(ConfigurationObject.TYPE_ENTRY, entry1.getKey(), endpoint.getName());
        synapseConfig.removeEndpoint(endpoint.getName());
        initEndpoint(endpoint, entry2.getKey());
        synapseConfig.addEndpoint(endpoint.getName(), endpoint);
        assertNoDependency(ConfigurationObject.TYPE_ENTRY, entry1.getKey());
        assertDependency(ConfigurationObject.TYPE_ENTRY, entry2.getKey(), endpoint.getName());

        Endpoint endpoint2 = createEndpoint("endpoint2");
        initEndpoint(endpoint2, null);
View Full Code Here

Examples of org.apache.synapse.config.SynapseConfiguration.addEndpoint()

        assertNoDependency(ConfigurationObject.TYPE_ENTRY, entry1.getKey());
        assertDependency(ConfigurationObject.TYPE_ENTRY, entry2.getKey(), endpoint.getName());

        Endpoint endpoint2 = createEndpoint("endpoint2");
        initEndpoint(endpoint2, null);
        synapseConfig.addEndpoint(endpoint2.getName(), endpoint2);

        SequenceMediator seq1 = createSequence("seq1", null);
        SendMediator send = new SendMediator();
        IndirectEndpoint endpointRef = new IndirectEndpoint();
        endpointRef.setKey(endpoint.getName());
View Full Code Here

Examples of org.apache.synapse.mediators.builtin.SendMediator.addEndpoint()

        Iterator iter = elem.getChildrenWithName(new QName(Constants.SYNAPSE_NAMESPACE, "endpoint"));
        while (iter.hasNext()) {

            OMElement endptElem = (OMElement) iter.next();
            Endpoint endpt = EndpointFactory.createEndpoint(endptElem, true);
            sm.addEndpoint(endpt);
        }

        return sm;
    }
View Full Code Here

Examples of org.apache.synapse.mediators.builtin.SendMediator.addEndpoint()

        Iterator iter = elem.getChildrenWithName(new QName(Constants.SYNAPSE_NAMESPACE, "endpoint"));
        while (iter.hasNext()) {

            OMElement endptElem = (OMElement) iter.next();
            Endpoint endpt = EndpointFactory.createEndpoint(endptElem, true);
            sm.addEndpoint(endpt);
        }

        return sm;
    }
View Full Code Here

Examples of org.apache.tuscany.sca.registry.hazelcast.HazelcastDomainRegistry.addEndpoint()

        reg1.start();

        System.out.println("Adding ep1");
        RuntimeEndpoint ep1 = createEndpoint("ep1uri");
        ep1.bind(extensionPoints, reg1);
        reg1.addEndpoint(ep1);

        System.out.println("Starting reg3");
        HazelcastDomainRegistry reg2 = new HazelcastDomainRegistry(extensionPoints, (Properties)null, "tuscany:foo?bind=127.0.0.1:9877&multicast=off&wka=127.0.0.1:9876", "bar");
        reg2.start();
View Full Code Here

Examples of org.apache.tuscany.sca.runtime.DomainRegistry.addEndpoint()

            compositeContext.getAttributes().putAll(configuration.getAttributes());
           
            // Add endpoint descriptions from the node configuration if the domain registry is local
            if (!domainRegistry.isDistributed()) {
                for (Endpoint e : configuration.getEndpointDescriptions()) {
                    domainRegistry.addEndpoint(e);
                }
            }
            // Activate the composite
            compositeActivator.activate(compositeContext, domainComposite);
View Full Code Here

Examples of org.apache.vysper.xmpp.server.XMPPServer.addEndpoint()

            accountManagement.addUser("user3@vysper.org", "password1");
        }

        XMPPServer server = new XMPPServer("vysper.org");

        server.addEndpoint(new TCPEndpoint());

        BoshEndpoint boshEndpoint = new BoshEndpoint();
        boshEndpoint.setAccessControlAllowOrigin(Arrays.asList("*"));
        //        boshEndpoint.setSSLEnabled(true);
        //        boshEndpoint.setSSLCertificateInfo("src/main/resources/keystore",
View Full Code Here

Examples of org.apache.vysper.xmpp.server.XMPPServer.addEndpoint()

        BoshEndpoint boshEndpoint = new BoshEndpoint();
        boshEndpoint.setAccessControlAllowOrigin(Arrays.asList("*"));
        //        boshEndpoint.setSSLEnabled(true);
        //        boshEndpoint.setSSLCertificateInfo("src/main/resources/keystore",
        //                "password");
        server.addEndpoint(boshEndpoint);

        //server.addEndpoint(new StanzaSessionFactory());
        server.setStorageProviderRegistry(providerRegistry);

        server.setTLSCertificateInfo(new File("src/test/resources/bogus_mina_tls.cert"), "boguspw");
View Full Code Here

Examples of org.apache.vysper.xmpp.server.XMPPServer.addEndpoint()

        accountManagement.addUser("test@vysper.org", "password");
        accountManagement.addUser("test2@vysper.org", "password");

        XMPPServer server = new XMPPServer("vysper.org");
        server.addEndpoint(new TCPEndpoint());
        server.setStorageProviderRegistry(providerRegistry);

        server.setTLSCertificateInfo(new File("src/main/config/bogus_mina_tls.cert"), "boguspw");

        try {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.