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

Java源码示例：org.springframework.messaging.tcp.FixedIntervalReconnectStrategy

示例1
@Override
protected void startInternal() {
	if (this.tcpClient == null) {
		this.tcpClient = initTcpClient();
	}

	if (logger.isInfoEnabled()) {
		logger.info("Starting \"system\" session, " + toString());
	}

	StompHeaderAccessor accessor = StompHeaderAccessor.create(StompCommand.CONNECT);
	accessor.setAcceptVersion("1.1,1.2");
	accessor.setLogin(this.systemLogin);
	accessor.setPasscode(this.systemPasscode);
	accessor.setHeartbeat(this.systemHeartbeatSendInterval, this.systemHeartbeatReceiveInterval);
	String virtualHost = getVirtualHost();
	if (virtualHost != null) {
		accessor.setHost(virtualHost);
	}
	accessor.setSessionId(SYSTEM_SESSION_ID);
	if (logger.isDebugEnabled()) {
		logger.debug("Forwarding " + accessor.getShortLogMessage(EMPTY_PAYLOAD));
	}

	SystemStompConnectionHandler handler = new SystemStompConnectionHandler(accessor);
	this.connectionHandlers.put(handler.getSessionId(), handler);

	this.stats.incrementConnectCount();
	this.tcpClient.connect(handler, new FixedIntervalReconnectStrategy(5000));
}
示例2
@Override
protected void startInternal() {
	if (this.tcpClient == null) {
		this.tcpClient = initTcpClient();
	}

	if (logger.isInfoEnabled()) {
		logger.info("Starting \"system\" session, " + toString());
	}

	StompHeaderAccessor accessor = StompHeaderAccessor.create(StompCommand.CONNECT);
	accessor.setAcceptVersion("1.1,1.2");
	accessor.setLogin(this.systemLogin);
	accessor.setPasscode(this.systemPasscode);
	accessor.setHeartbeat(this.systemHeartbeatSendInterval, this.systemHeartbeatReceiveInterval);
	String virtualHost = getVirtualHost();
	if (virtualHost != null) {
		accessor.setHost(virtualHost);
	}
	accessor.setSessionId(SYSTEM_SESSION_ID);
	if (logger.isDebugEnabled()) {
		logger.debug("Forwarding " + accessor.getShortLogMessage(EMPTY_PAYLOAD));
	}

	SystemStompConnectionHandler handler = new SystemStompConnectionHandler(accessor);
	this.connectionHandlers.put(handler.getSessionId(), handler);

	this.stats.incrementConnectCount();
	this.tcpClient.connect(handler, new FixedIntervalReconnectStrategy(5000));
}
示例3
@Override
protected void startInternal() {
	if (this.tcpClient == null) {
		StompDecoder decoder = new StompDecoder();
		decoder.setHeaderInitializer(getHeaderInitializer());
		Reactor2StompCodec codec = new Reactor2StompCodec(new StompEncoder(), decoder);
		this.tcpClient = new StompTcpClientFactory().create(this.relayHost, this.relayPort, codec);
	}

	if (logger.isInfoEnabled()) {
		logger.info("Connecting \"system\" session to " + this.relayHost + ":" + this.relayPort);
	}

	StompHeaderAccessor accessor = StompHeaderAccessor.create(StompCommand.CONNECT);
	accessor.setAcceptVersion("1.1,1.2");
	accessor.setLogin(this.systemLogin);
	accessor.setPasscode(this.systemPasscode);
	accessor.setHeartbeat(this.systemHeartbeatSendInterval, this.systemHeartbeatReceiveInterval);
	accessor.setHost(getVirtualHost());
	accessor.setSessionId(SYSTEM_SESSION_ID);
	if (logger.isDebugEnabled()) {
		logger.debug("Forwarding " + accessor.getShortLogMessage(EMPTY_PAYLOAD));
	}

	SystemStompConnectionHandler handler = new SystemStompConnectionHandler(accessor);
	this.connectionHandlers.put(handler.getSessionId(), handler);

	this.stats.incrementConnectCount();
	this.tcpClient.connect(handler, new FixedIntervalReconnectStrategy(5000));
}