Integrated snoop discovery/registration in everest sample app.

See arun-gupta#21

To run examples: run snoop-service in docker: docker run -it -p 8081:8080 ivargrimstad/snoop-service
Make sure application.yml files in services, user, order and catalog points to correct ip for snoop

microservice/catalog/pom.xml

@@ -21,6 +21,10 @@
             <groupId>org.javaee7.wildfly.samples</groupId>
             <artifactId>services</artifactId>
         </dependency>
+        <dependency>
+            <groupId>eu.agilejava</groupId>
+            <artifactId>snoop</artifactId>
+        </dependency>  
     </dependencies>
 
     <build>

microservice/catalog/src/main/java/org/javaee7/wildfly/samples/everest/catalog/ApplicationConfig.java

@@ -1,10 +1,12 @@
 package org.javaee7.wildfly.samples.everest.catalog;
 
+import eu.agilejava.snoop.annotation.EnableSnoopClient;
 import javax.ws.rs.core.Application;
 
 /**
  * @author arungupta
  */
+@EnableSnoopClient
 @javax.ws.rs.ApplicationPath("resources")
 public class ApplicationConfig extends Application {
 }

microservice/catalog/src/main/java/org/javaee7/wildfly/samples/everest/catalog/CatalogService.java

@@ -6,6 +6,7 @@
 import javax.ejb.Startup;
 import javax.inject.Inject;
 import org.javaee7.wildfly.samples.services.ServiceRegistry;
+import org.javaee7.wildfly.samples.services.SnoopRegistry;
 import org.javaee7.wildfly.samples.services.ZooKeeperRegistry;
 
 /**
@@ -14,7 +15,8 @@
 @Startup
 @Singleton
 public class CatalogService {
-    @Inject @ZooKeeperRegistry ServiceRegistry services;
+//    @Inject @ZooKeeperRegistry ServiceRegistry services;
+    @Inject @SnoopRegistry ServiceRegistry services;
 
     private static final String endpointURI = "http://localhost:8080/catalog/resources/catalog";
     private static final String serviceName = "catalog";

microservice/catalog/src/main/resources/META-INF/persistence.xml

@@ -1,6 +1,7 @@
 <?xml version="1.0" encoding="UTF-8" standalone="no"?>
 <persistence xmlns="http://xmlns.jcp.org/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.1" xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence http://xmlns.jcp.org/xml/ns/persistence/persistence_2_1.xsd">
     <persistence-unit name="catalogPU" transaction-type="JTA">
+       <jta-data-source>java:/jboss/datasources/ExampleDS</jta-data-source>
         <properties>
             <property name="javax.persistence.schema-generation.database.action" value="drop-and-create"/>
             <property name="javax.persistence.schema-generation.create-source" value="metadata"/> 

microservice/catalog/src/main/resources/application.yml

@@ -0,0 +1,7 @@
+snoop:
+   applicationName: catalog
+   applicationHome: http://localhost:8080/catalog/resources
+   applicationServiceRoot: catalog
+   serviceHost: 192.168.59.103:8081/snoop-service/
+
+

microservice/everest/src/main/java/org/javaee7/wildfly/samples/everest/catalog/CatalogBean.java

@@ -10,6 +10,7 @@
 import javax.json.JsonObject;
 import javax.ws.rs.client.Entity;
 import javax.ws.rs.core.Response;
+import org.javaee7.wildfly.samples.services.SnoopRegistry;
 import org.javaee7.wildfly.samples.services.ZooKeeperRegistry;
 import org.javaee7.wildfly.samples.services.discovery.ServiceDiscovery;
 
@@ -21,8 +22,9 @@
 public class CatalogBean implements Serializable {
     @Inject CatalogItem catalogItem;
 
-    @Inject @ZooKeeperRegistry ServiceDiscovery services;
-
+//    @Inject @ZooKeeperRegistry ServiceDiscovery services;
+    @Inject @SnoopRegistry ServiceDiscovery services;
+
     String status;
 
     public void addCatalog() {

microservice/everest/src/main/java/org/javaee7/wildfly/samples/everest/checkout/OrderBean.java

@@ -15,7 +15,9 @@
 import javax.ws.rs.core.Response;
 import org.javaee7.wildfly.samples.everest.cart.Cart;
 import org.javaee7.wildfly.samples.everest.cart.CartItem;
+import org.javaee7.wildfly.samples.services.SnoopRegistry;
 import org.javaee7.wildfly.samples.services.ZooKeeperRegistry;
+import org.javaee7.wildfly.samples.services.discovery.ServiceDiscovery;
 import org.javaee7.wildfly.samples.services.discovery.ServiceDiscoveryZooKeeper;
 
 /**
@@ -33,9 +35,8 @@ public class OrderBean implements Serializable {
 
     String status;
 
-    @Inject
-    @ZooKeeperRegistry
-    ServiceDiscoveryZooKeeper services;
+//    @Inject @ZooKeeperRegistry ServiceDiscoveryZooKeeper services;
+    @Inject @SnoopRegistry ServiceDiscovery services;
 
     public void saveOrder() {
         List<CartItem> cartItems = cart.getItems();

microservice/everest/src/main/java/org/javaee7/wildfly/samples/everest/uzer/UzerBean.java

@@ -11,6 +11,7 @@
 import javax.json.JsonWriter;
 import javax.ws.rs.client.Entity;
 import javax.ws.rs.core.Response;
+import org.javaee7.wildfly.samples.services.SnoopRegistry;
 import org.javaee7.wildfly.samples.services.ZooKeeperRegistry;
 import org.javaee7.wildfly.samples.services.discovery.ServiceDiscovery;
 
@@ -22,7 +23,8 @@
 public class UzerBean implements Serializable {
     @Inject UzerItem uzerItem;
 
-    @Inject @ZooKeeperRegistry ServiceDiscovery services;
+//    @Inject @ZooKeeperRegistry ServiceDiscovery services;
+    @Inject @SnoopRegistry ServiceDiscovery services;
 
     String status;
 

microservice/order/pom.xml

@@ -21,6 +21,10 @@
             <groupId>org.javaee7.wildfly.samples</groupId>
             <artifactId>services</artifactId>
         </dependency>
+        <dependency>
+            <groupId>eu.agilejava</groupId>
+            <artifactId>snoop</artifactId>
+        </dependency>     
     </dependencies>
 
     <build>

microservice/order/src/main/java/org/javaee7/wildfly/samples/everest/order/ApplicationConfig.java

@@ -1,10 +1,12 @@
 package org.javaee7.wildfly.samples.everest.order;
 
+import eu.agilejava.snoop.annotation.EnableSnoopClient;
 import javax.ws.rs.core.Application;
 
 /**
  * @author arungupta
  */
