Lines Matching refs:broker
126 ReplicationBroker broker =
138 ModifyMsg modMsg = receiveModifyMsg(broker);
145 receiveModifyMsg(broker);
149 broker.stop();
172 ReplicationBroker broker =
181 broker.publish(modMsg);
188 broker.stop();
206 ReplicationBroker broker =
222 // receive the message on the broker side.
223 ModifyMsg modMsg = receiveModifyMsg(broker);
255 broker.stop();
270 private ModifyMsg receiveModifyMsg(ReplicationBroker broker) throws SocketTimeoutException
272 ReplicationMsg msg = broker.receive();