public class SocketListener extends Object implements ChannelListener.ChannelListenerFactory
Modifier and Type | Field and Description |
---|---|
protected SSLAwareChannelHandler |
channelHandler |
Constructor and 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) |
Modifier and Type | Method and 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 the
SocketListener |
protected SSLAwareChannelHandler channelHandler
public SocketListener(InetSocketAddress address, SocketConfiguration config, ClientServiceRegistryImpl csr, StorageManager storageManager)
public SocketListener(InetSocketAddress address, int inputBufferSize, int outputBufferSize, int maxWorkers, SSLConfiguration config, ClientServiceRegistryImpl csr, StorageManager storageManager)
port
- inputBufferSize
- outputBufferSize
- engine
- null if SSL is disabledbindaddress
- server
- protected void configureChannelPipeline(io.netty.channel.ChannelPipeline pipeline, SSLConfiguration config, StorageManager storageManager) throws Exception
Exception
public int getPort()
public io.netty.util.concurrent.Future<?> stop()
SocketListener
public SocketListenerStats getStats()
protected SSLAwareChannelHandler createChannelHandler()
public ChannelListener createChannelListener(ObjectChannel channel)
createChannelListener
in interface ChannelListener.ChannelListenerFactory
public int getMaxMessageSize()
public void setMaxMessageSize(int maxMessageSize)
public void setMaxLobSize(long maxLobSize)
Copyright © 2019. All rights reserved.