code review changes

Author: peterj99a

stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManager.java

@@ -2854,7 +2854,7 @@ else if ( ( v instanceof String ) && isBlank( ( String ) v ) ) {
 
         // add to and index in collection of the application
         if ( !is_application) {
-            updateIndexForEniity(eType, entity, timestamp);
+            updateIndexForEntity(eType, entity, timestamp);
         }
 
         //write to our types map
@@ -2864,7 +2864,7 @@ else if ( ( v instanceof String ) && isBlank( ( String ) v ) ) {
         return entity;
     }
 
-    private <A extends Entity> void updateIndexForEniity(String eType, A entity,  long timestamp) throws Exception {
+    private <A extends Entity> void updateIndexForEntity(String eType, A entity, long timestamp) throws Exception {
         String collectionName = Schema.defaultCollectionName( eType );
         CpRelationManager cpr = ( CpRelationManager ) getRelationManager( getApplication() );
         cpr.addToCollection( collectionName, entity );

stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java

@@ -21,7 +21,6 @@
 
 
 import java.util.ArrayList;
-import java.util.Collections;
 import java.util.List;
 import java.util.UUID;
 

stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SNSQueueManagerImpl.java

@@ -84,6 +84,8 @@ public class SNSQueueManagerImpl implements LegacyQueueManager {
     private static final int MIN_VISIBILITY_TIMEOUT = 1; //seconds
     private static final String DEAD_LETTER_QUEUE_SUFFIX = "_dead";
 
+    private static final String FAILED_TO_SEND_MESSAGE = "FAILED INDEX REQUEST: Failed to send message to SNS Queue, sending asynchronously. Message:[{}] URL:[{}] Error:[{}]";
+
     static {
 
         /**
@@ -573,7 +575,7 @@ private <T extends Serializable> void sendMessageToAllRegionsSync(final T body)
             }
         } catch (Exception e) {
             if (logger.isErrorEnabled()) {
-                logger.error("Failed to send this message {} to SNS queue at {}", stringBody, topicArn);
+                logger.error(FAILED_TO_SEND_MESSAGE,  stringBody, topicArn, e);
             }
             sendMessageToAllRegionsAsync(body);
         }
@@ -591,7 +593,7 @@ private <T extends Serializable> void sendMessageToAllRegionsAsync(final T body
 
         final String stringBody = toString( body );
 
-        String topicArn = getWriteTopicArn();
+        final String topicArn = getWriteTopicArn();
 
         if ( logger.isTraceEnabled() ) {
             logger.trace( "Publishing Message...{} to arn: {}", stringBody, topicArn );
@@ -603,6 +605,7 @@ private <T extends Serializable> void sendMessageToAllRegionsAsync(final T body
             @Override
             public void onError( Exception e ) {
                 logger.error( "Error publishing message... {}", e );
+                logger.error(FAILED_TO_SEND_MESSAGE, stringBody, topicArn, e);
             }
 
 
@@ -713,7 +716,7 @@ private <T extends Serializable> void sendMessageToLocalRegionSync(final T body)
                     url);
             }
         } catch (Exception e) {
-            logger.error("Failed to send this message {}. To this address {}. Error was ",  messageRequest.getMessageBody(), url, e);
+            logger.error(FAILED_TO_SEND_MESSAGE,  messageRequest.getMessageBody(), url, e);
             sendMessageToLocalRegionAsync(body);
         }
 
@@ -740,7 +743,7 @@ private <T extends Serializable> void sendMessageToLocalRegionAsync(final T body
 
             @Override
             public void onError( final Exception e ) {
-                logger.error("Failed to send this message {}. To this address {}. Error was ", stringBody, url, e);
+                logger.error(FAILED_TO_SEND_MESSAGE, stringBody, url, e);
             }