This is an automated email from the ASF dual-hosted git repository. myrle pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/fineract-cn-notifications.git
commit 5e44714f25b138c77fe4f08df54d4f3e66414d86 Author: Ebenezer Graham <egraha...@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