You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@avro.apache.org by cu...@apache.org on 2011/02/24 23:53:59 UTC

svn commit: r1074338 - in /avro/trunk: CHANGES.txt lang/java/ipc/src/main/java/org/apache/avro/ipc/NettyTransceiver.java

Author: cutting
Date: Thu Feb 24 22:53:59 2011
New Revision: 1074338

URL: http://svn.apache.org/viewvc?rev=1074338&view=rev
Log:
AVRO-754. Java: Permit passing custom channel factory to NettyTransceiver.  Contributed by Bruno Dumon.

Modified:
    avro/trunk/CHANGES.txt
    avro/trunk/lang/java/ipc/src/main/java/org/apache/avro/ipc/NettyTransceiver.java

Modified: avro/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/avro/trunk/CHANGES.txt?rev=1074338&r1=1074337&r2=1074338&view=diff
==============================================================================
--- avro/trunk/CHANGES.txt (original)
+++ avro/trunk/CHANGES.txt Thu Feb 24 22:53:59 2011
@@ -182,6 +182,9 @@ Avro 1.5.0 (unreleased)
 
     AVRO-774. Java: Clean up repositories in pom.xml. (Lars Francke via cutting)
 
+    AVRO-754. Java: Permit passing custom channel factory to NettyTransceiver.
+    (Bruno Dumon via cutting)
+
   BUG FIXES
 
     AVRO-764. Java: Bug in BinaryData.compare() with offset comparison.

Modified: avro/trunk/lang/java/ipc/src/main/java/org/apache/avro/ipc/NettyTransceiver.java
URL: http://svn.apache.org/viewvc/avro/trunk/lang/java/ipc/src/main/java/org/apache/avro/ipc/NettyTransceiver.java?rev=1074338&r1=1074337&r2=1074338&view=diff
==============================================================================
--- avro/trunk/lang/java/ipc/src/main/java/org/apache/avro/ipc/NettyTransceiver.java (original)
+++ avro/trunk/lang/java/ipc/src/main/java/org/apache/avro/ipc/NettyTransceiver.java Thu Feb 24 22:53:59 2011
@@ -73,9 +73,13 @@ public class NettyTransceiver extends Tr
   NettyTransceiver() {}
   
   public NettyTransceiver(InetSocketAddress addr) {
+    this(addr, new NioClientSocketChannelFactory(Executors.
+        newCachedThreadPool(), Executors.newCachedThreadPool()));
+  }
+
+  public NettyTransceiver(InetSocketAddress addr, ChannelFactory channelFactory) {
     // Set up.
-    channelFactory = new NioClientSocketChannelFactory(Executors
-        .newCachedThreadPool(), Executors.newCachedThreadPool());
+    this.channelFactory = channelFactory;
     ClientBootstrap bootstrap = new ClientBootstrap(channelFactory);
 
     // Configure the event pipeline factory.