jobEater.start();
logApplier.start();
this.masterIp = masterIp;
this.masterPort = masterPort;
<BUG>masterConnection = new Connection( masterIp, masterPort );
while ( !masterConnection.connected() )
{
if ( masterConnection.connectionRefused() )
</BUG>
{

jobEater.start();
logApplier.start();
this.masterIp = masterIp;
this.masterPort = masterPort;
masterConnections = new Connection[xaDataSources.length];
for ( int i = 0; i < masterConnections.length; i++ )
{
masterConnections[i] = new Connection( masterIp, masterPort );
while ( !masterConnections[i].connected() )
{
if ( masterConnections[i].connectionRefused() )
{
