You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fineract.apache.org by my...@apache.org on 2018/06/21 16:19:18 UTC
[fineract-cn-notifications] 10/15: test
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 041ec3473717bfa0d45ca7f73cbafa4634e7bdb5
Author: Ebenezer Graham <eg...@alustudent.com>
AuthorDate: Fri Jun 15 04:04:00 2018 +0400
test
---
.../service/listener/OfficeEventListener.java | 48 ++++++++++++++--------
1 file changed, 32 insertions(+), 16 deletions(-)
diff --git a/service/src/main/java/org/apache/fineract/cn/notification/service/listener/OfficeEventListener.java b/service/src/main/java/org/apache/fineract/cn/notification/service/listener/OfficeEventListener.java
index c77510e..9f083c5 100644
--- a/service/src/main/java/org/apache/fineract/cn/notification/service/listener/OfficeEventListener.java
+++ b/service/src/main/java/org/apache/fineract/cn/notification/service/listener/OfficeEventListener.java
@@ -16,12 +16,14 @@
* specific language governing permissions and limitations
* under the License.
*/
-/*
+
package org.apache.fineract.cn.notification.service.listener;
-import org.apache.fineract.cn.accounting.api.v1.EventConstants;
+import org.apache.fineract.cn.notification.service.internal.service.EmailSender;
+import org.apache.fineract.cn.notification.service.internal.service.SMSSender;
+import org.apache.fineract.cn.office.api.v1.EventConstants;
import org.apache.fineract.cn.lang.config.TenantHeaderFilter;
-import org.apache.fineract.cn.test.listener.EventRecorder;
+import org.apache.fineract.cn.office.api.v1.client.OrganizationManager;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.messaging.handler.annotation.Header;
@@ -30,15 +32,35 @@ import org.springframework.stereotype.Component;
@Component
public class OfficeEventListener {
- private final EventRecorder eventRecorder;
+ private OrganizationManager organizationManager;
+ private SMSSender smsSender;
+ private EmailSender emailSender;
- @Autowired
- public OfficeEventListener(final EventRecorder eventRecorder) {
- super();
- this.eventRecorder = eventRecorder;
- }
+ @Autowired
+ public OfficeEventListener(final OrganizationManager organizationManager, SMSSender smsSender,
+ final EmailSender emailSender) {
+ this.organizationManager = organizationManager;
+ this.smsSender = smsSender;
+ this.emailSender = emailSender;
+ }
- @JmsListener(
+ @JmsListener(
+ subscription = EventConstants.DESTINATION,
+ destination = EventConstants.DESTINATION,
+ selector = EventConstants.SELECTOR_POST_OFFICE
+ )
+ public void onCreateOffice(@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
+ final String payload) {
+ //for testing purposes
+ String office = this.organizationManager.findOfficeByIdentifier(payload).getName();
+ if (office.equalsIgnoreCase("Head Office")) {
+ smsSender.sendSMS("+23058409206", "Test From Demo");
+ }
+ }
+}
+
+/*
+ @JmsListener(
subscription = EventConstants.DESTINATION,
destination = EventConstants.DESTINATION,
selector = EventConstants.SELECTOR_POST_EMPLOYEE
@@ -88,12 +110,6 @@ public class OfficeEventListener {
this.eventRecorder.event(tenant, EventConstants.OPERATION_DELETE_CONTACT_DETAIL, eventPayload, String.class);
}
- public void onCreateOffice(@Header(TenantHeaderFilter.TENANT_HEADER) final String tenant,
- final String payload)
- throws Exception {
- this.eventRecorder.event(tenant, EventConstants.OPERATION_POST_OFFICE, payload, String.class);
- }
-
@JmsListener(
subscription = EventConstants.DESTINATION,
destination = EventConstants.DESTINATION,