diff --git a/pom.xml b/pom.xml index fc9c51c..c7eb97a 100644 --- a/pom.xml +++ b/pom.xml @@ -5,7 +5,7 @@ 4.0.0 org.nhind xdmail - 8.1.0-SNAPSHOT + 8.1.4-SNAPSHOT NHIN Direct XD* Mail Gateway NHIN Direct XD* Mail Gateway https://github.com/DirectProjectJavaRI/xdmail @@ -94,19 +94,19 @@ org.nhind xd-common - 8.0.0 + 8.1.2-SNAPSHOT compile org.nhind agent - 8.0.0 + 8.1.2-SNAPSHOT compile org.nhind gateway - 8.0.0 + 8.1.4-SNAPSHOT compile @@ -130,7 +130,12 @@ org.springframework.cloud spring-cloud-stream-binder-rabbit test - + + + javax.xml.ws + jaxws-api + 2.3.1 + @@ -305,24 +310,25 @@ - - - nhind-site - NHIN Direct API publication site - sftp://api.nhindirect.org/x/www/api.nhindirect.org/java/site/xdmail/${project.version} - - - - sonatype-snapshot - Sonatype OSS Maven SNAPSHOT Repository - https://oss.sonatype.org/content/repositories/snapshots/ - false - - - sonatype-release - Sonatype OSS Maven Release Repositor - https://oss.sonatype.org/service/local/staging/deploy/maven2/ - false - - + + + nhind-site + NHIN Direct API publication site + sftp://api.nhindirect.org/x/www/api.nhindirect.org/java/site/xdmail/${project.version} + + + + sonatype-snapshot + Sonatype OSS Maven SNAPSHOT Repository + https://oss.sonatype.org/content/repositories/snapshots/ + false + + + sonatype-release + Sonatype OSS Maven Release Repositor + https://oss.sonatype.org/service/local/staging/deploy/maven2/ + false + + + diff --git a/src/main/java/org/nhind/mail/service/XDDeliveryCore.java b/src/main/java/org/nhind/mail/service/XDDeliveryCore.java index 92b66d3..3012f3b 100644 --- a/src/main/java/org/nhind/mail/service/XDDeliveryCore.java +++ b/src/main/java/org/nhind/mail/service/XDDeliveryCore.java @@ -103,6 +103,7 @@ public boolean processAndDeliverXDMessage(SMTPMailMessage smtpMailMessage) throw for (String directTo : recipAddresses) { + log.debug("GOING TO SEND TO " + resolver.getXdEndpoints(recipAddresses).toString() + " OVER " + endpointUrl); String response = documentRepository.forwardRequest(endpointUrl, request, directTo, sender.toString()); if (!isSuccessful(response)) diff --git a/src/main/java/org/nhind/xd/springconfig/XDDeliveryConfig.java b/src/main/java/org/nhind/xd/springconfig/XDDeliveryConfig.java index 214a3f6..f698070 100644 --- a/src/main/java/org/nhind/xd/springconfig/XDDeliveryConfig.java +++ b/src/main/java/org/nhind/xd/springconfig/XDDeliveryConfig.java @@ -17,7 +17,7 @@ @Configuration public class XDDeliveryConfig { - @Value("direct.gateway.xd.endpointUrl") + @Value("${direct.gateway.xd.endpointUrl: http://localhost:8080/xd/services/DocumentRepository_Service}") protected String endpointURL; @Autowired diff --git a/src/main/java/org/nhind/xd/streams/processors/XDRemoteDeliveryProcessor.java b/src/main/java/org/nhind/xd/streams/processors/XDRemoteDeliveryProcessor.java index 13ca69f..b1d7aad 100644 --- a/src/main/java/org/nhind/xd/streams/processors/XDRemoteDeliveryProcessor.java +++ b/src/main/java/org/nhind/xd/streams/processors/XDRemoteDeliveryProcessor.java @@ -43,8 +43,9 @@ public Consumer> directXDDeliveryInput() try { final SMTPMailMessage smtpMessage = SMTPMailMessageConverter.fromStreamMessage(streamMsg); - - deliveryCore.processAndDeliverXDMessage(smtpMessage); + + log.debug("XDRemoteDeliveryProcessor processing message from " + smtpMessage.getMailFrom().toString()); + deliveryCore.processAndDeliverXDMessage(smtpMessage); } catch (MessagingException e) { diff --git a/src/test/resources/application.yml b/src/test/resources/application.yml index e89b1f4..321944d 100644 --- a/src/test/resources/application.yml +++ b/src/test/resources/application.yml @@ -1,4 +1,4 @@ -spring: +spring: cloud: stream: source: direct-smtp-gateway-message @@ -9,4 +9,12 @@ spring: directXDDeliveryInput-in-0: destination: direct-xd-delivery - group: direct-xd-delivery-group \ No newline at end of file + group: direct-xd-delivery-group + + main: + allow-bean-definition-overriding: true + +direct: + gateway: + xd: + endpointurl: http://localhost:8080/xd/services/DocumentRepository_Service \ No newline at end of file