Examples of MinConcurrencyTest

org.apache.axis2.transport.testkit.tests.misc.MinConcurrencyTest
Generic test case to check whether a transport listener processes messages with the expected level of concurrency. This test case is used to verify that the listener is able to process messages simultaneously.
The test case deploys a given number of services and sends a configurable number of messages to each of these services. The services are configured with a custom message receiver that blocks until the expected level of concurrency (given by the number of endpoints times the number of messages) is reached. If after some timeout the concurrency level is not reached, the test fails.

Examples of org.apache.axis2.transport.testkit.tests.misc.MinConcurrencyTest

        
        builder.addEchoEndpoint(new AxisEchoEndpoint());
        
        builder.build();
        
        suite.addTest(new MinConcurrencyTest(new MailChannel[] { new MailChannel(), new MailChannel() }, 2, true, new GreenMailTestEnvironment("pop3")));
        return suite;
    }

View Full Code Here

Examples of org.apache.axis2.transport.testkit.tests.misc.MinConcurrencyTest

        
        builder.addEchoEndpoint(new MockEchoEndpoint());
        builder.addEchoEndpoint(new AxisEchoEndpoint());


        for (JMSTestEnvironment env : new JMSTestEnvironment[] { new QpidTestEnvironment(), new ActiveMQTestEnvironment() }) {
            suite.addTest(new MinConcurrencyTest(new AsyncChannel[] {
                    new JMSAsyncChannel("endpoint1", JMSConstants.DESTINATION_TYPE_QUEUE, ContentTypeMode.TRANSPORT),
                    new JMSAsyncChannel("endpoint2", JMSConstants.DESTINATION_TYPE_QUEUE, ContentTypeMode.TRANSPORT) },
                    2, false, env, new JMSTransportDescriptionFactory(false, false, 2)));
        }

View Full Code Here

Examples of org.apache.axis2.transport.testkit.tests.misc.MinConcurrencyTest

        
        builder.addEchoEndpoint(new AxisEchoEndpoint());
        
        builder.build();
        
        suite.addTest(new MinConcurrencyTest(new MailChannel[] { new MailChannel(), new MailChannel() }, 2, true, new GreenMailTestEnvironment("pop3")));
        return suite;
    }

View Full Code Here

Examples of org.apache.axis2.transport.testkit.tests.misc.MinConcurrencyTest

        
        builder.addEchoEndpoint(new MockEchoEndpoint());
        builder.addEchoEndpoint(new AxisEchoEndpoint());


        for (JMSTestEnvironment env : new JMSTestEnvironment[] { new QpidTestEnvironment(), new ActiveMQTestEnvironment() }) {
            suite.addTest(new MinConcurrencyTest(new AsyncChannel[] {
                    new JMSAsyncChannel("endpoint1", JMSConstants.DESTINATION_TYPE_QUEUE, ContentTypeMode.TRANSPORT),
                    new JMSAsyncChannel("endpoint2", JMSConstants.DESTINATION_TYPE_QUEUE, ContentTypeMode.TRANSPORT) },
                    2, false, env, new JMSTransportDescriptionFactory(false, false, 2)));
        }

View Full Code Here

Examples of org.apache.axis2.transport.testkit.tests.misc.MinConcurrencyTest

        builder.addEchoEndpoint(new AxisEchoEndpoint());
        builder.addEchoEndpoint(new JettyEchoEndpoint());
        
        builder.build();
        
        suite.addTest(new MinConcurrencyTest(new AsyncChannel[] { new HttpChannel(), new HttpChannel() }, 2, false, tdf));
    }

View Full Code Here

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.