Examples of Accept

com.sleepycat.je.rep.elections.Protocol.Accept
org.apache.sandesha2.wsrm.Accept
Represents the RM Accept element which may come within the Create Sequence Response.
org.apache.wink.common.internal.http.Accept
Represents a HTTP Accept header (see 14.1 of RFC 2616).
org.exquery.http.AcceptHeader.Accept
org.mmisw.ont.util.Accept
A helper class to query the "accept" header values. @author Carlos Rueda
org.purl.sword.atom.Accept
@author Neil Taylor (nst@aber.ac.uk)

Examples of org.apache.sandesha2.wsrm.Accept

          .getMessagePart(Sandesha2Constants.MessageParts.CREATE_SEQ_RESPONSE);
  
        // OFFER PROCESSING
      SequenceOffer offer = createSeqPart.getSequenceOffer();
      if (offer != null) {
        Accept accept = createSeqResPart.getAccept();
        if (accept == null) {
          if (log.isDebugEnabled())
            log.debug(SandeshaMessageHelper.getMessage(SandeshaMessageKeys.noAcceptPart));
          FaultManager.makeCreateSequenceRefusedFault(createSeqRMMsg, 
                                                      SandeshaMessageHelper.getMessage(SandeshaMessageKeys.noAcceptPart),

View Full Code Here

Examples of org.apache.sandesha2.wsrm.Accept


      
      //OFFER PROCESSING
      SequenceOffer offer = createSeqPart.getSequenceOffer();
      if (offer != null) {
        Accept accept = createSeqResPart.getAccept();
        if (accept == null) {
          String message = "An accept part has not been generated for the create seq request with an offer part"; 
          log.debug(message);
          throw new SandeshaException(message);
        }

View Full Code Here

Examples of org.apache.sandesha2.wsrm.Accept

    if (offer != null) {
      String outSequenceId = offer.getIdentifer().getIdentifier();


      if (outSequenceId != null && !"".equals(outSequenceId)) {


        Accept accept = new Accept(factory,rmNamespaceValue,addressingNamespaceValue);
        EndpointReference acksToEPR = createSeqMessage.getTo();
        AcksTo acksTo = new AcksTo(factory,rmNamespaceValue,addressingNamespaceValue);
        Address address = new Address(factory,addressingNamespaceValue);
        address.setEpr(acksToEPR);
        acksTo.setAddress(address);
        accept.setAcksTo(acksTo);
        response.setAccept(accept);
      }


    }

View Full Code Here

Examples of org.apache.sandesha2.wsrm.Accept

    
    
    Transaction offerProcessTransaction = storageManager.getTransaction();
    
    //processing for accept (offer has been sent)
    Accept accept = createSeqResponsePart.getAccept();
    if (accept != null) {
      //Find offered sequence from internal sequence id.
      SequencePropertyBean offeredSequenceBean = sequencePropMgr
          .retrieve(internalSequenceId,
              Sandesha2Constants.SequenceProperties.OFFERED_SEQUENCE);


      //TODO this should be detected in the Fault manager.
      if (offeredSequenceBean == null) {
        String message = "No offered sequence entry. But an accept was received"; 
        log.debug(message);
        throw new SandeshaException(message);
      }


      String offeredSequenceId = (String) offeredSequenceBean.getValue();


      EndpointReference acksToEPR = accept.getAcksTo().getAddress()
          .getEpr();
      SequencePropertyBean acksToBean = new SequencePropertyBean();
      acksToBean.setName(Sandesha2Constants.SequenceProperties.ACKS_TO_EPR);
      acksToBean.setSequenceID(offeredSequenceId);
      acksToBean.setValue(acksToEPR.getAddress());

View Full Code Here

Examples of org.apache.sandesha2.wsrm.Accept

      CreateSequenceResponse createSeqResPart = createSeqResponse.getCreateSequenceResponse();
  
      // OFFER PROCESSING
      SequenceOffer offer = createSeqPart.getSequenceOffer();
      if (offer != null) {
        Accept accept = createSeqResPart.getAccept();
        if (accept == null) {
          if (log.isDebugEnabled())
            log.debug(SandeshaMessageHelper.getMessage(SandeshaMessageKeys.noAcceptPart));
          FaultManager.makeCreateSequenceRefusedFault(createSeqRMMsg, SandeshaMessageHelper.getMessage(SandeshaMessageKeys.noAcceptPart), 
                                new Exception(),

View Full Code Here

Examples of org.apache.sandesha2.wsrm.Accept

        if (log.isDebugEnabled())
          log.debug(e);          
      }
    } else {
      // processing for accept (offer has been sent)
      Accept accept = createSeqResponsePart.getAccept();
      if (accept != null) {


        // TODO this should be detected in the Fault manager.
        if (rmsBean.getOfferedSequence() == null) {
          String message = SandeshaMessageHelper.getMessage(SandeshaMessageKeys.accptButNoSequenceOffered);
          log.debug(message);
          throw new SandeshaException(message);
        }


        RMDBean rMDBean = new RMDBean();
        
        EndpointReference acksToEPR = accept.getAcksTo().getEPR();
        rMDBean.setAcksToEndpointReference(acksToEPR);
        rMDBean.setSequenceID(rmsBean.getOfferedSequence());
        rMDBean.setNextMsgNoToProcess(1);
        rMDBean.setOutboundInternalSequence(rmsBean.getInternalSequenceID());

View Full Code Here

Examples of org.apache.sandesha2.wsrm.Accept

      if(log.isDebugEnabled()) log.debug("RMMsgCreator:: " + offer);
      String outSequenceId = offer.getIdentifer().getIdentifier();


      if (outSequenceId != null && !"".equals(outSequenceId)) {


        Accept accept = new Accept(namespace);


        // Putting the To EPR as the AcksTo for the response sequence. We echo back the
        // addressing version that the create used.
        String addressingNamespace = cs.getAddressingNamespaceValue();
        EndpointReference acksToEPR = createSeqMessage.getTo();
        if(acksToEPR != null) {
          acksToEPR = SandeshaUtil.cloneEPR(acksToEPR);
        } else {
          String anon = SpecSpecificConstants.getAddressingAnonymousURI(addressingNamespace);
          acksToEPR = new EndpointReference(anon);
        }
        
        AcksTo acksTo = new AcksTo(acksToEPR, namespace, cs.getAddressingNamespaceValue());
        accept.setAcksTo(acksTo);
        response.setAccept(accept);
      }
    }


    String version = SpecSpecificConstants.getSpecVersionString(namespace);

View Full Code Here

Examples of org.apache.sandesha2.wsrm.Accept

    if (offer != null) {
      String outSequenceId = offer.getIdentifer().getIdentifier();


      if (outSequenceId != null && !"".equals(outSequenceId)) {


        Accept accept = new Accept(factory);
        EndpointReference acksToEPR = createSeqMessage.getTo();
        AcksTo acksTo = new AcksTo(factory);
        Address address = new Address(factory);
        address.setEpr(acksToEPR);
        acksTo.setAddress(address);
        accept.setAcksTo(acksTo);
        response.setAccept(accept);
      }


    }

View Full Code Here

Examples of org.apache.sandesha2.wsrm.Accept

              newSequenceId);
      CreateSequenceResponse createSeqResPart = (CreateSequenceResponse) createSeqResponse
          .getMessagePart(Sandesha2Constants.MessageParts.CREATE_SEQ_RESPONSE);


      //If an offer is accepted do necessary procesing.
      Accept accept = createSeqResPart.getAccept();
      if (accept != null) {
        SequenceOffer offer = createSeqPart.getSequenceOffer();
        if (offer == null)
          throw new SandeshaException(
              "Internal error - no offer for the response message with Accept");

View Full Code Here

Examples of org.apache.sandesha2.wsrm.Accept

        Sandesha2Constants.SequenceProperties.INTERNAL_SEQUENCE_ID, internalSequenceId);
    sequencePropMgr.insert(outSequenceBean);
    sequencePropMgr.insert(internalSequenceBean);


    //processing for accept (offer has been sent)
    Accept accept = createSeqResponsePart.getAccept();
    if (accept != null) {
      //Find offered sequence from internal sequence id.
      SequencePropertyBean offeredSequenceBean = sequencePropMgr
          .retrieve(internalSequenceId,
              Sandesha2Constants.SequenceProperties.OFFERED_SEQUENCE);


      //TODO this should be detected in the Fault manager.
      if (offeredSequenceBean == null)
        throw new SandeshaException(
            "No offered sequence. But an accept was received");


      String offeredSequenceId = (String) offeredSequenceBean.getValue();


      EndpointReference acksToEPR = accept.getAcksTo().getAddress()
          .getEpr();
      SequencePropertyBean acksToBean = new SequencePropertyBean();
      acksToBean.setName(Sandesha2Constants.SequenceProperties.ACKS_TO_EPR);
      acksToBean.setSequenceId(offeredSequenceId);
      acksToBean.setValue(acksToEPR);

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.