Package org.webpieces.asyncserver.impl

Class DefaultConnectionListener

java.lang.Object

org.webpieces.asyncserver.impl.DefaultConnectionListener

All Implemented Interfaces:

org.webpieces.nio.api.handlers.ConnectionListener

public class DefaultConnectionListener
extends java.lang.Object
implements org.webpieces.nio.api.handlers.ConnectionListener

Constructor Summary

Constructors

Constructor	Description
DefaultConnectionListener(java.lang.String id, ConnectedChannels channels, ProxyDataListener listener)

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.CompletableFuture<java.lang.Void>	closeChannels()
java.util.concurrent.CompletableFuture<org.webpieces.nio.api.handlers.DataListener>	connected(org.webpieces.nio.api.channels.Channel tcpChannel, boolean isReadyForWrites)
void	disableOverloadMode()
void	enableOverloadMode(java.nio.ByteBuffer overloadResponse)
void	failed(org.webpieces.nio.api.channels.RegisterableChannel channel, java.lang.Throwable e)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultConnectionListener

public DefaultConnectionListener(java.lang.String id,
                                 ConnectedChannels channels,
                                 ProxyDataListener listener)

Method Detail

connected

public java.util.concurrent.CompletableFuture<org.webpieces.nio.api.handlers.DataListener> connected(org.webpieces.nio.api.channels.Channel tcpChannel,
                                                                                                     boolean isReadyForWrites)

Specified by:

connected in interface org.webpieces.nio.api.handlers.ConnectionListener

failed

public void failed(org.webpieces.nio.api.channels.RegisterableChannel channel,
                   java.lang.Throwable e)

Specified by:

failed in interface org.webpieces.nio.api.handlers.ConnectionListener

enableOverloadMode

public void enableOverloadMode(java.nio.ByteBuffer overloadResponse)

disableOverloadMode

public void disableOverloadMode()

closeChannels

public java.util.concurrent.CompletableFuture<java.lang.Void> closeChannels()