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 javax.jmdns.impl.tasks.Prober

        synchronized (this) {
            makeServiceNameUnique(info);
            services.put(info.getQualifiedName().toLowerCase(), info);
        }


        new /* Service */Prober(this).start(timer);
        try {
            synchronized (info) {
                while (info.getState().compareTo(DNSState.ANNOUNCED) < 0) {
                    info.wait();
                }

View Full Code Here

Examples of javax.jmdns.impl.tasks.Prober

                updateRecord(now, rec);
            }
        }


        if (hostConflictDetected || serviceConflictDetected) {
            new Prober(this).start(timer);
        }
    }

View Full Code Here

Examples of javax.jmdns.impl.tasks.Prober


            new Responder(this, in, addr, port).start();
        }


        if (hostConflictDetected || serviceConflictDetected) {
            new Prober(this).start(timer);
        }
    }

View Full Code Here

Examples of javax.jmdns.impl.tasks.state.Prober

         * (non-Javadoc)
         * @see javax.jmdns.impl.DNSTaskStarter#startProber()
         */
        @Override
        public void startProber() {
            new Prober(_jmDNSImpl).start(_stateTimer);
        }

View Full Code Here

Examples of org.mule.tck.probe.Prober

        MuleClient mc = new MuleClient(muleContext);
        mc.dispatch("vm://in5", "test", null);


        assertExceptionMessage(mc.request("vm://out5", FunctionalTestCase.RECEIVE_TIMEOUT));


        Prober prober = new PollingProber(5000, 100);
        prober.check(new Probe()
        {
            public boolean isSatisfied()
            {
                return !service.isStarted();
            }

View Full Code Here

Examples of org.mule.tck.probe.Prober

    public void testConsume() throws Exception
    {
        String feed = SampleFeed.feedAsString();
        muleContext.getClient().dispatch("vm://feed.in", feed, null);


        Prober prober = new PollingProber(10000, 100);
        prober.check(new Probe()
        {
            public boolean isSatisfied()
            {
                return counter.getCallbackCount() == ENTRIES_IN_RSS_FEED;
            }

View Full Code Here

Examples of org.mule.tck.probe.Prober

        assertEquals(ENTRIES_IN_RSS_FEED, counter.getCallbackCount());
    }


    private void waitForAllEntriesFromSampleFeedToArrive()
    {
        Prober prober = new PollingProber(10000, 100);
        prober.check(new Probe()
        {
            @Override
            public boolean isSatisfied()
            {
                return counter.getCallbackCount() == ENTRIES_IN_RSS_FEED;

View Full Code Here

Examples of org.mule.tck.probe.Prober

    }


    private void waitForTheNextPoll()
    {
        final int currentPollCount = pollCount.get();
        Prober prober = new PollingProber(2000, 100);
        prober.check(new Probe()
        {
            @Override
            public boolean isSatisfied()
            {
                return pollCount.get() > currentPollCount;

View Full Code Here

Examples of org.mule.tck.probe.Prober

    public void testConsumeFeedEntries() throws Exception
    {
        createSampleFeedFileInWorkDirectory();


        final EntryReceiver component = (EntryReceiver) getComponent("feedSplitterConsumer");
        Prober prober = new PollingProber(10000, 100);
        prober.check(new Probe()
        {
            public boolean isSatisfied()
            {
                return component.getCount() == SampleFeed.ENTRIES_IN_RSS_FEED;
            }

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

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.