Lines Matching defs:broker2
106 private ReplicationBroker broker2;
635 broker2 = openReplicationSession(server2ID, replServer1, dsGenId + 1);
645 broker2.publish(createAddMsg());
673 stop(broker2, broker3);
674 broker2 = broker3 = null;
700 debugInfo("Create again broker2");
701 broker2 = openReplicationSession(server2ID, replServer1, dsGenId);
702 assertTrue(broker2.isConnected(), "Broker2 failed to connect to replication server");
721 ChangeStatusMsg csMsg = waitForSpecificMsg(broker2, ChangeStatusMsg.class);
765 assertNoMessageReceived(broker2, "broker2", "bad gen id");
770 broker2.publish(emsg);
789 broker2.signalStatusChange(ServerStatus.FULL_UPDATE_STATUS);
791 int receivedEntriesNb = receiveImport(broker2, server2ID, null);
792 debugInfo("broker2 has been initialized from DS with #entries=" + receivedEntriesNb);
795 broker2.stop();
796 broker2 = openReplicationSession(server2ID, replServer1, dsGenId);
820 msg = broker2.receive();
829 broker2.publish(emsg2);
945 debugInfo("Connecting broker2 to replServer3 with a good genId");
946 broker2 = openReplicationSession(server2ID, replServer3, genId);
949 debugInfo("Expecting that broker2 is not in bad gen id since it has a correct genId");
956 debugInfo("Expect all genIds to keep their value since broker2 is still connected.");
1031 stop(broker2, broker3);
1032 broker2 = broker3 = null;