Author: david.lloyd(a)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, } }