added cdi/events-conditional-reception, clarified cdi/events test

Author: rhanus

cdi/events-conditional-reception/pom.xml

@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>org.javaee7</groupId>
+        <artifactId>cdi</artifactId>
+        <version>1.0-SNAPSHOT</version>
+        <relativePath>../pom.xml</relativePath>        
+    </parent>
+    <artifactId>cdi-events-conditional-reception</artifactId>
+    <name>Java EE 7 Sample: conditional reception of cdi events</name>
+</project>

cdi/events-conditional-reception/src/main/java/org/javaee7/cdi/events/conditional/EventReceiver.java

@@ -0,0 +1,8 @@
+package org.javaee7.cdi.events.conditional;
+
+/**
+ * @author Radim Hanus
+ */
+public interface EventReceiver {
+	String getGreet();
+}

cdi/events-conditional-reception/src/main/java/org/javaee7/cdi/events/conditional/EventSender.java

@@ -0,0 +1,8 @@
+package org.javaee7.cdi.events.conditional;
+
+/**
+ * @author Radim Hanus
+ */
+public interface EventSender {
+    void send(String message);
+}

cdi/events-conditional-reception/src/main/java/org/javaee7/cdi/events/conditional/GreetingReceiver.java

@@ -0,0 +1,23 @@
+package org.javaee7.cdi.events.conditional;
+
+import javax.enterprise.context.SessionScoped;
+import javax.enterprise.event.Observes;
+import javax.enterprise.event.Reception;
+import java.io.Serializable;
+
+/**
+ * @author Radim Hanus
+ */
+@SessionScoped
+public class GreetingReceiver implements EventReceiver, Serializable {
+	private String greet = "Willkommen";
+
+	void receive(@Observes(notifyObserver = Reception.IF_EXISTS) String greet) {
+		this.greet = greet;
+	}
+
+	@Override
+	public String getGreet() {
+		return greet;
+	}
+}

cdi/events-conditional-reception/src/main/java/org/javaee7/cdi/events/conditional/GreetingSender.java

@@ -0,0 +1,17 @@
+package org.javaee7.cdi.events.conditional;
+
+import javax.enterprise.event.Event;
+import javax.inject.Inject;
+
+/**
+ * @author Radim Hanus
+ */
+public class GreetingSender implements EventSender {
+    @Inject
+    private Event<String> event;
+
+    @Override
+    public void send(String message) {
+        event.fire(message);
+    }
+}

cdi/events-conditional-reception/src/test/java/org/javaee7/cdi/events/conditional/GreetingTest.java

@@ -0,0 +1,52 @@
+package org.javaee7.cdi.events.conditional;
+
+import org.jboss.arquillian.container.test.api.Deployment;
+import org.jboss.arquillian.junit.Arquillian;
+import org.jboss.shrinkwrap.api.Archive;
+import org.jboss.shrinkwrap.api.ShrinkWrap;
+import org.jboss.shrinkwrap.api.spec.JavaArchive;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+import javax.inject.Inject;
+
+import static org.hamcrest.CoreMatchers.*;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertThat;
+
+/**
+ * @author Radim Hanus
+ */
+@RunWith(Arquillian.class)
+public class GreetingTest {
+	@Deployment
+	public static Archive<?> deploy() {
+		return ShrinkWrap.create(JavaArchive.class)
+				.addClasses(EventReceiver.class, EventSender.class, GreetingReceiver.class, GreetingSender.class)
+				.addAsManifestResource("beans.xml");
+	}
+
+	@Inject
+	private EventSender sender;
+
+	@Inject
+	private EventReceiver receiver;
+
+	@Test
+	public void test() throws Exception {
+		assertThat(sender, is(notNullValue()));
+		assertThat(sender, instanceOf(GreetingSender.class));
+
+		assertThat(receiver, is(notNullValue()));
+		assertThat(receiver, instanceOf(GreetingReceiver.class));
+
+		// send a new greet but the receiver is not instantiated yet
+		sender.send("Welcome");
+		// default greet should be available (note that receiver has just been instantiated)
+		assertEquals("Willkommen", receiver.getGreet());
+		// send a new greet again
+		sender.send("Welcome");
+		// observer method was called so that new greet should be available
+		assertEquals("Welcome", receiver.getGreet());
+	}
+}

cdi/events-conditional-reception/src/test/resources/beans.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<beans xmlns="http://xmlns.jcp.org/xml/ns/javaee"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/beans_1_1.xsd"
+       bean-discovery-mode="all">
+
+</beans>

cdi/events/src/test/java/org/javaee7/cdi/events/GreetingTest.java

@@ -10,9 +10,7 @@
 
 import javax.inject.Inject;
 
-import static org.hamcrest.CoreMatchers.instanceOf;
-import static org.hamcrest.CoreMatchers.is;
-import static org.hamcrest.CoreMatchers.notNullValue;
+import static org.hamcrest.CoreMatchers.*;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertThat;
 
@@ -42,9 +40,7 @@ public void test() throws Exception {
         assertThat(receiver, is(notNullValue()));
         assertThat(receiver, instanceOf(GreetingReceiver.class));
 
-        // default greet
-        assertEquals("Willkommen", receiver.getGreet());
-        // send a new greet
+        // send a new greet, default greet "Willkommen" should be overwritten
         sender.send("Welcome");
         // receiver must not belongs to the dependent pseudo-scope since we are checking the result
         assertEquals("Welcome", receiver.getGreet());

cdi/pom.xml

@@ -35,6 +35,7 @@
         <module>nobeans-el-injection</module>
         <module>nobeans-el-injection-flowscoped</module>
         <module>events</module>
+        <module>events-conditional-reception</module>
     </modules>
 
     <dependencies>