[jboss-remoting-commits] JBoss Remoting SVN: r3516 - in remoting3/trunk: jrpp/src/main/java/org/jboss/cx/remoting/jrpp and 1 other directory.

[jboss-remoting-commits at lists.jboss.org]

Author: david.lloyd at jboss.com
Date: 2008-02-26 09:49:26 -0500 (Tue, 26 Feb 2008)
New Revision: 3516

Modified:
   remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/CommonKeys.java
   remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java
Log:
Start of JBREM-914 for someone to finish

Modified: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/CommonKeys.java
===================================================================
--- remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/CommonKeys.java	2008-02-26 06:40:57 UTC (rev 3515)
+++ remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/CommonKeys.java	2008-02-26 14:49:26 UTC (rev 3516)
@@ -44,4 +44,13 @@
     public static final AttributeKey<String> AUTHORIZATION_ID = key("AUTHORIZATION_ID");
 
     // TODO: add keys for SSL/TLS
+
+    // Protocol keys
+
+    /**
+     * The keepalive interval.  For protocols that are represented by a connection of some sort, this property indicates
+     * that a "keepalive" message should be sent at regular intervals to prevent an idle connection from being
+     * automatically closed by a firewall (for example).
+     */
+    public static final AttributeKey<Integer> KEEPALIVE_INTERVAL = key("KEEPALIVE_INTERVAL");
 }

Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java
===================================================================
--- remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java	2008-02-26 06:40:57 UTC (rev 3515)
+++ remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java	2008-02-26 14:49:26 UTC (rev 3516)
@@ -666,6 +666,9 @@
                             state.requireTransition(State.AWAITING_CLIENT_AUTH_REQUEST);
                             return;
                         }
+                        case PING: {
+                            return;
+                        }
                         default: break OUT;
                     }
                 }
@@ -704,6 +707,9 @@
                             state.transition(State.AWAITING_CLIENT_AUTH_REQUEST);
                             break; // fall thru to AWAITING_CLIENT_AUTH_REQUEST/AUTH_REQUEST
                         }
+                        case PING: {
+                            return;
+                        }
                         default: break OUT;
                     }
                 }
@@ -743,6 +749,9 @@
                             }
                             return;
                         }
+                        case PING: {
+                            return;
+                        }
                         default: break OUT;
                     }
                 }
@@ -759,6 +768,9 @@
                             state.requireTransition(State.AWAITING_SERVER_CHALLENGE);
                             return;
                         }
+                        case PING: {
+                            return;
+                        }
                         default: break OUT;
                     }
                 }
@@ -800,6 +812,9 @@
                             sendAuthRequest();
                             return;
                         }
+                        case PING: {
+                            return;
+                        }
                         default: break OUT;
                     }
                 }
@@ -873,6 +888,9 @@
                             protocolContext.receiveStreamData(streamIdentifier, input);
                             return;
                         }
+                        case PING: {
+                            return;
+                        }
                         default: break OUT;
                     }
                 }
@@ -905,5 +923,6 @@
         REQUEST,
         SERVICE_TERMINATE,
         STREAM_DATA,
+        PING,
     }
 }