[JMS] Added ActiveMQ integration

Author: anandrajneesh

pom.xml

@@ -56,6 +56,10 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-security</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-activemq</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.springframework.security</groupId>
             <artifactId>spring-security-test</artifactId>
@@ -98,6 +102,11 @@
             <version>${nosqlunit.version}</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.apache.activemq</groupId>
+            <artifactId>activemq-amqp</artifactId>
+            <version>5.15.2</version>
+        </dependency>
     </dependencies>
 
     <build>

src/main/java/org/gluecoders/library/events/Event.java

@@ -0,0 +1,23 @@
+package org.gluecoders.library.events;
+
+import org.gluecoders.library.services.notifiers.EventHandler;
+
+import java.io.Serializable;
+
+/**
+ * Created by Anand Rajneesh on 12/2/2017.
+ */
+public abstract class Event implements Serializable{
+
+    protected final String eventType;
+
+    public Event(String eventType) {
+        this.eventType = eventType;
+    }
+
+    public String getEventType() {
+        return eventType;
+    }
+
+    public abstract void accept(EventHandler handler);
+}

src/main/java/org/gluecoders/library/events/Events.java

@@ -0,0 +1,16 @@
+package org.gluecoders.library.events;
+
+import java.util.function.Supplier;
+
+/**
+ * Created by Anand Rajneesh on 12/2/2017.
+ */
+public enum Events implements Supplier<String> {
+
+    NEW_MEMBER;
+
+    @Override
+    public String get() {
+        return this.name();
+    }
+}

src/main/java/org/gluecoders/library/events/RegistrationEvent.java

@@ -0,0 +1,26 @@
+package org.gluecoders.library.events;
+
+import org.gluecoders.library.models.Member;
+import org.gluecoders.library.services.notifiers.EventHandler;
+
+/**
+ * Created by Anand Rajneesh on 12/2/2017.
+ */
+public class RegistrationEvent extends Event {
+
+    private final String username;
+
+    public RegistrationEvent(Member member) {
+        super(Events.NEW_MEMBER.get());
+        username = member.getEmail();
+    }
+
+    @Override
+    public void accept(EventHandler handler) {
+        handler.handle(this);
+    }
+
+    public String getUsername() {
+        return username;
+    }
+}

src/main/java/org/gluecoders/library/rest/Registration.java

