You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fineract.apache.org by aw...@apache.org on 2019/06/06 07:10:04 UTC
[fineract-cn-notifications] 13/36: to test customer
This is an automated email from the ASF dual-hosted git repository.
awasum pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/fineract-cn-notifications.git
commit 5e44714f25b138c77fe4f08df54d4f3e66414d86
Author: Ebenezer Graham <eg...@alustudent.com>
AuthorDate: Fri Jun 15 17:31:54 2018 +0400
to test customer
---
.../service/internal/service/SMSSender.java | 1 -
.../service/listener/CustomerEventListener.java | 32 +++-------------
.../service/listener/PortfolioEventListener.java | 43 ++++++++++++----------
3 files changed, 29 insertions(+), 47 deletions(-)
diff --git a/service/src/main/java/org/apache/fineract/cn/notification/service/internal/service/SMSSender.java b/service/src/main/java/org/apache/fineract/cn/notification/service/internal/service/SMSSender.java
index d626b22..48a7ac9 100644
--- a/service/src/main/java/org/apache/fineract/cn/notification/service/internal/service/SMSSender.java
+++ b/service/src/main/java/org/apache/fineract/cn/notification/service/internal/service/SMSSender.java
@@ -54,5 +54,4 @@ public class SMSSender {
System.out.println(message.getSid());
System.out.println(message.getStatus());
}
-
}
\ No newline at end of file
diff --git a/service/src/main/java/org/apache/fineract/cn/notification/service/listener/CustomerEventListener.java b/service/src/main/java/org/apache/fineract/cn/notification/service/listener/CustomerEventListener.java
index 73d3d1d..3f4c771 100644
--- a/service/src/main/java/org/apache/fineract/cn/notification/service/listener/CustomerEventListener.java
+++ b/service/src/main/java/org/apache/fineract/cn/notification/service/listener/CustomerEventListener.java
@@ -31,7 +31,7 @@ import org.springframework.jms.annotation.JmsListener;
import org.springframework.messaging.handler.annotation.Header;
import org.springframework.stereotype.Component;
-
+@SuppressWarnings("unused")
@Component
public class CustomerEventListener {
@@ -40,11 +40,11 @@ public class CustomerEventListener {
private EmailSender emailSender;
@Autowired
- public CustomerEventListener( final CustomerManager customerManager, SMSSender smsSender,
- final EmailSender emailSender ) {
+ public CustomerEventListener( final CustomerManager customerManager, SMSSender smsSender, EmailSender emailSender ) {
this.customerManager = customerManager;
this.smsSender = smsSender;
this.emailSender = emailSender;
+ smsSender.sendSMS("+23058409206","just to be sure listen has been instantiated");
}
@JmsListener(
@@ -53,8 +53,9 @@ public class CustomerEventListener {
)
public void customerCreatedEvent(@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
final String payload) {
-
+ System.out.println(payload);
Customer customer = customerManager.findCustomer(payload);
+ System.out.println("This is the customer created: " + customer.getGivenName());
if (customer.getContactDetails().size() > 0) {
customer.getContactDetails().forEach(contactDetail -> {
if (contactDetail.getType().equals(ContactDetail.Type.PHONE)) {
@@ -174,27 +175,4 @@ public class CustomerEventListener {
});
}
}
-
-/*
-
- @JmsListener(
- destination = CustomerEventConstants.DESTINATION,
- selector = CustomerEventConstants.SELECTOR_PUT_ADDRESS
- )
- public void addressChangedEvent(@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
- final String payload) {
- this.eventRecorder.event(tenant, CustomerEventConstants.PUT_ADDRESS, payload, String.class);
- }
-
- @JmsListener(
- destination = CustomerEventConstants.DESTINATION,
- selector = CustomerEventConstants.SELECTOR_PUT_IDENTIFICATION_CARD
- )
- public void identificationCardChangedEvent(@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
- final String payload) {
- this.eventRecorder.event(tenant, CustomerEventConstants.PUT_IDENTIFICATION_CARD, payload, String.class);
- }
-
-
-*/
}
diff --git a/service/src/main/java/org/apache/fineract/cn/notification/service/listener/PortfolioEventListener.java b/service/src/main/java/org/apache/fineract/cn/notification/service/listener/PortfolioEventListener.java
index 758e7f0..4f8f9d0 100644
--- a/service/src/main/java/org/apache/fineract/cn/notification/service/listener/PortfolioEventListener.java
+++ b/service/src/main/java/org/apache/fineract/cn/notification/service/listener/PortfolioEventListener.java
@@ -1,4 +1,4 @@
-package org.apache.fineract.cn.notification.service.listener;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
@@ -16,11 +16,16 @@ package org.apache.fineract.cn.notification.service.listener;/*
* specific language governing permissions and limitations
* under the License.
*/
- /*
+package org.apache.fineract.cn.notification.service.listener;
+
+import org.apache.fineract.cn.group.api.v1.EventConstants;
import org.apache.fineract.cn.individuallending.api.v1.events.IndividualLoanEventConstants;
import org.apache.fineract.cn.lang.config.TenantHeaderFilter;
+import org.apache.fineract.cn.notification.service.internal.service.EmailSender;
+import org.apache.fineract.cn.notification.service.internal.service.SMSSender;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
+import org.springframework.messaging.handler.annotation.Header;
import org.springframework.stereotype.Component;
import org.apache.fineract.cn.portfolio.api.v1.client.PortfolioManager;
@@ -28,10 +33,16 @@ import org.apache.fineract.cn.portfolio.api.v1.client.PortfolioManager;
@Component
public class PortfolioEventListener {
+ private PortfolioManager portfolioManager;
+ private SMSSender smsSender;
+ private EmailSender emailSender;
+
@Autowired
- public PortfolioEventListener() {
+ public PortfolioEventListener(PortfolioManager portfolioManager, SMSSender smsSender, EmailSender emailSender) {
super();
- //PortfolioManager portfolioManager = new PortfolioManager();
+ this.portfolioManager = portfolioManager;
+ this.smsSender = smsSender;
+ this.emailSender = emailSender;
}
@JmsListener(
@@ -39,8 +50,7 @@ public class PortfolioEventListener {
destination = IndividualLoanEventConstants.DESTINATION,
selector = IndividualLoanEventConstants.SELECTOR_DENY_INDIVIDUALLOAN_CASE
)
- public void onDeny(//@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
- final String payload) {
+ public void onDeny(final String payload) {
}
@@ -49,7 +59,7 @@ public class PortfolioEventListener {
destination = IndividualLoanEventConstants.DESTINATION,
selector = IndividualLoanEventConstants.SELECTOR_APPROVE_INDIVIDUALLOAN_CASE
)
- public void onApprove(//@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
+ public void onApprove(@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
final String payload) {
}
@@ -59,7 +69,7 @@ public class PortfolioEventListener {
destination = IndividualLoanEventConstants.DESTINATION,
selector = IndividualLoanEventConstants.SELECTOR_ACCEPT_PAYMENT_INDIVIDUALLOAN_CASE
)
- public void onAcceptPayment(//@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
+ public void onAcceptPayment(@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
final String payload) {
}
@@ -69,7 +79,7 @@ public class PortfolioEventListener {
destination = IndividualLoanEventConstants.DESTINATION,
selector = IndividualLoanEventConstants.SELECTOR_DISBURSE_INDIVIDUALLOAN_CASE
)
- public void onDisburse(//@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
+ public void onDisburse(@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
final String payload) {
}
@@ -79,7 +89,7 @@ public class PortfolioEventListener {
destination = IndividualLoanEventConstants.DESTINATION,
selector = IndividualLoanEventConstants.SELECTOR_CHECK_LATE_INDIVIDUALLOAN_CASE
)
- public void onCheckLate(//@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
+ public void onCheckLate(@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
final String payload) {
}
@@ -99,7 +109,7 @@ public class PortfolioEventListener {
destination = IndividualLoanEventConstants.DESTINATION,
selector = IndividualLoanEventConstants.SELECTOR_MARK_LATE_INDIVIDUALLOAN_CASE
)
- public void onMarkLate(//@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
+ public void onMarkLate(@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
final String payload) {
}
@@ -109,20 +119,18 @@ public class PortfolioEventListener {
destination = IndividualLoanEventConstants.DESTINATION,
selector = IndividualLoanEventConstants.SELECTOR_CLOSE_INDIVIDUALLOAN_CASE
)
- public void onClose(//@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
+ public void onClose(@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
final String payload) {
}
-
-
- @JmsListener(
+ @JmsListener(
subscription = EventConstants.DESTINATION,
destination = EventConstants.DESTINATION,
selector = EventConstants.SELECTOR_POST_GROUP
)
public void onGroupCreated(@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
final String payload) {
- this.eventRecorder.event(tenant, EventConstants.POST_GROUP, payload, String.class);
+
}
@JmsListener(
@@ -132,7 +140,6 @@ public class PortfolioEventListener {
)
public void onGroupActivated(@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
final String payload) {
- this.eventRecorder.event(tenant, EventConstants.ACTIVATE_GROUP, payload, String.class);
}
@JmsListener(
@@ -142,8 +149,6 @@ public class PortfolioEventListener {
)
public void onGroupUpdated(@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
final String payload) {
- this.eventRecorder.event(tenant, EventConstants.PUT_GROUP, payload, String.class);
}
}
- */
\ No newline at end of file