Package io.netty.channel.udt.nio
Class NioUdtMessageConnectorChannel
java.lang.Object
io.netty.util.DefaultAttributeMap
io.netty.channel.AbstractChannel
io.netty.channel.nio.AbstractNioChannel
io.netty.channel.nio.AbstractNioMessageChannel
io.netty.channel.udt.nio.NioUdtMessageConnectorChannel
- All Implemented Interfaces:
Channel,ChannelOutboundInvoker,UdtChannel,AttributeMap,Comparable<Channel>
- Direct Known Subclasses:
NioUdtMessageRendezvousChannel
@Deprecated
public class NioUdtMessageConnectorChannel
extends AbstractNioMessageChannel
implements UdtChannel
Deprecated.
The UDT transport is no longer maintained and will be removed.
Message Connector for UDT Datagrams.
Note: send/receive must use UdtMessage in the pipeline
-
Nested Class Summary
Nested classes/interfaces inherited from class io.netty.channel.nio.AbstractNioChannel
AbstractNioChannel.AbstractNioUnsafe, AbstractNioChannel.NioUnsafeNested classes/interfaces inherited from class io.netty.channel.AbstractChannel
AbstractChannel.AbstractUnsafeNested classes/interfaces inherited from interface io.netty.channel.Channel
Channel.Unsafe -
Field Summary
Fields inherited from class io.netty.channel.nio.AbstractNioChannel
readInterestOp, readOps -
Constructor Summary
ConstructorsConstructorDescriptionDeprecated.NioUdtMessageConnectorChannel(com.barchart.udt.nio.SocketChannelUDT channelUDT) Deprecated.NioUdtMessageConnectorChannel(com.barchart.udt.TypeUDT type) Deprecated.NioUdtMessageConnectorChannel(Channel parent, com.barchart.udt.nio.SocketChannelUDT channelUDT) Deprecated. -
Method Summary
Modifier and TypeMethodDescriptionconfig()Deprecated.Returns theUdtChannelConfigof the channel.protected voiddoBind(SocketAddress localAddress) Deprecated.Bind theChannelto theSocketAddressprotected voiddoClose()Deprecated.Close theChannelprotected booleandoConnect(SocketAddress remoteAddress, SocketAddress localAddress) Deprecated.Connect to the remote peerprotected voidDeprecated.Disconnect thisChannelfrom its remote peerprotected voidDeprecated.Finish the connectprotected intdoReadMessages(List<Object> buf) Deprecated.Read messages into the given array and return the amount which was read.protected booleandoWriteMessage(Object msg, ChannelOutboundBuffer in) Deprecated.Write a message to the underlyingChannel.booleanisActive()Deprecated.Returntrueif theChannelis active and so connected.protected com.barchart.udt.nio.SocketChannelUDTDeprecated.Deprecated.Returns the local address where this channel is bound to.protected SocketAddressDeprecated.Returns theSocketAddresswhich is bound locally.metadata()Deprecated.Deprecated.Returns the remote address where this channel is connected to.protected SocketAddressDeprecated.Return theSocketAddresswhich theChannelis connected to.Methods inherited from class io.netty.channel.nio.AbstractNioMessageChannel
closeOnReadError, continueOnWriteError, continueReading, doBeginRead, doWrite, newUnsafeMethods inherited from class io.netty.channel.nio.AbstractNioChannel
addAndSubmit, clearReadPending, doDeregister, doRegister, isCompatible, isOpen, isReadPending, newDirectBuffer, newDirectBuffer, registration, removeAndSubmit, selectionKey, setReadPending, unsafeMethods inherited from class io.netty.channel.AbstractChannel
closeFuture, compareTo, doRegister, doShutdownOutput, equals, eventLoop, filterOutboundMessage, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, maxMessagesPerWrite, newChannelPipeline, newId, parent, pipeline, toString, validateFileRegion, voidPromiseMethods inherited from class io.netty.util.DefaultAttributeMap
attr, hasAttrMethods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, waitMethods inherited from interface io.netty.util.AttributeMap
attr, hasAttrMethods inherited from interface io.netty.channel.Channel
alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, eventLoop, flush, getOption, id, isOpen, isRegistered, isWritable, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, setOption, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlushMethods inherited from interface java.lang.Comparable
compareTo
-
Constructor Details
-
NioUdtMessageConnectorChannel
public NioUdtMessageConnectorChannel()Deprecated. -
NioUdtMessageConnectorChannel
public NioUdtMessageConnectorChannel(Channel parent, com.barchart.udt.nio.SocketChannelUDT channelUDT) Deprecated. -
NioUdtMessageConnectorChannel
public NioUdtMessageConnectorChannel(com.barchart.udt.nio.SocketChannelUDT channelUDT) Deprecated. -
NioUdtMessageConnectorChannel
public NioUdtMessageConnectorChannel(com.barchart.udt.TypeUDT type) Deprecated.
-
-
Method Details
-
config
Deprecated.Description copied from interface:UdtChannelReturns theUdtChannelConfigof the channel.- Specified by:
configin interfaceChannel- Specified by:
configin interfaceUdtChannel
-
doBind
Deprecated.Description copied from class:AbstractChannelBind theChannelto theSocketAddress- Specified by:
doBindin classAbstractChannel- Throws:
Exception
-
doClose
Deprecated.Description copied from class:AbstractChannelClose theChannel- Overrides:
doClosein classAbstractNioChannel- Throws:
Exception
-
doConnect
protected boolean doConnect(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception Deprecated.Description copied from class:AbstractNioChannelConnect to the remote peer- Specified by:
doConnectin classAbstractNioChannel- Throws:
Exception
-
doDisconnect
Deprecated.Description copied from class:AbstractChannelDisconnect thisChannelfrom its remote peer- Specified by:
doDisconnectin classAbstractChannel- Throws:
Exception
-
doFinishConnect
Deprecated.Description copied from class:AbstractNioChannelFinish the connect- Specified by:
doFinishConnectin classAbstractNioChannel- Throws:
Exception
-
doReadMessages
Deprecated.Description copied from class:AbstractNioMessageChannelRead messages into the given array and return the amount which was read.- Specified by:
doReadMessagesin classAbstractNioMessageChannel- Throws:
Exception
-
doWriteMessage
Deprecated.Description copied from class:AbstractNioMessageChannelWrite a message to the underlyingChannel.- Specified by:
doWriteMessagein classAbstractNioMessageChannel- Returns:
trueif and only if the message has been written- Throws:
Exception
-
isActive
public boolean isActive()Deprecated.Description copied from interface:ChannelReturntrueif theChannelis active and so connected. -
javaChannel
protected com.barchart.udt.nio.SocketChannelUDT javaChannel()Deprecated.- Overrides:
javaChannelin classAbstractNioChannel
-
localAddress0
Deprecated.Description copied from class:AbstractChannelReturns theSocketAddresswhich is bound locally.- Specified by:
localAddress0in classAbstractChannel
-
metadata
Deprecated.Description copied from interface:Channel -
remoteAddress0
Deprecated.Description copied from class:AbstractChannelReturn theSocketAddresswhich theChannelis connected to.- Specified by:
remoteAddress0in classAbstractChannel
-
localAddress
Deprecated.Description copied from interface:ChannelReturns the local address where this channel is bound to. The returnedSocketAddressis supposed to be down-cast into more concrete type such asInetSocketAddressto retrieve the detailed information.- Specified by:
localAddressin interfaceChannel- Specified by:
localAddressin interfaceUdtChannel- Overrides:
localAddressin classAbstractChannel- Returns:
- the local address of this channel.
nullif this channel is not bound.
-
remoteAddress
Deprecated.Description copied from interface:ChannelReturns the remote address where this channel is connected to. The returnedSocketAddressis supposed to be down-cast into more concrete type such asInetSocketAddressto retrieve the detailed information.- Specified by:
remoteAddressin interfaceChannel- Specified by:
remoteAddressin interfaceUdtChannel- Overrides:
remoteAddressin classAbstractChannel- Returns:
- the remote address of this channel.
nullif this channel is not connected. If this channel is not connected but it can receive messages from arbitrary remote addresses (e.g.DatagramChannel, useDefaultAddressedEnvelope.recipient()to determine the origination of the received message as this method will returnnull.
-