@Override
public void start() {
	synchronized (this.lifecycleMonitor) {
		if (logger.isInfoEnabled()) {
			logger.info("Starting...");
		}
		this.clientInboundChannel.subscribe(this);
		this.brokerChannel.subscribe(this);
		if (this.clientInboundChannel instanceof InterceptableChannel) {
			((InterceptableChannel) this.clientInboundChannel).addInterceptor(0, this.unsentDisconnectInterceptor);
		}
		startInternal();
		this.running = true;
		logger.info("Started.");
	}
}
 

@Override
public void stop() {
	synchronized (this.lifecycleMonitor) {
		if (logger.isInfoEnabled()) {
			logger.info("Stopping...");
		}
		stopInternal();
		this.clientInboundChannel.unsubscribe(this);
		this.brokerChannel.unsubscribe(this);
		if (this.clientInboundChannel instanceof InterceptableChannel) {
			((InterceptableChannel) this.clientInboundChannel).removeInterceptor(this.unsentDisconnectInterceptor);
		}
		this.running = false;
		logger.info("Stopped.");
	}
}
 

@Override
public void start() {
	synchronized (this.lifecycleMonitor) {
		logger.info("Starting...");
		this.clientInboundChannel.subscribe(this);
		this.brokerChannel.subscribe(this);
		if (this.clientInboundChannel instanceof InterceptableChannel) {
			((InterceptableChannel) this.clientInboundChannel).addInterceptor(0, this.unsentDisconnectInterceptor);
		}
		startInternal();
		this.running = true;
		logger.info("Started.");
	}
}
 

@Override
public void stop() {
	synchronized (this.lifecycleMonitor) {
		logger.info("Stopping...");
		stopInternal();
		this.clientInboundChannel.unsubscribe(this);
		this.brokerChannel.unsubscribe(this);
		if (this.clientInboundChannel instanceof InterceptableChannel) {
			((InterceptableChannel) this.clientInboundChannel).removeInterceptor(this.unsentDisconnectInterceptor);
		}
		this.running = false;
		logger.info("Stopped.");
	}
}
 

@Override
public void start() {
	synchronized (this.lifecycleMonitor) {
		logger.info("Starting...");
		this.clientInboundChannel.subscribe(this);
		this.brokerChannel.subscribe(this);
		if (this.clientInboundChannel instanceof InterceptableChannel) {
			((InterceptableChannel) this.clientInboundChannel).addInterceptor(0, this.unsentDisconnectInterceptor);
		}
		startInternal();
		this.running = true;
		logger.info("Started.");
	}
}
 

@Override
public void stop() {
	synchronized (this.lifecycleMonitor) {
		logger.info("Stopping...");
		stopInternal();
		this.clientInboundChannel.unsubscribe(this);
		this.brokerChannel.unsubscribe(this);
		if (this.clientInboundChannel instanceof InterceptableChannel) {
			((InterceptableChannel) this.clientInboundChannel).removeInterceptor(this.unsentDisconnectInterceptor);
		}
		this.running = false;
		logger.info("Stopped.");
	}
}