return this.broker;
}
public void pullUpdates()
{
try
<BUG>{
receive( broker.getMaster().first().pullUpdates( getSlaveContext( -1 ) ) );
}</BUG>
catch ( ZooKeeperException e )
{

return this.broker;
}
public void pullUpdates()
{
try
{
if ( masterServer == null )
{
receive( broker.getMaster().first().pullUpdates( getSlaveContext( -1 ) ) );
}
}
catch ( ZooKeeperException e )
{
