AWS SNS Publish message method is not working inside a UNIX server

[MuthiahPrabhakaran]

Below is the program that I am using to publish a message to SNS. There is no issue when I execute this program(simple Java or Spring boot) in my local system. The message is published on the topic.

But, the actual program runs inside a thread in a spring boot project. The thread runs every 1 minute. Whenever the thread runs, the below program has to publish the message. This spring boot project deployed inside a standalone Unix server. From the server, it is not publishing messages. There is no exception. The logs are showing a successful handshake to the Amazon network.

I tried AmazonSNS and SnsClient classes as well. It is an even worse situation when I used these two. When the program executes the publish method without the Async process, it blocks the thread entirely. After that, that thread itself stopped working. No logs, or exceptions. That is why I changed the program to Async.

AmazonSNSAsync snsClient1 = AmazonSNSAsyncClient.asyncBuilder()
          .withCredentials(new AWSStaticCredentialsProvider(
              new BasicAWSCredentials("access-key",
                  "secret-key")))
          .withRegion("us-east-1")
          .build();
      log.info("STATUS: snsClient1 formed");
      PublishRequest publishReq =
          new PublishRequest()
              .withTopicArn("sns_topic-arn")
              .withMessage("mes: "+message);
      log.info("STATUS: publishReq formed");
      snsClient1.publishAsync(publishReq);

Current dependencies that I am using:

<dependency>
            <artifactId>aws-java-sdk-sns</artifactId>
            <groupId>com.amazonaws</groupId>
            <version>1.12.300</version>
        </dependency>

        <dependency>
            <artifactId>sns</artifactId>
            <groupId>software.amazon.awssdk</groupId>
            <version>2.15.35</version>
        </dependency>

I tried the below things already.

• moved the program out of the thread
• tried with a new topic
• used the latest dependency of SNS

However, when I published a message from the Unix box using AWS CLI, the message was published successfully.

Did anyone face a similar issue? If not, you can share any alternative way to hit the SNS from a Java program if you know.

[debora-ito]

The fact that there's no error in the logs is strange, maybe the exception is being swallowed?
How are you checking the message is being published? Are you monitoring via CloudWatch?
I see your sample code uses Java SDK v1 code, any reason you also have Java SDK v2 SNS as a dependency?

[MuthiahPrabhakaran]

@debora-ito Latest update.
I was trying to catch the exception earlier. Later, tried to catch the "Throwable" object. It was printing the issue. This is the cause of the code block. Looks like it was an error, not an exception. Stack trace as follows:

javax.xml.stream.FactoryConfigurationError: Provider for class javax.xml.stream.XMLInputFactory cannot be created at javax.xml.stream.FactoryFinder.findServiceProvider(FactoryFinder.java:370) ~[?:1.8.0_202] at javax.xml.stream.FactoryFinder.find(FactoryFinder.java:313) ~[?:1.8.0_202] at javax.xml.stream.FactoryFinder.find(FactoryFinder.java:227) ~[?:1.8.0_202] at javax.xml.stream.XMLInputFactory.newInstance(XMLInputFactory.java:154) ~[?:1.8.0_202] at com.amazonaws.util.XmlUtils.createXmlInputFactory(XmlUtils.java:63) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.util.XmlUtils.access$000(XmlUtils.java:27) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.util.XmlUtils$1.initialValue(XmlUtils.java:36) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.util.XmlUtils$1.initialValue(XmlUtils.java:33) ~[aws-java-sdk-core-1.11.792.jar!/:?] at java.lang.ThreadLocal.setInitialValue(ThreadLocal.java:180) ~[?:1.8.0_202] at java.lang.ThreadLocal.get(ThreadLocal.java:170) ~[?:1.8.0_202] at com.amazonaws.util.XmlUtils.getXmlInputFactory(XmlUtils.java:54) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.http.StaxResponseHandler.handle(StaxResponseHandler.java:94) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.http.StaxResponseHandler.handle(StaxResponseHandler.java:42) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.http.response.AwsResponseHandlerAdapter.handle(AwsResponseHandlerAdapter.java:69) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleResponse(AmazonHttpClient.java:1726) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleSuccessResponse(AmazonHttpClient.java:1446) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1368) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1145) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:802) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:770) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:744) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:704) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:686) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:550) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:530) ~[aws-java-sdk-core-1.11.792.jar!/:?] at com.amazonaws.services.sns.AmazonSNSClient.doInvoke(AmazonSNSClient.java:2270) ~[aws-java-sdk-sns-1.11.192.jar!/:?] at com.amazonaws.services.sns.AmazonSNSClient.invoke(AmazonSNSClient.java:2246) ~[aws-java-sdk-sns-1.11.192.jar!/:?] at com.amazonaws.services.sns.AmazonSNSClient.executeListTopics(AmazonSNSClient.java:1552) ~[aws-java-sdk-sns-1.11.192.jar!/:?] at com.amazonaws.services.sns.AmazonSNSClient.listTopics(AmazonSNSClient.java:1529) ~[aws-java-sdk-sns-1.11.192.jar!/:?] at com.amazonaws.services.sns.AmazonSNSClient.listTopics(AmazonSNSClient.java:1564) ~[aws-java-sdk-sns-1.11.192.jar!/:?]

