src/main/java/com/amazonaws/services/kinesis/aggregators/app/DateQueryServlet.java [121:150]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            return;
        }

        String streamName = (String) request.getServletContext().getAttribute(
                AggregatorsConstants.STREAM_NAME_PARAM);
        AggregatorGroup aggGroup = (AggregatorGroup) request.getServletContext().getAttribute(
                AggregatorsBeanstalkApp.AGGREGATOR_GROUP_PARAM);

        if (aggGroup == null) {
            doError(response, "Aggregator Application Not Initialised");
            return;
        }

        // initialise the aggregator group onto shard 'none' for this operation
        // - it may already be initialised
        try {
            aggGroup.initialize("none");
        } catch (Exception e) {
            throw new ServletException(e);
        }

        // put the initialised aggregator group back into the context
        request.getServletContext().setAttribute(AggregatorsBeanstalkApp.AGGREGATOR_GROUP_PARAM,
                aggGroup);

        // acquire the correct aggregator by namespace
        for (StreamAggregator agg : aggGroup.getAggregators()) {
            if (agg.getNamespace().equals(namespace)) {
                // run the query
                try {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/amazonaws/services/kinesis/aggregators/app/ListAggregateKeysServlet.java [108:137]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            return;
        }

        String streamName = (String) request.getServletContext().getAttribute(
                AggregatorsConstants.STREAM_NAME_PARAM);
        AggregatorGroup aggGroup = (AggregatorGroup) request.getServletContext().getAttribute(
                AggregatorsBeanstalkApp.AGGREGATOR_GROUP_PARAM);

        if (aggGroup == null) {
            doError(response, "Aggregator Application Not Initialised");
            return;
        }

        // initialise the aggregator group onto shard 'none' for this operation
        // - it may already be initialised
        try {
            aggGroup.initialize("none");
        } catch (Exception e) {
            throw new ServletException(e);
        }

        // put the initialised aggregator group back into the context
        request.getServletContext().setAttribute(AggregatorsBeanstalkApp.AGGREGATOR_GROUP_PARAM,
                aggGroup);

        // acquire the correct aggregator by namespace
        for (StreamAggregator agg : aggGroup.getAggregators()) {
            if (agg.getNamespace().equals(namespace)) {
                // run the query
                try {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -