Skip to content

Commit 31b875d

Browse files
SravanThotakura05SravanThotakura05
committed
Updated integration tests
1 parent e0081b6 commit 31b875d

File tree

1 file changed

+17
-17
lines changed

1 file changed

+17
-17
lines changed

‎pubsubplus-connector-spark_3.x/src/test/java/com/solacecoe/connectors/spark/SolaceSparkStreamingOAuthIT.java‎

Lines changed: 17 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ public void Should_ConnectToOAuthServer_WithoutValidatingCertificates_And_Proces
9696
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "5")
9797
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
9898
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_SSL_VALIDATE_CERTIFICATE, false)
99-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
99+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
100100
.option("checkpointLocation", path.toAbsolutePath().toString())
101101
.format("solace");
102102
final long[] count = {0};
@@ -152,7 +152,7 @@ public void Should_ConnectToInSecureOAuthServer_And_ProcessData() throws Timeout
152152
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "5")
153153
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
154154
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_SSL_VALIDATE_CERTIFICATE, false)
155-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
155+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
156156
.option("checkpointLocation", path.toAbsolutePath().toString())
157157
.format("solace");
158158
final long[] count = {0};
@@ -209,7 +209,7 @@ public void Should_Fail_When_InvalidOAuthUrlIsProvided() {
209209
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "5")
210210
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
211211
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_SSL_VALIDATE_CERTIFICATE, false)
212-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
212+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
213213
.option("checkpointLocation", path.toAbsolutePath().toString())
214214
.format("solace");
215215
Dataset<Row> dataset = reader.load();
@@ -237,7 +237,7 @@ public void Should_Fail_When_InvalidTLSVersionProvided() {
237237
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_CLIENT_CERTIFICATE, resources.toAbsolutePath().toString() + "/keycloak.crt")
238238
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_TRUSTSTORE_PASSWORD, "changeit")
239239
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_TLS_VERSION, "invalidtls")
240-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
240+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
241241
.option("checkpointLocation", path.toAbsolutePath().toString())
242242
.format("solace");
243243
Dataset<Row> dataset = reader.load();
@@ -264,7 +264,7 @@ public void Should_Fail_When_TrustStorePasswordIsNull() {
264264
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
265265
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_CLIENT_CERTIFICATE, resources.toAbsolutePath().toString() + "/keycloak.crt")
266266
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_TRUSTSTORE_FILE, resources.toAbsolutePath().toString() + "/custom_truststore.jks")
267-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
267+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
268268
.option("checkpointLocation", path.toAbsolutePath().toString())
269269
.format("solace");
270270
Dataset<Row> dataset = reader.load();
@@ -290,7 +290,7 @@ public void Should_ConnectToOAuthServer_AddClientCertificateToDefaultTrustStore_
290290
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
291291
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_CLIENT_CERTIFICATE, resources.toAbsolutePath().toString() + "/keycloak.crt")
292292
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_TRUSTSTORE_PASSWORD, "changeit")
293-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
293+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
294294
.option("checkpointLocation", path.toAbsolutePath().toString())
295295
.format("solace");
296296
final long[] count = {0};
@@ -349,7 +349,7 @@ public void Should_ConnectToOAuthServer_AddClientCertificateToCustomTrustStore_A
349349
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_CLIENT_CERTIFICATE, resources.toAbsolutePath().toString() + "/keycloak.crt")
350350
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_TRUSTSTORE_FILE, resources.toAbsolutePath().toString() + "/custom_truststore.jks")
351351
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_TRUSTSTORE_PASSWORD, resources.toAbsolutePath().toString() + "changeit")
352-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
352+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
353353
.option("checkpointLocation", path.toAbsolutePath().toString())
354354
.format("solace");
355355
final long[] count = {0};
@@ -417,7 +417,7 @@ public void Should_ReadAccessTokenFromFile_And_ProcessData() throws TimeoutExcep
417417
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
418418
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_ACCESSTOKEN, resources.toAbsolutePath().toString() + "/accesstoken.txt")
419419
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "50")
420-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
420+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
421421
.option("checkpointLocation", path.toAbsolutePath().toString())
422422
.format("solace");
423423
final long[] count = {0};
@@ -484,7 +484,7 @@ public void Should_Fail_When_AccessTokenIsInvalid() throws TimeoutException, Str
484484
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
485485
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_ACCESSTOKEN, resources.toAbsolutePath().toString() + "/accesstoken.txt")
486486
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "5")
487-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
487+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
488488
.option("checkpointLocation", path.toAbsolutePath().toString())
489489
.format("solace");
490490
final long[] count = {0};
@@ -532,7 +532,7 @@ public void Should_Fail_When_MultipleAccessTokensArePresentInFile() throws JCSMP
532532
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
533533
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_ACCESSTOKEN, resources.toAbsolutePath().toString() + "/accesstoken.txt")
534534
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "50")
535-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
535+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
536536
.option("checkpointLocation", path.toAbsolutePath().toString())
537537
.format("solace");
538538
Dataset<Row> dataset = reader.load();
@@ -560,7 +560,7 @@ public void Should_Fail_IfMandatoryOAuthURLIsMissing() {
560560
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "5")
561561
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
562562
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_SSL_VALIDATE_CERTIFICATE, false)
563-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
563+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
564564
.option("checkpointLocation", path.toAbsolutePath().toString())
565565
.format("solace");
566566
Dataset<Row> dataset = reader.load();
@@ -586,7 +586,7 @@ public void Should_Fail_IfMandatoryOAuthURLIsEmpty() {
586586
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "5")
587587
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
588588
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_SSL_VALIDATE_CERTIFICATE, false)
589-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
589+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
590590
.option("checkpointLocation", path.toAbsolutePath().toString())
591591
.format("solace");
592592
Dataset<Row> dataset = reader.load();
@@ -612,7 +612,7 @@ public void Should_Fail_IfMandatoryOAuthClientIdIsMissing() {
612612
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "5")
613613
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
614614
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_SSL_VALIDATE_CERTIFICATE, false)
615-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
615+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
616616
.option("checkpointLocation", path.toAbsolutePath().toString())
617617
.format("solace");
618618
Dataset<Row> dataset = reader.load();
@@ -638,7 +638,7 @@ public void Should_Fail_IfMandatoryOAuthClientIdIsEmpty() {
638638
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "5")
639639
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
640640
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_SSL_VALIDATE_CERTIFICATE, false)
641-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
641+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
642642
.option("checkpointLocation", path.toAbsolutePath().toString())
643643
.format("solace");
644644
Dataset<Row> dataset = reader.load();
@@ -664,7 +664,7 @@ public void Should_Fail_IfMandatoryOAuthClientSecretIsMissing() {
664664
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "5")
665665
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
666666
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_SSL_VALIDATE_CERTIFICATE, false)
667-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
667+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
668668
.option("checkpointLocation", path.toAbsolutePath().toString())
669669
.format("solace");
670670
Dataset<Row> dataset = reader.load();
@@ -690,7 +690,7 @@ public void Should_Fail_IfMandatoryOAuthClientSecretIsEmpty() {
690690
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "5")
691691
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
692692
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_SSL_VALIDATE_CERTIFICATE, false)
693-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
693+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
694694
.option("checkpointLocation", path.toAbsolutePath().toString())
695695
.format("solace");
696696
Dataset<Row> dataset = reader.load();
@@ -713,7 +713,7 @@ public void Should_Fail_IfAccessTokenFileIsEmpty() {
713713
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
714714
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_ACCESSTOKEN, "")
715715
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "50")
716-
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "10")
716+
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "50")
717717
.option("checkpointLocation", path.toAbsolutePath().toString())
718718
.format("solace");
719719
Dataset<Row> dataset = reader.load();

0 commit comments

Comments
 (0)