Examples of CorbaObjectHandler

Examples of org.apache.yoko.bindings.corba.types.CorbaObjectHandler

            assertTrue(evt.isStartDocument());
        } catch (XMLStreamException ex) {
        }
        assertNotNull(evtReader);
        
        CorbaObjectHandler resultObj = staxBindingImpl.readUnionFromStax(evtReader, 
                                                                     obj.getIdlType(), 
                                                                     obj.getTypeCode());
        assertNotNull(resultObj);
        
        assertTrue(resultObj instanceof CorbaUnionHandler);
        CorbaUnionHandler result = (CorbaUnionHandler)resultObj;
        
        CorbaObjectHandler resultDiscriminatorObj = result.getDiscriminator();
        assertTrue(resultDiscriminatorObj instanceof CorbaPrimitiveHandler);
        CorbaPrimitiveHandler resultDiscriminator = (CorbaPrimitiveHandler)resultDiscriminatorObj;
        Object resultDiscValueObj = resultDiscriminator.getValue();
        assertTrue(resultDiscValueObj instanceof Short);
        Short resultDiscValue = (Short)resultDiscValueObj;
        assertTrue(resultDiscValue.shortValue() == discriminatorValue.shortValue());
        
        CorbaObjectHandler resultValueObj = result.getValue();
        assertTrue(resultValueObj instanceof CorbaPrimitiveHandler);
        CorbaPrimitiveHandler resultValue = (CorbaPrimitiveHandler)resultValueObj;
        Object unionResultValueObj = resultValue.getValue();
        assertTrue(unionResultValueObj instanceof Character);
        Character unionResultValue = (Character)unionResultValueObj;

View Full Code Here

