usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sfeld...@apache.org
Subject [17/30] incubator-usergrid git commit: changing buffer impl to queue
Date Mon, 09 Mar 2015 15:14:34 GMT
changing buffer impl to queue


Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/6066b6e9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/6066b6e9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/6066b6e9

Branch: refs/heads/two-dot-o
Commit: 6066b6e98e3f3324858d8812fb607bf77b37f9a8
Parents: 5ad1a8c
Author: Shawn Feldman <sfeldman@apache.org>
Authored: Fri Mar 6 15:50:48 2015 -0700
Committer: Shawn Feldman <sfeldman@apache.org>
Committed: Fri Mar 6 15:50:48 2015 -0700

----------------------------------------------------------------------
 .../notifications/Usergrid.Notifications/MainPage.xaml.cs    | 8 ++++----
 .../persistence/index/impl/EsIndexBufferConsumerImpl.java    | 2 --
 2 files changed, 4 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/6066b6e9/sdks/dotnet/samples/notifications/Usergrid.Notifications/MainPage.xaml.cs
----------------------------------------------------------------------
diff --git a/sdks/dotnet/samples/notifications/Usergrid.Notifications/MainPage.xaml.cs b/sdks/dotnet/samples/notifications/Usergrid.Notifications/MainPage.xaml.cs
index ccef239..2120eeb 100644
--- a/sdks/dotnet/samples/notifications/Usergrid.Notifications/MainPage.xaml.cs
+++ b/sdks/dotnet/samples/notifications/Usergrid.Notifications/MainPage.xaml.cs
@@ -44,7 +44,7 @@ namespace Usergrid.Notifications
         {
             this.InitializeComponent();
             //TODO: change me to your server
-            serverUrl = "http://10.0.1.20:8080/";
+            serverUrl = "http://server/";
             //TODO: change me to your org
             org = "test-organization";
             //TODO: change me to your app
@@ -52,9 +52,9 @@ namespace Usergrid.Notifications
             //TODO: change me to your notifier name
             notifier = "windows";
             //TODO: change me to your user
-            user = "mobileuser";
+            user = "test";
             //TODO: change me to your password
-            password = "P@ssw0rd1";
+            password = "test";
             this.NavigationCacheMode = NavigationCacheMode.Required;
             usergrid = new Client.Usergrid(serverUrl, org, app, user, password, notifier);
 
@@ -79,7 +79,7 @@ namespace Usergrid.Notifications
             // If you are using the NavigationHelper provided by some templates,
             // this event is handled for you.
         }
-         
+
         private void pushText_TextChanged(object sender, TextChangedEventArgs e)
         {
 

http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/6066b6e9/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
index 625f4e7..d952d78 100644
--- a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
+++ b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
@@ -93,7 +93,6 @@ public class EsIndexBufferConsumerImpl implements IndexBufferConsumer {
                                 if(polled!=null) {
                                     drainList.add(polled);
                                     producerQueue.drainTo(drainList, config.getIndexBufferSize());
-                                    System.out.println("Consumer Thread" + Thread.currentThread().getName());
                                     for(IndexOperationMessage drained : drainList){
                                         subscriber.onNext(drained);
                                     }
@@ -116,7 +115,6 @@ public class EsIndexBufferConsumerImpl implements IndexBufferConsumer
{
             .doOnNext(new Action1<List<IndexOperationMessage>>() {
                 @Override
                 public void call(List<IndexOperationMessage> containerList) {
-                    System.out.println("Buffered Consumer Thread" + Thread.currentThread().getName());
                     if (containerList.size() > 0) {
                         flushMeter.mark(containerList.size());
                         Timer.Context time = flushTimer.time();


Mime
View raw message