Author: remy.maucherat(a)jboss.com Date: 2008-05-28 21:37:56 -0400 (Wed, 28 May 2008) New Revision: 645 Modified: trunk/java/org/jboss/web/cluster/ClusterListener.java Log: - Add the various config parameters. Modified: trunk/java/org/jboss/web/cluster/ClusterListener.java =================================================================== --- trunk/java/org/jboss/web/cluster/ClusterListener.java 2008-05-28 14:45:29 UTC (rev 644) +++ trunk/java/org/jboss/web/cluster/ClusterListener.java 2008-05-29 01:37:56 UTC (rev 645) @@ -141,6 +141,102 @@ public void setSocketTimeout(int socketTimeout) { this.socketTimeout = socketTimeout; } + /** + * Domain parameter, which allows tying a jvmRoute to a particular domain. + */ + protected String domain = null; + public String getDomain() { return domain; } + public void setDomain(String domain) { this.domain = domain; } + + + /** + * Allows controlling flushing of packets. + */ + protected boolean flushPackets = false; + public boolean getFlushPackets() { return flushPackets; } + public void setFlushPackets(boolean flushPackets) { this.flushPackets = flushPackets; } + + + /** + * Time to wait before flushing packets. + */ + protected int flushWait = -1; + public int getFlushWait() { return flushWait; } + public void setFlushWait(int flushWait) { this.flushWait = flushWait; } + + + /** + * Time to wait for a pong answer to a ping. + */ + protected int ping = -1; + public int getPing() { return ping; } + public void setPing(int ping) { this.ping = ping; } + + + /** + * Soft maximum inactive connection count. + */ + protected int smax = -1; + public int getSmax() { return smax; } + public void setSmax(int smax) { this.smax = smax; } + + + /** + * Maximum time on seconds for idle connections above smax. + */ + protected int ttl = -1; + public int getTtl() { return ttl; } + public void setTtl(int ttl) { this.ttl = ttl; } + + + /** + * Name of the balancer. + */ + protected String balancer = null; + public String getBalancer() { return balancer; } + public void setBalancer(String balancer) { this.balancer = balancer; } + + + /** + * Enables sticky sessions. + */ + protected boolean stickySession = true; + public boolean getStickySession() { return stickySession; } + public void setStickySession(boolean stickySession) { this.stickySession = stickySession; } + + + /** + * Remove session when the request cannot be routed to the right node. + */ + protected boolean stickySessionRemove = false; + public boolean getStickySessionRemove() { return stickySessionRemove; } + public void setStickySessionRemove(boolean stickySessionRemove) { this.stickySessionRemove = stickySessionRemove; } + + + /** + * Return an error when the request cannot be routed to the right node. + */ + protected boolean stickySessionForce = true; + public boolean getStickySessionForce() { return stickySessionForce; } + public void setStickySessionForce(boolean stickySessionForce) { this.stickySessionForce = stickySessionForce; } + + + /** + * Timeout to wait for an available worker (default is no wait). + */ + protected int workerTimeout = -1; + public int getWorkerTimeout() { return workerTimeout; } + public void setWorkerTimeout(int workerTimeout) { this.workerTimeout = workerTimeout; } + + + /** + * Maximum number of attempts to send the request to the backend server. + */ + protected int maxAttempts = -1; + public int getMaxAttempts() { return maxAttempts; } + public void setMaxAttempts(int maxAttempts) { this.maxAttempts = maxAttempts; } + + // ---------------------------------------------- LifecycleListener Methods @@ -430,6 +526,50 @@ parameters.put("Type", "http"); } + // Other configuration parameters + if (domain != null) { + parameters.put("Domain", domain); + } + if (flushPackets) { + parameters.put("flushpackets", "On"); + } + if (flushWait != -1) { + parameters.put("flushwait", "" + flushWait); + } + if (ping != -1) { + parameters.put("ping", "" + ping); + } + if (smax != -1) { + parameters.put("smax", "" + smax); + } + if (ttl != -1) { + parameters.put("ttl", "" + ttl); + } + if (balancer != null) { + parameters.put("Balancer", balancer); + } + if (!stickySession) { + parameters.put("StickySession", "No"); + } + if (org.apache.catalina.Globals.SESSION_COOKIE_NAME.equals("JSESSIONID")) { + parameters.put("StickySessionCookie", org.apache.catalina.Globals.SESSION_COOKIE_NAME); + } + if (org.apache.catalina.Globals.SESSION_PARAMETER_NAME.equals("jsessionid")) { + parameters.put("StickySessionPath", org.apache.catalina.Globals.SESSION_PARAMETER_NAME); + } + if (stickySessionRemove) { + parameters.put("StickSessionRemove", "Yes"); + } + if (!stickySessionForce) { + parameters.put("StickySessionForce", "No"); + } + if (workerTimeout != -1) { + parameters.put("Timeout", "" + workerTimeout); + } + if (maxAttempts != -1) { + parameters.put("Maxattempts", "" + maxAttempts); + } + // Send CONFIG request sendRequest("CONFIG", false, parameters); }