public interface IChannelMultiplexer extends ILocationAware, IContainer<IChannel>
channels
over a shared physical connection.ILocationAware.Location
IContainer.Modifiable<E>, IContainer.Persistable<E>, IContainer.Persistence<E>
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_OPEN_CHANNEL_TIMEOUT
Indicates to use the timeout that is configured via debug property
open.channel.timeout (see .options
file) which has a default of 10 seconds. |
static long |
NO_CHANNEL_TIMEOUT |
Modifier and Type | Method and Description |
---|---|
Collection<IChannel> |
getChannels()
Returns a collection of currently open channels.
|
long |
getOpenChannelTimeout() |
IChannel |
openChannel()
Synchronous request to open a new
IChannel with an undefined channel protocol. |
IChannel |
openChannel(IProtocol<?> protocol)
Synchronous request to open a new
IChannel with the given channel protocol . |
IChannel |
openChannel(String protocolID,
Object infraStructure)
Synchronous request to open a new
IChannel with a channel protocol defined by a given protocol identifier. |
void |
setOpenChannelTimeout(long openChannelTimeout) |
getLocation, isClient, isServer
getElements, isEmpty
addListener, getListeners, hasListeners, removeListener
static final long NO_CHANNEL_TIMEOUT
static final long DEFAULT_OPEN_CHANNEL_TIMEOUT
open.channel.timeout
(see .options
file) which has a default of 10 seconds.IChannel openChannel() throws ChannelException
IChannel
with an undefined channel protocol. Since the peer connector
can't lookup a protocol factory
without a protocol identifier the IBufferHandler
of the
peer IChannel
can only be provided by externally provided channel lifecycle
listeners
.
ChannelException
openChannel(String, Object)
,
openChannel(IProtocol)
IChannel openChannel(String protocolID, Object infraStructure) throws ChannelException
IChannel
with a channel protocol defined by a given protocol identifier.
The peer connector will lookup a protocol factory
with the protocol identifier, create a
IBufferHandler
and inject it into the peer IChannel
.
ChannelException
openChannel()
,
openChannel(IProtocol)
IChannel openChannel(IProtocol<?> protocol) throws ChannelException
IChannel
with the given channel protocol . The peer connector will lookup
a protocol factory
with the protocol identifier, create a IBufferHandler
and inject it
into the peer channel.
ChannelException
openChannel()
,
openChannel(String, Object)
Collection<IChannel> getChannels()
long getOpenChannelTimeout()
void setOpenChannelTimeout(long openChannelTimeout)
Copyright (c) 2011-2015 Eike Stepper (Berlin, Germany) and others.