Pārlūkot izejas kodu

Mailer API consumer

dagarcos 2 gadi atpakaļ
vecāks
revīzija
c34b3fbcc5

+ 8 - 3
src/main/java/es/uv/garcosda/controllers/WorkerController.java

@@ -30,8 +30,12 @@ public class WorkerController {
 	    return sb.toString();
 	}
 	
-	@RabbitListener(queues = {"q.new_user"})
+	@RabbitListener(queues = {"${rabbitmq.queue.name}"})
 	public void compute(User user) {
+		
+		HttpEntity<MailDTO> request = new HttpEntity<>(new MailDTO("system@mailer.com", "system@mailer.com", "New account created", "Created new account for user "+user.getEmail()));
+		restTemplate.postForObject("http://localhost:8080/api/v1/mailbox", request, String.class);
+		
 		try {
 		    Thread.sleep(10 * 1000);
 		} 
@@ -40,8 +44,9 @@ public class WorkerController {
 		}
 		
 		String passwd = generatePasswd(6);
-		HttpEntity<MailDTO> request = new HttpEntity<>(new MailDTO("system@mailer.com", user.getEmail(), "New account created", "Welcome to mailer app. You can access to your account by using this password: "+passwd));
-		String response = restTemplate.postForObject("http://localhost:8080/api/v1/mailbox", request, String.class);
+		request = new HttpEntity<>(new MailDTO("system@mailer.com", user.getEmail(), "Welcome to Mailer APP", "Welcome to mailer app. You can access to your account by using this password: "+passwd));
+		restTemplate.postForObject("http://localhost:8080/api/v1/mailbox", request, String.class);
+		
 		
 	}
 }

+ 17 - 0
src/main/resources/META-INF/additional-spring-configuration-metadata.json

@@ -0,0 +1,17 @@
+{"properties": [
+  {
+    "name": "rabbitmq.queue.name",
+    "type": "java.lang.String",
+    "description": "A description for 'rabbitmq.queue.name'"
+  },
+  {
+    "name": "rabbitmq.exchange.name",
+    "type": "java.lang.String",
+    "description": "A description for 'rabbitmq.exchange.name'"
+  },
+  {
+    "name": "rabbitmq.routing.key",
+    "type": "java.lang.String",
+    "description": "A description for 'rabbitmq.routing.key'"
+  }
+]}

+ 7 - 0
src/main/resources/application.properties

@@ -1 +1,8 @@
 server.port=8081
+spring.rabbitmq.host=localhost
+spring.rabbitmq.port=5672
+spring.rabbitmq.username=guest
+spring.rabbitmq.password=guest
+rabbitmq.queue.name=q.new_user
+rabbitmq.exchange.name=mailer
+rabbitmq.routing.key=k.new_user