@Test( expected = IllegalArgumentException.class ) public void shouldNotAddConnectionWithInvalidTargetPort () { builder.connect( "op1", "op2", -1 ); }
public FlowDefBuilder connect ( final String sourceOperatorId, final String destinationOperatorId ) { return connect( sourceOperatorId, DEFAULT_PORT_INDEX, destinationOperatorId, DEFAULT_PORT_INDEX ); }
FlowDefBuilder { public FlowDefBuilder connect ( final String sourceOperatorId, final String destinationOperatorId ) { return connect( sourceOperatorId, DEFAULT_PORT_INDEX, destinationOperatorId, DEFAULT_PORT_INDEX ); } }
FlowDefBuilder { public FlowDefBuilder connect ( final String sourceOperatorId, final String destinationOperatorId ) { return connect( sourceOperatorId, DEFAULT_PORT_INDEX, destinationOperatorId, DEFAULT_PORT_INDEX ); }  }
FlowDefBuilder { public FlowDefBuilder connect ( final String sourceOperatorId, final String destinationOperatorId ) { return connect( sourceOperatorId, DEFAULT_PORT_INDEX, destinationOperatorId, DEFAULT_PORT_INDEX ); }  FlowDef build(); FlowDefBuilder add( final OperatorDefBuilder operatorDefBuilder ); FlowDefBuilder add( final OperatorDef operatorDef ); FlowDefBuilder connect( final String sourceOperatorId, final String destinationOperatorId ); FlowDefBuilder connect( final String sourceOperatorId, int sourcePort, final String destinationOperatorId ); FlowDefBuilder connect( final String sourceOperatorId, final String destinationOperatorId, final int destinationPort ); FlowDefBuilder connect( final String sourceOperatorId,
                                    final int sourcePort,
                                    final String destinationOperatorId,
                                    final int destinationPort ); }
FlowDefBuilder { public FlowDefBuilder connect ( final String sourceOperatorId, final String destinationOperatorId ) { return connect( sourceOperatorId, DEFAULT_PORT_INDEX, destinationOperatorId, DEFAULT_PORT_INDEX ); }  FlowDef build(); FlowDefBuilder add( final OperatorDefBuilder operatorDefBuilder ); FlowDefBuilder add( final OperatorDef operatorDef ); FlowDefBuilder connect( final String sourceOperatorId, final String destinationOperatorId ); FlowDefBuilder connect( final String sourceOperatorId, int sourcePort, final String destinationOperatorId ); FlowDefBuilder connect( final String sourceOperatorId, final String destinationOperatorId, final int destinationPort ); FlowDefBuilder connect( final String sourceOperatorId,
                                    final int sourcePort,
                                    final String destinationOperatorId,
                                    final int destinationPort );  }