Package org.mule.tck.probe

Examples of org.mule.tck.probe.Prober

20
21
22
23
24
25
26
27
28
29
30
31
32
33
    protected void assertOnlyOneThreadWaiting(final List<String> messages, CountDownLatch latch)
    {
        boolean failure = false;

        Prober prober = new PollingProber(RECEIVE_TIMEOUT, 50);
        try
        {
            prober.check(new Probe()
            {
                private final int count = 1;

                @Override
                public boolean isSatisfied()
View Full Code Here
2306
2307
2308
2309
2310
2311
2312
2313
2314
2315
2316
2317
        assertStatus(artifactName, ApplicationStatus.STARTED);
    }

    private void assertDeploymentSuccess(final DeploymentListener listener, final String artifactName)
    {
        Prober prober = new PollingProber(DEPLOYMENT_TIMEOUT, 100);
        prober.check(new Probe()
        {
            public boolean isSatisfied()
            {
                try
                {
View Full Code Here
2331
2332
2333
2334
2335
2336
2337
2338
2339
2340
2341
2342
        });
    }

    private void assertMuleContextCreated(final DeploymentListener listener, final String appName)
    {
        Prober prober = new PollingProber(DEPLOYMENT_TIMEOUT, 100);
        prober.check(new Probe()
        {
            public boolean isSatisfied()
            {
                try
                {
View Full Code Here
2356
2357
2358
2359
2360
2361
2362
2363
2364
2365
2366
2367
        });
    }

    private void assertMuleContextInitialized(final DeploymentListener listener, final String appName)
    {
        Prober prober = new PollingProber(DEPLOYMENT_TIMEOUT, 100);
        prober.check(new Probe()
        {
            public boolean isSatisfied()
            {
                try
                {
View Full Code Here
2381
2382
2383
2384
2385
2386
2387
2388
2389
2390
2391
2392
        });
    }

    private void assertMuleContextConfigured(final DeploymentListener listener, final String appName)
    {
        Prober prober = new PollingProber(DEPLOYMENT_TIMEOUT, 100);
        prober.check(new Probe()
        {
            public boolean isSatisfied()
            {
                try
                {
View Full Code Here
2406
2407
2408
2409
2410
2411
2412
2413
2414
2415
2416
2417
        });
    }

    private void assertUndeploymentSuccess(final DeploymentListener listener, final String appName)
    {
        Prober prober = new PollingProber(DEPLOYMENT_TIMEOUT, 100);
        prober.check(new Probe()
        {
            public boolean isSatisfied()
            {
                try
                {
View Full Code Here
2462
2463
2464
2465
2466
2467
2468
2469
2470
2471
2472
2473
        assertStatus(app, status);
    }

    private void assertStatus(final Application application, final ApplicationStatus status)
    {
        Prober prober = new PollingProber(DEPLOYMENT_TIMEOUT, 100);
        prober.check(new JUnitProbe()
        {
            @Override
            protected boolean test() throws Exception
            {
                assertThat(application.getStatus(), is(status));
View Full Code Here
2484
2485
2486
2487
2488
2489
2490
2491
2492
2493
2494
2495
    }

    private void assertDeploymentFailure(final DeploymentListener listener, final String artifactName, final VerificationMode mode)
    {
        Prober prober = new PollingProber(DEPLOYMENT_TIMEOUT, 100);
        prober.check(new Probe()
        {
            public boolean isSatisfied()
            {
                try
                {
View Full Code Here
2511
2512
2513
2514
2515
2516
2517
2518
2519
2520
2521
2522
2523
2524
    private void assertNoDeploymentInvoked(final DeploymentListener deploymentListener)
    {
        //TODO(pablo.kraan): look for a better way to test this
        boolean invoked;
        Prober prober = new PollingProber(DeploymentDirectoryWatcher.DEFAULT_CHANGES_CHECK_INTERVAL_MS * 2, 100);
        try
        {
            prober.check(new Probe()
            {
                public boolean isSatisfied()
                {
                    try
                    {
View Full Code Here
2803
2804
2805
2806
2807
2808
2809
2810
2811
        return new File(artifactDir, anchorFileName);
    }

    private void assertAppFolderIsDeleted(String appName)
    {
        Prober prober = new PollingProber(DEPLOYMENT_TIMEOUT, 100);
        File appFolder = new File(appsDir, appName);
        prober.check(new FileDoesNotExists(appFolder));
    }
View Full Code Here
TOP

Related Classes of org.mule.tck.probe.Prober

  • org.mule.context.notification.FailingNotificationListenerTestCase
  • org.mule.endpoint.outbound.DynamicOutboundEndpointTestCase
  • org.mule.module.cxf.employee.MtomClientTestCase
  • org.mule.module.cxf.jaxws.JettyTestCase
  • org.mule.module.launcher.DeploymentServiceTestCase
  • org.mule.module.rss.FeedConsumeAndSplitExplicitNonHttpTestCase
  • org.mule.module.rss.FeedConsumeAndSplitTestCase
  • org.mule.module.rss.FileRssFeedConsumeTestCase
  • org.mule.routing.correlation.EventCorrelatorTestCase
  • org.mule.routing.correlation.EventProcessingThreadTestCase
    • Copyright © 2018 www.massapicom. 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.