Package org.teiid.transport
Class SocketListener
- java.lang.Object
-
- org.teiid.transport.SocketListener
-
- All Implemented Interfaces:
ChannelListener.ChannelListenerFactory
- Direct Known Subclasses:
ODBCSocketListener
public class SocketListener extends Object implements ChannelListener.ChannelListenerFactory
Server-side class to listen for new connection requests and create a SocketClientConnection for each connection request.
-
-
Field Summary
Fields Modifier and Type Field Description protected SSLAwareChannelHandler
channelHandler
-
Constructor Summary
Constructors Constructor Description SocketListener(InetSocketAddress address, int inputBufferSize, int outputBufferSize, int maxWorkers, SSLConfiguration config, ClientServiceRegistryImpl csr, StorageManager storageManager)
SocketListener(InetSocketAddress address, SocketConfiguration config, ClientServiceRegistryImpl csr, StorageManager storageManager)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
configureChannelPipeline(io.netty.channel.ChannelPipeline pipeline, SSLConfiguration config, StorageManager storageManager)
protected SSLAwareChannelHandler
createChannelHandler()
ChannelListener
createChannelListener(ObjectChannel channel)
int
getMaxMessageSize()
int
getPort()
SocketListenerStats
getStats()
void
setMaxLobSize(long maxLobSize)
void
setMaxMessageSize(int maxMessageSize)
io.netty.util.concurrent.Future<?>
stop()
Stops theSocketListener
-
-
-
Field Detail
-
channelHandler
protected SSLAwareChannelHandler channelHandler
-
-
Constructor Detail
-
SocketListener
public SocketListener(InetSocketAddress address, SocketConfiguration config, ClientServiceRegistryImpl csr, StorageManager storageManager)
-
SocketListener
public SocketListener(InetSocketAddress address, int inputBufferSize, int outputBufferSize, int maxWorkers, SSLConfiguration config, ClientServiceRegistryImpl csr, StorageManager storageManager)
-
-
Method Detail
-
configureChannelPipeline
protected void configureChannelPipeline(io.netty.channel.ChannelPipeline pipeline, SSLConfiguration config, StorageManager storageManager) throws Exception
- Throws:
Exception
-
getPort
public int getPort()
-
stop
public io.netty.util.concurrent.Future<?> stop()
Stops theSocketListener
- Returns:
- a Future if the transport was started successfully that can notify of successfully killing all clients
-
getStats
public SocketListenerStats getStats()
-
createChannelHandler
protected SSLAwareChannelHandler createChannelHandler()
-
createChannelListener
public ChannelListener createChannelListener(ObjectChannel channel)
- Specified by:
createChannelListener
in interfaceChannelListener.ChannelListenerFactory
-
getMaxMessageSize
public int getMaxMessageSize()
-
setMaxMessageSize
public void setMaxMessageSize(int maxMessageSize)
-
setMaxLobSize
public void setMaxLobSize(long maxLobSize)
-
-