Examples of AckRequested

nl.clockwork.mule.ebms.model.ebxml.AckRequested
3.org/2001/XMLSchema}anyType"> <sequence> <any/> </sequence> <attGroup ref="{http://www.oasis-open.org/committees/ebxml-msg/schema/msg-header-2_0.xsd}headerExtension.grp"/> <attribute ref="{http://schemas.xmlsoap.org/soap/envelope/}actor"/> <attribute name="signed" use="required" type="{http://www.w3.org/2001/XMLSchema}boolean" /> </restriction> </complexContent> </complexType>
org.apache.sandesha2.wsrm.AckRequested
Represent the AckRequested header block. The 2005/02 spec includes a 'MessageNumber' part in the ack request, but the 2006/08 spec does not. As the message number was never used in our implementation we simply ignore it.

Examples of org.apache.sandesha2.wsrm.AckRequested

          .getMessageParts(Sandesha2Constants.MessageParts.ACK_REQUEST);
  
      //In case of ack request messages sequenceId is decided based on the sequenceId of the first 
      //AckRequested.
      
      AckRequested ackReq = (AckRequested) ackRequestIter.next();
      sequenceID = ackReq.getIdentifier().getIdentifier();
    } else if (messageType == Sandesha2Constants.MessageTypes.CLOSE_SEQUENCE) {
      CloseSequence closeSequence = (CloseSequence) rmMessageContext
          .getMessagePart(Sandesha2Constants.MessageParts.CLOSE_SEQUENCE);
      sequenceID = closeSequence.getIdentifier().getIdentifier();
    } else if (messageType == Sandesha2Constants.MessageTypes.CLOSE_SEQUENCE_RESPONSE) {

View Full Code Here

Examples of org.apache.sandesha2.wsrm.AckRequested

    }


    //In case of ack request messages RM Namespace is decided based on the sequenceId of the last 
    //ack request.
    for (Iterator iter = elements.getAckRequests();iter.hasNext();) {
      AckRequested ackRequest = (AckRequested) iter.next();
      rmMsgContext.setMessagePart(Sandesha2Constants.MessageParts.ACK_REQUEST, ackRequest);
      rmNamespace = ackRequest.getNamespaceValue();
    }


    if (elements.getCloseSequence() != null) {
      rmMsgContext.setMessagePart(Sandesha2Constants.MessageParts.CLOSE_SEQUENCE, elements.getCloseSequence());
      rmNamespace = elements.getCloseSequence().getNamespaceValue();

View Full Code Here

Examples of org.apache.sandesha2.wsrm.AckRequested

      //if there is only on sequenceAck, sequenceId will be set. Otherwise it will not be.
      if (!sequenceAcknowledgementsIter.hasNext())
        sequenceID = sequenceAcknowledgement.getIdentifier().getIdentifier();
    } else if (ackRequestedIter.hasNext()) {
      rmMsgCtx.setMessageType(Sandesha2Constants.MessageTypes.ACK_REQUEST);
      AckRequested ackRequest = (AckRequested) ackRequestedIter.next();


      //if there is only on sequenceAck, sequenceId will be set. Otherwise it will not be.
      if (!ackRequestedIter.hasNext())
        sequenceID = ackRequest.getIdentifier().getIdentifier();
    } else if (closeSequence != null) {
      rmMsgCtx.setMessageType(Sandesha2Constants.MessageTypes.CLOSE_SEQUENCE);
      sequenceID = closeSequence.getIdentifier().getIdentifier();
    } else if (closeSequenceResponse != null) {
      rmMsgCtx.setMessageType(Sandesha2Constants.MessageTypes.CLOSE_SEQUENCE_RESPONSE);

View Full Code Here

Examples of org.apache.sandesha2.wsrm.AckRequested

        QName headerName = new QName(Sandesha2Constants.SPEC_NS_URIS[i], Sandesha2Constants.WSRM_COMMON.ACK_REQUESTED);
        
        Iterator acks = header.getChildrenWithName(headerName);
        while(acks.hasNext()) {
          OMElement ack = (OMElement) acks.next();
          AckRequested ackReq = new AckRequested(headerName.getNamespaceURI());
          ackReq.fromOMElement(ack);
          boolean paused = processAckRequestedHeader(message, ack, ackReq);
          //if nto already paused we might be now
          if(!msgCtxPaused){
            msgCtxPaused = paused;
          }

View Full Code Here

Examples of org.apache.sandesha2.wsrm.AckRequested

    getConfigurationContext().registerOperationContext(ackRequestRMMsg.getMessageId(), opcontext);
    getMsgContext().setOperationContext(opcontext);
    
    Iterator iterator = ackRequestRMMsg.getMessageParts(Sandesha2Constants.MessageParts.ACK_REQUEST);
    
    AckRequested ackRequested = null;
    while (iterator.hasNext()) {
      ackRequested = (AckRequested) iterator.next(); 
    }
    
    if (iterator.hasNext()) {

View Full Code Here

Examples of org.apache.sandesha2.wsrm.AckRequested

          .getMessageParts(Sandesha2Constants.MessageParts.ACK_REQUEST);
  
      //In case of ack request messages sequenceId is decided based on the sequenceId of the first 
      //AckRequested.
      
      AckRequested ackReq = (AckRequested) ackRequestIter.next();
      sequenceID = ackReq.getIdentifier().getIdentifier();
    } else if (messageType == Sandesha2Constants.MessageTypes.CLOSE_SEQUENCE) {
      CloseSequence closeSequence = (CloseSequence) rmMessageContext
          .getMessagePart(Sandesha2Constants.MessageParts.CLOSE_SEQUENCE);
      sequenceID = closeSequence.getIdentifier().getIdentifier();
    } else if (messageType == Sandesha2Constants.MessageTypes.CLOSE_SEQUENCE_RESPONSE) {

View Full Code Here

Examples of org.apache.sandesha2.wsrm.AckRequested

    }


    //In case of ack request messages RM Namespace is decided based on the sequenceId of the last 
    //ack request.
    for (Iterator iter = elements.getAckRequests();iter.hasNext();) {
      AckRequested ackRequest = (AckRequested) iter.next();
      rmMsgContext.setMessagePart(Sandesha2Constants.MessageParts.ACK_REQUEST, ackRequest);
      rmNamespace = ackRequest.getNamespaceValue();
    }


    if (elements.getCloseSequence() != null) {
      rmMsgContext.setMessagePart(Sandesha2Constants.MessageParts.CLOSE_SEQUENCE, elements.getCloseSequence());
      rmNamespace = elements.getCloseSequence().getNamespaceValue();

View Full Code Here

Examples of org.apache.sandesha2.wsrm.AckRequested

      //if there is only on sequenceAck, sequenceId will be set. Otherwise it will not be.
      if (!sequenceAcknowledgementsIter.hasNext())
        sequenceID = sequenceAcknowledgement.getIdentifier().getIdentifier();
    } else if (ackRequestedIter.hasNext()) {
      rmMsgCtx.setMessageType(Sandesha2Constants.MessageTypes.ACK_REQUEST);
      AckRequested ackRequest = (AckRequested) ackRequestedIter.next();


      //if there is only on sequenceAck, sequenceId will be set. Otherwise it will not be.
      if (!ackRequestedIter.hasNext())
        sequenceID = ackRequest.getIdentifier().getIdentifier();
    } else if (closeSequence != null) {
      rmMsgCtx.setMessageType(Sandesha2Constants.MessageTypes.CLOSE_SEQUENCE);
      sequenceID = closeSequence.getIdentifier().getIdentifier();
    } else if (closeSequenceResponse != null) {
      rmMsgCtx.setMessageType(Sandesha2Constants.MessageTypes.CLOSE_SEQUENCE_RESPONSE);

View Full Code Here

Examples of org.apache.sandesha2.wsrm.AckRequested

        QName headerName = new QName(Sandesha2Constants.SPEC_NS_URIS[i], Sandesha2Constants.WSRM_COMMON.ACK_REQUESTED);
        
        Iterator acks = header.getChildrenWithName(headerName);
        while(acks.hasNext()) {
          OMElement ack = (OMElement) acks.next();
          AckRequested ackReq = new AckRequested(headerName.getNamespaceURI());
          ackReq.fromOMElement(ack);
          boolean paused = processAckRequestedHeader(message, ack, ackReq);
          //if nto already paused we might be now
          if(!msgCtxPaused){
            msgCtxPaused = paused;
          }

View Full Code Here

Examples of org.apache.sandesha2.wsrm.AckRequested

    msgContext.setOperationContext(opcontext);
    msgContext.setAxisOperation(outInAxisOp);
    
    Iterator iterator = ackRequestRMMsg.getMessageParts(Sandesha2Constants.MessageParts.ACK_REQUEST);
    
    AckRequested ackRequested = null;
    while (iterator.hasNext()) {
      ackRequested = (AckRequested) iterator.next(); 
    }
    
    if (iterator.hasNext()) {
      String message = "Passed message has more than one AckRequest. You can have only one";
      throw new SandeshaException (message);
    }
    
    if (ackRequested==null) {
      String message = "No AckRequested part was present in the message";
      throw new SandeshaException (message);
    }
    
    ackRequested.getIdentifier().setIndentifer(outSequenceID);
    
    ackRequestRMMsg.setFlow(MessageContext.OUT_FLOW);
    msgContext.setProperty(Sandesha2Constants.APPLICATION_PROCESSING_DONE, "true");


    ackRequestRMMsg.setTo(new EndpointReference(toAddress));

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.