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) 2014 Eike Stepper (Berlin, Germany) and others.
All rights reserved. This program and the accompanying materials are made available under the terms of the Eclipse Public License v1.0 which accompanies this distribution, and is available at http://www.eclipse.org/legal/epl-v10.html