Examples of org.apache.yoko.bindings.corba.types.CorbaObjectHandler

                XMLEventWriter evtWriter = outputFactory.createXMLEventWriter(outStream);
                writer.write(objContext.getReturn(), callback.getWebResultQName(), evtWriter);


                ByteArrayInputStream inStream = new ByteArrayInputStream(outStream.toByteArray());
                XMLEventReader evtReader = inputFactory.createXMLEventReader(inStream);
                CorbaObjectHandler obj = readObjectFromStax(evtReader, 
                                                            opElement.getReturn().getIdltype(), 
                                                            false);
                CorbaStreamable streamable = new CorbaStreamable(obj, callback.getWebResultQName());
                corbaCtx.getMessage().setStreamableReturn(streamable);
            } else if (isInputMessage && callback.getWebResult() != null && !hasOutParamReturn) {
                QName retName = callback.getWebResultQName();
                QName retIdlType = opElement.getReturn().getIdltype();
                CorbaObjectHandler obj = 
                    CorbaHandlerUtils.initializeObjectHandler(orb, retName, retIdlType, typeMaps);
                CorbaStreamable streamable = new CorbaStreamable(obj, retName);
                corbaCtx.getMessage().setStreamableReturn(streamable);
            }
        } catch (java.lang.Exception ex) {

View Full Code Here

Examples of org.apache.yoko.bindings.corba.types.CorbaObjectHandler

            writer.write(partValue, elName, evtWriter);


            ByteArrayInputStream inStream = new ByteArrayInputStream(outStream.toByteArray());
            XMLEventReader evtReader = inputFactory.createXMLEventReader(inStream);
            QName idlType = param.getIdltype();
            CorbaObjectHandler obj = null;
            boolean skipRead = false;
            if (isServer) {
                if (param.getMode().equals(ModeType.IN)) {
                    skipRead = true;
                }

View Full Code Here

Examples of org.apache.yoko.bindings.corba.types.CorbaObjectHandler

                // This could be a system exception?
            } else {
                LOG.log(Level.INFO, "Found exception in the raises list.  Marshalling.");
                ByteArrayInputStream inStream = new ByteArrayInputStream(outStream.toByteArray());
                XMLEventReader evtReader = inputFactory.createXMLEventReader(inStream);
                CorbaObjectHandler obj = readObjectFromStax(evtReader, exIdlType, false);
                CorbaStreamable streamable = new CorbaStreamable(obj, elName);
                corbaCtx.getMessage().setStreamableException(streamable);
            }

View Full Code Here

Examples of org.apache.yoko.bindings.corba.types.CorbaObjectHandler

            Method currentMethod = (Method)objContext.get(ObjectMessageContext.METHOD_OBJ);
            Class<?>[] methodExs = currentMethod.getExceptionTypes();


            CorbaMessage message = corbaCtx.getMessage();
            CorbaStreamable streamableEx = message.getStreamableException();
            CorbaObjectHandler exObject = streamableEx.getObject();
            String name = exObject.getName().getLocalPart();
            
            Class exWrapperCls = null;
            for (int i = 0; i < methodExs.length; ++i) {
                // Right now, this assumes that all exceptions will have unique simple names.  REVISIT.
                if (name.equals(methodExs[i].getSimpleName())) {

View Full Code Here

Examples of org.apache.yoko.bindings.corba.types.CorbaObjectHandler

        // TODO - provide implementation.
    }


    public CorbaObjectHandler readObjectFromStax(XMLEventReader reader, QName idlType, boolean isNested)
        throws CorbaBindingException {
        CorbaObjectHandler obj = null;
        // Find the first start element in the reader.  This should be the beginning of our object
        try {
            if (!isNested) {
                while (reader.peek().getEventType() != XMLStreamConstants.START_ELEMENT) {
                    reader.nextEvent();

View Full Code Here

Examples of org.apache.yoko.bindings.corba.types.CorbaObjectHandler

        }
        writer.add(charEvt);
    }


    public CorbaObjectHandler readAliasFromStax(XMLEventReader reader, QName idlType, TypeCode tc) {
        CorbaObjectHandler obj = null;
        CorbaTypeImpl typeDefinition = CorbaUtils.getCorbaType(idlType, typeMaps);


        // We need to create an ObjectHandler from the base type of the typedef.  So we recursively call
        // the readObjectFromStax call.  However, this is not a true nested read so still pass false as the 
        // nested flag.

View Full Code Here

Examples of org.apache.yoko.bindings.corba.types.CorbaObjectHandler

                arrayBound = arrayType.getBound();
            }
            StartElement arrayStartEl = reader.nextEvent().asStartElement();
            obj = new CorbaArrayHandler(arrayStartEl.getName(), idlType, tc, typeDefinition);
            for (int i = 0; i < arrayBound; ++i) {
                CorbaObjectHandler element = readObjectFromStax(reader, arrayElemType, true);
                obj.addElement(element);
            }
            reader.nextEvent().asEndElement();
        } catch (java.lang.Exception ex) {
            LOG.log(Level.SEVERE, "Received exception while reading object of type " + idlType);

View Full Code Here

Examples of org.apache.yoko.bindings.corba.types.CorbaObjectHandler

            StartElement exStartEl = reader.nextEvent().asStartElement();
            obj = new CorbaExceptionHandler(exStartEl.getName(), idlType, tc, exType);
            List<MemberType> exMembers = exType.getMember();
            for (Iterator<MemberType> iter = exMembers.iterator(); iter.hasNext();) {
                MemberType m = iter.next();
                CorbaObjectHandler member = readObjectFromStax(reader, m.getIdltype(), true);
                obj.addMember(member);
            }
            reader.nextEvent().asEndElement();
        } catch (java.lang.Exception ex) {
            LOG.log(Level.SEVERE, "Received exception while reading object of type " + idlType);

View Full Code Here

Examples of org.apache.yoko.bindings.corba.types.CorbaObjectHandler

            StartElement seqStartEl = reader.nextEvent().asStartElement();
            obj = new CorbaSequenceHandler(seqStartEl.getName(), idlType, tc, typeDefinition);
            if (bound == 0) {
                LOG.log(Level.INFO, "Unbounded sequence found");
                while (reader.peek().getEventType() == XMLStreamConstants.START_ELEMENT) {
                    CorbaObjectHandler element = readObjectFromStax(reader, seqElementType, true);
                    obj.addElement(element);
                }
            } else {
                LOG.log(Level.INFO, "Bounded sequence found");
                for (long i = 0; i < bound; ++i) {
                    CorbaObjectHandler element = readObjectFromStax(reader, seqElementType, true);
                    obj.addElement(element);
                }
            }
            reader.nextEvent().asEndElement();
        } catch (java.lang.Exception ex) {

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.