Looks like the conflict of various dependencies. I introduced the bom concept and converted SDK v1 into SDK v2. Now, the message has published the topic. I am using the below dependency alone now.

<dependency>
      <groupId>software.amazon.awssdk</groupId>
      <artifactId>sns</artifactId>
    </dependency>

<dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>software.amazon.awssdk</groupId>
        <artifactId>bom</artifactId>
        <version>2.17.230</version>
        <type>pom</type>
        <scope>import</scope>
      </dependency>
    </dependencies>
  </dependencyManagement>

`

But, still I am getting the above except for the SDK2 sns dependency. Since I use the catch block with the throwable object, the project is not stopping.

[debora-ito]

Can you share the stacktrace of the error after you moved to SDK v2?

[MuthiahPrabhakaran]

@debora-ito

SDK2 Program

`try {
      SnsClient snsClient =
          SnsClient.builder()
              .credentialsProvider(
                  () ->
                      AwsBasicCredentials.create(
                          "access-key",
                          "secret-key"))
              .build();

      PublishRequest publishRequest =
          PublishRequest.builder()
              .message("message")
              .topicArn("topic-arn")
              .build();

      PublishResponse result = snsClient.publish(publishRequest);

      log.debug("Message is sent to SNS topic. Status is {}", result.sdkHttpResponse().statusCode());

      snsClient.close();

    } catch (Throwable e) {
      log.error("Error while sending message to SNS Topic. Error: ", e);
    }

