Examples of ProcessorContext

ca.uhn.hl7v2.protocol.ProcessorContext
The operational context of a Processor. This defines certain resources that are not part of the Processor, but are needed in order to implement it, and may vary between deployments. @author Bryan Tripp @version $Revision: 1.1 $ updated on $Date: 2007-02-19 02:24:38 $ by $Author: jamesagnew $
org.apache.tez.runtime.api.ProcessorContext
Context handle for the Processor to initialize itself. This interface is not supposed to be implemented by users
org.apache.tuscany.sca.contribution.processor.ProcessorContext
Context for contribution processors @tuscany.spi.extension.asclient
org.mapstruct.ap.processor.ModelElementProcessor.ProcessorContext

Examples of ca.uhn.hl7v2.protocol.ProcessorContext

     * @return a <code>Processor</code> connected to the given address  
     * @throws TransportException
     */
    public Processor accept(String theAddress) throws TransportException {
        TransportLayer transport = getTransport(myServerSocket, theAddress);
        ProcessorContext context = null;
        
        if (myServerSocket2 == null) { //we're doing inbound & outbound on the same port
            transport.connect();
            context = new ProcessorContextImpl(myRouter, transport, myStorage);
        } else {

View Full Code Here

Examples of org.apache.tez.runtime.api.ProcessorContext

    OutputDescriptor e3OutDesc1 = createTestOutputDescriptor();
    dist.requestMemory(5000, e3Callback, e3OutputContext1, e3OutDesc1);
    
    // Fourth request - processor
    MemoryUpdateCallbackForTest e4Callback = new MemoryUpdateCallbackForTest();
    ProcessorContext e4ProcessorContext1 = createTestProcessortContext();
    ProcessorDescriptor e4ProcessorDesc1 = createTestProcessorDescriptor();
    dist.requestMemory(5000, e4Callback, e4ProcessorContext1, e4ProcessorDesc1);
    
    
    dist.makeInitialAllocations();

View Full Code Here

Examples of org.apache.tuscany.sca.contribution.processor.ProcessorContext

    @BeforeClass
    public static void setUp() throws Exception {
        final DefaultExtensionPointRegistry ep = new DefaultExtensionPointRegistry();
        final Contribution contrib = new DefaultContributionFactory().createContribution();
        contrib.setLocation(here());
        ctx = new ProcessorContext(contrib, null);
        xif = XMLInputFactory.newInstance();
        xof = XMLOutputFactory.newInstance();
        final StAXArtifactProcessorExtensionPoint xpep = new DefaultStAXArtifactProcessorExtensionPoint(ep);
        xproc = new ExtensibleStAXArtifactProcessor(xpep, xif, xof);
    }

View Full Code Here

Examples of org.apache.tuscany.sca.contribution.processor.ProcessorContext

     */
    static Builder<WSDLInterface> wsdli(final String uri, final String ns, final String name, final Contribution c) {
        return new Builder<WSDLInterface>() {
            public WSDLInterface build(final Context ec) {
                try {
                    final ProcessorContext ctx = new ProcessorContext();
                    final WSDLDefinition wd = ec.aproc.read(null, new URI(uri), new URL(new URL(c.getLocation()), uri), ctx, WSDLDefinition.class);
                    c.getModelResolver().addModel(wd, ctx);
                    c.getModelResolver().resolveModel(WSDLDefinition.class, wd, ctx);
                    final WSDLObject<PortType> pt = wd.getWSDLObject(PortType.class, new QName(ns, name));
                    if(pt == null)

View Full Code Here

Examples of org.apache.tuscany.sca.contribution.processor.ProcessorContext

    @Ignore
    public void testBuildModel() {
        try {
            InputStream is = getClass().getResourceAsStream("/Calculator.composite");
            XMLStreamReader reader = inputFactory.createXMLStreamReader(is);
            ProcessorContext context = new ProcessorContext(extensionPoints);
            Composite composite = (Composite)staxProcessor.read(reader, context);


            is.close();
            Assert.assertNotNull(composite);


            resolver.addModel(composite, context);


            staxProcessor.resolve(composite, resolver, new ProcessorContext());


            SCABinding referenceSCABinding =
                (SCABinding)composite.getComponents().get(0).getReferences().get(0).getBindings().get(0);
            SCABinding serviceSCABinding =
                (SCABinding)composite.getComponents().get(1).getServices().get(0).getBindings().get(0);

View Full Code Here

Examples of org.apache.tuscany.sca.contribution.processor.ProcessorContext

    private static ProcessorContext context;
    
    @BeforeClass
    public static void setUp() throws Exception {
        ExtensionPointRegistry extensionPoints = new DefaultExtensionPointRegistry();
        context = new ProcessorContext(extensionPoints);
        
        inputFactory = XMLInputFactory.newInstance();
        StAXArtifactProcessorExtensionPoint staxProcessors = extensionPoints.getExtensionPoint(StAXArtifactProcessorExtensionPoint.class);
        staxProcessor = new ExtensibleStAXArtifactProcessor(staxProcessors, inputFactory, null);
    }

View Full Code Here

Examples of org.apache.tuscany.sca.contribution.processor.ProcessorContext

    private static ProcessorContext context;
    
    @BeforeClass
    public static void setUp() throws Exception {
        DefaultExtensionPointRegistry extensionPoints = new DefaultExtensionPointRegistry();
        context = new ProcessorContext(extensionPoints);
        StAXArtifactProcessorExtensionPoint staxProcessors = extensionPoints.getExtensionPoint(StAXArtifactProcessorExtensionPoint.class);
        inputFactory = XMLInputFactory.newInstance();
        outputFactory = XMLOutputFactory.newInstance();
        staxProcessor = new ExtensibleStAXArtifactProcessor(staxProcessors, inputFactory, outputFactory);
    }

View Full Code Here

Examples of org.apache.tuscany.sca.contribution.processor.ProcessorContext


    @Test
    public void testMinimal() throws Exception {
        String xml = "<import.sdo xmlns='http://tuscany.apache.org/xmlns/sca/1.1'/>";
        XMLStreamReader reader = getReader(xml);
        assertTrue(loader.read(reader, new ProcessorContext(registry)) instanceof ImportSDO);
    }

View Full Code Here

Examples of org.apache.tuscany.sca.contribution.processor.ProcessorContext


    @Test
    public void testLocation() throws Exception {
        String xml = "<import.sdo xmlns='http://tuscany.apache.org/xmlns/sca/1.1' location='ipo.xsd'/>";
        XMLStreamReader reader = getReader(xml);
        assertTrue(loader.read(reader, new ProcessorContext(registry)) instanceof ImportSDO);
    }

View Full Code Here

Examples of org.apache.tuscany.sca.contribution.processor.ProcessorContext

        String xml = "<import.sdo xmlns='http://tuscany.apache.org/xmlns/sca/1.1' " + "factory='"
                     + MockFactory.class.getName()
                     + "'/>";
        XMLStreamReader reader = getReader(xml);
        assertFalse(inited);
        ProcessorContext context = new ProcessorContext(registry);
        ImportSDO importSDO = loader.read(reader, context);
        assertNotNull(importSDO);
        ModelResolver resolver = new TestModelResolver();
        resolver.addModel(new ClassReference(MockFactory.class), context);
        loader.resolve(importSDO, resolver, context);

View Full Code Here

0 1 2 3 4 5

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.