james-server-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nor...@apache.org
Subject svn commit: r1049069 - in /james/server/trunk/netty-socket/src/main/java/org/apache/james/socket/netty: AbstractConfigurableAsyncServer.java ConnectionCountHandler.java
Date Tue, 14 Dec 2010 12:46:17 GMT
Author: norman
Date: Tue Dec 14 12:46:16 2010
New Revision: 1049069

URL: http://svn.apache.org/viewvc?rev=1049069&view=rev
Log:
Replace tabs with spaces

Modified:
    james/server/trunk/netty-socket/src/main/java/org/apache/james/socket/netty/AbstractConfigurableAsyncServer.java
    james/server/trunk/netty-socket/src/main/java/org/apache/james/socket/netty/ConnectionCountHandler.java

Modified: james/server/trunk/netty-socket/src/main/java/org/apache/james/socket/netty/AbstractConfigurableAsyncServer.java
URL: http://svn.apache.org/viewvc/james/server/trunk/netty-socket/src/main/java/org/apache/james/socket/netty/AbstractConfigurableAsyncServer.java?rev=1049069&r1=1049068&r2=1049069&view=diff
==============================================================================
--- james/server/trunk/netty-socket/src/main/java/org/apache/james/socket/netty/AbstractConfigurableAsyncServer.java
(original)
+++ james/server/trunk/netty-socket/src/main/java/org/apache/james/socket/netty/AbstractConfigurableAsyncServer.java
Tue Dec 14 12:46:16 2010
@@ -438,24 +438,25 @@ public abstract class AbstractConfigurab
         return "plain";
     }
     
+    /*
+     * (non-Javadoc)
+     * 
+     * @see org.apache.james.socket.ServerMBean#getStartTLSSupported()
+     */
+    public boolean getStartTLSSupported() {
+        return isStartTLSSupported();
+    }
+
+    /*
+     * (non-Javadoc)
+     * 
+     * @see
+     * org.apache.james.socket.ServerMBean#getMaximumConcurrentConnections()
+     */
+    public int getMaximumConcurrentConnections() {
+        return connectionLimit;
+    }
 
-	/*
-	 * (non-Javadoc)
-	 * @see org.apache.james.socket.ServerMBean#getStartTLSSupported()
-	 */
-	public boolean getStartTLSSupported() {
-		return isStartTLSSupported();
-	}
-
-
-	/*
-	 * (non-Javadoc)
-	 * @see org.apache.james.socket.ServerMBean#getMaximumConcurrentConnections()
-	 */
-	public int getMaximumConcurrentConnections() {
-		return connectionLimit;
-	}
-	
     @Override
     protected Executor createBossExecutor() {
         return JMXEnabledThreadPoolExecutor.newCachedThreadPool("org.apache.james:type=server,name="
+ jmxName + ",sub-type=threadpool", "boss");

Modified: james/server/trunk/netty-socket/src/main/java/org/apache/james/socket/netty/ConnectionCountHandler.java
URL: http://svn.apache.org/viewvc/james/server/trunk/netty-socket/src/main/java/org/apache/james/socket/netty/ConnectionCountHandler.java?rev=1049069&r1=1049068&r2=1049069&view=diff
==============================================================================
--- james/server/trunk/netty-socket/src/main/java/org/apache/james/socket/netty/ConnectionCountHandler.java
(original)
+++ james/server/trunk/netty-socket/src/main/java/org/apache/james/socket/netty/ConnectionCountHandler.java
Tue Dec 14 12:46:16 2010
@@ -30,29 +30,26 @@ import org.jboss.netty.channel.SimpleCha
  */
 public class ConnectionCountHandler extends SimpleChannelUpstreamHandler {
 
-	public AtomicInteger currentConnectionCount = new AtomicInteger();
-	
-	@Override
-	public void channelClosed(ChannelHandlerContext ctx,
-			ChannelStateEvent e) throws Exception {
-		currentConnectionCount.decrementAndGet();
-		super.channelClosed(ctx, e);
-	}
+    public AtomicInteger currentConnectionCount = new AtomicInteger();
 
-	@Override
-	public void channelOpen(ChannelHandlerContext ctx,
-			ChannelStateEvent e) throws Exception {
-		currentConnectionCount.incrementAndGet();
-		super.channelOpen(ctx, e);
-	}
+    @Override
+    public void channelClosed(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception
{
+        currentConnectionCount.decrementAndGet();
+        super.channelClosed(ctx, e);
+    }
 
-	
-	/**
-	 * Return the count of the current open connections
-	 * 
-	 * @return count
-	 */
-	public int getCurrentConnectionCount() {
-		return currentConnectionCount.get();
-	}
+    @Override
+    public void channelOpen(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception
{
+        currentConnectionCount.incrementAndGet();
+        super.channelOpen(ctx, e);
+    }
+
+    /**
+     * Return the count of the current open connections
+     * 
+     * @return count
+     */
+    public int getCurrentConnectionCount() {
+        return currentConnectionCount.get();
+    }
 }



---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org


Mime
View raw message