Examples of Prober

javax.jmdns.impl.tasks.Prober
The Prober sends three consecutive probes for all service infos that needs probing as well as for the host name. The state of each service info of the host name is advanced, when a probe has been sent for it. When the prober has run three times, it launches an Announcer.
If a conflict during probes occurs, the affected service infos (and affected host name) are taken away from the prober. This eventually causes the prober tho cancel itself.
javax.jmdns.impl.tasks.state.Prober
The Prober sends three consecutive probes for all service infos that needs probing as well as for the host name. The state of each service info of the host name is advanced, when a probe has been sent for it. When the prober has run three times, it launches an Announcer.
If a conflict during probes occurs, the affected service infos (and affected host name) are taken away from the prober. This eventually causes the prober to cancel itself.
org.mule.tck.probe.Prober
Checks wheter a given {@link Probe} is satisfied or not.
org.robotninjas.barge.utils.Prober
Repeatedly probe for some condition to become true.

Examples of org.mule.tck.probe.Prober

            if (!acceptCalledLath.await(WAIT_TIME, TimeUnit.MILLISECONDS))
            {
                fail("retry template should be executed");
            }


            Prober prober = new PollingProber(100, 1);
            prober.check(new Probe()
            {
                public boolean isSatisfied()
                {
                    try
                    {

View Full Code Here

Examples of org.mule.tck.probe.Prober


    }


    private void assertEventDispatched()
    {
        Prober prober = new PollingProber();
        prober.check(new Probe()
        {
            @Override
            public boolean isSatisfied()
            {
                return MyMessageDispatcherFactory.dispatcher != null && MyMessageDispatcherFactory.dispatcher.dispatchedEvent;

View Full Code Here

Examples of org.mule.tck.probe.Prober

        assertNotNull(MyMessageDispatcherFactory.dispatcher.sensedDispatchEvent.getMessage());
    }


    private void assertEventSent()
    {
        Prober prober = new PollingProber();
        prober.check(new Probe()
        {
            @Override
            public boolean isSatisfied()
            {
                return MyMessageDispatcherFactory.dispatcher != null && MyMessageDispatcherFactory.dispatcher.sentEvent;

View Full Code Here

Examples of org.mule.tck.probe.Prober


        eventCorrelator.start();


        try
        {
            Prober prober = new PollingProber(1000, 50);
            prober.check(new Probe() {
                public boolean isSatisfied()
                {
                    try
                    {
                        return !memoryObjectStore.contains(TEST_GROUP_ID);

View Full Code Here

Examples of org.mule.tck.probe.Prober

    {
        final TestEventProcessingThread processingThread = new TestEventProcessingThread("testEventProcessingThread", 1);
        try
        {
            processingThread.start();
            Prober prober = new PollingProber(100, 1);
            prober.check(new Probe()
            {
                public boolean isSatisfied()
                {
                    return processingThread.count > 1;
                }

View Full Code Here

Examples of org.mule.tck.probe.Prober

        assertAttachmentWasSaved();
    }
    
    private void assertAttachmentWasSaved()
    {
        Prober prober = new PollingProber(10000, 100);
        prober.check(new Probe()
        {
            public boolean isSatisfied()
            {
                // FIXME DZ: don't know why these are empty, so just compare the saved email
                // file to the expected content

View Full Code Here

Examples of org.mule.tck.probe.Prober


    }


    private void waitForPolls() 
    {
        Prober prober = new PollingProber(10000, 100);
        prober.check(new Probe()
        {
            private int requiredPollAttempts = numberOfMadePolls+3; // +3 should be safe
            @Override
            public boolean isSatisfied()
            {

View Full Code Here

Examples of org.mule.tck.probe.Prober

    @Test
    public void testEchoService() throws Exception
    {
        final EmployeeDirectoryImpl svc = (EmployeeDirectoryImpl) getComponent("employeeDirectoryService");


        Prober prober = new PollingProber(6000, 500);
        prober.check(new Probe()
        {
            @Override
            public boolean isSatisfied()
            {
                return (svc.getInvocationCount() == 1);

View Full Code Here

Examples of org.mule.tck.probe.Prober

    {
        assertThat(server.getReceivedMessages().length, is(equalTo(NUMBER_OF_MESSAGES)));


        flowExecutionListener.waitUntilFlowIsComplete();


        Prober prober = new PollingProber(TIMEOUT_MILLIS, POLL_DELAY_MILLIS);
        prober.check(new Probe()
        {
            @Override
            public boolean isSatisfied()
            {
                return (retrievedMessages.size() == NUMBER_OF_MESSAGES);

View Full Code Here

Examples of org.mule.tck.probe.Prober

        MuleMessage result = client.send("clientEndpoint", "Dan", props);
        assertEquals("Hello Dan", result.getPayload());


        final GreeterImpl impl = getGreeter();


        Prober prober = new PollingProber(5000, 100);
        prober.check(new GreeterNotNull(impl));


        assertEquals(1, impl.getInvocationCount());
    }

View Full Code Here

0 1 2 3 4

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.