Adding missing last mile delivery classes from previous checkin.

Author: gm2552

src/main/java/org/nhindirect/gateway/streams/STALastMileDeliveryOutput.java

@@ -0,0 +1,12 @@
+package org.nhindirect.gateway.streams;
+
+import org.springframework.cloud.stream.annotation.Output;
+import org.springframework.messaging.MessageChannel;
+
+public interface STALastMileDeliveryOutput
+{
+	public static final String STA_LAST_MILE_OUTPUT = "direct-sta-last-mile-output";
+	
+	@Output(STA_LAST_MILE_OUTPUT)
+	MessageChannel staLastMileOutput();
+}

src/main/java/org/nhindirect/gateway/streams/STALastMileDeliverySource.java

@@ -0,0 +1,23 @@
+package org.nhindirect.gateway.streams;
+
+import org.nhindirect.common.mail.SMTPMailMessage;
+import org.nhindirect.common.mail.streams.SMTPMailMessageConverter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.cloud.stream.annotation.EnableBinding;
+import org.springframework.cloud.stream.annotation.Output;
+import org.springframework.messaging.MessageChannel;
+
+@EnableBinding(STALastMileDeliveryOutput.class)
+public class STALastMileDeliverySource
+{
+	@Autowired
+	@Qualifier(STALastMileDeliveryOutput.STA_LAST_MILE_OUTPUT)
+	private MessageChannel lastMileChannel;
+	
+	@Output(STALastMileDeliveryOutput.STA_LAST_MILE_OUTPUT)
+	public <T> void staLastMile(SMTPMailMessage msg) 
+	{
+		this.lastMileChannel.send(SMTPMailMessageConverter.toStreamMessage(msg));
+	}
+}

src/main/java/org/nhindirect/gateway/streams/processor/STAPostProcessProcessor.java

@@ -16,7 +16,7 @@
 import org.nhindirect.common.tx.model.TxDetail;
 import org.nhindirect.common.tx.model.TxDetailType;
 import org.nhindirect.common.tx.model.TxMessageType;
-import org.nhindirect.gateway.streams.STALastMileSource;
+import org.nhindirect.gateway.streams.STALastMileDeliverySource;
 import org.nhindirect.gateway.streams.STAPostProcessInput;
 import org.nhindirect.gateway.streams.SmtpRemoteDeliverySource;
 import org.nhindirect.gateway.streams.XDRemoteDeliverySource;
@@ -50,7 +50,7 @@ public class STAPostProcessProcessor
 	protected XDRemoteDeliverySource xdRemoteDeliverySource;
 
 	@Autowired 
-	protected STALastMileSource lastMileSource;
+	protected STALastMileDeliverySource lastMileSource;
 
 	@Autowired
 	protected RoutingResolver routingResolver;