瀏覽代碼

Passwd recovery

dagarcos 2 年之前
父節點
當前提交
10dcda5440

+ 19 - 1
src/main/java/es/uv/garcosda/controllers/WorkerController.java

@@ -30,7 +30,7 @@ public class WorkerController {
 	    return sb.toString();
 	}
 	
-	@RabbitListener(queues = {"${rabbitmq.queue.name}"})
+	@RabbitListener(queues = {"${rabbitmq.queue.name.user}"})
 	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()));
@@ -46,7 +46,25 @@ public class WorkerController {
 		String passwd = generatePasswd(6);
 		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);
+	
+	}
+	
+	@RabbitListener(queues = {"${rabbitmq.queue.name.recover}"})
+	public void computePasswd(User user) {
 		
+		HttpEntity<MailDTO> request = new HttpEntity<>(new MailDTO("system@mailer.com", "system@mailer.com", "Password recover", "Password recover issued by "+user.getEmail()));
+		restTemplate.postForObject("http://localhost:8080/api/v1/mailbox", request, String.class);
+		
+		try {
+		    Thread.sleep(10 * 1000);
+		} 
+		catch (InterruptedException ie) {
+		    Thread.currentThread().interrupt();
+		}
 		
+		String passwd = generatePasswd(6);
+		request = new HttpEntity<>(new MailDTO("system@mailer.com", user.getEmail(), "Your new password", "Your new password is: "+passwd));
+		restTemplate.postForObject("http://localhost:8080/api/v1/mailbox", request, String.class);
+	
 	}
 }

+ 16 - 6
src/main/resources/META-INF/additional-spring-configuration-metadata.json

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

+ 4 - 2
src/main/resources/application.properties

@@ -3,6 +3,8 @@ spring.rabbitmq.host=localhost
 spring.rabbitmq.port=5672
 spring.rabbitmq.username=guest
 spring.rabbitmq.password=guest
-rabbitmq.queue.name=q.new_user
+rabbitmq.queue.name.user=q.new_user
+rabbitmq.queue.name.recover=q.recover
 rabbitmq.exchange.name=mailer
-rabbitmq.routing.key=k.new_user
+rabbitmq.routing.key.user=k.new_user
+rabbitmq.routing.key.recover=k.recover