Package org.apache.sandesha2.wsrm

Examples of org.apache.sandesha2.wsrm.SequenceAcknowledgement.toOMElement()

533
534
535
536
537
538
539
540
541
542
543
      }

    }

    SOAPEnvelope envelope = factory.getDefaultEnvelope();
    response.toOMElement(envelope.getBody());
    outMessage.setWSAAction(SpecSpecificConstants.getCreateSequenceResponseAction(SandeshaUtil.getRMVersion(
        newSequenceID, storageManager)));
    outMessage.setSoapAction(SpecSpecificConstants.getCreateSequenceResponseSOAPAction(SandeshaUtil.getRMVersion(
        newSequenceID, storageManager)));
    outMessage.setProperty(AddressingConstants.WS_ADDRESSING_VERSION, addressingNamespaceValue);
View Full Code Here
504
505
506
507
508
509
510
511
512
513
514
      }

    }

    SOAPEnvelope envelope = factory.getDefaultEnvelope();
    response.toOMElement(envelope.getBody());
    outMessage.setWSAAction(SpecSpecificConstants.getCreateSequenceResponseAction(SandeshaUtil.getRMVersion(newSequenceID,configurationContext)));
    outMessage.setSoapAction(SpecSpecificConstants.getCreateSequenceResponseSOAPAction(SandeshaUtil.getRMVersion(newSequenceID,configurationContext)));
    outMessage.setProperty(AddressingConstants.WS_ADDRESSING_VERSION,addressingNamespaceValue);
   
    String newMessageId = SandeshaUtil.getUUID();
View Full Code Here
318
319
320
321
322
323
324
325
326
327
328
      }

    }

    SOAPEnvelope envelope = factory.getDefaultEnvelope();
    response.toOMElement(envelope.getBody());
    outMessage
        .setWSAAction(Sandesha2Constants.WSRM.Actions.ACTION_CREATE_SEQUENCE_RESPONSE);
    outMessage
        .setSoapAction(Sandesha2Constants.WSRM.Actions.SOAP_ACTION_CREATE_SEQUENCE_RESPONSE);
View Full Code Here
694
695
696
697
698
699
700
701
702
703
704
      }
    }

    applicationMsg.setMessagePart(Sandesha2Constants.MessageParts.SEQ_ACKNOWLEDGEMENT, sequenceAck);

    sequenceAck.toOMElement(envelope.getHeader());
   
    if (applicationMsg.getWSAAction()==null) {
      applicationMsg.setAction(SpecSpecificConstants.getSequenceAcknowledgementAction(SandeshaUtil.getRMVersion(
          sequenceId, storageManager)));
      applicationMsg.setSOAPAction(SpecSpecificConstants.getSequenceAcknowledgementSOAPAction(SandeshaUtil
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
              OMElement ackElement = (OMElement) iter.next();

              SequenceAcknowledgement sequenceAcknowledgement = new SequenceAcknowledgement (Sandesha2Constants.SPEC_NS_URIS[i]);
              sequenceAcknowledgement.fromOMElement(ackElement);
             
              sequenceAcknowledgement.toOMElement(appMsgHeaders);
              acks = true;
            }
          }
        }
       
View Full Code Here
296
297
298
299
300
301
302
303
304
305
306
      data.setSubcode(Sandesha2Constants.SOAPFaults.Subcodes.INVALID_ACKNOWLEDGEMENT);
      data.setReason(reason);
     
      SOAPFactory factory = SOAPAbstractFactory.getSOAPFactory(SOAPVersion);
      OMElement dummyElement = factory.createOMElement("dummyElem",null);
      sequenceAcknowledgement.toOMElement(dummyElement);
     
      OMElement sequenceAckElement = dummyElement.getFirstChildWithName(
          new QName (Sandesha2Constants.WSRM_COMMON.SEQUENCE_ACK));
      data.setDetail(sequenceAckElement);
View Full Code Here
674
675
676
677
678
679
680
681
682
683
684
      }
    }

    applicationMsg.setMessagePart(Sandesha2Constants.MessageParts.SEQ_ACKNOWLEDGEMENT,sequenceAck);
   
    sequenceAck.toOMElement(envelope.getHeader());
    applicationMsg
        .setAction(SpecSpecificConstants.getSequenceAcknowledgementAction(SandeshaUtil.getRMVersion(sequenceId,ctx)));
    applicationMsg
        .setSOAPAction(SpecSpecificConstants.getSequenceAcknowledgementSOAPAction(SandeshaUtil.getRMVersion(sequenceId,ctx)));
    applicationMsg.setMessageId(SandeshaUtil.getUUID());
View Full Code Here
385
386
387
388
389
390
391
392
393
394
395
    while (iterator.hasNext()) {
      AcknowledgementRange ackRange = (AcknowledgementRange) iterator.next();
      sequenceAck.addAcknowledgementRanges(ackRange);
    }

    sequenceAck.toOMElement(envelope.getHeader());
    applicationMsg
        .setAction(Sandesha2Constants.WSRM.Actions.ACTION_SEQUENCE_ACKNOWLEDGEMENT);
    applicationMsg
        .setSOAPAction(Sandesha2Constants.WSRM.Actions.SOAP_ACTION_SEQUENCE_ACKNOWLEDGEMENT);
    applicationMsg.setMessageId(SandeshaUtil.getUUID());
View Full Code Here
343
344
345
346
347
348
349
350
351
352
353
        data.setSubcode(Sandesha2Constants.SOAPFaults.Subcodes.INVALID_ACKNOWLEDGEMENT);
        data.setReason(reason);

        SOAPFactory factory = SOAPAbstractFactory.getSOAPFactory(SOAPVersion);
        OMElement dummyElement = factory.createOMElement("dummyElem", null);
        sequenceAcknowledgement.toOMElement(dummyElement);

        OMElement sequenceAckElement = dummyElement.getFirstChildWithName(new QName(
            Sandesha2Constants.WSRM_COMMON.SEQUENCE_ACK));
        data.setDetail(sequenceAckElement);
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
      faultCode.setDetailOMElement(faultData.getDetail());
      faultCode.setExtendedDetailOMElement(faultData.getDetail2());
    }
    sequenceFault.setFaultCode(faultCode);
   
    sequenceFault.toOMElement(faultMessageContext.getEnvelope().getHeader());
  }

  /**
   * Building the envelope with SOAP 1.1
   *
 
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.