Add null check back for batch sending of SQS w/proper SQS client. Less logging would occur in the event of batch send when the client is not initialized.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/fbb6c823 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/fbb6c823 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/fbb6c823 Branch: refs/heads/remove-inmemory-event-service Commit: fbb6c823b7e2a1f5f55ab044942b38d1157970c0 Parents: d8e6572 Author: Michael Russo <michaelaru...@gmail.com> Authored: Mon Oct 19 21:28:46 2015 -0700 Committer: Michael Russo <michaelaru...@gmail.com> Committed: Mon Oct 19 21:28:46 2015 -0700 ---------------------------------------------------------------------- .../usergrid/persistence/queue/impl/SNSQueueManagerImpl.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/fbb6c823/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SNSQueueManagerImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SNSQueueManagerImpl.java b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SNSQueueManagerImpl.java index 3c18992..1bb00dc 100644 --- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SNSQueueManagerImpl.java +++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SNSQueueManagerImpl.java @@ -543,6 +543,11 @@ public class SNSQueueManagerImpl implements QueueManager { @Override public void sendMessages( final List bodies ) throws IOException { + if ( sqsAsync == null ) { + logger.error( "SQS client is null, perhaps it failed to initialize successfully" ); + return; + } + for ( Object body : bodies ) { sendMessage( ( Serializable ) body ); }