`

Error Trace(but the message is published to the topic)

javax.xml.stream.FactoryConfigurationError: Provider for class javax.xml.stream.XMLInputFactory cannot be created at javax.xml.stream.FactoryFinder.findServiceProvider(FactoryFinder.java:370) ~[?:1.8.0_202] at javax.xml.stream.FactoryFinder.find(FactoryFinder.java:313) ~[?:1.8.0_202] at javax.xml.stream.FactoryFinder.find(FactoryFinder.java:227) ~[?:1.8.0_202] at javax.xml.stream.XMLInputFactory.newInstance(XMLInputFactory.java:154) ~[?:1.8.0_202] at software.amazon.awssdk.protocols.query.unmarshall.XmlDomParser.createXmlInputFactory(XmlDomParser.java:131) ~[aws-query-protocol-2.17.230.jar!/:?] at java.lang.ThreadLocal$SuppliedThreadLocal.initialValue(ThreadLocal.java:284) ~[?:1.8.0_202] at java.lang.ThreadLocal.setInitialValue(ThreadLocal.java:180) ~[?:1.8.0_202] at java.lang.ThreadLocal.get(ThreadLocal.java:170) ~[?:1.8.0_202] at software.amazon.awssdk.protocols.query.unmarshall.XmlDomParser.parse(XmlDomParser.java:51) ~[aws-query-protocol-2.17.230.jar!/:?] at java.util.Optional.map(Optional.java:215) ~[?:1.8.0_202] at software.amazon.awssdk.protocols.query.internal.unmarshall.QueryProtocolUnmarshaller.unmarshall(QueryProtocolUnmarshaller.java:85) ~[aws-query-protocol-2.17.230.jar!/:?] at software.amazon.awssdk.protocols.query.internal.unmarshall.AwsQueryResponseHandler.unmarshallResponse(AwsQueryResponseHandler.java:74) ~[aws-query-protocol-2.17.230.jar!/:?] at software.amazon.awssdk.protocols.query.internal.unmarshall.AwsQueryResponseHandler.handle(AwsQueryResponseHandler.java:59) ~[aws-query-protocol-2.17.230.jar!/:?] at software.amazon.awssdk.protocols.query.internal.unmarshall.AwsQueryResponseHandler.handle(AwsQueryResponseHandler.java:41) ~[aws-query-protocol-2.17.230.jar!/:?] at software.amazon.awssdk.core.http.MetricCollectingHttpResponseHandler.lambda$handle$0(MetricCollectingHttpResponseHandler.java:52) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.util.MetricUtils.measureDurationUnsafe(MetricUtils.java:63) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.http.MetricCollectingHttpResponseHandler.handle(MetricCollectingHttpResponseHandler.java:52) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.awscore.client.handler.AwsSyncClientHandler$Crc32ValidationResponseHandler.handle(AwsSyncClientHandler.java:95) ~[aws-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.handler.BaseClientHandler.lambda$resultTransformationResponseHandler$8(BaseClientHandler.java:262) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.CombinedResponseHandler.handleSuccessResponse(CombinedResponseHandler.java:99) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.CombinedResponseHandler.handleResponse(CombinedResponseHandler.java:75) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.CombinedResponseHandler.handle(CombinedResponseHandler.java:60) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.CombinedResponseHandler.handle(CombinedResponseHandler.java:41) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.HandleResponseStage.execute(HandleResponseStage.java:40) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.HandleResponseStage.execute(HandleResponseStage.java:30) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.RequestPipelineBuilder$ComposingRequestPipelineStage.execute(RequestPipelineBuilder.java:206) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.ApiCallAttemptTimeoutTrackingStage.execute(ApiCallAttemptTimeoutTrackingStage.java:73) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.ApiCallAttemptTimeoutTrackingStage.execute(ApiCallAttemptTimeoutTrackingStage.java:42) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.TimeoutExceptionHandlingStage.execute(TimeoutExceptionHandlingStage.java:78) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.TimeoutExceptionHandlingStage.execute(TimeoutExceptionHandlingStage.java:40) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.ApiCallAttemptMetricCollectionStage.execute(ApiCallAttemptMetricCollectionStage.java:50) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.ApiCallAttemptMetricCollectionStage.execute(ApiCallAttemptMetricCollectionStage.java:36) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.RetryableStage.execute(RetryableStage.java:81) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.RetryableStage.execute(RetryableStage.java:36) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.RequestPipelineBuilder$ComposingRequestPipelineStage.execute(RequestPipelineBuilder.java:206) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.StreamManagingStage.execute(StreamManagingStage.java:56) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.StreamManagingStage.execute(StreamManagingStage.java:36) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.ApiCallTimeoutTrackingStage.executeWithTimer(ApiCallTimeoutTrackingStage.java:80) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.ApiCallTimeoutTrackingStage.execute(ApiCallTimeoutTrackingStage.java:60) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.ApiCallTimeoutTrackingStage.execute(ApiCallTimeoutTrackingStage.java:42) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.ApiCallMetricCollectionStage.execute(ApiCallMetricCollectionStage.java:48) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.ApiCallMetricCollectionStage.execute(ApiCallMetricCollectionStage.java:31) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.RequestPipelineBuilder$ComposingRequestPipelineStage.execute(RequestPipelineBuilder.java:206) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.RequestPipelineBuilder$ComposingRequestPipelineStage.execute(RequestPipelineBuilder.java:206) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.ExecutionFailureExceptionReportingStage.execute(ExecutionFailureExceptionReportingStage.java:37) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.pipeline.stages.ExecutionFailureExceptionReportingStage.execute(ExecutionFailureExceptionReportingStage.java:26) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.http.AmazonSyncHttpClient$RequestExecutionBuilderImpl.execute(AmazonSyncHttpClient.java:193) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.handler.BaseSyncClientHandler.invoke(BaseSyncClientHandler.java:103) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.handler.BaseSyncClientHandler.doExecute(BaseSyncClientHandler.java:167) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.handler.BaseSyncClientHandler.lambda$execute$1(BaseSyncClientHandler.java:82) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.handler.BaseSyncClientHandler.measureApiCallSuccess(BaseSyncClientHandler.java:175) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.internal.handler.BaseSyncClientHandler.execute(BaseSyncClientHandler.java:76) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.core.client.handler.SdkSyncClientHandler.execute(SdkSyncClientHandler.java:45) ~[sdk-core-2.17.230.jar!/:?] at software.amazon.awssdk.awscore.client.handler.AwsSyncClientHandler.execute(AwsSyncClientHandler.java:56) ~[aws-core-2.17.230.jar!/:?] at software.amazon.awssdk.services.sns.DefaultSnsClient.publish(DefaultSnsClient.java:2797) ~[sns-2.17.230.jar!/:?] at com.mypackage.MyClass.sendSnsNotification(MyClass.java:542) ~[classes!/:0.0.1-SNAPSHOT] at com.mypackage.controller.runner.MyClass.main(MyClass.java:118) ~[classes!/:0.0.1-SNAPSHOT] at com.mypackage.thread.AbstractThread.run(AbstractThread.java:79) ~[classes!/:0.0.1-SNAPSHOT] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202] Caused by: java.lang.RuntimeException: Provider for class javax.xml.stream.XMLInputFactory cannot be created at javax.xml.stream.FactoryFinder.findServiceProvider(FactoryFinder.java:367) ~[?:1.8.0_202] ... 58 more Caused by: java.util.ServiceConfigurationError: javax.xml.stream.XMLInputFactory: Provider com.ctc.wstx.stax.WstxInputFactory not found at java.util.ServiceLoader.fail(ServiceLoader.java:239) ~[?:1.8.0_202] at java.util.ServiceLoader.access$300(ServiceLoader.java:185) ~[?:1.8.0_202] at java.util.ServiceLoader$LazyIterator.nextService(ServiceLoader.java:372) ~[?:1.8.0_202] at java.util.ServiceLoader$LazyIterator.next(ServiceLoader.java:404) ~[?:1.8.0_202] at java.util.ServiceLoader$1.next(ServiceLoader.java:480) ~[?:1.8.0_202] at javax.xml.stream.FactoryFinder$1.run(FactoryFinder.java:353) ~[?:1.8.0_202] at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_202] at javax.xml.stream.FactoryFinder.findServiceProvider(FactoryFinder.java:341) ~[?:1.8.0_202] ... 58 more