https://projects.eclipse.org/projects/ee4j.grizzly/grizzly-framework: Grizzly Bill of Materials (BOM) (Oracle Corporation) 
/*
 * Copyright (c) 2008, 2020 Oracle and/or its affiliates. All rights reserved.
 * Copyright (c) 2018 Payara Services Ltd.
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License v. 2.0, which is available at
 * http://www.eclipse.org/legal/epl-2.0.
 *
 * This Source Code may also be made available under the following Secondary
 * Licenses when the conditions for such availability set forth in the
 * Eclipse Public License v. 2.0 are satisfied: GNU General Public License,
 * version 2 with the GNU Classpath Exception, which is available at
 * https://www.gnu.org/software/classpath/license.html.
 *
 * SPDX-License-Identifier: EPL-2.0 OR GPL-2.0 WITH Classpath-exception-2.0
 */

package org.glassfish.grizzly;

import java.io.IOException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.TimeUnit;

import org.glassfish.grizzly.attributes.Attribute;
import org.glassfish.grizzly.attributes.AttributeBuilder;
import org.glassfish.grizzly.memory.MemoryManager;
import org.glassfish.grizzly.monitoring.MonitoringAware;
import org.glassfish.grizzly.monitoring.MonitoringConfig;
import org.glassfish.grizzly.threadpool.ThreadPoolConfig;
import org.glassfish.grizzly.threadpool.ThreadPoolProbe;
import org.glassfish.grizzly.utils.StateHolder;


Transport interface describes the transport unit used in Grizzly.
Transport implementation could operate over TCP, UDP or other custom protocol, using blocking, NIO or NIO.2 Java API.

Author:Alexey Stashok
/**
 * Transport interface describes the transport unit used in Grizzly.
 *
 * Transport implementation could operate over TCP, UDP or other custom protocol, using blocking, NIO or NIO.2 Java API.
 *
 * @author Alexey Stashok
 */
public interface Transport extends MonitoringAware<TransportProbe> {

    
The default read buffer size.

/**
     * The default read buffer size.
     */
    int DEFAULT_READ_BUFFER_SIZE = -1;

    
The default write buffer size.

/**
     * The default write buffer size.
     */
    int DEFAULT_WRITE_BUFFER_SIZE = -1;

    
Default read timeout in seconds.

/**
     * Default read timeout in seconds.
     */
    int DEFAULT_READ_TIMEOUT = 30;

    
Default write timeout in seconds.

/**
     * Default write timeout in seconds.
     */
    int DEFAULT_WRITE_TIMEOUT = 30;

    enum State {
        STARTING, STARTED, PAUSING, PAUSED, STOPPING, STOPPED
    }

    
Gets the Transport name. 
Returns:the Transport name.
/**
     * Gets the {@link Transport} name.
     *
     * @return the {@link Transport} name.
     */
    String getName();

    
Sets the Transport name. 
Params:
/**
     * Sets the {@link Transport} name.
     *
     * @param name the {@link Transport} name.
     */
    void setName(String name);

    
Return the Transport state controller. Using the state controller, it is possible to get/set the Transport state in thread-safe manner. 
Returns:StateHolder state controller.
/**
     * Return the {@link Transport} state controller. Using the state controller, it is possible to get/set the
     * {@link Transport} state in thread-safe manner.
     *
     * @return {@link StateHolder} state controller.
     */
    StateHolder<State> getState();

    
Returns the Transport mode. true, if Transport is operating in blocking mode, or false otherwise. Specific Transport Connections may override this setting by Connection.isBlocking(). 
Returns:the Transport mode. true, if Transport is operating in blocking mode, or false otherwise.
/**
     * Returns the {@link Transport} mode. <tt>true</tt>, if {@link Transport} is operating in blocking mode, or
     * <tt>false</tt> otherwise. Specific {@link Transport} {@link Connection}s may override this setting by
     * {@link Connection#isBlocking()}.
     *
     * @return the {@link Transport} mode. <tt>true</tt>, if {@link Transport} is operating in blocking mode, or
     * <tt>false</tt> otherwise.
     */
    boolean isBlocking();

    
Sets the Transport mode. Specific Transport Connections may override this setting by Connection.configureBlocking(boolean). 
Params:
  • isBlocking – the Transport mode. true, if Transport should operate in blocking mode, or false otherwise.
/**
     * Sets the {@link Transport} mode. Specific {@link Transport} {@link Connection}s may override this setting by
     * {@link Connection#configureBlocking(boolean)}.
     *
     * @param isBlocking the {@link Transport} mode. <tt>true</tt>, if {@link Transport} should operate in blocking mode, or
     * <tt>false</tt> otherwise.
     */
    void configureBlocking(boolean isBlocking);

