Lines Matching defs:BrokerReader
429 BrokerReader br3 = null;
430 BrokerReader br2 = null;
453 br3 = new BrokerReader(ds3, DS3_ID);
524 br2 = new BrokerReader(ds2, DS2_ID);
578 BrokerReader br = null;
595 br = new BrokerReader(ds2, DS2_ID);
638 br = new BrokerReader(ds2, DS2_ID);
672 br = new BrokerReader(ds2, DS2_ID);
715 br = new BrokerReader(ds2, DS2_ID);
754 br = new BrokerReader(ds2, DS2_ID);
786 br = new BrokerReader(ds2, DS2_ID);
898 private BrokerReader reader = null;
927 reader = new BrokerReader(rb, serverId);
1040 private BrokerReader reader = null;
1065 reader = new BrokerReader(rb, serverId);
1307 private class BrokerReader extends Thread
1315 public BrokerReader(ReplicationBroker rb, int serverId)
1317 super("BrokerReader for broker " + serverId);