aggregator-core/src/main/java/org/arrowhead/wp5/agg/impl/Aggregator.java
public void aggregateFlexOffers() {
		this.aggFlexOffers.clear();
		try {
			Collection<AggregatedFlexOffer> aggList = agg.Aggregate(
					this.aggParameters, getAllSimpleFlexOffers());
			/* Let's give local IDs to new aggregated flex-offers */
			if (aggList != null) {
				for (AggregatedFlexOffer af : aggList) {
					af.setId(Aggregator.afoCounter.incrementAndGet());
					this.aggFlexOffers.put(af.getId(), af);
				}
			}
		} catch (AggregationException e) {
			logger.error("Error aggregating flex-offers. Error: ", e);
		}
	}
/* An internal method for triggering flex-offer aggregation */
An internal method for triggering flex-offer aggregation
An internal method for triggering flex - offer aggregation
public void aggregateFlexOffers() {
		this.aggFlexOffers.clear();
		try {
			Collection<AggregatedFlexOffer> aggList = agg.Aggregate(
					this.aggParameters, getAllSimpleFlexOffers());
			/* Let's give local IDs to new aggregated flex-offers */
			if (aggList != null) {
				for (AggregatedFlexOffer af : aggList) {
					af.setId(Aggregator.afoCounter.incrementAndGet());
					this.aggFlexOffers.put(af.getId(), af);
				}
			}
		} catch (AggregationException e) {
			logger.error("Error aggregating flex-offers. Error: ", e);
		}
	}
public void aggregateFlexOffers ( ) { this . aggFlexOffers . clear ( ) ; try { Collection < AggregatedFlexOffer > aggList = agg . Aggregate ( this . aggParameters , getAllSimpleFlexOffers ( ) ) ; /* Let's give local IDs to new aggregated flex-offers */ if ( aggList != null ) { for ( AggregatedFlexOffer af : aggList ) { af . setId ( Aggregator . afoCounter . incrementAndGet ( ) ) ; this . aggFlexOffers . put ( af . getId ( ) , af ) ; } } } catch ( AggregationException e ) { logger . error ( "Error aggregating flex-offers. Error: " , e ) ; } }
An internal method for triggering flex-offer aggregation
An internal method for triggering flex - offer aggregation