PubsubIO: implement an unbounded source and sink

pom.xml

@@ -69,6 +69,7 @@
     <!-- If updating dependencies, please update any relevant javadoc offlineLinks -->
     <avro.version>1.7.7</avro.version>
     <bigquery.version>v2-rev295-1.22.0</bigquery.version>
+    <pubsubgrpc.version>0.0.2</pubsubgrpc.version>
     <bigtable.version>0.2.3</bigtable.version>
     <clouddebugger.version>v2-rev8-1.22.0</clouddebugger.version>
     <dataflow.version>v1b3-rev26-1.22.0</dataflow.version>

sdk/pom.xml

@@ -485,11 +485,30 @@
       <version>0.12.0</version>
     </dependency>
 
+    <dependency>
+      <groupId>io.netty</groupId>
+      <artifactId>netty-handler</artifactId>
+      <version>4.1.0.Beta8</version>
+    </dependency>
+
+    <dependency>
+      <groupId>com.google.api.grpc</groupId>
+      <artifactId>grpc-pubsub-v1</artifactId>
+      <version>${pubsubgrpc.version}</version>
+      <exclusions>
+        <!-- Exclude an old version of guava that is being pulled in by a transitive 
+          dependency of google-api-client -->
+        <exclusion>
+          <groupId>com.google.guava</groupId>
+          <artifactId>guava-jdk5</artifactId>
+        </exclusion>
+      </exclusions>
+    </dependency>
+
     <dependency>
       <groupId>com.google.auth</groupId>
       <artifactId>google-auth-library-oauth2-http</artifactId>
       <version>0.4.0</version>
-      <scope>runtime</scope>
       <exclusions>
         <!-- Exclude an old version of guava that is being pulled in by a transitive
           dependency of google-api-client -->