    void configureStandalone(boolean isStandalone);

    boolean isStandalone();

    
Gets the default Processor, which will process Transport Connections I/O events in case, if Connection doesn't have own Processor preferences. If Transport associated Processor is null, and Connection doesn't have any preferred Processor - then Transport will try to get Processor using ProcessorSelector.select(IOEvent, Connection). 
Params:
  • ioEvent – the type of events the Processor should handle
  • connection – connection to obtain Processor for
Returns:the default Processor, which will process Connection I/O events, if one doesn't have own Processor preferences.
/**
     * Gets the default {@link Processor}, which will process <tt>Transport</tt> {@link Connection}s I/O events in case, if
     * {@link Connection} doesn't have own {@link Processor} preferences. If {@link Transport} associated {@link Processor}
     * is <tt>null</tt>, and {@link Connection} doesn't have any preferred {@link Processor} - then {@link Transport} will
     * try to get {@link Processor} using {@link ProcessorSelector#select(IOEvent, Connection)}.
     *
     * @param ioEvent the type of events the Processor should handle
     * @param connection connection to obtain Processor for
     * @return the default {@link Processor}, which will process {@link Connection} I/O events, if one doesn't have own
     * {@link Processor} preferences.
     */
    Processor obtainProcessor(IOEvent ioEvent, Connection connection);

    
Gets the default Processor, which will process Connection I/O events in case, if Connection doesn't have own Processor preferences. If Transport associated Processor is null, and Connection doesn't have any preferred Processor - then Transport will try to get Processor using ProcessorSelector.select(IOEvent, Connection). 
Returns:the default Processor, which will process Connection I/O events, if one doesn't have own Processor preferences.
/**
     * Gets the default {@link Processor}, which will process {@link Connection} I/O events in case, if {@link Connection}
     * doesn't have own {@link Processor} preferences. If {@link Transport} associated {@link Processor} is <tt>null</tt>,
     * and {@link Connection} doesn't have any preferred {@link Processor} - then {@link Transport} will try to get
     * {@link Processor} using {@link ProcessorSelector#select(IOEvent, Connection)}.
     *
     * @return the default {@link Processor}, which will process {@link Connection} I/O events, if one doesn't have own
     * {@link Processor} preferences.
     */
    Processor getProcessor();

    
Sets the default Processor, which will process Connection I/O events in case, if Connection doesn't have own Processor preferences. 
Params:
/**
     * Sets the default {@link Processor}, which will process {@link Connection} I/O events in case, if {@link Connection}
     * doesn't have own {@link Processor} preferences.
     *
     * @param processor the default {@link Processor}, which will process {@link Connection} I/O events, if one doesn't have
     * own {@link Processor} preferences.
     */
    void setProcessor(Processor processor);

    
Gets the default ProcessorSelector, which will be used to get Processor to process Connection I/O events, in case if this Transport's Processor is null and Connection doesn't have neither preferred Processor nor ProcessorSelector. Transport's ProcessorSelector is the last place, where Transport will try to get Processor to process Connection I/O event. If ProcessorSelector is not set - IllegalStateException will be thrown. 
Returns:the default ProcessorSelector, which will be used to get Processor to process Connection I/O events, in case if this Transport's Processor is null and Connection doesn't have neither preferred Processor nor ProcessorSelector.
/**
     * Gets the default {@link ProcessorSelector}, which will be used to get {@link Processor} to process {@link Connection}
     * I/O events, in case if this {@link Transport}'s {@link Processor} is <tt>null</tt> and {@link Connection} doesn't
     * have neither preferred {@link Processor} nor {@link ProcessorSelector}.
     *
     * {@link Transport}'s {@link ProcessorSelector} is the last place, where {@link Transport} will try to get
     * {@link Processor} to process {@link Connection} I/O event. If {@link ProcessorSelector} is not set -
     * {@link IllegalStateException} will be thrown.
     *
     * @return the default {@link ProcessorSelector}, which will be used to get {@link Processor} to process
     * {@link Connection} I/O events, in case if this {@link Transport}'s {@link Processor} is <tt>null</tt> and
     * {@link Connection} doesn't have neither preferred {@link Processor} nor {@link ProcessorSelector}.
     */
    ProcessorSelector getProcessorSelector();

    
Sets the default ProcessorSelector, which will be used to get Processor to process Connection I/O events, in case if this Transport's Processor is null and Connection doesn't have neither preferred Processor nor ProcessorSelector. Transport's ProcessorSelector is the last place, where Transport will try to get Processor to process Connection I/O event. If ProcessorSelector is not set - IllegalStateException will be thrown. 
Params:
/**
     * Sets the default {@link ProcessorSelector}, which will be used to get {@link Processor} to process {@link Connection}
     * I/O events, in case if this {@link Transport}'s {@link Processor} is <tt>null</tt> and {@link Connection} doesn't
     * have neither preferred {@link Processor} nor {@link ProcessorSelector}.
     *
     * {@link Transport}'s {@link ProcessorSelector} is the last place, where {@link Transport} will try to get
     * {@link Processor} to process {@link Connection} I/O event. If {@link ProcessorSelector} is not set -
     * {@link IllegalStateException} will be thrown.
     *
     * @param selector the default {@link ProcessorSelector}, which will be used to get {@link Processor} to process
     * {@link Connection} I/O events, in case if this {@link Transport}'s {@link Processor} is <tt>null</tt> and
     * {@link Connection} doesn't have neither preferred {@link Processor} nor {@link ProcessorSelector}.
     */
    void setProcessorSelector(ProcessorSelector selector);

    
Get the Transport associated MemoryManager, which will be used by the Transport, its Connections and by during processing I/O events, occurred on Connections. 
Returns:the Transport associated MemoryManager, which will be used by the Transport, its Connections and by during processing I/O events, occurred on Connections.
/**
     * Get the {@link Transport} associated {@link MemoryManager}, which will be used by the {@link Transport}, its
     * {@link Connection}s and by during processing I/O events, occurred on {@link Connection}s.
     *
     * @return the {@link Transport} associated {@link MemoryManager}, which will be used by the {@link Transport}, its
     * {@link Connection}s and by during processing I/O events, occurred on {@link Connection}s.
     */
    MemoryManager getMemoryManager();

    
Set the Transport associated MemoryManager, which will be used by the Transport, its Connections and by during processing I/O events, occurred on Connections. 
Params:
/**
     * Set the {@link Transport} associated {@link MemoryManager}, which will be used by the {@link Transport}, its
     * {@link Connection}s and by during processing I/O events, occurred on {@link Connection}s.
     *
     * @param memoryManager the {@link Transport} associated {@link MemoryManager}, which will be used by the
     * {@link Transport}, its {@link Connection}s and by during processing I/O events, occurred on {@link Connection}s.
     */
    void setMemoryManager(MemoryManager memoryManager);

    
Get the IOStrategy implementation, which will be used by Transport to process IOEvent. IOStrategy is responsible for choosing the way, how I/O event will be processed: using current Thread, worker Thread; or make any other decisions. 
Returns:the IOStrategy implementation, which will be used by Transport to process IOEvent.
/**
     * Get the {@link IOStrategy} implementation, which will be used by {@link Transport} to process {@link IOEvent}.
     * {@link IOStrategy} is responsible for choosing the way, how I/O event will be processed: using current
     * {@link Thread}, worker {@link Thread}; or make any other decisions.
     *
     * @return the {@link IOStrategy} implementation, which will be used by {@link Transport} to process {@link IOEvent}.
     */
    IOStrategy getIOStrategy();

    
Set the IOStrategy implementation, which will be used by Transport to process IOEvent. IOStrategy is responsible for choosing the way, how I/O event will be processed: using current Thread, worker Thread; or make any other decisions. 
Params:
/**
     * Set the {@link IOStrategy} implementation, which will be used by {@link Transport} to process {@link IOEvent}.
     * {@link IOStrategy} is responsible for choosing the way, how I/O event will be processed: using current
     * {@link Thread}, worker {@link Thread}; or make any other decisions.
     *
     * @param IOStrategy the {@link IOStrategy} implementation, which will be used by {@link Transport} to process
     * {@link IOEvent}.
     */
    void setIOStrategy(IOStrategy IOStrategy);

    
Get the default size of Buffers, which will be allocated for reading data from Transport's Connections. For particular Connection, this setting could be overridden by Connection.getReadBufferSize(). 
Returns:the default size of Buffers, which will be allocated for reading data from Transport's Connections.
/**
     * Get the default size of {@link Buffer}s, which will be allocated for reading data from {@link Transport}'s
     * {@link Connection}s. For particular {@link Connection}, this setting could be overridden by
     * {@link Connection#getReadBufferSize()}.
     *
     * @return the default size of {@link Buffer}s, which will be allocated for reading data from {@link Transport}'s
     * {@link Connection}s.
     */
    int getReadBufferSize();

    
Set the default size of Buffers, which will be allocated for reading data from Transport's Connections. For particular Connection, this setting could be overridden by Connection.setReadBufferSize(int). If not explicitly configured, this value will be set to DEFAULT_READ_BUFFER_SIZE. 
Params:
/**
     * Set the default size of {@link Buffer}s, which will be allocated for reading data from {@link Transport}'s
     * {@link Connection}s. For particular {@link Connection}, this setting could be overridden by
     * {@link Connection#setReadBufferSize(int)}.
     *
     * If not explicitly configured, this value will be set to {@link #DEFAULT_READ_BUFFER_SIZE}.
     *
     * @param readBufferSize the default size of {@link Buffer}s, which will be allocated for reading data from
     * {@link Transport}'s {@link Connection}s.
     */
    void setReadBufferSize(int readBufferSize);

    
Get the default size of Buffers, which will be allocated for writing data to Transport's Connections. For particular Connection, this setting could be overridden by Connection.getWriteBufferSize(). 
Returns:the default size of Buffers, which will be allocated for writing data to Transport's Connections.
/**
     * Get the default size of {@link Buffer}s, which will be allocated for writing data to {@link Transport}'s
     * {@link Connection}s. For particular {@link Connection}, this setting could be overridden by
     * {@link Connection#getWriteBufferSize()}.
     *
     * @return the default size of {@link Buffer}s, which will be allocated for writing data to {@link Transport}'s
     * {@link Connection}s.
     */
    int getWriteBufferSize();

    
Set the default size of Buffers, which will be allocated for writing data to Transport's Connections. For particular Connection, this setting could be overridden by Connection.setWriteBufferSize(int). 
Params:
/**
     * Set the default size of {@link Buffer}s, which will be allocated for writing data to {@link Transport}'s
     * {@link Connection}s. For particular {@link Connection}, this setting could be overridden by
     * {@link Connection#setWriteBufferSize(int)}.
     *
     * @param writeBufferSize the default size of {@link Buffer}s, which will be allocated for writing data to
     * {@link Transport}'s {@link Connection}s.
     */
    void setWriteBufferSize(int writeBufferSize);

    
Get a thread pool, which will run IOEvent processing (depending on Transport IOStrategy) to let kernel threads continue their job. 
Returns:ExecutorService transport worker thread pool.
/**
     * Get a thread pool, which will run IOEvent processing (depending on Transport {@link IOStrategy}) to let kernel
     * threads continue their job.
     *
     * @return {@link ExecutorService} transport worker thread pool.
     */
    ExecutorService getWorkerThreadPool();

    
Returns:ExecutorService responsible for running Transport internal tasks. For example SelectorRunner threads for NIO.
/**
     * @return {@link ExecutorService} responsible for running Transport internal tasks. For example
     * {@link org.glassfish.grizzly.nio.SelectorRunner} threads for NIO.
     */
    ExecutorService getKernelThreadPool();

    
Set a thread pool, which will run IOEvent processing (depending on Transport IOStrategy) to let kernel threads continue their job. 
Params:
/**
     * Set a thread pool, which will run IOEvent processing (depending on Transport {@link IOStrategy}) to let kernel
     * threads continue their job.
     *
     * @param threadPool {@link ExecutorService} transport worker thread pool.
     */
    void setWorkerThreadPool(ExecutorService threadPool);

    
Set a thread pool which will run Transport internal tasks. For example SelectorRunner threads for NIO. 
Params:
/**
     * Set a thread pool which will run Transport internal tasks. For example
     * {@link org.glassfish.grizzly.nio.SelectorRunner} threads for NIO.
     *
     * @param threadPool {@link ExecutorService} for {@link org.glassfish.grizzly.nio.SelectorRunner}s
     */
    void setKernelThreadPool(ExecutorService threadPool);

    
Set the ThreadPoolConfig to be used by the Transport internal thread pool. 
Params:
  • kernelConfig – kernel thread pool configuration.
/**
     * Set the {@link ThreadPoolConfig} to be used by the Transport internal thread pool.
     *
     * @param kernelConfig kernel thread pool configuration.
     */
    void setKernelThreadPoolConfig(final ThreadPoolConfig kernelConfig);

    
Set the ThreadPoolConfig to be used by the worker thread pool. 
Params:
  • workerConfig – worker thread pool configuration.
/**
     * Set the {@link ThreadPoolConfig} to be used by the worker thread pool.
     *
     * @param workerConfig worker thread pool configuration.
     */
    void setWorkerThreadPoolConfig(final ThreadPoolConfig workerConfig);

    
Returns:the ThreadPoolConfig that will be used to construct the ExecutorService which will run the Transport's internal tasks. For example SelectorRunners for NIO.
/**
     * @return the {@link ThreadPoolConfig} that will be used to construct the {@link java.util.concurrent.ExecutorService}
     * which will run the {@link org.glassfish.grizzly.Transport}'s internal tasks. For example
     * {@link org.glassfish.grizzly.nio.SelectorRunner}s for NIO.
     */
    ThreadPoolConfig getKernelThreadPoolConfig();

    
Returns:the ThreadPoolConfig that will be used to construct the ExecutorService for IOStrategies that require worker threads. Depending on the IOStrategy being used, this may return null.
/**
     * @return the {@link ThreadPoolConfig} that will be used to construct the {@link java.util.concurrent.ExecutorService}
     * for <code>IOStrategies</code> that require worker threads. Depending on the {@link IOStrategy} being used, this may
     * return <code>null</code>.
     */
    ThreadPoolConfig getWorkerThreadPoolConfig();

    
Get Transport associated AttributeBuilder, which will be used by Transport and its Connections to store custom Attributes. 
Returns:Transport associated AttributeBuilder, which will be used by Transport and its Connections to store custom Attributes.
/**
     * Get {@link Transport} associated {@link AttributeBuilder}, which will be used by {@link Transport} and its
     * {@link Connection}s to store custom {@link Attribute}s.
     *
     * @return {@link Transport} associated {@link AttributeBuilder}, which will be used by {@link Transport} and its
     * {@link Connection}s to store custom {@link Attribute}s.
     */
    AttributeBuilder getAttributeBuilder();

    
Set Transport associated AttributeBuilder, which will be used by Transport and its Connections to store custom Attributes. 
Params:
/**
     * Set {@link Transport} associated {@link AttributeBuilder}, which will be used by {@link Transport} and its
     * {@link Connection}s to store custom {@link Attribute}s.
     *
     * @param attributeBuilder {@link Transport} associated {@link AttributeBuilder}, which will be used by
     * {@link Transport} and its {@link Connection}s to store custom {@link Attribute}s.
     */
    void setAttributeBuilder(AttributeBuilder attributeBuilder);

    
Starts the transport

Throws:
  • IOException – if transport fails to start. This may not occur if Transport was not in State.STOPPED.
/**
     * Starts the transport
     *
     * @throws IOException if transport fails to start. This may not occur if Transport was not in {@link State#STOPPED}.
     */
    void start() throws IOException;

    
Stops the transport and closes all the connections

Throws:
  • IOException – if there was an error shutting down
Deprecated:Use shutdownNow().
/**
     * Stops the transport and closes all the connections
     *
     * @throws IOException if there was an error shutting down
     *
     * @deprecated Use {@link #shutdownNow()}.
     */
    @Deprecated
    void stop() throws IOException;

    
Gracefully stops the transport accepting new connections and allows existing work to complete before finalizing the shutdown. This method will wait indefinitely for all interested parties to signal it is safe to terminate the transport. Invoke shutdownNow() to terminate the transport if the graceful shutdown is taking too long. 
See Also:
Returns:a GrizzlyFuture which will return the stopped transport.
Since:2.3.5
/**
     * Gracefully stops the transport accepting new connections and allows existing work to complete before finalizing the
     * shutdown. This method will wait indefinitely for all interested parties to signal it is safe to terminate the
     * transport. Invoke {@link #shutdownNow()} to terminate the transport if the graceful shutdown is taking too long.
     *
     * @return a {@link GrizzlyFuture} which will return the stopped transport.
     *
     * @since 2.3.5
     *
     * @see GracefulShutdownListener
     */
    GrizzlyFuture<Transport> shutdown();

    
Gracefully stops the transport accepting new connections and allows existing work to complete before finalizing the
shutdown. This method will wait for the specified time for all interested parties to signal it is safe to terminate
the transport. If the timeout is exceeded, the transport will be terminated forcefully.

Params:
  • gracePeriod – the grace period for a graceful shutdown before the transport is forcibly terminated. If
gracePeriod is zero or less, then there is no time limit for the shutdown.
  • timeUnit – the TimeUnit of the specified grace period.
Returns:a GrizzlyFuture which will return the stopped transport.
Since:2.3.5
/**
     * Gracefully stops the transport accepting new connections and allows existing work to complete before finalizing the
     * shutdown. This method will wait for the specified time for all interested parties to signal it is safe to terminate
     * the transport. If the timeout is exceeded, the transport will be terminated forcefully.
     *
     * @param gracePeriod the grace period for a graceful shutdown before the transport is forcibly terminated. If
     * gracePeriod is zero or less, then there is no time limit for the shutdown.
     * @param timeUnit the {@link TimeUnit} of the specified grace period.
     *
     * @return a {@link GrizzlyFuture} which will return the stopped transport.
     *
     * @since 2.3.5
     */
    GrizzlyFuture<Transport> shutdown(final long gracePeriod, final TimeUnit timeUnit);

    
Forcibly stops the transport and closes all connections.

Throws:
  • IOException – if there was an error shutting down
See Also:
Since:2.3.5
/**
     * Forcibly stops the transport and closes all connections.
     *
     * @throws IOException if there was an error shutting down
     * @see #shutdown() to complete gracefully
     * @since 2.3.5
     */
    void shutdownNow() throws IOException;

    
Adds a GracefulShutdownListener which will be called when shutdown() is called to enable graceful shutdown of transports. This allows the owner of the listener to signal that all shutdown tasks are complete and that it's safe to finalize the termination of the transport 
Params:
Returns:true if the listener was successfully registered, otherwise false. When this method
returns false it means one of two things: the transport is stopping or is stopped, or the listener has
already been registered.
Since:2.3.5
/**
     * Adds a {@link GracefulShutdownListener} which will be called when {@link #shutdown()} is called to enable graceful
     * shutdown of transports. This allows the owner of the listener to signal that all shutdown tasks are complete and that
     * it's safe to finalize the termination of the transport
     *
     * @param shutdownListener the {@link GracefulShutdownListener}
     *
     * @return <code>true</code> if the listener was successfully registered, otherwise <code>false</code>. When this method
     * returns <code>false</code> it means one of two things: the transport is stopping or is stopped, or the listener has
     * already been registered.
     *
     * @since 2.3.5
     */
    boolean addShutdownListener(final GracefulShutdownListener shutdownListener);

    
Pauses the transport

/**
     * Pauses the transport
     */
    void pause();

    
Resumes the transport after a pause

/**
     * Resumes the transport after a pause
     */
    void resume();

    
Fires specific IOEvent on the Connection 
Params:
  • ioEvent – I/O event
  • connection – Connection, on which we fire the event.
  • listener – I/O event life-cycle listener.
/**
     * Fires specific {@link IOEvent} on the {@link Connection}
     *
     * @param ioEvent I/O event
     * @param connection {@link Connection}, on which we fire the event.
     * @param listener I/O event life-cycle listener.
     */
    void fireIOEvent(IOEvent ioEvent, Connection connection, IOEventLifeCycleListener listener);

    
Returns true, if this Transport is in stopped state, false otherwise.

Returns:true, if this Transport is in stopped state, false otherwise.
/**
     * Returns <tt>true</tt>, if this <tt>Transport</tt> is in stopped state, <tt>false</tt> otherwise.
     * 
     * @return <tt>true</tt>, if this <tt>Transport</tt> is in stopped state, <tt>false</tt> otherwise.
     */
    boolean isStopped();

