diff --git a/src/main/java/com/mfsys/uco/exception/BenificiaryAlreadyExistsException.java b/src/main/java/com/mfsys/uco/exception/BenificiaryAlreadyExistsException.java
new file mode 100644
index 0000000..9871f8e
--- /dev/null
+++ b/src/main/java/com/mfsys/uco/exception/BenificiaryAlreadyExistsException.java
@@ -0,0 +1,11 @@
+package com.mfsys.uco.exception;
+
+
+import com.mfsys.comm.exception.ApplicationException;
+import com.mfsys.comm.exception.ERRCode;
+
+public class BenificiaryAlreadyExistsException extends ApplicationException {
+    public BenificiaryAlreadyExistsException() {
+        super(null, ERRCode.BENEFICIARY_ALREADY_EXISTS, null);
+    }
+}
diff --git a/src/main/java/com/mfsys/uco/service/CustomerProfileService.java b/src/main/java/com/mfsys/uco/service/CustomerProfileService.java
index 79bb5a3..8f59857 100644
--- a/src/main/java/com/mfsys/uco/service/CustomerProfileService.java
+++ b/src/main/java/com/mfsys/uco/service/CustomerProfileService.java
@@ -1,6 +1,7 @@
 package com.mfsys.uco.service;
 
 import com.mfsys.uco.dto.UpdateProfileRequestPayload;
+import com.mfsys.uco.exception.BenificiaryAlreadyExistsException;
 import com.mfsys.uco.model.Beneficiary;
 import com.mfsys.uco.model.CustomerProfile;
 import com.mfsys.uco.model.CustomerProfileId;
@@ -30,8 +31,10 @@ public class CustomerProfileService {
     }
 
     public void addBeneficiary(Beneficiary beneficiary) {
-        OptionalbeneficiaryRepository.findBeneficiaryByEmailAndPorOrgacodeAndMbmBkmsnumberRef(beneficiary.getEmail(),beneficiary.getPorOrgacode(), beneficiary.getMbmBkmsnumberRef());
-       if()
+        Optional<Beneficiary> existing =  beneficiaryRepository.findBeneficiaryByEmailAndPorOrgacodeAndMbmBkmsnumberRef(beneficiary.getEmail(),beneficiary.getPorOrgacode(), beneficiary.getMbmBkmsnumberRef());
+       if(existing.isPresent()){
+           throw new BenificiaryAlreadyExistsException();
+       }
         beneficiaryRepository.save(beneficiary);
     }
 }