Added firing newly added event when an administrator has added a new country and...

Signed-off-by: Roland Häder <roland@mxchange.org>

diff --git a/src/java/org/mxchange/jjobs/beans/country/JobsAdminCountryWebApplicationBean.java b/src/java/org/mxchange/jjobs/beans/country/JobsAdminCountryWebApplicationBean.java
index e79c576241316abb0afe257c7fde8907e2aa0ab0..ce28ecfdd5c38d11f96ca7d01c0c25cb55c81587 100644 (file)
--- a/src/java/org/mxchange/jjobs/beans/country/JobsAdminCountryWebApplicationBean.java
+++ b/src/java/org/mxchange/jjobs/beans/country/JobsAdminCountryWebApplicationBean.java
@@ -20,6 +20,8 @@ import java.util.Iterator;
 import java.util.List;
 import java.util.Objects;
 import javax.enterprise.context.ApplicationScoped;
+import javax.enterprise.event.Event;
+import javax.enterprise.inject.Any;
 import javax.faces.view.facelets.FaceletException;
 import javax.inject.Inject;
 import javax.inject.Named;
@@ -29,6 +31,8 @@ import javax.naming.NamingException;
 import org.mxchange.jcountry.data.Country;
 import org.mxchange.jcountry.data.CountryData;
 import org.mxchange.jcountry.data.CountrySingletonBeanRemote;
+import org.mxchange.jcountry.events.AdminAddedCountryEvent;
+import org.mxchange.jcountry.events.AdminEventCountryAdded;
 import org.mxchange.jcountry.exceptions.CountryAlreadyAddedException;
 
 /**
@@ -66,6 +70,13 @@ public class JobsAdminCountryWebApplicationBean implements JobsAdminCountryWebAp
        @Inject
        private JobsCountryWebApplicationController countryController;
 
+       /**
+        * An event triggered when the administrator has added a country
+        */
+       @Inject
+       @Any
+       private Event<AdminAddedCountryEvent> addedCountryEvent;
+
        /**
         * Local dial prefix
         */
@@ -126,6 +137,9 @@ public class JobsAdminCountryWebApplicationBean implements JobsAdminCountryWebAp
                        // Send country to bean
                        this.countryBean.addCountry(country);
 
+                       // Fire event
+                       this.addedCountryEvent.fire(new AdminEventCountryAdded(country));
+
                        // Clear bean
                        this.clear();
                } catch (final CountryAlreadyAddedException ex) {

diff --git a/src/java/org/mxchange/jjobs/beans/country/JobsCountryWebApplicationBean.java b/src/java/org/mxchange/jjobs/beans/country/JobsCountryWebApplicationBean.java
index a39e2251afcedeca9e765f207c5ef2ce411bf37b..d52d26850cdb201405e0d9bf920d5c63df56a20f 100644 (file)
--- a/src/java/org/mxchange/jjobs/beans/country/JobsCountryWebApplicationBean.java
+++ b/src/java/org/mxchange/jjobs/beans/country/JobsCountryWebApplicationBean.java
@@ -16,10 +16,12 @@
  */
 package org.mxchange.jjobs.beans.country;
 
+import java.text.MessageFormat;
 import java.util.Collections;
 import java.util.List;
 import javax.annotation.PostConstruct;
 import javax.enterprise.context.ApplicationScoped;
+import javax.enterprise.event.Observes;
 import javax.faces.view.facelets.FaceletException;
 import javax.inject.Named;
 import javax.naming.Context;
@@ -27,6 +29,7 @@ import javax.naming.InitialContext;
 import javax.naming.NamingException;
 import org.mxchange.jcountry.data.Country;
 import org.mxchange.jcountry.data.CountrySingletonBeanRemote;
+import org.mxchange.jcountry.events.AdminAddedCountryEvent;
 
 /**
  * A country bean
@@ -69,6 +72,27 @@ public class JobsCountryWebApplicationBean implements JobsCountryWebApplicationC
                }
        }
 
+       @Override
+       public void afterAdminAddedCountry (@Observes final AdminAddedCountryEvent event) {
+               // Is all valid?
+               if (null == event) {
+                       // Throw NPE
+                       throw new NullPointerException("event is null"); //NOI18N
+               } else if (event.getAddedCountry() == null) {
+                       // Throw again ...
+                       throw new NullPointerException("event.addedCountry is null"); //NOI18N
+               } else if (event.getAddedCountry().getCountryId() == null) {
+                       // And again ...
+                       throw new NullPointerException("event.addedCountry.countryId is null"); //NOI18N
+               } else if (event.getAddedCountry().getCountryId() < 1) {
+                       // Id is invalid
+                       throw new IllegalArgumentException(MessageFormat.format("event.addedCountry.countryId={0} is not valid.", event.getAddedCountry().getCountryId())); //NOI18N
+               }
+
+               // Add the event
+               this.countryList.add(event.getAddedCountry());
+       }
+
        @Override
        public List<Country> allCountries () {
                // Return "cached" version

diff --git a/src/java/org/mxchange/jjobs/beans/country/JobsCountryWebApplicationController.java b/src/java/org/mxchange/jjobs/beans/country/JobsCountryWebApplicationController.java
index 78550df46b5bcac04ee9aca5e18e25259c9aca8f..226fcc4584f6bcf3ba2c4b3f2163e42e38ac9811 100644 (file)
--- a/src/java/org/mxchange/jjobs/beans/country/JobsCountryWebApplicationController.java
+++ b/src/java/org/mxchange/jjobs/beans/country/JobsCountryWebApplicationController.java
@@ -19,6 +19,7 @@ package org.mxchange.jjobs.beans.country;
 import java.io.Serializable;
 import java.util.List;
 import org.mxchange.jcountry.data.Country;
+import org.mxchange.jcountry.events.AdminAddedCountryEvent;
 
 /**
  * An interface for country beans
@@ -33,4 +34,13 @@ public interface JobsCountryWebApplicationController extends Serializable {
         * @return All countries
         */
        List<Country> allCountries ();
+
+       /**
+        * Observing method when the event is fired that an administrator added a
+        * new country
+        * <p>
+        * @param event Event instance
+        */
+       void afterAdminAddedCountry (final AdminAddedCountryEvent event);
+
 }