You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sn...@apache.org on 2014/03/15 01:27:37 UTC

[49/50] [abbrv] Merge branch 'two-dot-o' into asyncqueue

http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/5c014edb/stack/corepersistence/collection/pom.xml
----------------------------------------------------------------------
diff --cc stack/corepersistence/collection/pom.xml
index 7a8e780,374dc94..7b34b0b
--- a/stack/corepersistence/collection/pom.xml
+++ b/stack/corepersistence/collection/pom.xml
@@@ -2,219 -2,203 +2,206 @@@
  <project xmlns="http://maven.apache.org/POM/4.0.0"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
- 
-   <properties>
-     <guice.version>3.0</guice.version>
-     <guicyfig.version>3.3</guicyfig.version>
-     <slf4j.version>1.7.2</slf4j.version>
-     <log4j.version>1.2.17</log4j.version>
-     <chop.version>1.0</chop.version>
-     <rx.version>0.17.0</rx.version>
-   </properties>
- 
-   <parent>
-     <artifactId>persistence</artifactId>
-     <groupId>org.apache.usergrid</groupId>
-     <version>1.0-SNAPSHOT</version>
-   </parent>
-   <modelVersion>4.0.0</modelVersion>
-   <description>The module for handling all scope I/O</description>
- 
-   <artifactId>collection</artifactId>
- 
-   <build>
- 
- 
-     <plugins>
- 
- 
-       <plugin>
-         <groupId>org.safehaus.chop</groupId>
-         <artifactId>chop-maven-plugin</artifactId>
-         <version>${chop.version}</version>
- 
-         <!--
-         NOTE: you should be putting most of these variables into your settings.xml
-         as an automatically activated profile.
-         -->
- 
-         <configuration>
-           <accessKey>${aws.s3.key}</accessKey>
-           <secretKey>${aws.s3.secret}</secretKey>
-           <availabilityZone>${availabilityZone}</availabilityZone>
-           <bucketName>${aws.s3.bucket}</bucketName>
-           <managerAppUsername>admin</managerAppUsername>
-           <managerAppPassword>${manager.app.password}</managerAppPassword>
-           <testPackageBase>org.apache.usergrid</testPackageBase>
-           <runnerSSHKeyFile>${runner.ssh.key.file}</runnerSSHKeyFile>
-           <failIfCommitNecessary>false</failIfCommitNecessary>
-           <amiID>${ami.id}</amiID>
-           <instanceType>m1.large</instanceType>
-           <resultsDirectory>${resultsDirectory}</resultsDirectory>
-           <dumpType>${dumpType}</dumpType>
-           <coldRestartTomcat>true</coldRestartTomcat>
-           <awsSecurityGroup>${security.group}</awsSecurityGroup>
-           <runnerKeyPairName>${runner.keypair.name}</runnerKeyPairName>
-           <runnerCount>6</runnerCount>
-           <securityGroupExceptions>
-             <!--
-             Add your own IP address as an exception to allow access
-             but please do this in the settings.xml file .. essentially
-             all parameters should be in the settings.xml file.
-             -->
-             <param>${myip.address}/32:24981</param>
-             <param>${myip.address}/32:22</param>
-           </securityGroupExceptions>
-         </configuration>
-       </plugin>
-     </plugins>
-   </build>
- 
-   <dependencies>
- 
-     <dependency>
-       <groupId>org.safehaus.chop</groupId>
-       <artifactId>chop-api</artifactId>
-       <version>${chop.version}</version>
-     </dependency>
- 
-     <!-- Google Guice Integration Test Injectors -->
- 
-     <dependency>
-       <groupId>${project.parent.groupId}</groupId>
-       <artifactId>model</artifactId>
-       <version>${project.version}</version>
-     </dependency>
- 
-     <dependency>
-       <groupId>com.netflix.astyanax</groupId>
-       <artifactId>astyanax-core</artifactId>
-       <version>${astyanax.version}</version>
-     </dependency>
- 
-     <dependency>
-       <groupId>com.netflix.astyanax</groupId>
-       <artifactId>astyanax-thrift</artifactId>
-       <version>${astyanax.version}</version>
-     </dependency>
- 
-     <dependency>
-       <groupId>com.netflix.astyanax</groupId>
-       <artifactId>astyanax-cassandra</artifactId>
-       <version>${astyanax.version}</version>
-       <exclusions>
-         <exclusion>
-           <artifactId>servlet-api</artifactId>
-           <groupId>org.mortbay.jetty</groupId>
-         </exclusion>
-       </exclusions>
-     </dependency>
- 
-     <dependency>
-       <groupId>org.safehaus.guicyfig</groupId>
-       <artifactId>guicyfig</artifactId>
-       <version>${guicyfig.version}</version>
-     </dependency>
- 
-     <dependency>
-       <groupId>org.jukito</groupId>
-       <artifactId>jukito</artifactId>
-       <version>${jukito.version}</version>
-       <scope>test</scope>
-     </dependency>
- 
-     <!-- lang utils for setting uuids etc -->
-     <dependency>
-       <groupId>org.apache.commons</groupId>
-       <artifactId>commons-lang3</artifactId>
-       <version>3.1</version>
-     </dependency>
-     <!-- Serialization libraries -->
- 
-     <dependency>
-       <groupId>org.codehaus.jackson</groupId>
-       <artifactId>jackson-smile</artifactId>
-       <version>1.9.13</version>
-     </dependency>
- 
-     <dependency>
-       <groupId>com.esotericsoftware.kryo</groupId>
-       <artifactId>kryo</artifactId>
-       <version>2.22</version>
-     </dependency>
- 
-     <!-- helper serializers for kryo -->
-     <dependency>
-       <groupId>de.javakaffee</groupId>
-       <artifactId>kryo-serializers</artifactId>
-       <version>0.26</version>
-     </dependency>
- 
-     <!-- Google Guice -->
-     <dependency>
-       <groupId>com.google.inject</groupId>
-       <artifactId>guice</artifactId>
-       <version>${guice.version}</version>
-     </dependency>
- 
-     <!-- RX java -->
- 
-     <dependency>
-         <groupId>com.netflix.rxjava</groupId>
-         <artifactId>rxjava-core</artifactId>
-         <version>${rx.version}</version>
-     </dependency>
-     <dependency>
-            <groupId>com.netflix.rxjava</groupId>
-            <artifactId>rxjava-math</artifactId>
-            <version>${rx.version}</version>
-        </dependency>
- 
- 
-     <!--<dependency>-->
-       <!--<groupId>com.netflix.rxjava</groupId>-->
-       <!--<artifactId>rxjava-contrib</artifactId>-->
-       <!--<version>0.14.6</version>-->
-     <!--</dependency>-->
- 
-     <dependency>
-       <groupId>com.google.inject.extensions</groupId>
-       <artifactId>guice-multibindings</artifactId>
-       <version>${guice.version}</version>
-     </dependency>
- 
-     <dependency>
-       <groupId>com.google.inject.extensions</groupId>
-       <artifactId>guice-assistedinject</artifactId>
-       <version>${guice.version}</version>
-     </dependency>
- 
-     <dependency>
-       <groupId>org.slf4j</groupId>
-       <artifactId>slf4j-api</artifactId>
-       <version>${slf4j.version}</version>
-     </dependency>
- 
-     <dependency>
-       <groupId>org.slf4j</groupId>
-       <artifactId>slf4j-log4j12</artifactId>
-       <version>${slf4j.version}</version>
-     </dependency>
- 
-     <dependency>
-       <groupId>log4j</groupId>
-       <artifactId>log4j</artifactId>
-       <version>${log4j.version}</version>
-     </dependency>
- 
-     <!-- Re-add once this is done
-     https://github.com/Netflix/Hystrix/pull/209-->
- 
-     <!--<dependency>-->
-         <!--<groupId>com.netflix.hystrix</groupId>-->
-         <!--<artifactId>hystrix-core</artifactId>-->
-         <!--<version>1.3.13</version>-->
-     <!--</dependency>-->
- 
-   </dependencies>
+   
+     <parent>
+         <artifactId>persistence</artifactId>
+         <groupId>org.apache.usergrid</groupId>
+         <version>1.0-SNAPSHOT</version>
+     </parent>
+ 
+     <modelVersion>4.0.0</modelVersion>
+     <description>The module for handling all scope I/O</description>
+ 
+     <artifactId>collection</artifactId>
+ 
+     <build>
+ 
+         <plugins>
+ 
+             <plugin>
+                 <groupId>org.safehaus.chop</groupId>
+                 <artifactId>chop-maven-plugin</artifactId>
+                 <version>${chop.version}</version>
+ 
+                 <!--
+                 NOTE: you should be putting most of these variables into your settings.xml
+                 as an automatically activated profile.
+                 -->
+ 
+                 <configuration>
+                     <accessKey>${aws.s3.key}</accessKey>
+                     <secretKey>${aws.s3.secret}</secretKey>
+                     <availabilityZone>${availabilityZone}</availabilityZone>
+                     <bucketName>${aws.s3.bucket}</bucketName>
+                     <managerAppUsername>admin</managerAppUsername>
+                     <managerAppPassword>${manager.app.password}</managerAppPassword>
+                     <testPackageBase>org.apache.usergrid</testPackageBase>
+                     <runnerSSHKeyFile>${runner.ssh.key.file}</runnerSSHKeyFile>
+                     <failIfCommitNecessary>false</failIfCommitNecessary>
+                     <amiID>${ami.id}</amiID>
+                     <instanceType>m1.large</instanceType>
+                     <resultsDirectory>${resultsDirectory}</resultsDirectory>
+                     <dumpType>${dumpType}</dumpType>
+                     <coldRestartTomcat>true</coldRestartTomcat>
+                     <awsSecurityGroup>${security.group}</awsSecurityGroup>
+                     <runnerKeyPairName>${runner.keypair.name}</runnerKeyPairName>
+                     <runnerCount>6</runnerCount>
+                     <securityGroupExceptions>
+                         <!--
+                         Add your own IP address as an exception to allow access
+                         but please do this in the settings.xml file .. essentially
+                         all parameters should be in the settings.xml file.
+                         -->
+                         <param>${myip.address}/32:24981</param>
+                         <param>${myip.address}/32:22</param>
+                     </securityGroupExceptions>
+                 </configuration>
+             </plugin>
+         </plugins>
+     </build>
+ 
+     <dependencies>
+ 
+         <dependency>
+             <groupId>org.safehaus.chop</groupId>
+             <artifactId>chop-api</artifactId>
+             <version>${chop.version}</version>
+         </dependency>
+ 
+         <!-- Google Guice Integration Test Injectors -->
+ 
+         <dependency>
+             <groupId>${project.parent.groupId}</groupId>
+             <artifactId>model</artifactId>
+             <version>${project.version}</version>
+         </dependency>
+ 
+         <dependency>
+             <groupId>com.netflix.astyanax</groupId>
+             <artifactId>astyanax-core</artifactId>
+             <version>${astyanax.version}</version>
+         </dependency>
+ 
+         <dependency>
+             <groupId>com.netflix.astyanax</groupId>
+             <artifactId>astyanax-thrift</artifactId>
+             <version>${astyanax.version}</version>
+         </dependency>
+ 
+         <dependency>
+             <groupId>com.netflix.astyanax</groupId>
+             <artifactId>astyanax-cassandra</artifactId>
+             <version>${astyanax.version}</version>
+             <exclusions>
+                 <exclusion>
+                     <artifactId>servlet-api</artifactId>
+                     <groupId>org.mortbay.jetty</groupId>
+                 </exclusion>
+             </exclusions>
+         </dependency>
+ 
+         <dependency>
+             <groupId>org.safehaus.guicyfig</groupId>
+             <artifactId>guicyfig</artifactId>
+             <version>${guicyfig.version}</version>
+         </dependency>
+ 
+         <dependency>
+             <groupId>org.jukito</groupId>
+             <artifactId>jukito</artifactId>
+             <version>${jukito.version}</version>
+             <scope>test</scope>
+         </dependency>
+ 
+         <!-- lang utils for setting uuids etc -->
+ 
+         <dependency>
+             <groupId>org.apache.commons</groupId>
+             <artifactId>commons-lang3</artifactId>
+             <version>${commons.lang.version}</version>
+         </dependency>
+ 
+         <!-- Serialization libraries -->
+ 
+         <dependency>
+             <groupId>org.codehaus.jackson</groupId>
+             <artifactId>jackson-smile</artifactId>
+             <version>${jackson-smile.verson}</version>
+         </dependency>
+ 
+         <dependency>
+             <groupId>com.esotericsoftware.kryo</groupId>
+             <artifactId>kryo</artifactId>
+             <version>${kryo.version}</version>
+         </dependency>
+ 
+         <!-- helper serializers for kryo -->
+         <dependency>
+             <groupId>de.javakaffee</groupId>
+             <artifactId>kryo-serializers</artifactId>
+             <version>${kryo-serializers.version}</version>
+         </dependency>
+ 
+         <!-- Google Guice -->
+ 
+         <dependency>
+             <groupId>com.google.inject</groupId>
+             <artifactId>guice</artifactId>
+             <version>${guice.version}</version>
+         </dependency>
+ 
+         <dependency>
+             <groupId>com.google.inject.extensions</groupId>
+             <artifactId>guice-multibindings</artifactId>
+             <version>${guice.version}</version>
+         </dependency>
+ 
+         <dependency>
+             <groupId>com.google.inject.extensions</groupId>
+             <artifactId>guice-assistedinject</artifactId>
+             <version>${guice.version}</version>
+         </dependency>
+ 
+         <!-- RX java -->
+ 
 -        <dependency>
 -            <groupId>com.netflix.rxjava</groupId>
 -            <artifactId>rxjava-core</artifactId>
 -            <version>0.16.1</version>
 -        </dependency>
 -
 -        <dependency>
 -            <groupId>com.netflix.rxjava</groupId>
 -            <artifactId>rxjava-contrib</artifactId>
 -            <version>0.14.6</version>
 -        </dependency>
 -
 -        <dependency>
 -            <groupId>com.netflix.hystrix</groupId>
 -            <artifactId>hystrix-core</artifactId>
 -            <version>${hystrix.version}</version>
 -        </dependency>
