Uses of Interface org.jboss.xnio.ChannelListener (XNIO API 2.0.2.GA API)

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

XNIO API 2.0.2.GA

PREV NEXT

FRAMES NO FRAMES

Uses of Interface
org.jboss.xnio.ChannelListener

Packages that use ChannelListener
org.jboss.xnio	The main API package for XNIO.
org.jboss.xnio.channels	Defines an enhanced set of channels.

Uses of ChannelListener in org.jboss.xnio

Methods in org.jboss.xnio that return ChannelListener
`static ChannelListener<java.nio.channels.Channel>`	`IoUtils.closingChannelListener()` Get a channel listener which closes the channel when notified.
`static ChannelListener<java.nio.channels.Channel>`	`IoUtils.nullChannelListener()` Get a channel listener which does nothing.

Methods in org.jboss.xnio that return types with arguments of type ChannelListener

static



<T extends java.nio.channels.Channel> 


IoFuture.Notifier<T,ChannelListener<? super T>>

IoUtils.channelListenerNotifier()
Get the notifier that invokes the channel listener given as an attachment.

Methods in org.jboss.xnio with parameters of type ChannelListener

IoFuture<T> ChannelDestination.accept(ChannelListener<? super T> openListener, ChannelListener<? super BoundChannel<A>> bindListener)
Accept a connection.

IoFuture<T> Acceptor.acceptTo(A dest, ChannelListener<? super T> openListener, ChannelListener<? super BoundChannel<A>> bindListener)
Accept a connection at a destination address.

IoFuture<T> Connector.connectTo(A dest, ChannelListener<? super T> openListener, ChannelListener<? super BoundChannel<A>> bindListener)
Establish a connection to a destination.

IoFuture<TcpChannel> TcpConnector.connectTo(java.net.InetSocketAddress dest, ChannelListener<? super TcpChannel> openListener, ChannelListener<? super BoundChannel<java.net.InetSocketAddress>> bindListener)
Establish a connection to a TCP server.

LocalServer Xnio.createLocalDatagramServer(ChannelListener<? super DatagramChannel<java.lang.String>> openHandler, OptionMap optionMap)
Create a local datagram server.

LocalServer Xnio.createLocalDatagramServer(java.util.concurrent.Executor executor, ChannelListener<? super DatagramChannel<java.lang.String>> openHandler, OptionMap optionMap)
Create a local datagram server.

LocalServer Xnio.createLocalStreamServer(ChannelListener<? super ConnectedStreamChannel<java.lang.String>> openListener, OptionMap optionMap)
Create a local stream server.

LocalServer Xnio.createLocalStreamServer(java.util.concurrent.Executor executor, ChannelListener<? super ConnectedStreamChannel<java.lang.String>> openListener, OptionMap optionMap)
Create a local stream server.

IoFuture<? extends java.io.Closeable> Xnio.createOneWayPipeConnection(ChannelListener<? super StreamSourceChannel> sourceHandler, ChannelListener<? super StreamSinkChannel> sinkHandler)
Create a single one-way pipe connection.

IoFuture<? extends java.io.Closeable> Xnio.createOneWayPipeConnection(java.util.concurrent.Executor executor, ChannelListener<? super StreamSourceChannel> sourceHandler, ChannelListener<? super StreamSinkChannel> sinkHandler)
Create a single one-way pipe connection.

IoFuture<? extends java.io.Closeable> Xnio.createPipeConnection(ChannelListener<? super StreamChannel> leftHandler, ChannelListener<? super StreamChannel> rightHandler)
Create a single pipe connection.

IoFuture<? extends java.io.Closeable> Xnio.createPipeConnection(java.util.concurrent.Executor executor, ChannelListener<? super StreamChannel> leftHandler, ChannelListener<? super StreamChannel> rightHandler)
Create a single pipe connection.

ChannelSource<? extends StreamChannel> Xnio.createPipeServer(ChannelListener<? super StreamChannel> openHandler)
Create a pipe "server".

ChannelSource<? extends StreamChannel> Xnio.createPipeServer(java.util.concurrent.Executor executor, ChannelListener<? super StreamChannel> openHandler)
Create a pipe "server".

