[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