src/main/java/com/nhncorp/mods/socket/io/impl/Manager.java
public void onOpen(final String sessionId) {
		open.put(sessionId, true);
		if (this.closed(sessionId) != null) {
			vertx.eventBus().unregisterHandler("dispatch:" + sessionId, new Handler<Message>() {
				@Override
				public void handle(Message event) {
					Transport transport = transports.get(sessionId);
					List<Buffer> buffers = closed.get(sessionId);
					if (buffers != null && buffers.size() > 0 && transport != null) {
						if (transport.isOpen()) {
							transport.payload(buffers);
							closed.remove(sessionId);
						}
					}
				}
			});
		}

		Transport transport = this.transport(sessionId);
		if (transport != null) {
			transport.discard();
			this.transports.remove(sessionId);
		}
	}
/**
	 * Called when a client opens a request in a different node.
	 *
	 * @see "Manager.prototype.onOpen"
	 * @param sessionId
	 */
Called when a client opens a request in a different node.
Called when a client opens a request in a different node .
public void onOpen(final String sessionId) {
		open.put(sessionId, true);
		if (this.closed(sessionId) != null) {
			vertx.eventBus().unregisterHandler("dispatch:" + sessionId, new Handler<Message>() {
				@Override
				public void handle(Message event) {
					Transport transport = transports.get(sessionId);
					List<Buffer> buffers = closed.get(sessionId);
					if (buffers != null && buffers.size() > 0 && transport != null) {
						if (transport.isOpen()) {
							transport.payload(buffers);
							closed.remove(sessionId);
						}
					}
				}
			});
		}
		Transport transport = this.transport(sessionId);
		if (transport != null) {
			transport.discard();
			this.transports.remove(sessionId);
		}
	}
public void onOpen ( final String sessionId ) { open . put ( sessionId , true ) ; if ( this . closed ( sessionId ) != null ) { vertx . eventBus ( ) . unregisterHandler ( "dispatch:" + sessionId , new Handler < Message > ( ) { @ Override public void handle ( Message event ) { Transport transport = transports . get ( sessionId ) ; List < Buffer > buffers = closed . get ( sessionId ) ; if ( buffers != null && buffers . size ( ) > 0 && transport != null ) { if ( transport . isOpen ( ) ) { transport . payload ( buffers ) ; closed . remove ( sessionId ) ; } } } } ) ; } Transport transport = this . transport ( sessionId ) ; if ( transport != null ) { transport . discard ( ) ; this . transports . remove ( sessionId ) ; } }
Called when a client opens a request in a different node.
Called when a client opens a request in a different node .