ChannelSource<? extends StreamSinkChannel> Xnio.createPipeSinkServer(ChannelListener<? super StreamSourceChannel> openHandler)
Create a one-way pipe "server".

ChannelSource<? extends StreamSinkChannel> Xnio.createPipeSinkServer(java.util.concurrent.Executor executor, ChannelListener<? super StreamSourceChannel> openHandler)
Create a one-way pipe "server".

ChannelSource<? extends StreamSourceChannel> Xnio.createPipeSourceServer(ChannelListener<? super StreamSinkChannel> openHandler)
Create a one-way pipe "server".

ChannelSource<? extends StreamSourceChannel> Xnio.createPipeSourceServer(java.util.concurrent.Executor executor, ChannelListener<? super StreamSinkChannel> openHandler)
Create a one-way pipe "server".

TcpServer Xnio.createTcpServer(ChannelListener<? super TcpChannel> openHandler, OptionMap optionMap)
Create an unbound TCP server.

TcpServer Xnio.createTcpServer(java.util.concurrent.Executor executor, ChannelListener<? super TcpChannel> openHandler, OptionMap optionMap)
Create an unbound TCP server.

UdpServer Xnio.createUdpServer(ChannelListener<? super UdpChannel> openHandler, OptionMap optionMap)
Create an unbound UDP server.

UdpServer Xnio.createUdpServer(java.util.concurrent.Executor executor, ChannelListener<? super UdpChannel> openHandler, OptionMap optionMap)
Create an unbound UDP server.

static



<T extends java.nio.channels.Channel> 


java.lang.Runnable

IoUtils.getChannelListenerTask(T channel,
                       ChannelListener<? super T> channelListener)

Get a task which invokes the given channel listener on the given channel.

static



<T extends java.nio.channels.Channel> 


void

IoUtils.invokeChannelListener(java.util.concurrent.Executor executor,
                      T channel,
                      ChannelListener<? super T> channelListener)

Invoke a channel listener on a given channel, logging any errors, using the given executor.

static



<T extends java.nio.channels.Channel> 


boolean

IoUtils.invokeChannelListener(T channel,
                      ChannelListener<? super T> channelListener)

Invoke a channel listener on a given channel, logging any errors.

IoFuture<? extends T> ChannelSource.open(ChannelListener<? super T> openListener)
Open a channel.

IoFuture<TcpChannel> TcpChannelSource.open(ChannelListener<? super TcpChannel> openListener)
Open a channel.

void ChannelListener.Setter.set(ChannelListener<? super T> listener)
Set the listener, or null to ignore the associated event type.

Method parameters in org.jboss.xnio with type arguments of type ChannelListener

static



<T extends java.nio.channels.Channel> 


ChannelListener.Setter<T>

IoUtils.getSetter(java.util.concurrent.atomic.AtomicReference<ChannelListener<? super T>> atomicReference)
Get a setter based on an atomic reference.

static



<T extends java.nio.channels.Channel,C> 


ChannelListener.Setter<T>

IoUtils.getSetter(C channel,
          java.util.concurrent.atomic.AtomicReferenceFieldUpdater<C,ChannelListener> updater)

Get a setter based on an atomic reference field updater.

Uses of ChannelListener in org.jboss.xnio.channels

Methods in org.jboss.xnio.channels that return ChannelListener
`static ChannelListener<TcpChannel>`	`Channels.createSslTcpChannelListener(javax.net.ssl.SSLContext sslContext, ChannelListener<? super SslTcpChannel> sslChannelListener, java.util.concurrent.Executor executor, OptionMap optionMap)` Create a channel lister which wraps the incoming connection with an SSL connection.

Methods in org.jboss.xnio.channels with parameters of type ChannelListener
`static ChannelListener<TcpChannel>`	`Channels.createSslTcpChannelListener(javax.net.ssl.SSLContext sslContext, ChannelListener<? super SslTcpChannel> sslChannelListener, java.util.concurrent.Executor executor, OptionMap optionMap)` Create a channel lister which wraps the incoming connection with an SSL connection.