import org.springframework.messaging.simp.broker.BrokerAvailabilityEvent; //导入依赖的package包/类
@Override
public void onApplicationEvent(BrokerAvailabilityEvent event) {
	if (event.isBrokerAvailable()) {
		long delay = getRegistryExpirationPeriod() / 2;
		this.scheduledFuture = this.scheduler.scheduleWithFixedDelay(this.schedulerTask, delay);
	}
	else if (this.scheduledFuture != null ){
		this.scheduledFuture.cancel(true);
		this.scheduledFuture = null;
	}
}
 

import org.springframework.messaging.simp.broker.BrokerAvailabilityEvent; //导入依赖的package包/类
@Override
public void publishEvent(Object event) {
	logger.debug("Processing ApplicationEvent " + event);
	if (event instanceof BrokerAvailabilityEvent) {
		this.eventQueue.add((BrokerAvailabilityEvent) event);
	}
}
 

import org.springframework.messaging.simp.broker.BrokerAvailabilityEvent; //导入依赖的package包/类
private Runnable getUserRegistryTask() {
	BrokerAvailabilityEvent event = new BrokerAvailabilityEvent(true, this);
	this.handler.onApplicationEvent(event);

	ArgumentCaptor<? extends Runnable> captor = ArgumentCaptor.forClass(Runnable.class);
	verify(this.taskScheduler).scheduleWithFixedDelay(captor.capture(), eq(10000L));

	return captor.getValue();
}
 

import org.springframework.messaging.simp.broker.BrokerAvailabilityEvent; //导入依赖的package包/类
@Override
public void onApplicationEvent(BrokerAvailabilityEvent brokerAvailabilityEvent) {
    this.brokerAvailable.set(brokerAvailabilityEvent.isBrokerAvailable());
}
 

import org.springframework.messaging.simp.broker.BrokerAvailabilityEvent; //导入依赖的package包/类
@Override
public void onApplicationEvent(BrokerAvailabilityEvent event) {
    this.brokerAvailable.set(event.isBrokerAvailable());
}
 

import org.springframework.messaging.simp.broker.BrokerAvailabilityEvent; //导入依赖的package包/类
public void expectBrokerAvailabilityEvent(boolean isBrokerAvailable) throws InterruptedException {
	BrokerAvailabilityEvent event = this.eventQueue.poll(20000, TimeUnit.MILLISECONDS);
	assertNotNull("Times out waiting for BrokerAvailabilityEvent[" + isBrokerAvailable + "]", event);
	assertEquals(isBrokerAvailable, event.isBrokerAvailable());
}
 

import org.springframework.messaging.simp.broker.BrokerAvailabilityEvent; //导入依赖的package包/类
@Override
public void onApplicationEvent(BrokerAvailabilityEvent event) {
  logger.info("BrokerAvailabilityEvent: [{}]", event.toString());
}
 

import org.springframework.messaging.simp.broker.BrokerAvailabilityEvent; //导入依赖的package包/类
@Override
public void onApplicationEvent(BrokerAvailabilityEvent event) {
	this.brokerAvailable.set(event.isBrokerAvailable());
}
 

import org.springframework.messaging.simp.broker.BrokerAvailabilityEvent; //导入依赖的package包/类
@Override
public void onApplicationEvent(BrokerAvailabilityEvent event) {
    this.brokerAvailable = event.isBrokerAvailable();
}