Examples of PolicyEngineData

Examples of org.apache.sandesha2.policy.PolicyEngineData

35
36
37
38
39
40
41
42
43
44
45
46
47
    case RMProcessorContext.COMMIT:

      // //////////

      PolicyEngineData engineData = rmpc.readCurrentPolicyEngineData();
      String txt = rmpc.getAssertion().getStrValue();
      engineData.setMaximumRetransmissionCount(Integer.parseInt(txt.trim()));

      // /////////////////////////////////

      break;
    case RMProcessorContext.ABORT:
View Full Code Here

Examples of org.apache.sandesha2.policy.PolicyEngineData

33
34
35
36
37
38
39
40
41
42
43
44
45
     
    case RMProcessorContext.COMMIT:
     
      //////////////
     
      PolicyEngineData ped = rmpc.readCurrentPolicyEngineData();
      String value = rmpc.getAssertion().getStrValue();
      ped.setInactivityTimeoutMeassure(value);
     
      //////////////
     
      break;
    case RMProcessorContext.ABORT:
View Full Code Here

Examples of org.apache.sandesha2.policy.PolicyEngineData

36
37
38
39
40
41
42
43
44
45
46
47
48
    case RMProcessorContext.COMMIT:

      // ///////

      PolicyEngineData ped = rmpc.readCurrentPolicyEngineData();
      String text = rmpc.getAssertion().getStrValue();
      ped.setExponentialBackoff(new Boolean(text.trim()).booleanValue());

      // ///////

      break;
    case RMProcessorContext.ABORT:
View Full Code Here

Examples of org.apache.sandesha2.policy.PolicyEngineData

33
34
35
36
37
38
39
40
41
42
43
44
45
      }

    case RMProcessorContext.COMMIT:

      // //////////////////
      PolicyEngineData ped = rmpc.readCurrentPolicyEngineData();
      String text = rmpc.getAssertion().getStrValue();
      ped.setRetransmissionInterval(Long.parseLong(text));
      // /////////////////

      break;
    case RMProcessorContext.ABORT:
      break;
View Full Code Here

Examples of org.apache.sandesha2.policy.PolicyEngineData

48
49
50
51
52
53
54
55
56
57
58
59
60
61
    }
    return new Boolean(true);
  }

  public Object doStorageManager(RMProcessorContext rmpc) {
    PolicyEngineData ped = rmpc.readCurrentPolicyEngineData();
    String cls = rmpc.getAssertion().getStrValue();

    if (cls != null && !cls.trim().equals("")) {
      ped.setStorageManager(cls.trim());
    }

    return new Boolean(true);
  }
View Full Code Here

Examples of org.apache.sandesha2.policy.PolicyEngineData

59
60
61
62
63
64
65
66
67
68
69
70
71
72
    return new Boolean(true);
  }

  public Object doPermanentStorageManager(RMProcessorContext spc) {
    PolicyEngineData ped = spc.readCurrentPolicyEngineData();
    String cls = spc.getAssertion().getStrValue();

    if (cls != null && !cls.trim().equals("")) {
      ped.setStorageManager(cls.trim());
    }

    return new Boolean(true);
  }
View Full Code Here

Examples of org.apache.sandesha2.policy.PolicyEngineData

31
32
33
34
35
36
37
38
39
40
41
42
43
      }
      logger.debug(rmpt.getTokenName());
     
    case RMProcessorContext.COMMIT:
     
      PolicyEngineData ped = rmpc.readCurrentPolicyEngineData();
      String text = rmpc.getAssertion().getStrValue();
      ped.setInvokeInOrder(new Boolean(text).booleanValue());
      break;
    case RMProcessorContext.ABORT:
      break;
    }
    return new Boolean(true);
View Full Code Here

Examples of org.apache.sandesha2.policy.PolicyEngineData

36
37
38
39
40
41
42
43
44
45
46
47
48
    case RMProcessorContext.COMMIT:

      // //////////

      PolicyEngineData engineData = rmpc.readCurrentPolicyEngineData();
      String txt = rmpc.getAssertion().getStrValue();
      engineData.setAcknowledgementInterval(Long.parseLong(txt.trim()));

      // /////////////////////////////////

      break;
    case RMProcessorContext.ABORT:
View Full Code Here

Examples of org.apache.sandesha2.policy.PolicyEngineData

34
35
36
37
38
39
40
41
42
43
44
45
46
      logger.debug(rmpt.getTokenName());
     
    case RMProcessorContext.COMMIT:
     
      ///////////////
      PolicyEngineData ped = rmpc.readCurrentPolicyEngineData();
      String text = rmpc.getAssertion().getStrValue();
      ped.setInactivityTimeout(Long.parseLong(text));
      ///////////////
     
      break;
    case RMProcessorContext.ABORT:
      break;
View Full Code Here

Examples of org.apache.sandesha2.policy.PolicyEngineData

36
37
38
39
40
41
42
43
44
45
46
47
48
      logger.debug(rmpt.getTokenName());

    case RMProcessorContext.COMMIT:

      // ////////////////////
      PolicyEngineData ped = rmpc.readCurrentPolicyEngineData();
      String text = rmpc.getAssertion().getStrValue();
      ped.setMessageTypesToDrop(text);
      // ////////////////////

      break;
    case RMProcessorContext.ABORT:
      break;
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.