james-server-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nor...@apache.org
Subject svn commit: r1087846 - /james/imap/trunk/processor/src/main/java/org/apache/james/imap/processor/IdleProcessor.java
Date Fri, 01 Apr 2011 18:50:21 GMT
Author: norman
Date: Fri Apr  1 18:50:20 2011
New Revision: 1087846

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

Modified:
    james/imap/trunk/processor/src/main/java/org/apache/james/imap/processor/IdleProcessor.java

Modified: james/imap/trunk/processor/src/main/java/org/apache/james/imap/processor/IdleProcessor.java
URL: http://svn.apache.org/viewvc/james/imap/trunk/processor/src/main/java/org/apache/james/imap/processor/IdleProcessor.java?rev=1087846&r1=1087845&r2=1087846&view=diff
==============================================================================
--- james/imap/trunk/processor/src/main/java/org/apache/james/imap/processor/IdleProcessor.java
(original)
+++ james/imap/trunk/processor/src/main/java/org/apache/james/imap/processor/IdleProcessor.java
Fri Apr  1 18:50:20 2011
@@ -119,37 +119,39 @@ public class IdleProcessor extends Abstr
                         // See if we need to cancel the idle heartbeat handling
                         Object oFuture = session.getAttribute(HEARTBEAT_FUTURE);
                         if (oFuture != null) {
-                        	ScheduledFuture<?> future = (ScheduledFuture<?>)oFuture;
-                        	if (future.cancel(true) == false) {
-                        		// unable to cancel the future so better logout now!
-                        		session.getLog().error("Unable to disable idle heartbeat for unknown
reason! Force logout");
-                        		session.logout();
-                        	}
+                            ScheduledFuture<?> future = (ScheduledFuture<?>)
oFuture;
+                            if (future.cancel(true) == false) {
+                                // unable to cancel the future so better logout
+                                // now!
+                                session.getLog().error("Unable to disable idle heartbeat
for unknown reason! Force logout");
+                                session.logout();
+                            }
                         }
                     }                    
                 }
             });
-            
-            // Check if we should send heartbeats 
+
+            // Check if we should send heartbeats
             if (heartbeatInterval > 0) {
-            	ScheduledFuture<?> heartbeatFuture = heartbeatExecutor.scheduleWithFixedDelay(new
Runnable() {
-				
-            		public void run() {
-            			// Send a heartbeat to the client to make sure we reset the idle timeout.
This is kind of the same workaround as dovecot use.
-            			//
-            			// This is mostly needed because of the broken outlook client, but can't harm
for other clients too.
-            			// See IMAP-272
-            			StatusResponse response = getStatusResponseFactory().untaggedOk(HumanReadableText.HEARTBEAT);
-            			responder.respond(response);
-            		}
-            	}, heartbeatInterval, heartbeatInterval, heartbeatIntervalUnit);
-            	
-            	// store future for later usage
-            	session.setAttribute(HEARTBEAT_FUTURE, heartbeatFuture);
+                ScheduledFuture<?> heartbeatFuture = heartbeatExecutor.scheduleWithFixedDelay(new
Runnable() {
+
+                    public void run() {
+                        // Send a heartbeat to the client to make sure we reset
+                        // the idle timeout. This is kind of the same workaround
+                        // as dovecot use.
+                        //
+                        // This is mostly needed because of the broken outlook
+                        // client, but can't harm for other clients too.
+                        // See IMAP-272
+                        StatusResponse response = getStatusResponseFactory().untaggedOk(HumanReadableText.HEARTBEAT);
+                        responder.respond(response);
+                    }
+                }, heartbeatInterval, heartbeatInterval, heartbeatIntervalUnit);
+
+                // store future for later usage
+                session.setAttribute(HEARTBEAT_FUTURE, heartbeatFuture);
             }
-            
-            
-            
+
         } catch (MailboxException e) {
             closed.set(true);
             // TODO: What should we do here?



---------------------------------------------------------------------
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