1/*2 * Licensed to the Apache Software Foundation (ASF) under one or more3 * contributor license agreements. See the NOTICE file distributed with4 * this work for additional information regarding copyright ownership.5 * The ASF licenses this file to You under the Apache License, Version 2.06 * (the "License"); you may not use this file except in compliance with7 * the License. You may obtain a copy of the License at8 * 9 * http://www.apache.org/licenses/LICENSE-2.010 * 11 * Unless required by applicable law or agreed to in writing, software12 * distributed under the License is distributed on an "AS IS" BASIS,13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.14 * See the License for the specific language governing permissions and15 * limitations under the License.16 */1718packageorg.apache.jetspeed.aggregator;
1920import org.apache.jetspeed.pipeline.PipelineException;
21import org.apache.jetspeed.pipeline.valve.AbstractValve;
22import org.apache.jetspeed.pipeline.valve.ValveContext;
23import org.apache.jetspeed.request.RequestContext;
2425/***26 * Invokes the aggregator service in the request pipeline27 *28 * @author <a href="mailto:david@bluesunrise.com">David Sean Taylor</a>29 * @version $Id: AggregatorValve.java 517124 2007-03-12 08:10:25Z ate $30 */31publicclassAggregatorValve32extendsAbstractValve33 {
34private Aggregator aggregator;
3536publicAggregatorValve(Aggregator aggregator)
37 {
38this.aggregator = aggregator;
39 }
4041publicvoid invoke( RequestContext request, ValveContext context )
42 throws PipelineException
43 {
44try45 {
46 aggregator.build(request);
47 }
48catch (Exception e)
49 {
50thrownew PipelineException(e.toString(), e);
51 }
52// Pass control to the next Valve in the Pipeline53 context.invokeNext( request );
54 }
5556public String toString()
57 {
58return"AggregatorValve";
59 }
60 }