| Modifier and Type | Class and Description |
|---|---|
| public static enum |
| Modifier and Type | Field and Description |
|---|---|
| public static final int | DEFAULT_READ_BUFFER_SIZE
The default read buffer size. |
| public static final int | DEFAULT_READ_TIMEOUT
Default read timeout in seconds. |
| public static final int | DEFAULT_WRITE_BUFFER_SIZE
The default write buffer size. |
| public static final int | DEFAULT_WRITE_TIMEOUT
Default write timeout in seconds. |
| Modifier and Type | Method and Description |
|---|---|
| public boolean | 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.Adds a |
| public void | |
| public void | |
| public void | fireIOEvent(IOEvent
I/O event ioEvent, Connection<L> Connection, on which we fire the event.I/O event life-cycle listener. listener)Fires specific |
| public AttributeBuilder | Returns: Transport associated AttributeBuilder, which will be used by Transport and its
Connections to store custom Attributes.Get |
| public MonitoringConfig | Returns: the configurationGet the monitoring configuration for Transport |
| public IOStrategy | getIOStrategy()
Get the |
| public ExecutorService | |
| public ThreadPoolConfig | getKernelThreadPoolConfig()
Returns: the |
| public MemoryManager | Returns: theTransport associated MemoryManager, which will be used by the Transport, its
Connections and by during processing I/O events, occurred on Connections.Get the |
| public MonitoringConfig | getMonitoringConfig()
Redeclares org. Get the Transport monitoring configuration |
| public String | |
| public Processor | Returns: the defaultProcessor, which will process Connection I/O events, if one doesn't have own
Processor preferences.Gets the default |
| public ProcessorSelector | Returns: the defaultProcessorSelector, 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 |
| public int | Returns: the default size ofBuffers, which will be allocated for reading data from Transport's
Connections.Get the default size of |
| public Reader | |
| public Reader | |
| public long | Returns: the value of the read timeoutthe timeUnit)TimeUnit to convert the returned result to.Returns the current value for the blocking read timeout converted to the provided |
| public StateHolder | |
| public MonitoringConfig | Returns: the configurationGet the monitoring configuration for Transport thread pool. |
| public ExecutorService | Returns: ExecutorService transport worker thread pool.Get a thread pool, which will run IOEvent processing (depending on Transport |
| public ThreadPoolConfig | getWorkerThreadPoolConfig()
Returns: the |
| public int | Returns: the default size ofBuffers, which will be allocated for writing data to Transport's
Connections.Get the default size of |
| public Writer | |
| public Writer | |
| public long | Returns: the value of the write timeoutthe timeUnit)TimeUnit to convert the returned result to.Returns the current value for the blocking write timeout converted to the provided |
| public boolean | |
| public boolean | |
| public boolean | |
| public boolean | Returns: true, if this Transport is in stopped state, false otherwise.Returns true, if this Transport is in stopped state, false otherwise. |
| public void | notifyTransportError(Throwable error)
Method gets invoked, when error occur during the Transport lifecycle. |
| public Processor | Returns: the defaultProcessor, which will process Connection I/O events, if one doesn't have own
Processor preferences.the type of events the Processor should handle ioEvent, Connection<L> connection to obtain Processor for connection)Gets the default |
| public void | |
| public void | |
| public void | setAttributeBuilder(AttributeBuilder
Transport associated AttributeBuilder, which will be used by
Transport and its Connections to store custom Attributes.Set |
| public void | setIOStrategy(IOStrategy IOStrategy)
Set the |
| public void | setKernelThreadPool(ExecutorService threadPool)
Set a thread pool which will run Transport internal tasks. |
| public void | setKernelThreadPoolConfig(final ThreadPoolConfig
kernel thread pool configuration. kernelConfig)Set the |
| public void | setMemoryManager(MemoryManager<E extends Buffer>
the memoryManager)Transport associated MemoryManager, which will be used by the
Transport, its Connections and by during processing I/O events, occurred on Connections.Set the |
| public void | |
| public void | setProcessor(Processor<E extends Context>
the default processor)Processor, which will process Connection I/O events, if one doesn't have
own Processor preferences.Sets the default |
| public void | setProcessorSelector(ProcessorSelector
the default selector)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.Sets the default |
| public void | setReadBufferSize(int readBufferSize)
Set the default size of |
| public void | setReadTimeout(long
the new timeout value timeout, TimeUnit the timeUnit)TimeUnit specification of the provided value.Specifies the timeout for the blocking reads. |
| public void | setWorkerThreadPool(ExecutorService
ExecutorService transport worker thread pool.Set a thread pool, which will run IOEvent processing (depending on Transport |
| public void | setWorkerThreadPoolConfig(final ThreadPoolConfig
worker thread pool configuration. workerConfig)Set the |
| public void | setWriteBufferSize(int writeBufferSize)
Set the default size of |
| public void | setWriteTimeout(long
the new timeout value timeout, TimeUnit the timeUnit)TimeUnit specification of the provided value.Specifies the timeout for the blocking writes. |
| public GrizzlyFuture | Returns: aGrizzlyFuture which will return the stopped transport.Gracefully stops the transport accepting new connections and allows existing work to complete before finalizing the shutdown. |
| public GrizzlyFuture | Returns: aGrizzlyFuture which will return the stopped transport.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. gracePeriod, final TimeUnit the timeUnit)TimeUnit of the specified grace period.Gracefully stops the transport accepting new connections and allows existing work to complete before finalizing the shutdown. |
| public void | |
| public void | |
| public void |