You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sf...@apache.org on 2015/07/02 21:29:00 UTC
[5/6] incubator-usergrid git commit: Add and update comments.
Add and update comments.
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/2edf6813
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/2edf6813
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/2edf6813
Branch: refs/heads/two-dot-o-dev
Commit: 2edf68131af1c2e47761e0d41341b2438bdc71a2
Parents: 67cfa20
Author: Michael Russo <mi...@gmail.com>
Authored: Thu Jul 2 10:35:33 2015 -0700
Committer: Michael Russo <mi...@gmail.com>
Committed: Thu Jul 2 10:35:33 2015 -0700
----------------------------------------------------------------------
.../corepersistence/asyncevents/AmazonAsyncEventService.java | 2 +-
.../usergrid/persistence/queue/impl/SNSQueueManagerImpl.java | 7 +++++++
2 files changed, 8 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/2edf6813/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java
index e652405..c5b836b 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java
@@ -450,9 +450,9 @@ public class AmazonAsyncEventService implements AsyncEventService {
List batch = new ArrayList<EdgeScope>();
for ( EdgeScope e : edges){
+ //change to id scope to avoid serialization issues
batch.add(new EntityIndexEvent(new EntityIdScope(e.getApplicationScope(), e.getEdge().getTargetNode())));
}
- //change to id scope to avoid serialization issues
offerBatch(batch);
}
}
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/2edf6813/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 6c6cae9..257f25e 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
@@ -247,6 +247,13 @@ public class SNSQueueManagerImpl implements QueueManager {
private AmazonSNSAsyncClient createSNSClient(final Region region) {
final UsergridAwsCredentialsProvider ugProvider = new UsergridAwsCredentialsProvider();
+
+ /**
+ * The Async client will use default client configurations (default max conn: 50)
+ * http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/ClientConfiguration.html
+ * http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/constant-values.html#com.amazonaws.ClientConfiguration.DEFAULT_MAX_CONNECTIONS
+ */
+
final AmazonSNSAsyncClient sns = new AmazonSNSAsyncClient(ugProvider.getCredentials());
sns.setRegion(region);