Examples of com.volantis.shared.dependency.DependencyContext.addDependency()

Class com.volantis.shared.dependency.DependencyContext

Examples of com.volantis.shared.dependency.DependencyContext.addDependency()

com.volantis.shared.dependency.DependencyContext.addDependency()
Add a dependency to the tracker. @param dependency The dependency to add.


        try {
            // Add the dependency information for this value to the pipeline.
            DependencyContext dependencyContext =
                    context.getDependencyContext();
            dependencyContext.addDependency(dependency);


            XMLProcess process;


            // Select the process to which the content should be sent based
            // on whether it needs to be processed through the dynamic pipeline

View Full Code Here

        if (xmlPipelineContext != null) {
            final DependencyContext dependencyContext =
                xmlPipelineContext.getDependencyContext();
            if (dependencyContext != null &&
                    dependencyContext.isTrackingDependencies()) {
                dependencyContext.addDependency(dependency);
            }
        }
        return respAccessor;
    }

View Full Code Here

                    if (xmlPipelineContext != null) {
                        final DependencyContext dependencyContext =
                            xmlPipelineContext.getDependencyContext();
                        if (dependencyContext != null &&
                                dependencyContext.isTrackingDependencies()) {
                            dependencyContext.addDependency(
                                UncacheableDependency.getInstance());
                        }
                    }
                    return new HTTPClientResponseAccessor(method, statusCode);
                } catch (IOException e) {

View Full Code Here

            final DependencyContext dependencyContext =
                context.getDependencyContext();
            if (dependencyContext != null &&
                dependencyContext.isTrackingDependencies()) {


                dependencyContext.addDependency(content.getDependency());
            }


            // perform the inclusion
            reader.parse(source);

View Full Code Here

            final DependencyContext dependencyContext =
                context.getDependencyContext();
            if (dependencyContext != null &&
                dependencyContext.isTrackingDependencies()) {


                dependencyContext.addDependency(content.getDependency());
            }
        } catch (UnsupportedEncodingException uee) {
            // get hold of the current locator
            Locator currentLocator =
                    context.getCurrentLocator();

View Full Code Here

        }


        Dependency dependency = new TestDependency(
                cacheability, timeToLive, freshness, revalidated);


        dependencyContext.addDependency(dependency);


        return null;
    }


    public void endElement(

View Full Code Here

                cacheable ? Cacheability.CACHEABLE : Cacheability.UNCACHEABLE;


        Dependency dependency = new TestDependency(cacheability, timeToLive,
                freshness, revalidated);
        DependencyContext dependencyContext = context.getDependencyContext();
        dependencyContext.addDependency(dependency);


        ExpressionFactory factory = context.getFactory();
        return factory.createStringValue("freshness = " + freshness + ", " +
                "revalidate = " + revalidated + ", " +
                "cacheable = " + cacheable + ", " +

View Full Code Here

                state = CacheBodyOperationProcessState.PLAYBACK_AND_SUPPRESS;


                // add the dependency to the dependency context
                final DependencyContext dependencyContext =
                    getPipelineContext().getDependencyContext();
                dependencyContext.addDependency(value.getDependency());
            } else {


                // We should check to see if this thread is responsible for
                // updating the cached result.
                final CacheEntry entry = async.getEntry();

View Full Code Here

                                SystemClock.getDefaultInstance();
                            final Time currentTime = clock.getCurrentTime();
                            final PipelineCacheState pcs =
                                new PipelineCacheState(currentTime.addPeriod(
                                    dependency.getTimeToLive()));
                            dependencyContext.addDependency(dependency);


                            // update the cache with the old value so other
                            // threads don't need to wait the timeout period
                            ProviderResult result = new ProviderResult(
                                value, group, true, pcs);

View Full Code Here

                dependency = new FixedTTLDependency(
                    clock, cacheControl.getTimeToLive());
            } else {
                dependency = dependencyContext.extractDependency();
            }
            dependencyContext.addDependency(dependency);


            // Set the result to cachable based on the inErrorRecoveryMode
            // state.
            final PipelineCacheState pcs = new PipelineCacheState(
                clock.getCurrentTime().addPeriod(dependency.getTimeToLive()));

View Full Code Here

0 1

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.