[infinispan-commits] Infinispan SVN: r1814 - trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty.

infinispan-commits at lists.jboss.org infinispan-commits at lists.jboss.org
Tue May 18 12:17:22 EDT 2010


Author: mircea.markus
Date: 2010-05-18 12:17:21 -0400 (Tue, 18 May 2010)
New Revision: 1814

Added:
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientPipelaneFactory.java
Removed:
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotrodClientPipelaneFactory.java
Log:
renamed

Copied: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientPipelaneFactory.java (from rev 1813, trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotrodClientPipelaneFactory.java)
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientPipelaneFactory.java	                        (rev 0)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientPipelaneFactory.java	2010-05-18 16:17:21 UTC (rev 1814)
@@ -0,0 +1,40 @@
+package org.infinispan.client.hotrod.impl.transport.netty;
+
+import org.infinispan.util.logging.Log;
+import org.infinispan.util.logging.LogFactory;
+import org.jboss.netty.channel.ChannelEvent;
+import org.jboss.netty.channel.ChannelPipeline;
+import org.jboss.netty.channel.ChannelPipelineFactory;
+import org.jboss.netty.channel.DefaultChannelPipeline;
+import org.jboss.netty.handler.codec.http.HttpRequestEncoder;
+import org.jboss.netty.handler.codec.http.HttpResponseDecoder;
+import static org.jboss.netty.channel.Channels.*;
+
+/**
+ * @author Mircea.Markus at jboss.com
+ * @since 4.1
+ */
+public class HotrodClientPipelaneFactory implements ChannelPipelineFactory {
+
+   private static Log log = LogFactory.getLog(HotrodClientPipelaneFactory.class);
+
+   private HotrodClientDecoder decoder;
+
+   public HotrodClientPipelaneFactory(HotrodClientDecoder decoder) {
+      this.decoder = decoder;
+   }
+
+   @Override
+   public ChannelPipeline getPipeline() throws Exception {
+      ChannelPipeline pipeline = new DefaultChannelPipeline() {
+         @Override
+         protected void notifyHandlerException(ChannelEvent e, Throwable t) {
+            log.warn("Exception on event: " + e, t);
+            super.notifyHandlerException(e, t);
+         }
+      };
+      pipeline.addLast("decoder", decoder);
+      pipeline.addLast("encoder", new HotrodClientEncoder());
+      return pipeline;
+   }
+}

Deleted: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotrodClientPipelaneFactory.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotrodClientPipelaneFactory.java	2010-05-18 16:16:23 UTC (rev 1813)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotrodClientPipelaneFactory.java	2010-05-18 16:17:21 UTC (rev 1814)
@@ -1,40 +0,0 @@
-package org.infinispan.client.hotrod.impl.transport.netty;
-
-import org.infinispan.util.logging.Log;
-import org.infinispan.util.logging.LogFactory;
-import org.jboss.netty.channel.ChannelEvent;
-import org.jboss.netty.channel.ChannelPipeline;
-import org.jboss.netty.channel.ChannelPipelineFactory;
-import org.jboss.netty.channel.DefaultChannelPipeline;
-import org.jboss.netty.handler.codec.http.HttpRequestEncoder;
-import org.jboss.netty.handler.codec.http.HttpResponseDecoder;
-import static org.jboss.netty.channel.Channels.*;
-
-/**
- * @author Mircea.Markus at jboss.com
- * @since 4.1
- */
-public class HotrodClientPipelaneFactory implements ChannelPipelineFactory {
-
-   private static Log log = LogFactory.getLog(HotrodClientPipelaneFactory.class);
-
-   private HotrodClientDecoder decoder;
-
-   public HotrodClientPipelaneFactory(HotrodClientDecoder decoder) {
-      this.decoder = decoder;
-   }
-
-   @Override
-   public ChannelPipeline getPipeline() throws Exception {
-      ChannelPipeline pipeline = new DefaultChannelPipeline() {
-         @Override
-         protected void notifyHandlerException(ChannelEvent e, Throwable t) {
-            log.warn("Exception on event: " + e, t);
-            super.notifyHandlerException(e, t);
-         }
-      };
-      pipeline.addLast("decoder", decoder);
-      pipeline.addLast("encoder", new HotrodClientEncoder());
-      return pipeline;
-   }
-}



More information about the infinispan-commits mailing list