Package org.wso2.carbon.tomcat

Examples of org.wso2.carbon.tomcat.BetterTomcat.start()

45
46
47
48
49
50
51
52
53
54
55
        try {
            CarbonRepositoryUtils.persistConfiguration(config, tenantId);
            DeploymentSynchronizer synchronizer = CarbonRepositoryUtils.
                    newCarbonRepositorySynchronizer(tenantId);
            if (synchronizer != null) {
                synchronizer.start();
            } else {
                String msg = "Unable to create a deployment synchronizer instance";
                log.warn(msg);
                throw new DeploymentSynchronizerException(msg);
            }
View Full Code Here
20
21
22
23
24
25
26
27
28
29
30
        String repoLocation = "/home/hemapani/playground/events/wso2carbon-3.2.0-SNAPSHOT/repository";
       
        String confFile = repoLocation + "/conf/axis2_client.xml";
       
        SimpleMessageReceiver messageReceiver = new SimpleMessageReceiver(repoLocation, confFile,null);
        messageReceiver.start();
       
        BrokerClient brokerClient = new BrokerClient("http://127.0.0.1:9763/services/EventBrokerService");
        //brokerClient.subscribe(topic, messageReceiver.getListenerUrl());
       
        brokerClient.subscribe(topic, "http://parakum:6666/axis2/services/MessageCollector/receive/");
View Full Code Here
29
30
31
32
33
34
35
36
37
38
39
                public void mesageReceived(SOAPEnvelope envelope) {
                    System.out.println("recevied "+ envelope);
                   
                }
            });
            messageReceiver.start();
           
            //Initialize the broker
            //BrokerClient brokerClient = new BrokerClient("http://127.0.0.1:9763/services/EventBrokerService");
            BrokerClient brokerClient = new BrokerClient("https://127.0.0.1:9443/services/EventBrokerService", "admin", "admin");
           
View Full Code Here
28
29
30
31
32
33
34
35
36
37
38
        public void mesageReceived(SOAPEnvelope envelope) {
            System.out.println("recevied "+ envelope);
           
        }
    });
    messageReceiver.start();
   
    //Initialize the broker
    //BrokerClient brokerClient = new BrokerClient("http://127.0.0.1:9763/services/EventBrokerService");
    BrokerClient brokerClient = new BrokerClient("https://127.0.0.1:9443/services/EventBrokerService", "admin", "admin");
   
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
            start trying load balancing between endpoints written in to the file.
         */
        if (!CarbonUtils.isChildNode()) {
            EndPointManager endPointManager = new EndPointManager();
            try {
                endPointManager.start();
            } catch (Exception e) {
                log.error("Error Occure while running Multiple Instance Port updator", e);
            }
        }
    }
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54

    public void testServer() throws ServletException, LifecycleException, BetterTomcatException {
        BetterTomcat tomcat = new BetterTomcat(8080);
        tomcat.addWebapp("/hello", WEBAPP_PATH);
        tomcat.start();
    }

    public void stop(BundleContext bundleContext) throws Exception {
        if (serviceRegistration != null) {
            serviceRegistration.unregister();
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
    @Override
    public void successfulScenario() throws RemoteException {
        updateESBConfiguration("/soap_2_pox.xml");
        SimpleHttpServer httpServer = new SimpleHttpServer();
        try {
            httpServer.start();
        } catch (IOException e) {
            handleError("Error while starting the HTTP server", e);
        }

        TestRequestInterceptor interceptor = new TestRequestInterceptor();
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
    public void successfulScenario() throws RemoteException {
        updateESBConfiguration("/pass_thru.xml");

        SimpleHttpServer httpServer = new SimpleHttpServer();
        try {
            httpServer.start();
            makeGET(new URL(getMainSequenceURL() + "/foo/bar/service?wsdl"));

        } catch (IOException e) {
            handleError("Error while running the GET request test", e);
        } finally {
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
    public void successfulScenario() throws RemoteException {
        updateESBConfiguration("/query_param.xml");

        SimpleHttpServer httpServer = new SimpleHttpServer();
        try {
            httpServer.start();
            makeGET(new URL(getProxyServiceURL("ParamManipulationProxy", false) + "?MyParam=TestValue"));

        } catch (IOException e) {
            handleError("Error while running the GET request test", e);
        } finally {
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
    public void successfulScenario() throws RemoteException {
        updateESBConfiguration("/get_request.xml");

        SimpleHttpServer httpServer = new SimpleHttpServer();
        try {
            httpServer.start();
            TestRequestInterceptor interceptor = new TestRequestInterceptor();
            httpServer.getRequestHandler().setInterceptor(interceptor);

            String path = "/foo/bar";
            String query1 = "?param1=value1";
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.