Lines Matching refs:broker
227 protected ReplicationBroker broker;
348 * An object used to protect the initialization of the underlying broker
482 broker.signalStatusChange(status);
619 return broker.getReplicaInfos();
651 return broker.getReplicaStates();
662 return broker.getRsInfos();
675 return broker.getRsServerId();
744 msg = broker.receive(true, true, false);
773 This must be done while we are still holding the broker lock
855 by the broker lock so that we keep receiving update
860 broker.receive() method.
873 && broker.getRsGroupId() == getGroupId()
1493 ieCtx.initNumLostConnections = broker.getNumLostConnections();
1501 broker.publish(initTargetMsg);
1518 broker.publish(
1530 logger.trace("[IE] In " + broker.getReplicationMonitorInstanceName()
1531 + " export ends with connected=" + broker.isConnected()
1544 So we MUST rely on the test broker.isConnected()
1548 if (!broker.isConnected())
1557 while (!broker.shuttingDown()
1558 && !broker.isConnected()
1567 && broker.isConnected()
1587 broker.publish(new ErrorMsg(
1687 while (!done && waitResultAttempt < 1200 && !broker.shuttingDown());
1779 while (!done && !broker.shuttingDown()); // infinite wait
1869 // re-connection done transparently by the broker because of a better
1873 msg = broker.receive(false, false, true);
1878 + broker.getReplicationMonitorInstanceName()
1884 if (broker.shuttingDown())
1894 .get(broker.getReplicationServer())));
1922 broker.publish(amsg, false);
1926 + broker.getReplicationMonitorInstanceName()
2042 while (!broker.shuttingDown())
2085 if (broker.hasConnectionError()
2086 || broker.getNumLostConnections() != ieCtx.initNumLostConnections)
2090 ERR_INIT_RS_DISCONNECTION_DURING_EXPORT.get(broker.getRsServerId()));
2111 boolean sent = broker.publish(entryMessage, false);
2115 || broker.hasConnectionError()
2116 || broker.getNumLostConnections() != ieCtx.initNumLostConnections)
2120 ERR_INIT_RS_DISCONNECTION_DURING_EXPORT.get(broker.getRsServerId()));
2169 LocalizableMessage errMsg = !broker.isConnected()
2195 broker.publish(ieCtx.initReqMsgSent);
2291 + " connected=" + broker.isConnected());
2302 broker.reStart(false);
2305 && broker.isConnected()
2328 broker.publish(ieCtx.initReqMsgSent);
2356 + " connected=" + broker.isConnected()
2363 if (broker.isConnected() && ieCtx.getException() != null)
2368 broker.publish(errorMsg);
2372 Particularly, broker.restart() after import success must be done
2415 broker.signalStatusChange(status);
2571 broker.publish(genIdMessage);
2602 if (broker != null)
2604 return broker.getMaxRcvWindow();
2616 if (broker != null)
2618 return broker.getCurrentRcvWindow();
2630 if (broker != null)
2632 return broker.getMaxSendWindow();
2644 if (broker != null)
2646 return broker.getCurrentSendWindow();
2657 if (broker != null)
2659 return broker.getNumLostConnections();
2670 return broker != null && broker.isSessionEncrypted();
2680 return broker != null && broker.isConnected();
2685 * A Connection error happens when the broker could not be created
2686 * or when the broker could not find any ReplicationServer to connect to.
2692 return broker == null || broker.hasConnectionError();
2704 if (broker != null)
2706 return broker.getReplicationServer();
2922 if (broker == null)
2924 // create the broker object used to publish and receive changes
2925 broker = new ReplicationBroker(
2927 broker.start();
3011 Stop the broker first in order to prevent the listener from
3014 if (broker != null)
3016 broker.stop();
3065 broker.start();
3078 if (broker != null && broker.changeConfig(config))
3098 if (attrsModified && broker != null)
3181 broker.updateWindowAfterReplay();
3189 && broker.getProtocolVersion() >= ProtocolVersion.REPLICATION_PROTOCOL_V2)
3193 if (broker.getRsGroupId() == getGroupId())
3205 broker.publish(ackMsg);
3274 return isAssured() && broker.getRsGroupId() == getGroupId();
3357 broker.getRsServerId());
3363 broker.getRsServerId());
3389 broker.publish(msg);
3460 final ReplicationBroker tmp = broker;