Examples of AckRequestedType

org.apache.cxf.ws.rm.AckRequestedType
3.org/2001/XMLSchema}anyType"> <sequence> <element ref="{http://schemas.xmlsoap.org/ws/2005/02/rm}Identifier"/> <element name="MaxMessageNumberUsed" type="{http://www.w3.org/2001/XMLSchema}unsignedLong" minOccurs="0"/> <any processContents='lax' namespace='##other' maxOccurs="unbounded" minOccurs="0"/> </sequence> <anyAttribute processContents='lax' namespace='##other'/> </restriction> </complexContent> </complexType>
org.apache.cxf.ws.rm.v200702.AckRequestedType
org.objectweb.celtix.ws.rm.AckRequestedType
org.servicemix.ws.xmlbeans.rm.AckRequestedType
as.xmlsoap.org/ws/2005/02/rm). This is a complex type.

Examples of org.objectweb.celtix.ws.rm.AckRequestedType

                            SequenceAcknowledgement ack = decodeProperty(SequenceAcknowledgement.class,
                                                            headerElement,
                                                            unmarshaller);
                            acks.add(ack);                            
                        } else if (Names.WSRM_ACK_REQUESTED_NAME.equals(localName)) {
                            AckRequestedType ar = decodeProperty(AckRequestedType.class,
                                                            headerElement,
                                                            unmarshaller);
                            requested.add(ar);
                        }
                    }

View Full Code Here

Examples of org.objectweb.celtix.ws.rm.AckRequestedType

        assertTrue(codec.handleMessage(context));
        RMProperties rmps = RMContextUtils.retrieveRMProperties(context, false);
        Collection<AckRequestedType> requested = rmps.getAcksRequested();
        assertNotNull(requested);
        assertEquals(1, requested.size());
        AckRequestedType ar = requested.iterator().next();
        assertNotNull(ar);
        assertEquals(ar.getIdentifier().getValue(), SEQ_IDENTIFIER);


        SequenceType s = rmps.getSequence();
        assertNotNull(s);
        assertEquals(s.getIdentifier().getValue(), SEQ_IDENTIFIER);
        assertEquals(s.getMessageNumber(), MSG2_MESSAGE_NUMBER);

View Full Code Here

Examples of org.objectweb.celtix.ws.rm.AckRequestedType

    }
    
    public void requestAcknowledgement(Collection<SourceSequence> seqs) {
        List<AckRequestedType> requested = new ArrayList<AckRequestedType>();
        for (AbstractSequenceImpl seq : seqs) {
            AckRequestedType ar = RMUtils.getWSRMFactory().createAckRequestedType();
            ar.setIdentifier(seq.getIdentifier());
            requested.add(ar);
        }
        RMPropertiesImpl rmps = new RMPropertiesImpl();        
        rmps.setAcksRequested(requested);
    }

View Full Code Here

Examples of org.servicemix.ws.xmlbeans.rm.AckRequestedType

        
        return resultDoc;
    }


    public SequenceAcknowledgementDocument acknowledgeRequested(AckRequestedDocument doc) {
        AckRequestedType sequence = doc.getAckRequested();
        String identifier = sequence.getIdentifier().getStringValue();
        Sequence s = sequenceStore.retrieve(identifier);
        
        if( s == null ) {
            throw new SoapFault(
                    "The value of wsrm:Identifier is not a known Sequence identifier", 
                    "Sender", 
                    "wsrm:UnknownSequence",
                    sequence.getIdentifier().xmlText());
        }
        
        SequenceAcknowledgementDocument resultDoc = SequenceAcknowledgementDocument.Factory.newInstance();
        SequenceAcknowledgement acknowledgement = resultDoc.addNewSequenceAcknowledgement();
        acknowledgement.setIdentifier(sequence.getIdentifier());
        if( s.lastMessageAcked> 0 ) {
            AcknowledgementRange range = acknowledgement.addNewAcknowledgementRange();
            range.setLower(BigInteger.ONE);
            range.setUpper(new BigInteger(""+s.lastMessageAcked));
        }

View Full Code Here

0 1 2 3

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.