public class NioSctpServerChannel extends io.netty.channel.nio.AbstractNioMessageChannel implements SctpServerChannel
SctpServerChannel
implementation which use non-blocking mode to accept new
connections and create the NioSctpChannel
for them.
Be aware that not all operations systems support SCTP. Please refer to the documentation of your operation system,
to understand what you need to do to use it. Also this feature is only supported on Java 7+.io.netty.channel.nio.AbstractNioChannel.AbstractNioUnsafe, io.netty.channel.nio.AbstractNioChannel.NioUnsafe
Constructor and Description |
---|
NioSctpServerChannel()
Create a new instance
|
Modifier and Type | Method and Description |
---|---|
Set<InetSocketAddress> |
allLocalAddresses()
Return all local addresses of the SCTP server channel.
|
io.netty.channel.ChannelFuture |
bindAddress(InetAddress localAddress)
Bind a address to the already bound channel to enable multi-homing.
|
io.netty.channel.ChannelFuture |
bindAddress(InetAddress localAddress,
io.netty.channel.ChannelPromise promise)
Bind a address to the already bound channel to enable multi-homing.
|
SctpServerChannelConfig |
config()
Returns the
SctpServerChannelConfig configuration of the channel. |
protected void |
doBind(SocketAddress localAddress) |
protected void |
doClose() |
protected boolean |
doConnect(SocketAddress remoteAddress,
SocketAddress localAddress) |
protected void |
doDisconnect() |
protected void |
doFinishConnect() |
protected int |
doReadMessages(List<Object> buf) |
protected boolean |
doWriteMessage(Object msg,
io.netty.channel.ChannelOutboundBuffer in) |
protected Object |
filterOutboundMessage(Object msg) |
boolean |
isActive() |
protected SctpServerChannel |
javaChannel() |
InetSocketAddress |
localAddress()
Return the (primary) local address of the SCTP server channel.
|
protected SocketAddress |
localAddress0() |
io.netty.channel.ChannelMetadata |
metadata() |
InetSocketAddress |
remoteAddress() |
protected SocketAddress |
remoteAddress0() |
io.netty.channel.ChannelFuture |
unbindAddress(InetAddress localAddress)
Unbind the address from channel's multi-homing address list.
|
io.netty.channel.ChannelFuture |
unbindAddress(InetAddress localAddress,
io.netty.channel.ChannelPromise promise)
Unbind the address from channel's multi-homing address list.
|
closeOnReadError, continueOnWriteError, continueReading, doBeginRead, doWrite, newUnsafe
clearReadPending, doDeregister, doRegister, eventLoop, isCompatible, isOpen, isReadPending, newDirectBuffer, newDirectBuffer, selectionKey, setReadPending, unsafe
alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doShutdownOutput, equals, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, maxMessagesPerWrite, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, toString, validateFileRegion, voidPromise, write, write, writeAndFlush, writeAndFlush
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isOpen, isRegistered, isWritable, parent, pipeline, read, unsafe
bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush
compareTo
public io.netty.channel.ChannelMetadata metadata()
metadata
in interface io.netty.channel.Channel
public Set<InetSocketAddress> allLocalAddresses()
SctpServerChannel
allLocalAddresses
in interface SctpServerChannel
public SctpServerChannelConfig config()
SctpServerChannel
SctpServerChannelConfig
configuration of the channel.config
in interface io.netty.channel.Channel
config
in interface SctpServerChannel
public boolean isActive()
isActive
in interface io.netty.channel.Channel
public InetSocketAddress remoteAddress()
remoteAddress
in interface io.netty.channel.Channel
remoteAddress
in class io.netty.channel.AbstractChannel
public InetSocketAddress localAddress()
SctpServerChannel
localAddress
in interface io.netty.channel.Channel
localAddress
in interface SctpServerChannel
localAddress
in class io.netty.channel.AbstractChannel
protected SctpServerChannel javaChannel()
javaChannel
in class io.netty.channel.nio.AbstractNioChannel
protected SocketAddress localAddress0()
localAddress0
in class io.netty.channel.AbstractChannel
protected void doBind(SocketAddress localAddress) throws Exception
doBind
in class io.netty.channel.AbstractChannel
Exception
protected void doClose() throws Exception
doClose
in class io.netty.channel.nio.AbstractNioChannel
Exception
protected int doReadMessages(List<Object> buf) throws Exception
doReadMessages
in class io.netty.channel.nio.AbstractNioMessageChannel
Exception
public io.netty.channel.ChannelFuture bindAddress(InetAddress localAddress)
SctpServerChannel
bindAddress
in interface SctpServerChannel
public io.netty.channel.ChannelFuture bindAddress(InetAddress localAddress, io.netty.channel.ChannelPromise promise)
SctpServerChannel
ChannelPromise
and return a ChannelFuture
bindAddress
in interface SctpServerChannel
public io.netty.channel.ChannelFuture unbindAddress(InetAddress localAddress)
SctpServerChannel
unbindAddress
in interface SctpServerChannel
public io.netty.channel.ChannelFuture unbindAddress(InetAddress localAddress, io.netty.channel.ChannelPromise promise)
SctpServerChannel
ChannelPromise
and return a ChannelFuture
unbindAddress
in interface SctpServerChannel
protected boolean doConnect(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception
doConnect
in class io.netty.channel.nio.AbstractNioChannel
Exception
protected void doFinishConnect() throws Exception
doFinishConnect
in class io.netty.channel.nio.AbstractNioChannel
Exception
protected SocketAddress remoteAddress0()
remoteAddress0
in class io.netty.channel.AbstractChannel
protected void doDisconnect() throws Exception
doDisconnect
in class io.netty.channel.AbstractChannel
Exception
protected boolean doWriteMessage(Object msg, io.netty.channel.ChannelOutboundBuffer in) throws Exception
doWriteMessage
in class io.netty.channel.nio.AbstractNioMessageChannel
Exception
Copyright © 2008–2021 The Netty Project. All rights reserved.