aboutsummaryrefslogtreecommitdiff
path: root/src/test/java/at/gv/egiz/moazs/SameThreadDeliveryPipelineTest.java
diff options
context:
space:
mode:
authorChristof Rabensteiner <christof.rabensteiner@iaik.tugraz.at>2019-06-27 14:41:51 +0200
committerChristof Rabensteiner <christof.rabensteiner@iaik.tugraz.at>2019-06-27 14:47:22 +0200
commit9556dc6bd7e327dfbfc3c2d5228ad920ad7b9f8e (patch)
tree01db0a1c4c94c66118256e17ecdb821e04ed657c /src/test/java/at/gv/egiz/moazs/SameThreadDeliveryPipelineTest.java
parenta8e726382b0472ad030d7a579fe8d6878a216bd4 (diff)
downloadmoa-zs-9556dc6bd7e327dfbfc3c2d5228ad920ad7b9f8e.tar.gz
moa-zs-9556dc6bd7e327dfbfc3c2d5228ad920ad7b9f8e.tar.bz2
moa-zs-9556dc6bd7e327dfbfc3c2d5228ad920ad7b9f8e.zip
Inject Configurable HTTP Policies to MsgClient
- Refactor: Get rid of MsgClient, because MsgClientFactory can do all the work. - Add Connection Timeout and Request Timeout (Policies of HTTP Client) to mzs:DeliveryRequest/Config and application.yaml. - Update readme: Add JDK 12 Requirement
Diffstat (limited to 'src/test/java/at/gv/egiz/moazs/SameThreadDeliveryPipelineTest.java')
-rw-r--r--src/test/java/at/gv/egiz/moazs/SameThreadDeliveryPipelineTest.java12
1 files changed, 4 insertions, 8 deletions
diff --git a/src/test/java/at/gv/egiz/moazs/SameThreadDeliveryPipelineTest.java b/src/test/java/at/gv/egiz/moazs/SameThreadDeliveryPipelineTest.java
index df54ef7..e685816 100644
--- a/src/test/java/at/gv/egiz/moazs/SameThreadDeliveryPipelineTest.java
+++ b/src/test/java/at/gv/egiz/moazs/SameThreadDeliveryPipelineTest.java
@@ -1,8 +1,6 @@
package at.gv.egiz.moazs;
-import at.gv.egiz.moazs.msg.MsgClient;
import at.gv.egiz.moazs.msg.MsgClientFactory;
-import at.gv.egiz.moazs.msg.StoreSOAPBodyBinaryInRepositoryInterceptor;
import at.gv.egiz.moazs.pipeline.DeliveryPipeline;
import at.gv.egiz.moazs.pipeline.SameThreadDeliveryPipeline;
import at.gv.egiz.moazs.repository.DeliveryRepository;
@@ -12,6 +10,7 @@ import at.gv.egiz.moazs.tnvz.TnvzClient;
import at.gv.egiz.moazs.tnvz.TnvzResultVerifier;
import at.gv.egiz.moazs.verify.MoaSPSSSignatureVerifier;
import at.gv.zustellung.app2mzs.xsd.DeliveryRequestType;
+import at.gv.zustellung.msg.xsd.App2ZusePort;
import at.gv.zustellung.msg.xsd.DeliveryRequestStatusType;
import at.gv.zustellung.msg.xsd.MetaData;
import at.gv.zustellung.tnvz.xsd.MimeTypeList;
@@ -55,15 +54,12 @@ public class SameThreadDeliveryPipelineTest {
private MsgClientFactory msgClientFactory;
@Mock
- private MsgClient msgClient;
+ private App2ZusePort msgClient;
@Mock
private Mzs2MsgConverter converter;
@Mock
- private StoreSOAPBodyBinaryInRepositoryInterceptor interceptor;
-
- @Mock
private MoaSPSSSignatureVerifier verifier;
@@ -72,7 +68,7 @@ public class SameThreadDeliveryPipelineTest {
@Before
public void setup() {
pipeline = new SameThreadDeliveryPipeline(repository, tnvzClient, new TnvzResultVerifier(),
- converter,interceptor, msgClientFactory, verifier);
+ converter, msgClientFactory, verifier);
}
@Test
@@ -174,7 +170,7 @@ public class SameThreadDeliveryPipelineTest {
when(converter.convert(eq(mzsRequest) )).thenReturn(msgRequest);
when(converter.convert(eq(mzsRequest), any())).thenReturn(msgRequest);
when(msgClientFactory.create(any())).thenReturn(msgClient);
- when(msgClient.send(msgRequest)).thenReturn(status);
+ when(msgClient.delivery(msgRequest)).thenReturn(status);
return status;