+@EnableSnoopClient
 @javax.ws.rs.ApplicationPath("resources")
 public class ApplicationConfig extends Application {
 }

microservice/order/src/main/java/org/javaee7/wildfly/samples/everest/order/OrderService.java

@@ -6,6 +6,7 @@
 import javax.ejb.Startup;
 import javax.inject.Inject;
 import org.javaee7.wildfly.samples.services.ServiceRegistry;
+import org.javaee7.wildfly.samples.services.SnoopRegistry;
 import org.javaee7.wildfly.samples.services.ZooKeeperRegistry;
 
 /**
@@ -14,7 +15,8 @@
 @Startup
 @Singleton
 public class OrderService {
-    @Inject @ZooKeeperRegistry ServiceRegistry services;
+//    @Inject @ZooKeeperRegistry ServiceRegistry services;
+    @Inject @SnoopRegistry ServiceRegistry services;
 
     private static final String endpointURI = "http://localhost:8080/order/resources/order";
     private static final String serviceName = "order";

microservice/order/src/main/resources/META-INF/persistence.xml

@@ -1,6 +1,7 @@
 <?xml version="1.0" encoding="UTF-8" standalone="no"?>
 <persistence xmlns="http://xmlns.jcp.org/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.1" xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence http://xmlns.jcp.org/xml/ns/persistence/persistence_2_1.xsd">
     <persistence-unit name="orderPU" transaction-type="JTA">
+       <jta-data-source>java:/jboss/datasources/ExampleDS</jta-data-source>
         <properties>
             <property name="javax.persistence.schema-generation.database.action" value="drop-and-create"/>
             <property name="javax.persistence.schema-generation.create-source" value="metadata"/> 

microservice/order/src/main/resources/application.yml

@@ -0,0 +1,7 @@
+snoop:
+   applicationName: order
+   applicationHome: http://localhost:8080/order/resources
+   applicationServiceRoot: order
+   serviceHost: 192.168.59.103:8081/snoop-service/
+
+

microservice/pom.xml

@@ -23,7 +23,10 @@
         <version.wildfly-swarm>1.0.0.Alpha1</version.wildfly-swarm>
         <version.docker-plugin>0.11.3</version.docker-plugin>
         <version.resteasy>3.0.11.Final</version.resteasy>
-        <version.curator>2.8.0</version.curator>
+        <version.curator>2.8.0</version.curator>        
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <maven.compiler.source>1.8</maven.compiler.source>
+        <maven.compiler.target>1.8</maven.compiler.target>
     </properties>
 
     <dependencyManagement>
@@ -67,6 +70,11 @@
                     </exclusion>
                 </exclusions>
             </dependency>
+            <dependency>
+                <groupId>eu.agilejava</groupId>
+                <artifactId>snoop</artifactId>
+                <version>1.0.0-SNAPSHOT</version>
+            </dependency>  
         </dependencies>
     </dependencyManagement>
 
@@ -196,4 +204,17 @@
         </profile>
     </profiles>
 
+    <repositories>
+        <repository>
+           <id>snoop</id>
+           <url>http://nexus.agilejava.eu/nexus/content/groups/public</url>
+           <releases>
+              <enabled>true></enabled>
+           </releases>
+           <snapshots>
+              <enabled>true</enabled>
+           </snapshots>
+        </repository>
+    </repositories>
+
 </project>

microservice/user/pom.xml

@@ -15,12 +15,16 @@
     <packaging>war</packaging>
 
     <name>user</name>
-    
+
     <dependencies>
         <dependency>
             <groupId>org.javaee7.wildfly.samples</groupId>
             <artifactId>services</artifactId>
-        </dependency>    
+        </dependency>  
+        <dependency>
+            <groupId>eu.agilejava</groupId>
+            <artifactId>snoop</artifactId>
+        </dependency>  
     </dependencies>
 
     <build>

microservice/user/src/main/java/org/javaee7/wildfly/samples/everest/uzer/ApplicationConfig.java

@@ -1,10 +1,12 @@
 package org.javaee7.wildfly.samples.everest.uzer;
 
+import eu.agilejava.snoop.annotation.EnableSnoopClient;
 import javax.ws.rs.core.Application;
 
 /**
  * @author arungupta
  */
