Updating to SpringBoot 2.1.0.RELEASE

Adding load generator.

Author: gm2552

pom.xml

@@ -18,7 +18,7 @@
 	<parent>
 	   <groupId>org.springframework.boot</groupId>
 	   <artifactId>spring-boot-starter-parent</artifactId>
-	   <version>2.1.0.RC1</version>
+	   <version>2.1.0.RELEASE</version>
 	</parent>	
     <developers>
         <developer>
@@ -47,21 +47,13 @@
             <name>Spring Milestone Releases</name>
             <url>https://repo.spring.io/milestone/</url>
         </repository>
-     </repositories>  
-     <pluginRepositories>
-	    <!-- Temp repository for Spring Boot Milestone -->
-        <pluginRepository>
-            <id>spring-milestone</id>
-            <name>Spring Milestone Releases</name>
-            <url>https://repo.spring.io/milestone/</url>
-        </pluginRepository>
-     </pluginRepositories>     
+     </repositories>     
 	<dependencyManagement>
 		<dependencies>											
 			<dependency>
 				<groupId>org.springframework.boot</groupId>
 				<artifactId>spring-boot-dependencies</artifactId>
-				<version>2.1.0.RC1</version> 
+				<version>2.1.0.RELEASE</version> 
 				<type>pom</type>
 				<scope>import</scope>
 			</dependency>

src/main/java/org/nhindirect/smtpmq/gateway/boot/SmtpGatewayApplication.java

@@ -7,10 +7,12 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.builder.SpringApplicationBuilder;
 import org.springframework.context.annotation.ComponentScan;
+import org.springframework.scheduling.annotation.EnableScheduling;
 import org.subethamail.smtp.server.SMTPServer;
 
 @ComponentScan({"org.nhindirect.smtpmq.gateway"})
 @SpringBootApplication
+@EnableScheduling
 public class SmtpGatewayApplication implements CommandLineRunner
 {
 	@Autowired

src/main/java/org/nhindirect/smtpmq/gateway/task/SimulatedLoadTask.java

@@ -0,0 +1,51 @@
+package org.nhindirect.smtpmq.gateway.task;
+
+import java.util.Arrays;
+import java.util.Calendar;
+
+import javax.mail.Message;
+import javax.mail.Session;
+import javax.mail.internet.InternetAddress;
+import javax.mail.internet.MimeMessage;
+
+import org.nhindirect.common.mail.SMTPMailMessage;
+import org.nhindirect.smtpmq.gateway.streams.SmtpGatewayMessageSource;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@ConditionalOnProperty(name="direct.smtpmqgateway.loadgen.rate", matchIfMissing=false)
+@Component
+public class SimulatedLoadTask
+{
+	private static final Logger LOGGER = LoggerFactory.getLogger(SimulatedLoadTask.class);	
+	
+	@Value("${direct.smtpmqgateway.loadgen.sender}")
+	protected String sender;
+	
+	@Value("${direct.smtpmqgateway.loadgen.recipient}")
+	protected String recipient;	
+	
+	@Autowired
+	protected SmtpGatewayMessageSource msgSource;
+	
+	@Scheduled(fixedRateString = "${direct.smtpmqgateway.loadgen.rate}", initialDelayString = "${direct.smtpmqgateway.loadgen.initialdelay:5000}")
+	public void sendMessages() throws Exception 
+	{
+		final MimeMessage msg = new MimeMessage((Session)null);
+		msg.setFrom(new InternetAddress(sender));
+		msg.setRecipient(Message.RecipientType.TO, new InternetAddress(recipient));
+		msg.setSentDate(Calendar.getInstance().getTime());
+		msg.setText("Load Test");
+		
+		SMTPMailMessage smptMsg = new SMTPMailMessage(msg, Arrays.asList(new InternetAddress(recipient)), new InternetAddress(sender));
+		
+		LOGGER.info("Sending generated load from " + sender + " to " + recipient);
+		
+		msgSource.forwardSMTPMessage(smptMsg);
+	}
+}