++          <dependency>
++              <groupId>com.netflix.rxjava</groupId>
++              <artifactId>rxjava-core</artifactId>
++              <version>${rx.version}</version>
++          </dependency>
++          <dependency>
++                 <groupId>com.netflix.rxjava</groupId>
++                 <artifactId>rxjava-math</artifactId>
++                 <version>${rx.version}</version>
++             </dependency>
++
++
++      <!-- Re-add once this is done
++      https://github.com/Netflix/Hystrix/pull/209-->
++
++        <!--<dependency>-->
++            <!--<groupId>com.netflix.hystrix</groupId>-->
++            <!--<artifactId>hystrix-core</artifactId>-->
++            <!--<version>${hystrix.version}</version>-->
++        <!--</dependency>-->
+ 
+         <dependency>
+             <groupId>org.slf4j</groupId>
+             <artifactId>slf4j-api</artifactId>
+             <version>${slf4j.version}</version>
+         </dependency>
+ 
+         <dependency>
+             <groupId>org.slf4j</groupId>
+             <artifactId>slf4j-log4j12</artifactId>
+             <version>${slf4j.version}</version>
+         </dependency>
+ 
+         <dependency>
+             <groupId>log4j</groupId>
+             <artifactId>log4j</artifactId>
+             <version>${log4j.version}</version>
+         </dependency>
+ 
+     </dependencies>
  </project>

http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/5c014edb/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/rx/CassandraThreadScheduler.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/5c014edb/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/guice/GraphModule.java
----------------------------------------------------------------------
diff --cc stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/guice/GraphModule.java
index a5dda9a,3ac87a0..b499e4c
--- a/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/guice/GraphModule.java
+++ b/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/guice/GraphModule.java
@@@ -49,15 -40,17 +48,11 @@@ import org.apache.usergrid.persistence.
  import org.apache.usergrid.persistence.graph.serialization.impl.EdgeSerializationImpl;
  import org.apache.usergrid.persistence.graph.serialization.impl.NodeSerializationImpl;
  
 -import com.google.common.eventbus.EventBus;
  import com.google.inject.AbstractModule;
 -import com.google.inject.TypeLiteral;
  import com.google.inject.assistedinject.FactoryModuleBuilder;
 -import com.google.inject.matcher.Matchers;
  import com.google.inject.multibindings.Multibinder;
 -import com.google.inject.spi.InjectionListener;
 -import com.google.inject.spi.TypeEncounter;
 -import com.google.inject.spi.TypeListener;
  
  
- /**
-  *
-  *
-  */
  public class GraphModule extends AbstractModule {
  
      @Override