+@EnableSnoopClient
 @javax.ws.rs.ApplicationPath("resources")
 public class ApplicationConfig extends Application {
 }

microservice/user/src/main/java/org/javaee7/wildfly/samples/everest/uzer/UserService.java

@@ -6,6 +6,7 @@
 import javax.ejb.Startup;
 import javax.inject.Inject;
 import org.javaee7.wildfly.samples.services.ServiceRegistry;
+import org.javaee7.wildfly.samples.services.SnoopRegistry;
 import org.javaee7.wildfly.samples.services.ZooKeeperRegistry;
 
 /**
@@ -14,8 +15,9 @@
 @Startup
 @Singleton
 public class UserService {
-    @Inject @ZooKeeperRegistry ServiceRegistry services;
-
+//    @Inject @ZooKeeperRegistry ServiceRegistry services;
+    @Inject @SnoopRegistry ServiceRegistry services;
+
     private static final String endpointURI = "http://localhost:8080/user/resources/user";
     private static final String serviceName = "user";
 

microservice/user/src/main/resources/META-INF/persistence.xml

@@ -1,6 +1,7 @@
 <?xml version="1.0" encoding="UTF-8" standalone="no"?>
 <persistence xmlns="http://xmlns.jcp.org/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.1" xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence http://xmlns.jcp.org/xml/ns/persistence/persistence_2_1.xsd">
     <persistence-unit name="userPU" transaction-type="JTA">
+       <jta-data-source>java:/jboss/datasources/ExampleDS</jta-data-source>
         <properties>
             <property name="javax.persistence.schema-generation.database.action" value="drop-and-create"/>
             <property name="javax.persistence.schema-generation.create-source" value="metadata"/> 

microservice/user/src/main/resources/application.yml

@@ -0,0 +1,7 @@
+snoop:
+   applicationName: user
+   applicationHome: http://localhost:8080/user/resources
+   applicationServiceRoot: user
+   serviceHost: 192.168.59.103:8081/snoop-service/
+
+