Package org.openxri.config

Examples of org.openxri.config.PipelineRegistry


        }

        // check if the authority overrides the LOOKUP pipeline. if not, use the default.

        ServerConfig serverConfig = ServerConfigFactory.getSingleton();
        PipelineRegistry pipelineRegistry = (serverConfig == null) ? null : serverConfig.getPipelineRegistry();
        Pipeline lookupPipeline = null;

        if (this.store instanceof StoreAttributable) {

          StoreAttributable storeAttributable = (StoreAttributable) this.store;

          String pipelineName = storeAttributable.getAuthorityAttributes(namespaceAuthority).get(Pipeline.ATTRIBUTE_OVERRIDE_LOOKUP_PIPELINE);
          if (pipelineRegistry != null && pipelineName != null) lookupPipeline = pipelineRegistry.getPipelineByName(pipelineName);
        }

        if (pipelineRegistry != null && lookupPipeline == null) lookupPipeline = pipelineRegistry.getDefaultLookupPipeline();

        // execute LOOKUP pipeline

        xrd = lookupPipeline.execute(
            this.store,
View Full Code Here


        }

        // check if the parent authority overrides the LOOKUP pipeline. if not, use the default.

        ServerConfig serverConfig = ServerConfigFactory.getSingleton();
        PipelineRegistry pipelineRegistry = (serverConfig == null) ? null : serverConfig.getPipelineRegistry();
        Pipeline lookupPipeline = null;

        if (this.store instanceof StoreAttributable) {

          StoreAttributable storeAttributable = (StoreAttributable) this.store;

          String pipelineName = storeAttributable.getAuthorityAttributes(parentAuthority).get(Pipeline.ATTRIBUTE_OVERRIDE_LOOKUP_PIPELINE);
          if (pipelineRegistry != null && pipelineName != null) lookupPipeline = pipelineRegistry.getPipelineByName(pipelineName);
        }

        if (pipelineRegistry != null && lookupPipeline == null) lookupPipeline = pipelineRegistry.getDefaultLookupPipeline();

        // execute LOOKUP pipeline

        xrd = lookupPipeline.execute(
            this.store,
View Full Code Here

        }

        // check if the authority overrides the LOOKUP pipeline. if not, use the default.

        ServerConfig serverConfig = ServerConfigFactory.getSingleton();
        PipelineRegistry pipelineRegistry = (serverConfig == null) ? null : serverConfig.getPipelineRegistry();
        Pipeline lookupPipeline = null;

        if (this.store instanceof StoreAttributable) {

          StoreAttributable storeAttributable = (StoreAttributable) this.store;

          String pipelineName = storeAttributable.getAuthorityAttributes(authority).get(Pipeline.ATTRIBUTE_OVERRIDE_LOOKUP_PIPELINE);
          if (pipelineRegistry != null && pipelineName != null) lookupPipeline = pipelineRegistry.getPipelineByName(pipelineName);
        }

        if (pipelineRegistry != null && lookupPipeline == null) lookupPipeline = pipelineRegistry.getDefaultLookupPipeline();

        // execute LOOKUP pipeline

        xrd = lookupPipeline.execute(
            this.store,
View Full Code Here

    log.trace("createAuthority()");

    // use the default CREATE pipeline.

    ServerConfig serverConfig = ServerConfigFactory.getSingleton();
    PipelineRegistry pipelineRegistry = (serverConfig == null) ? null : serverConfig.getPipelineRegistry();
    Pipeline createPipeline = null;

    if (pipelineRegistry != null) createPipeline = pipelineRegistry.getDefaultCreatePipeline();

    // start database session

    Session session = this.getSessionFactory().getCurrentSession();
View Full Code Here

    log.trace("createRootSubSegment()");

    // use the default CREATE pipeline.

    ServerConfig serverConfig = ServerConfigFactory.getSingleton();
    PipelineRegistry pipelineRegistry = (serverConfig == null) ? null : serverConfig.getPipelineRegistry();
    Pipeline createPipeline = null;

    if (pipelineRegistry != null) createPipeline = pipelineRegistry.getDefaultCreatePipeline();

    // start database session

    Session session = this.getSessionFactory().getCurrentSession();
View Full Code Here

    if (! (parentAuthority instanceof DbAuthority)) throw new StoreNotFoundException("Parent authority is not from this store.");

    // check if the parent authority overrides the CREATE pipeline. if not, use the default.

    ServerConfig serverConfig = ServerConfigFactory.getSingleton();
    PipelineRegistry pipelineRegistry = (serverConfig == null) ? null : serverConfig.getPipelineRegistry();
    Pipeline createPipeline = null;

    String pipelineName = this.getAuthorityAttributes(parentAuthority).get(Pipeline.ATTRIBUTE_OVERRIDE_CREATE_PIPELINE);
    if (pipelineRegistry != null && pipelineName != null) createPipeline = pipelineRegistry.getPipelineByName(pipelineName);
    if (pipelineRegistry != null && createPipeline == null) createPipeline = pipelineRegistry.getDefaultCreatePipeline();

    // start database session

    Session session = this.getSessionFactory().getCurrentSession();
View Full Code Here

          break;
        }

        // check if the authority overrides the LOOKUP pipeline. if not, use the default.

        PipelineRegistry pipelineRegistry = (this.serverConfig == null) ? null : this.serverConfig.getPipelineRegistry();
        Pipeline lookupPipeline = null;

        if (this.store instanceof StoreAttributable) {

          StoreAttributable storeAttributable = (StoreAttributable) this.store;

          String pipelineName = storeAttributable.getAuthorityAttributes(namespaceAuthority).get(Pipeline.ATTRIBUTE_OVERRIDE_LOOKUP_PIPELINE);
          if (pipelineRegistry != null && pipelineName != null) lookupPipeline = pipelineRegistry.getPipelineByName(pipelineName);
        }

        if (pipelineRegistry != null && lookupPipeline == null) lookupPipeline = pipelineRegistry.getDefaultLookupPipeline();

        // execute LOOKUP pipeline

        xrd = lookupPipeline.execute(
            this.store,
View Full Code Here

          continue;
        }

        // check if the parent authority overrides the LOOKUP pipeline. if not, use the default.

        PipelineRegistry pipelineRegistry = (this.serverConfig == null) ? null : this.serverConfig.getPipelineRegistry();
        Pipeline lookupPipeline = null;

        if (this.store instanceof StoreAttributable) {

          StoreAttributable storeAttributable = (StoreAttributable) this.store;

          String pipelineName = storeAttributable.getAuthorityAttributes(parentAuthority).get(Pipeline.ATTRIBUTE_OVERRIDE_LOOKUP_PIPELINE);
          if (pipelineRegistry != null && pipelineName != null) lookupPipeline = pipelineRegistry.getPipelineByName(pipelineName);
        }

        if (pipelineRegistry != null && lookupPipeline == null) lookupPipeline = pipelineRegistry.getDefaultLookupPipeline();

        // execute LOOKUP pipeline

        xrd = lookupPipeline.execute(
            this.store,
View Full Code Here

          continue;
        }

        // check if the authority overrides the LOOKUP pipeline. if not, use the default.

        PipelineRegistry pipelineRegistry = (this.serverConfig == null) ? null : this.serverConfig.getPipelineRegistry();
        Pipeline lookupPipeline = null;

        if (this.store instanceof StoreAttributable) {

          StoreAttributable storeAttributable = (StoreAttributable) this.store;

          String pipelineName = storeAttributable.getAuthorityAttributes(authority).get(Pipeline.ATTRIBUTE_OVERRIDE_LOOKUP_PIPELINE);
          if (pipelineRegistry != null && pipelineName != null) lookupPipeline = pipelineRegistry.getPipelineByName(pipelineName);
        }

        if (pipelineRegistry != null && lookupPipeline == null) lookupPipeline = pipelineRegistry.getDefaultLookupPipeline();

        // execute LOOKUP pipeline

        xrd = lookupPipeline.execute(
            this.store,
View Full Code Here

    log.trace("createAuthority()");

    // use the default CREATE pipeline.

    PipelineRegistry pipelineRegistry = (this.serverConfig == null) ? null : this.serverConfig.getPipelineRegistry();
    Pipeline createPipeline = null;

    if (pipelineRegistry != null) createPipeline = pipelineRegistry.getDefaultCreatePipeline();

    // start database session

    Session session = this.getSessionFactory().getCurrentSession();
View Full Code Here

TOP

Related Classes of org.openxri.config.PipelineRegistry

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.