private void setQueueTupleCounts ( final SchedulingStrategy schedulingStrategy )
{
if ( schedulingStrategy instanceof ScheduleWhenTuplesAvailable )
{
final ScheduleWhenTuplesAvailable ss = (ScheduleWhenTuplesAvailable) schedulingStrategy;
<BUG>for ( int portIndex = 0; portIndex < ss.getPortCount(); portIndex++ )
{
queue.ensureCapacity( portIndex, ss.getTupleCount( portIndex ) );
}</BUG>
queue.setTupleCounts( ss.getTupleCounts(), ss.getTupleAvailabilityByPort() );

private void setQueueTupleCounts ( final SchedulingStrategy schedulingStrategy )
{
if ( schedulingStrategy instanceof ScheduleWhenTuplesAvailable )
{
final ScheduleWhenTuplesAvailable ss = (ScheduleWhenTuplesAvailable) schedulingStrategy;
queue.setTupleCounts( ss.getTupleCounts(), ss.getTupleAvailabilityByPort() );
