源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：org.springframework.messaging.support.InterceptableChannel

示例1
@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.");
	}
}
示例2
@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.");
	}
}
示例3
@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.");
	}
}
示例4
@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.");
	}
}
示例5
@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.");
	}
}
示例6
@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.");
	}
}