File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/it Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -107,6 +107,7 @@ public void test01writeAndReadWithMultipleSempClientFactory() {
107107 SolaceIO .read ()
108108 .from (Queue .fromName (QUEUE_NAME ))
109109 .withMaxNumConnections (1 )
110+ .withDeduplicateRecords (true )
110111 .withSempClientFactory (
111112 BasicAuthMultipleSempClientFactory .builder ()
112113 .backlogHosts (
@@ -172,7 +173,7 @@ private Pipeline createWriterPipeline(
172173 .withWriterType (writerType )
173174 .withDeliveryMode (DeliveryMode .PERSISTENT )
174175 .withNumberOfClientsPerWorker (1 )
175- .withMaxNumOfUsedWorkers (1 )
176+ .withNumShards (1 )
176177 .withSessionServiceFactory (
177178 BasicAuthJcsmpSessionServiceFactory .builder ()
178179 .host ("localhost:" + solaceContainerJcsmpPort )
You can’t perform that action at this time.
0 commit comments