You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by to...@apache.org on 2014/10/17 03:29:05 UTC
git commit: Added logging
Repository: incubator-usergrid
Updated Branches:
refs/heads/index-rebuild c31c553f9 -> 0ca6b1270
Added logging
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/0ca6b127
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/0ca6b127
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/0ca6b127
Branch: refs/heads/index-rebuild
Commit: 0ca6b1270b11af2e2d768bb63db703438fe0f6ee
Parents: c31c553
Author: Todd Nine <to...@apache.org>
Authored: Thu Oct 16 19:29:01 2014 -0600
Committer: Todd Nine <to...@apache.org>
Committed: Thu Oct 16 19:29:01 2014 -0600
----------------------------------------------------------------------
.../usergrid/persistence/index/impl/EsEntityIndexImpl.java | 3 ++-
.../services/notifications/AbstractServiceNotificationIT.java | 4 ----
2 files changed, 2 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/0ca6b127/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexImpl.java b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexImpl.java
index 821f7b9..1e6c077 100644
--- a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexImpl.java
+++ b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexImpl.java
@@ -277,9 +277,10 @@ public class EsEntityIndexImpl implements EntityIndex {
//now try to refresh, to ensure that it's recognized by everyone. Occasionally we can get a success
//before we can write.
- for ( int i = 0; i < MAX_WAITS; i++ ) {
+ for ( int i = 0; i < MAX_WAITS-1; i++ ) {
try {
client.admin().indices().prepareRefresh( indexName ).execute().actionGet();
+ log.debug( "Refreshed index: " + indexName );
return;
}
catch ( IndexMissingException e ) {
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/0ca6b127/stack/services/src/test/java/org/apache/usergrid/services/notifications/AbstractServiceNotificationIT.java
----------------------------------------------------------------------
diff --git a/stack/services/src/test/java/org/apache/usergrid/services/notifications/AbstractServiceNotificationIT.java b/stack/services/src/test/java/org/apache/usergrid/services/notifications/AbstractServiceNotificationIT.java
index e16f111..a9ca955 100644
--- a/stack/services/src/test/java/org/apache/usergrid/services/notifications/AbstractServiceNotificationIT.java
+++ b/stack/services/src/test/java/org/apache/usergrid/services/notifications/AbstractServiceNotificationIT.java
@@ -41,11 +41,7 @@ import static org.junit.Assert.fail;
public class AbstractServiceNotificationIT extends AbstractServiceIT {
private NotificationsService ns;
- @Autowired
- private ServiceManagerFactory smf;
- @Autowired
- private EntityManagerFactory emf;
@Rule
public TestName name = new TestName();