    boolean isPaused();

    
Get the Reader to read data from the Connection. The Transport may decide to return blocking or non-blocking Reader depending on the Connection settings. 
Params:
Returns:Reader.
/**
     * Get the {@link Reader} to read data from the {@link Connection}. The <tt>Transport</tt> may decide to return blocking
     * or non-blocking {@link Reader} depending on the {@link Connection} settings.
     *
     * @param connection {@link Connection}.
     *
     * @return {@link Reader}.
     */
    Reader getReader(Connection connection);

    
Get the Reader implementation, depending on the requested mode. 
Params:
  • isBlocking – blocking mode.
Returns:Reader.
/**
     * Get the {@link Reader} implementation, depending on the requested mode.
     *
     * @param isBlocking blocking mode.
     *
     * @return {@link Reader}.
     */
    Reader getReader(boolean isBlocking);

    
Get the Writer to write data to the Connection. The Transport may decide to return blocking or non-blocking Writer depending on the Connection settings. 
Params:
Returns:Writer.
/**
     * Get the {@link Writer} to write data to the {@link Connection}. The <tt>Transport</tt> may decide to return blocking
     * or non-blocking {@link Writer} depending on the {@link Connection} settings.
     *
     * @param connection {@link Connection}.
     *
     * @return {@link Writer}.
     */
    Writer getWriter(Connection connection);

    
Get the Writer implementation, depending on the requested mode. 
Params:
  • isBlocking – blocking mode.
Returns:Writer.
/**
     * Get the {@link Writer} implementation, depending on the requested mode.
     *
     * @param isBlocking blocking mode.
     *
     * @return {@link Writer}.
     */
    Writer getWriter(boolean isBlocking);

    
Get the monitoring configuration for Transport Connections. 
Returns:the configuration
/**
     * Get the monitoring configuration for Transport {@link Connection}s.
     * 
     * @return the configuration
     */
    MonitoringConfig<ConnectionProbe> getConnectionMonitoringConfig();

    
Get the monitoring configuration for Transport thread pool.

Returns:the configuration
/**
     * Get the monitoring configuration for Transport thread pool.
     * 
     * @return the configuration
     */
    MonitoringConfig<ThreadPoolProbe> getThreadPoolMonitoringConfig();

    
Get the Transport monitoring configuration MonitoringConfig. 
/**
     * Get the <tt>Transport</tt> monitoring configuration {@link MonitoringConfig}.
     */
    @Override
    MonitoringConfig<TransportProbe> getMonitoringConfig();

    
Method gets invoked, when error occur during the Transport lifecycle.

Params:
/**
     * Method gets invoked, when error occur during the <tt>Transport</tt> lifecycle.
     *
     * @param error {@link Throwable}.
     */
    void notifyTransportError(Throwable error);

    
Returns the current value for the blocking read timeout converted to the provided TimeUnit specification. If this value hasn't been explicitly set, it will default to 30 seconds. 
Params:
  • timeUnit – the TimeUnit to convert the returned result to.
Returns:the value of the read timeout
Since:2.3
/**
     * Returns the current value for the blocking read timeout converted to the provided {@link TimeUnit} specification. If
     * this value hasn't been explicitly set, it will default to {@value #DEFAULT_READ_TIMEOUT} seconds.
     *
     * @param timeUnit the {@link TimeUnit} to convert the returned result to.
     * @return the value of the read timeout
     *
     * @since 2.3
     */
    long getReadTimeout(TimeUnit timeUnit);

    
Specifies the timeout for the blocking reads. This may be overridden on a per-connection basis. A value of zero or
less effectively disables the timeout.

Params:
  • timeout – the new timeout value
  • timeUnit – the TimeUnit specification of the provided value.
See Also:
Since:2.3
/**
     * Specifies the timeout for the blocking reads. This may be overridden on a per-connection basis. A value of zero or
     * less effectively disables the timeout.
     *
     * @param timeout the new timeout value
     * @param timeUnit the {@link TimeUnit} specification of the provided value.
     *
     * @see Connection#setReadTimeout(long, java.util.concurrent.TimeUnit)
     *
     * @since 2.3
     */
    void setReadTimeout(long timeout, TimeUnit timeUnit);

    
Returns the current value for the blocking write timeout converted to the provided TimeUnit specification. If this value hasn't been explicitly set, it will default to 30 seconds. 
Params:
  • timeUnit – the TimeUnit to convert the returned result to.
Returns:the value of the write timeout
Since:2.3
/**
     * Returns the current value for the blocking write timeout converted to the provided {@link TimeUnit} specification. If
     * this value hasn't been explicitly set, it will default to {@value #DEFAULT_WRITE_TIMEOUT} seconds.
     *
     * @param timeUnit the {@link TimeUnit} to convert the returned result to.
     * @return the value of the write timeout
     *
     * @since 2.3
     */
    long getWriteTimeout(TimeUnit timeUnit);

    
Specifies the timeout for the blocking writes. This may be overridden on a per-connection basis. A value of zero or
less effectively disables the timeout.

Params:
  • timeout – the new timeout value
  • timeUnit – the TimeUnit specification of the provided value.
See Also:
Since:2.3
/**
     * Specifies the timeout for the blocking writes. This may be overridden on a per-connection basis. A value of zero or
     * less effectively disables the timeout.
     *
     * @param timeout the new timeout value
     * @param timeUnit the {@link TimeUnit} specification of the provided value.
     *
     * @see Connection#setWriteTimeout(long, java.util.concurrent.TimeUnit)
     *
     * @since 2.3
     */
    void setWriteTimeout(long timeout, TimeUnit timeUnit);

}