Package com.comcast.cmb.common.model

Examples of com.comcast.cmb.common.model.CMBPolicy.addStatement()

134
135
136
137
138
139
140
141
142
143
144
          policy = new CMBPolicy(attributes.getPolicy());
        } else {
          policy = new CMBPolicy();
        }

        if (policy.addStatement(CMBPolicy.SERVICE.CNS, label, "Allow", userList, actionList, topicArn, null)) {
          attributes.setPolicy(policy.toString());
          PersistenceFactory.getCNSAttributePersistence().setTopicAttributes(attributes, topicArn);
        } else {
          throw new CMBException(CMBErrorCodes.InvalidParameterValue, "Value " + label + " for parameter Label is invalid. Reason: Already exists.");
        }
View Full Code Here
106
107
108
109
110
111
112
113
114
115
116
            throw new CMBException(CMBErrorCodes.NotFound, "ActionName is required");
        }
       
        CMBPolicy policy = new CMBPolicy(queue.getPolicy());
       
        if (policy.addStatement(CMBPolicy.SERVICE.CQS, label, "Allow", userList, actionList, queue.getArn(), null)) {
            PersistenceFactory.getQueuePersistence().updatePolicy(queue.getRelativeUrl(), policy.toString());
            queue.setPolicy(policy.toString());
        } else {
          throw new CMBException(CMBErrorCodes.InvalidParameterValue, "Value " + label + " for parameter Label is invalid. Reason: Already exists.");
        }
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
    public void testCMBStatement() {
     
        try {
          CMBPolicy policy = new CMBPolicy();
 
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest1", "Allow", Arrays.asList("1234567", "345678", "6789"), Arrays.asList("SendMessage", "GetQueueUrl"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest2", "Allow", Arrays.asList("1234567"), Arrays.asList("DeleteMessage", "GetQueueUrl"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest3", "Allow", Arrays.asList("1234567"), Arrays.asList("GetQueueUrl"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest4", "Allow", Arrays.asList("1234567", "345678", "6789"), Arrays.asList("ReceiveMessage"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
         
          String policyStr = policy.toString();
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
     
        try {
          CMBPolicy policy = new CMBPolicy();
 
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest1", "Allow", Arrays.asList("1234567", "345678", "6789"), Arrays.asList("SendMessage", "GetQueueUrl"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest2", "Allow", Arrays.asList("1234567"), Arrays.asList("DeleteMessage", "GetQueueUrl"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest3", "Allow", Arrays.asList("1234567"), Arrays.asList("GetQueueUrl"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest4", "Allow", Arrays.asList("1234567", "345678", "6789"), Arrays.asList("ReceiveMessage"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
         
          String policyStr = policy.toString();
         
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
        try {
          CMBPolicy policy = new CMBPolicy();
 
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest1", "Allow", Arrays.asList("1234567", "345678", "6789"), Arrays.asList("SendMessage", "GetQueueUrl"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest2", "Allow", Arrays.asList("1234567"), Arrays.asList("DeleteMessage", "GetQueueUrl"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest3", "Allow", Arrays.asList("1234567"), Arrays.asList("GetQueueUrl"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest4", "Allow", Arrays.asList("1234567", "345678", "6789"), Arrays.asList("ReceiveMessage"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
         
          String policyStr = policy.toString();
         
          CMBPolicy policy2;
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
          CMBPolicy policy = new CMBPolicy();
 
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest1", "Allow", Arrays.asList("1234567", "345678", "6789"), Arrays.asList("SendMessage", "GetQueueUrl"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest2", "Allow", Arrays.asList("1234567"), Arrays.asList("DeleteMessage", "GetQueueUrl"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest3", "Allow", Arrays.asList("1234567"), Arrays.asList("GetQueueUrl"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
          policy.addStatement(CMBPolicy.SERVICE.CQS, "unittest4", "Allow", Arrays.asList("1234567", "345678", "6789"), Arrays.asList("ReceiveMessage"), "arn:cmb:cqs:ccp:331770435817:MyQueue123456789", null);
         
          String policyStr = policy.toString();
         
          CMBPolicy policy2;
   
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.