diff options
| author |   efiacor <fiachra.corcoran@est.tech> | 2022-07-22 13:28:38 +0100 |
|---|---|---|
| committer | efiacor <fiachra.corcoran@est.tech> | 2022-07-22 13:28:58 +0100 |
| commit | fd9efa89fcf31880ba31e6dd2f49e932781952c7 (patch) | |
| tree | 51ac5726e0da0c5cd316439ff9bf2366c286f242 | |
| parent | afbb5c931f8bf39cbe3639a8d601a7dfda5ecd1b (diff) | |
[DMAAP-MR] Remove acl update for deny
Signed-off-by: efiacor <fiachra.corcoran@est.tech>
Change-Id: I97f443730d21daf0652f334cd5a4efa1e3a5b708
Issue-ID: DMAAP-1744
| -rw-r--r-- | src/main/java/org/onap/dmaap/dmf/mr/service/impl/TopicServiceImpl.java | 16 |
1 files changed, 12 insertions, 4 deletions
diff --git a/src/main/java/org/onap/dmaap/dmf/mr/service/impl/TopicServiceImpl.java b/src/main/java/org/onap/dmaap/dmf/mr/service/impl/TopicServiceImpl.java index 92aea97..386fb97 100644 --- a/src/main/java/org/onap/dmaap/dmf/mr/service/impl/TopicServiceImpl.java +++ b/src/main/java/org/onap/dmaap/dmf/mr/service/impl/TopicServiceImpl.java @@ -444,9 +444,13 @@ public class TopicServiceImpl implements TopicService { throw new TopicExistsException("Failed to revoke write access to producer [" + producerId + "] for topic. Topic [" + topicName + "] does not exist."); } - topic.denyWritesFromUser(producerId, user); - LOGGER.info("Write access has been revoked to producer [" + producerId + "] for topic [" + topicName + if (isUseCustomAcls()) { + topic.denyWritesFromUser(producerId, user); + LOGGER.info("Write access has been revoked to producer [" + producerId + "] for topic [" + topicName + "]. Sending response."); + } else { + LOGGER.info("Ignoring acl update"); + } respondOk(dmaapContext, "Write access has been revoked for publisher."); } @@ -500,9 +504,13 @@ public class TopicServiceImpl implements TopicService { throw new TopicExistsException("Failed to permit read access to consumer [" + consumerId + "] for topic. Topic [" + topicName + "] does not exist."); } - topic.denyReadsByUser(consumerId, user); - LOGGER.info("Read access has been revoked to consumer [" + consumerId + "] for topic [" + topicName + if (isUseCustomAcls()) { + topic.denyReadsByUser(consumerId, user); + LOGGER.info("Read access has been revoked to consumer [" + consumerId + "] for topic [" + topicName + "]. Sending response."); + } else { + LOGGER.info("Ignoring acl update"); + } respondOk(dmaapContext, "Read access has been revoked for consumer [" + consumerId + "] for topic [" + topicName + "]."); |