@@ -9,6 +9,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -26,6 +27,7 @@ public class Registration {
     private static final Logger LOGGER = LoggerFactory.getLogger(Registration.class);
 
     @Autowired
+    @Qualifier("registrationService")
     private RegistrationService registrationService;
 
     @Autowired

src/main/java/org/gluecoders/library/services/DefaultRegistrationService.java

@@ -17,7 +17,7 @@
 /**
  * Created by Anand_Rajneesh on 7/1/2017.
  */
-@Component
+@Component("defaultRegistrationService")
 public class DefaultRegistrationService implements  RegistrationService {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(DefaultRegistrationService.class);

src/main/java/org/gluecoders/library/services/NotifyingRegistrationService.java

@@ -0,0 +1,37 @@
+package org.gluecoders.library.services;
+
+import org.gluecoders.library.events.RegistrationEvent;
+import org.gluecoders.library.exceptions.ResourceAlreadyExistsException;
+import org.gluecoders.library.models.Credentials;
+import org.gluecoders.library.models.Member;
+import org.gluecoders.library.services.notifiers.JmsSender;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.stereotype.Component;
+
+/**
+ * Created by Anand Rajneesh on 12/2/2017.
+ */
+@Component("registrationService")
+public class NotifyingRegistrationService implements RegistrationService {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(NotifyingRegistrationService.class);
+
+    @Autowired
+    @Qualifier("defaultRegistrationService")
+    private RegistrationService registrationService;
+
+    @Autowired
+    private JmsSender jmsSender;
+
+    @Override
+    public Member register(Credentials credentials) throws ResourceAlreadyExistsException {
+        Member member = registrationService.register(credentials);
+        LOGGER.info("Notifying registration event");
+        RegistrationEvent registrationEvent = new RegistrationEvent(member);
+        registrationEvent.accept(jmsSender);
+        return member;
+    }
+}

src/main/java/org/gluecoders/library/services/listeners/RegistrationEventListener.java

@@ -0,0 +1,21 @@
+package org.gluecoders.library.services.listeners;
+
+import org.gluecoders.library.events.RegistrationEvent;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.jms.annotation.JmsListener;
+import org.springframework.stereotype.Component;
+
+/**
+ * Created by Anand Rajneesh on 12/2/2017.
+ */
+@Component
+public class RegistrationEventListener {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(RegistrationEventListener.class);
+
+    @JmsListener(destination = "members")
+    public void receive(RegistrationEvent event){
+        LOGGER.info("Received event {} from members queue", event.getEventType());
+    }
+}

src/main/java/org/gluecoders/library/services/notifiers/EventHandler.java

@@ -0,0 +1,11 @@
+package org.gluecoders.library.services.notifiers;
+
+import org.gluecoders.library.events.RegistrationEvent;
+
+/**
+ * Created by Anand Rajneesh on 12/2/2017.
+ */
+public interface EventHandler {
+
+    void handle(RegistrationEvent event);
+}

src/main/java/org/gluecoders/library/services/notifiers/JmsSender.java

@@ -0,0 +1,26 @@
+package org.gluecoders.library.services.notifiers;
+
+import org.gluecoders.library.events.RegistrationEvent;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jms.core.JmsTemplate;
+import org.springframework.stereotype.Component;
+
+/**
+ * Created by Anand Rajneesh on 12/2/2017.
+ */
+@Component
+public class JmsSender implements EventHandler{
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(JmsSender.class);
+
+    @Autowired
+    private JmsTemplate jmsTemplate;
+
+    @Override
+    public void handle(RegistrationEvent event) {
+        jmsTemplate.convertAndSend("members", event);
+        LOGGER.info("Registration event send to destination : members");
+    }
+}

src/main/resources/application.properties

@@ -1 +1,4 @@
-spring.data.mongodb.uri=mongodb://localhost:27017/test
+spring.data.mongodb.uri=mongodb://localhost:27017/books
+spring.activemq.in-memory=true
+spring.activemq.packages.trustAll=true
+logging.level=DEBUG

src/test/java/org/gluecoders/library/events/RegistrationEventTest.java

@@ -0,0 +1,52 @@
+package org.gluecoders.library.events;
+
+import org.gluecoders.library.models.Member;
+import org.gluecoders.library.services.notifiers.EventHandler;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.Mockito;
+import org.mockito.runners.MockitoJUnitRunner;
+
+import static org.junit.Assert.*;
+import static org.mockito.Mockito.*;
+/**
+ * Created by Anand Rajneesh on 12/3/2017.
+ */
+@RunWith(MockitoJUnitRunner.class)
+public class RegistrationEventTest {
+
+    private static class MockEventHandler implements EventHandler{
+
+        @Override
+        public void handle(RegistrationEvent event) {
+
+        }
+    }
+
+    private MockEventHandler eventHandler;
+
+    @Before
+    public void setup(){
+        eventHandler = Mockito.spy(new MockEventHandler());
+    }
+
+    @Test
+    public void testRegistrationEvent_SetsUsername(){
+        Member m = new Member();
+        m.setEmail("email");
+        RegistrationEvent registrationEvent = new RegistrationEvent(m);
+        assertNotNull("Eventtype should never be null", registrationEvent.getEventType());
+        assertNotNull("Username should not be null if present in member", registrationEvent.getUsername());
+    }
+
+    @Test
+    public void testAccept(){
+        Member m = new Member();
+        m.setEmail("email");
+        RegistrationEvent registrationEvent = new RegistrationEvent(m);
+        registrationEvent.accept(eventHandler);
+        verify(eventHandler, times(1)).handle(registrationEvent);
+    }
+
+}

src/test/java/org/gluecoders/library/rest/RegistrationTest.java

@@ -32,7 +32,7 @@ public class RegistrationTest {
     @Autowired
     private MockMvc mvc;
 
-    @MockBean
+    @MockBean(name = "registrationService")
     private RegistrationService registrationService;
 
     @Autowired

src/test/java/org/gluecoders/library/services/NotifyingRegistrationServiceTest.java

@@ -0,0 +1,85 @@
+package org.gluecoders.library.services;
+
+import org.gluecoders.library.models.Credentials;
+import org.gluecoders.library.models.Member;
+import org.gluecoders.library.services.notifiers.JmsSender;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.runners.MockitoJUnitRunner;
+
+import static org.junit.Assert.*;
+import static org.mockito.Mockito.*;
+
+
+/**
+ * Created by Anand Rajneesh on 12/3/2017.
+ */
+@RunWith(MockitoJUnitRunner.class)
+public class NotifyingRegistrationServiceTest {
+
+    @Mock
+    private DefaultRegistrationService defaultRegistrationService;
+
+    @Mock
+    private JmsSender jmsSender;
+
+    @InjectMocks
+    private NotifyingRegistrationService testObject;
+
+    @Before
+    public void setup(){
+        doNothing().when(jmsSender).handle(any());
+    }
+
+    @Test
+    public void testRegister_DelegateSuccess_JmsSuccess() throws Exception {
+        Credentials c = new Credentials();
+        c.setPwd("pwd");
+        c.setUsername("username");
+        Member m = new Member();
+        m.setEmail(c.getUsername());
+        doReturn(m).when(defaultRegistrationService).register(c);
+        m = testObject.register(c);
+        assertNotNull(m);
+        verify(defaultRegistrationService, times(1)).register(c);
+        verify(jmsSender, times(1)).handle(any());
+    }
+
+    @Test(expected = Exception.class)
+    public void testRegister_DelegateFails() throws Exception {
+        Credentials c = new Credentials();
+        c.setPwd("pwd");
+        c.setUsername("username");
+        Member m = new Member();
+        m.setEmail(c.getUsername());
+        doThrow(Exception.class).when(defaultRegistrationService).register(c);
+        try {
+            testObject.register(c);
+        }catch (Exception e){
+            verify(defaultRegistrationService, times(1)).register(c);
+            verify(jmsSender, never()).handle(any());
+            throw e;
+        }
+    }
+
+    @Test(expected = Exception.class)
+    public void testRegister_DelegateSuccess_JmsFails() throws Exception {
+        Credentials c = new Credentials();
+        c.setPwd("pwd");
+        c.setUsername("username");
+        Member m = new Member();
+        m.setEmail(c.getUsername());
+        doReturn(m).when(defaultRegistrationService).register(c);
+        doThrow(Exception.class).when(jmsSender).handle(any());
+        try {
+            testObject.register(c);
+        }catch (Exception e){
+            verify(defaultRegistrationService, times(1)).register(c);
+            verify(jmsSender, times(1)).handle(any());
+            throw e;
+        }
+    }
+}

src/test/java/org/gluecoders/library/services/listeners/RegistrationEventListenerTest.java

@@ -0,0 +1,16 @@
+package org.gluecoders.library.services.listeners;
+
+import org.junit.Test;
+
+import static org.junit.Assert.*;
+
+/**
+ * Created by Anand Rajneesh on 12/3/2017.
+ */
+public class RegistrationEventListenerTest {
+
+    @Test
+    public void testReceive() throws Exception {
+
+    }
+}