Page History

/**
 * @return {@code True} if new type of direct connections supported.
 */
public default boolean pipeConnectionSupportedchannelConnectionSupported() {
    return false;
}
 
/**
 * @param src Source cluster node to initiate connection with.
 * @return Channel to listen.
 * @throws IgniteSpiException If fails.
 */
public default ReadableByteChannel getRemotePipe(ClusterNode src) throws IgniteSpiException {
    throw new UnsupportedOperationException();
}
 
/**
 * @param dest remote Destination cluster node to communicate with.
 * @param outmsg ChannelConfiguration tochannel write datamessage.
 * @throws IgniteSpiException If fails.
 */
public default voidIgniteSocketChannel sendOnPipechannel(ClusterNode destremote, WritableByteChannelT outmsg) throws IgniteSpiException {
    throw new UnsupportedOperationException();
}