I am using java 5 and I need to design a package.

the package contains -
Filter
Queue
Aggregator

the way the ddata flows is -
a filter rule is passed to the filter. the object is checked with this
expression. If the data is passed then the data is sent to a queue
from where the aggregator picks the object.

In the aggregator the grouping is done based on the rule. the the
aggregation of the columns happens based on the rule.
Can someone help me in making this a nice package using a design
pattern.