KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > jboss > web > tomcat > tc6 > session > ClusteredSessionValve


1 /*
2 * JBoss, Home of Professional Open Source
3 * Copyright 2005, JBoss Inc., and individual contributors as indicated
4 * by the @authors tag. See the copyright.txt in the distribution for a
5 * full listing of individual contributors.
6 *
7 * This is free software; you can redistribute it and/or modify it
8 * under the terms of the GNU Lesser General Public License as
9 * published by the Free Software Foundation; either version 2.1 of
10 * the License, or (at your option) any later version.
11 *
12 * This software is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * Lesser General Public License for more details.
16 *
17 * You should have received a copy of the GNU Lesser General Public
18 * License along with this software; if not, write to the Free
19 * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
20 * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
21 */
22 package org.jboss.web.tomcat.tc6.session;
23
24 import java.io.IOException JavaDoc;
25 import java.util.Iterator JavaDoc;
26 import java.util.Map JavaDoc;
27
28 import javax.servlet.ServletException JavaDoc;
29
30 import org.apache.catalina.*;
31 import org.apache.catalina.connector.Request;
32 import org.apache.catalina.connector.Response;
33 import org.apache.catalina.util.LifecycleSupport;
34 import org.apache.catalina.valves.ValveBase;
35
36 /**
37  * This Valve detects all sessions that were used in a request. All sessions are given to a snapshot
38  * manager that handles the distribution of modified sessions.
39  * <p/>
40  * TOMCAT 4.1.12 UPDATE: Added findLifecycleListeners() to comply with the latest
41  * Lifecycle interface.
42  *
43  * @author Thomas Peuss <jboss@peuss.de>
44  * @author Brian Stansberry
45  * @version $Revision: 56542 $
46  */
47 public class ClusteredSessionValve extends ValveBase implements Lifecycle
48 {
49    // The info string for this Valve
50 private static final String JavaDoc info = "ClusteredSessionValve/1.0";
51
52    // Valve-lifecycle_ helper object
53 private LifecycleSupport support = new LifecycleSupport(this);
54
55    /**
56     * Create a new Valve.
57     */
58    public ClusteredSessionValve()
59    {
60       super();
61    }
62
63    /**
64     * Get information about this Valve.
65     */
66    public String JavaDoc getInfo()
67    {
68       return info;
69    }
70
71    /**
72     * Valve-chain handler method.
73     * This method gets called when the request goes through the Valve-chain. Our session replication mechanism replicates the
74     * session after request got through the servlet code.
75     *
76     * @param request The request object associated with this request.
77     * @param response The response object associated with this request.
78     */
79    public void invoke(Request request, Response response) throws IOException JavaDoc, ServletException JavaDoc
80    {
81       // Initialize the context and store the request and response objects
82 // for any clustering code that has no direct access to these objects
83 SessionReplicationContext.enterWebapp(request, response, true);
84       try
85       {
86          
87          
88          // let the servlet invocation go through
89 getNext().invoke(request, response);
90       }
91       finally // We replicate no matter what
92 {
93          // --> We are now after the servlet invocation
94 try
95          {
96             SessionReplicationContext ctx = SessionReplicationContext.exitWebapp();
97             
98             if (ctx.getSoleSnapshotManager() != null)
99             {
100                ctx.getSoleSnapshotManager().snapshot(ctx.getSoleSession());
101             }
102             else
103             {
104                // Cross-context request touched multiple sesssions;
105 // need to replicate them all
106 Map JavaDoc sessions = ctx.getCrossContextSessions();
107                if (sessions != null && sessions.size() > 0)
108                {
109                   for (Iterator JavaDoc iter = sessions.entrySet().iterator(); iter.hasNext();)
110                   {
111                      Map.Entry JavaDoc entry = (Map.Entry JavaDoc) iter.next();
112                      ((SnapshotManager) entry.getValue()).snapshot((ClusteredSession) entry.getKey());
113                   }
114                }
115             }
116          }
117          finally
118          {
119             SessionReplicationContext.finishCacheActivity();
120          }
121          
122       }
123    }
124
125    // Lifecylce-interface
126 public void addLifecycleListener(LifecycleListener listener)
127    {
128       support.addLifecycleListener(listener);
129    }
130
131    public void removeLifecycleListener(LifecycleListener listener)
132    {
133       support.removeLifecycleListener(listener);
134    }
135
136    public LifecycleListener[] findLifecycleListeners()
137    {
138       return support.findLifecycleListeners();
139    }
140
141    public void start() throws LifecycleException
142    {
143       support.fireLifecycleEvent(START_EVENT, this);
144    }
145
146    public void stop() throws LifecycleException
147    {
148       support.fireLifecycleEvent(STOP_EVENT, this);
149    }
150
151 }
152
Popular Tags