public interface IChannelMultiplexer extends ILocationAware, IContainer<IChannel>
channels over a shared physical connection.ILocationAware.LocationIContainer.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 |
|---|---|
java.util.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(java.lang.String protocolID,
java.lang.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, isServergetElements, isEmptyaddListener, getListeners, hasListeners, removeListenerstatic 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.
ChannelExceptionopenChannel(String, Object),
openChannel(IProtocol)IChannel openChannel(java.lang.String protocolID, java.lang.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.
ChannelExceptionopenChannel(),
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.
ChannelExceptionopenChannel(),
openChannel(String, Object)java.util.Collection<IChannel> getChannels()
long getOpenChannelTimeout()
void setOpenChannelTimeout(long openChannelTimeout)
Copyright (c) 2004-2019 Eike Stepper (Loehne, 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