Skip to content

Commit f3ce2b5

Browse files
Update SolaceSparkStreamingOAuthIT.java
1 parent ccce8dc commit f3ce2b5

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -292,7 +292,7 @@ void Should_ConnectToInSecureOAuthServer_And_ProcessData_And_PublishToSolace() t
292292
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_URL, "http://localhost:7777/realms/solace/protocol/openid-connect/token")
293293
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_CLIENT_ID, "solace")
294294
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_CREDENTIALS_CLIENTSECRET, "solace-secret")
295-
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "5")
295+
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "50")
296296
.option(SolaceSparkStreamingProperties.QUEUE, SolaceOAuthContainer.INTEGRATION_TEST_QUEUE_NAME)
297297
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_SSL_VALIDATE_CERTIFICATE, false)
298298
.option(SolaceSparkStreamingProperties.BATCH_SIZE, "100")
@@ -329,7 +329,7 @@ public void onException(JCSMPException e) {
329329
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_URL, "http://localhost:7777/realms/solace/protocol/openid-connect/token")
330330
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_CLIENT_ID, "solace")
331331
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_CREDENTIALS_CLIENTSECRET, "solace-secret")
332-
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "5")
332+
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_TOKEN_REFRESH_INTERVAL, "50")
333333
.option(SolaceSparkStreamingProperties.OAUTH_CLIENT_AUTHSERVER_SSL_VALIDATE_CERTIFICATE, false)
334334
.option(SolaceSparkStreamingProperties.MESSAGE_ID, "my-default-id")
335335
.option(SolaceSparkStreamingProperties.TOPIC, "random/topic")

0 commit comments

Comments
 (0)