A B C D E F G H I J K L M N O P Q R S T U V W Y _

A

AbstractDispatchObject - Class in org.fusesource.hawtdispatch.internal

AbstractDispatchObject() - Constructor for class org.fusesource.hawtdispatch.internal.AbstractDispatchObject

AbstractProtocolCodec - Class in org.fusesource.hawtdispatch.transport

Provides an abstract base class to make implementing the ProtocolCodec interface easier.

AbstractProtocolCodec() - Constructor for class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

AbstractProtocolCodec.Action - Interface in org.fusesource.hawtdispatch.transport

accept() - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

acceptSource - Variable in class org.fusesource.hawtdispatch.transport.PipeTransportServer

acceptSource - Variable in class org.fusesource.hawtdispatch.transport.TcpTransportServer

Activator - Class in org.fusesource.hawtdispatch.internal

OSGi integration point.

Activator() - Constructor for class org.fusesource.hawtdispatch.internal.Activator

ActiveMetricsCollector - Class in org.fusesource.hawtdispatch.internal

ActiveMetricsCollector(DispatchQueue) - Constructor for class org.fusesource.hawtdispatch.internal.ActiveMetricsCollector

add(TimerThread.TimerRequest) - Method in class org.fusesource.hawtdispatch.internal.TimerThread

add(Task) - Method in class org.fusesource.hawtdispatch.transport.ServiceBase.CallbackSupport

add(Task) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.CANCELING

add(Task) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport.CANCELING

addAbsolute(Task, DispatchQueue, long, TimeUnit) - Method in class org.fusesource.hawtdispatch.internal.TimerThread

addAbsolute(V, long, TimeUnit) - Method in class org.fusesource.hawtdispatch.internal.util.TimerHeap

addAndGet(int) - Method in class org.fusesource.hawtdispatch.internal.util.IntegerCounter

addFields(Object, Class<?>, Class<?>, LinkedHashMap<String, Object>) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

addInternal(V, long) - Method in class org.fusesource.hawtdispatch.internal.util.TimerHeap

addItem(String, String, OpenType) - Method in class org.fusesource.hawtdispatch.jmx.JmxService.CompositeTypeFactory

addRelative(Task, DispatchQueue, long, TimeUnit) - Method in class org.fusesource.hawtdispatch.internal.TimerThread

addRelative(V, long, TimeUnit) - Method in class org.fusesource.hawtdispatch.internal.util.TimerHeap

AggregatingExecutor - Class in org.fusesource.hawtdispatch

Sends runnable tasks to a DispatchQueue via a an EventAggregator so that they first batch up on the sender side before being sent to the DispatchQueue which then executes that tasks.

AggregatingExecutor(DispatchQueue) - Constructor for class org.fusesource.hawtdispatch.AggregatingExecutor

aggregator - Variable in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

allocateNextWriteBuffer() - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

AnnotatedMBean - Class in org.fusesource.hawtdispatch.jmx

MBean that looks for method/parameter descriptions in the Info annotation.

AnnotatedMBean(T, Class<T>) - Constructor for class org.fusesource.hawtdispatch.jmx.AnnotatedMBean

Instance where the MBean interface is implemented by another object.

AnnotatedMBean(Class<?>) - Constructor for class org.fusesource.hawtdispatch.jmx.AnnotatedMBean

Instance where the MBean interface is implemented by this object.

ANY_ADDRESS - Static variable in class org.fusesource.hawtdispatch.transport.UdpTransport

apply() - Method in interface org.fusesource.hawtdispatch.transport.AbstractProtocolCodec.Action

assertConnected() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

assertConnected() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

assertExecuting() - Method in interface org.fusesource.hawtdispatch.DispatchQueue

Asserts that the current dispatch queue is executing.

assertExecuting() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

assertExecuting() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

assertExecuting() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

assertMessage(String) - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

assertRetained() - Method in class org.fusesource.hawtdispatch.BaseRetained

Subclasses can use this method to validate that the object has not yet been released.

attachment - Variable in class org.fusesource.hawtdispatch.internal.NioDispatchSource.KeyState

await() - Method in class org.fusesource.hawtdispatch.internal.util.RunnableCountDownLatch

await(long, TimeUnit) - Method in class org.fusesource.hawtdispatch.internal.util.RunnableCountDownLatch

B

backlog - Variable in class org.fusesource.hawtdispatch.transport.TcpTransportServer

BaseRetained - Class in org.fusesource.hawtdispatch

Base class that implements the Retained interface.

BaseRetained() - Constructor for class org.fusesource.hawtdispatch.BaseRetained

BaseSuspendable - Class in org.fusesource.hawtdispatch.internal

BaseSuspendable() - Constructor for class org.fusesource.hawtdispatch.internal.BaseSuspendable

bind(String) - Static method in class org.fusesource.hawtdispatch.transport.PipeTransportRegistry

bindAddress - Variable in class org.fusesource.hawtdispatch.transport.TcpTransportServer

bindAddress - Variable in class org.fusesource.hawtdispatch.transport.UdpTransportServer

bindScheme - Variable in class org.fusesource.hawtdispatch.transport.TcpTransportServer

bindScheme - Variable in class org.fusesource.hawtdispatch.transport.UdpTransportServer

blockingExecutor - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

blockingExecutor - Variable in class org.fusesource.hawtdispatch.transport.TcpTransportServer

blockingExecutor - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

blockingExecutor - Variable in class org.fusesource.hawtdispatch.transport.UdpTransportServer

BufferPool - Class in org.fusesource.hawtdispatch.util

BufferPool(int) - Constructor for class org.fusesource.hawtdispatch.util.BufferPool

bufferPools - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

BufferPools - Class in org.fusesource.hawtdispatch.util

BufferPools() - Constructor for class org.fusesource.hawtdispatch.util.BufferPools

bufferSize - Variable in class org.fusesource.hawtdispatch.util.BufferPool

BufferState() - Constructor for enum org.fusesource.hawtdispatch.transport.ProtocolCodec.BufferState

C

callbacks - Variable in class org.fusesource.hawtdispatch.transport.ServiceBase.CallbackSupport

CallbackSupport() - Constructor for class org.fusesource.hawtdispatch.transport.ServiceBase.CallbackSupport

CALLERS - Static variable in class org.fusesource.hawtdispatch.BaseRetained

cancel() - Method in interface org.fusesource.hawtdispatch.DispatchSource

Asynchronously cancel the dispatch source, preventing any further invocation of its event handler runnable.

cancel() - Method in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

cancel() - Method in class org.fusesource.hawtdispatch.internal.NioAttachment

cancel() - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

cancel(SelectionKey) - Method in class org.fusesource.hawtdispatch.internal.NioManager

CANCEL_HANDLER - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

CANCEL_HANDLER - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

canceled - Variable in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

canceled - Variable in class org.fusesource.hawtdispatch.internal.NioDispatchSource

CANCELED(boolean) - Constructor for class org.fusesource.hawtdispatch.transport.TcpTransport.CANCELED

CANCELED(boolean) - Constructor for class org.fusesource.hawtdispatch.transport.UdpTransport.CANCELED

cancelHandler - Variable in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

cancelHandler - Variable in class org.fusesource.hawtdispatch.internal.NioDispatchSource

CANCELING() - Constructor for class org.fusesource.hawtdispatch.transport.TcpTransport.CANCELING

CANCELING() - Constructor for class org.fusesource.hawtdispatch.transport.UdpTransport.CANCELING

channel - Variable in class org.fusesource.hawtdispatch.internal.NioDispatchSource

channel - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

channel - Variable in class org.fusesource.hawtdispatch.transport.TcpTransportServer

channel - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

channel - Variable in class org.fusesource.hawtdispatch.transport.UdpTransportServer

checkCollector() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

checkin(T) - Method in class org.fusesource.hawtdispatch.util.ThreadLocalPool

checkout() - Method in class org.fusesource.hawtdispatch.util.ThreadLocalPool

clear() - Method in class org.fusesource.hawtdispatch.internal.util.TimerHeap

client() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

ClientAuth() - Constructor for enum org.fusesource.hawtdispatch.transport.SslProtocolCodec.ClientAuth

clientAuth - Variable in class org.fusesource.hawtdispatch.transport.SslTransport

ClientAuth() - Constructor for enum org.fusesource.hawtdispatch.transport.SslTransport.ClientAuth

clientAuth - Variable in class org.fusesource.hawtdispatch.transport.SslTransportServer

close() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec.SSLReadChannel

close() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec.SSLWriteChannel

close() - Method in class org.fusesource.hawtdispatch.transport.SslTransport.SSLChannel

close() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

closeOnCancel - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

codec - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

codec - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

command - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport.OneWay

command - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport.OneWay

command - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport.OneWay

CompositeTypeFactory() - Constructor for class org.fusesource.hawtdispatch.jmx.JmxService.CompositeTypeFactory

connect(String) - Static method in class org.fusesource.hawtdispatch.transport.PipeTransportRegistry

connect() - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

connected - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

connected(SocketChannel) - Method in class org.fusesource.hawtdispatch.transport.SslTransport

connected(SocketChannel) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

CONNECTED() - Constructor for class org.fusesource.hawtdispatch.transport.TcpTransport.CONNECTED

connected(DatagramChannel) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

CONNECTED() - Constructor for class org.fusesource.hawtdispatch.transport.UdpTransport.CONNECTED

connecting(URI, URI) - Method in class org.fusesource.hawtdispatch.transport.SslTransport

connecting(URI, URI) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

CONNECTING() - Constructor for class org.fusesource.hawtdispatch.transport.TcpTransport.CONNECTING

connecting(URI, URI) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

CONNECTING() - Constructor for class org.fusesource.hawtdispatch.transport.UdpTransport.CONNECTING

connectionCounter - Variable in class org.fusesource.hawtdispatch.transport.PipeTransportServer

connectURI - Variable in class org.fusesource.hawtdispatch.transport.PipeTransportServer

convert(Object, Class<?>) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

convert(Metrics, TimeUnit) - Static method in class org.fusesource.hawtdispatch.jmx.JmxService

convertToString(Object, Class<?>) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

countDown() - Method in class org.fusesource.hawtdispatch.internal.util.RunnableCountDownLatch

counter - Variable in class org.fusesource.hawtdispatch.internal.util.IntegerCounter

create(Class<T>, T, DispatchQueue) - Static method in class org.fusesource.hawtdispatch.DispatchQueueProxy

Create an asynchronous dispatch proxy to the target object via the dispatch queue.

create(ClassLoader, Class<T>, T, DispatchQueue) - Static method in class org.fusesource.hawtdispatch.DispatchQueueProxy

Create an asynchronous dispatch proxy to the target object via the dispatch queue.

create(String, int) - Static method in class org.fusesource.hawtdispatch.internal.DispatcherConfig

create(Object) - Static method in class org.fusesource.hawtdispatch.jmx.AnnotatedMBean

create(Class) - Method in class org.fusesource.hawtdispatch.jmx.JmxService.CompositeTypeFactory

create(String, String) - Method in class org.fusesource.hawtdispatch.jmx.JmxService.CompositeTypeFactory

create() - Method in class org.fusesource.hawtdispatch.util.BufferPool

create() - Method in class org.fusesource.hawtdispatch.util.ThreadLocalPool

createClientTransport() - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

CREATED - Static variable in class org.fusesource.hawtdispatch.transport.ServiceBase

createDisconnectTask() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.CONNECTED

createDisconnectTask() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport.CONNECTED

createDispatcher() - Method in class org.fusesource.hawtdispatch.internal.DispatcherConfig

createQueue(String) - Static method in class org.fusesource.hawtdispatch.Dispatch

Creates a new serial dispatch queue to which runnable objects may be submitted.

createQueue() - Static method in class org.fusesource.hawtdispatch.Dispatch

Creates a new serial dispatch queue to which runnable objects may be submitted.

createQueue(String) - Method in interface org.fusesource.hawtdispatch.Dispatcher

Creates a new serial dispatch queue to which runnable objects may be submitted.

createQueue(String) - Method in interface org.fusesource.hawtdispatch.DispatchQueue

Creates a new serial dispatch queue with this queue set as it's target queue.

createQueue(String) - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

createQueue(String) - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

createQueue(String) - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

createQueue(String) - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

createServerTransport() - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

createSource(SelectableChannel, int, DispatchQueue) - Static method in class org.fusesource.hawtdispatch.Dispatch

Creates a new DispatchSource to monitor SelectableChannel objects and automatically submit a handler runnable to a dispatch queue in response to events.

createSource(EventAggregator<Event, MergedEvent>, DispatchQueue) - Static method in class org.fusesource.hawtdispatch.Dispatch

Creates a new CustomDispatchSource to monitor events merged into the dispatch source and automatically submit a handler runnable to a dispatch queue in response to the events.

createSource(SelectableChannel, int, DispatchQueue) - Method in interface org.fusesource.hawtdispatch.Dispatcher

Creates a new DispatchSource to monitor SelectableChannel objects and automatically submit a handler runnable to a dispatch queue in response to events.

createSource(EventAggregator<Event, MergedEvent>, DispatchQueue) - Method in interface org.fusesource.hawtdispatch.Dispatcher

Creates a new CustomDispatchSource to monitor events merged into the dispatch source and automatically submit a handler runnable to a dispatch queue in response to the events.

createSource(SelectableChannel, int, DispatchQueue) - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

createSource(EventAggregator<Event, MergedEvent>, DispatchQueue) - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

createTransport(URI) - Static method in class org.fusesource.hawtdispatch.transport.SslTransport

Allows subclasses of TcpTransportFactory to create custom instances of TcpTransport.

createTransport() - Method in class org.fusesource.hawtdispatch.transport.SslTransportServer

createTransport() - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

createTransport() - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

createTransportServer(URI) - Static method in class org.fusesource.hawtdispatch.transport.SslTransportServer

createWorker(int) - Method in class org.fusesource.hawtdispatch.internal.pool.SimplePool

CURRENT_QUEUE - Static variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

currentWorkerThread() - Static method in class org.fusesource.hawtdispatch.internal.WorkerThread

CustomDispatchSource<Event,MergedEvent> - Interface in org.fusesource.hawtdispatch

A dispatch source that is used to coalesce multiple application generated events for later processing by the dispatch source event handler.

D

DEBUG - Static variable in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

debug(String, Object...) - Method in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

debug(Throwable, String, Object...) - Method in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

DEBUG - Static variable in class org.fusesource.hawtdispatch.internal.NioDispatchSource

debug(String, Object...) - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

debug(Throwable, String, Object...) - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

DEBUG - Static variable in class org.fusesource.hawtdispatch.internal.pool.SimplePool

debug(String, Object...) - Method in class org.fusesource.hawtdispatch.internal.pool.SimplePool

debug(Throwable, String, Object...) - Method in class org.fusesource.hawtdispatch.internal.pool.SimplePool

DEBUG - Static variable in class org.fusesource.hawtdispatch.internal.pool.SimpleThread

debug(String, Object...) - Method in class org.fusesource.hawtdispatch.internal.pool.SimpleThread

debug(Throwable, String, Object...) - Method in class org.fusesource.hawtdispatch.internal.pool.SimpleThread

decrementAndGet() - Method in class org.fusesource.hawtdispatch.internal.util.IntegerCounter

DEFAULT - Static variable in class org.fusesource.hawtdispatch.Dispatch

DEFAULT_QUEUE - Variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

defaultConstant(Type) - Method in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

defaultDispatcher - Static variable in class org.fusesource.hawtdispatch.internal.DispatcherConfig

DefaultTransportListener - Class in org.fusesource.hawtdispatch.transport

DefaultTransportListener() - Constructor for class org.fusesource.hawtdispatch.transport.DefaultTransportListener

defineClass(String, byte[]) - Method in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

defineClassMethod - Variable in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

dequeued - Variable in class org.fusesource.hawtdispatch.internal.ActiveMetricsCollector

dequeued - Variable in class org.fusesource.hawtdispatch.Metrics

The number of runnable tasks that have been removed from the queue and executed.

directReadBuffer - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

disabledCypherSuites - Variable in class org.fusesource.hawtdispatch.transport.SslTransport

disabledCypherSuites - Variable in class org.fusesource.hawtdispatch.transport.SslTransportServer

DISCONNECTED() - Constructor for class org.fusesource.hawtdispatch.transport.TcpTransport.DISCONNECTED

DISCONNECTED() - Constructor for class org.fusesource.hawtdispatch.transport.UdpTransport.DISCONNECTED

Dispatch - Class in org.fusesource.hawtdispatch

The Dispatch class is used to get or create dispatch objects such as global queues, thread queues, serial queues, or dispatch sources.

Dispatch() - Constructor for class org.fusesource.hawtdispatch.Dispatch

DISPATCH_QUEUE - Static variable in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

dispatchApply(DispatchQueue, int, Runnable) - Static method in class org.fusesource.hawtdispatch.internal.util.QueueSupport

dispatchApply(DispatchQueue, int, Task) - Static method in class org.fusesource.hawtdispatch.internal.util.QueueSupport

DISPATCHER - Static variable in class org.fusesource.hawtdispatch.Dispatch

Dispatcher - Interface in org.fusesource.hawtdispatch

The Dispatcher interface is used to get or create dispatch objects such as global queues, thread queues, serial queues, or dispatch sources.

dispatcher - Variable in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

dispatcher - Variable in class org.fusesource.hawtdispatch.internal.HawtThreadGroup

dispatcher - Variable in class org.fusesource.hawtdispatch.jmx.JmxService.JmxDispatcher

DISPATCHER_OBJECT_NAME - Static variable in class org.fusesource.hawtdispatch.jmx.JmxService

DispatcherConfig - Class in org.fusesource.hawtdispatch.internal

DispatcherConfig() - Constructor for class org.fusesource.hawtdispatch.internal.DispatcherConfig

DispatchObject - Interface in org.fusesource.hawtdispatch

Implemented by dispatch objects that can be configured with a target queue that it uses for executing the object's asynchronous tasks.

DispatchPriority - Enum in org.fusesource.hawtdispatch

Defines the supported global/concurrent queue priorities.

DispatchPriority() - Constructor for enum org.fusesource.hawtdispatch.DispatchPriority

DispatchQueue - Interface in org.fusesource.hawtdispatch

Dispatch queues are lightweight objects to which runnable objects may be submitted for asynchronous execution and therefore are Executor objects.

dispatchQueue - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

dispatchQueue - Variable in class org.fusesource.hawtdispatch.transport.PipeTransportServer

dispatchQueue - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

dispatchQueue - Variable in class org.fusesource.hawtdispatch.transport.TcpTransportServer

dispatchQueue - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

dispatchQueue - Variable in class org.fusesource.hawtdispatch.transport.UdpTransportServer

DispatchQueue.QueueType - Enum in org.fusesource.hawtdispatch

Defines the types of dispatch queues supported by the system.

DispatchQueueProxy - Class in org.fusesource.hawtdispatch

This class creates proxy objects that allow you to easily service all method calls to an interface via a DispatchQueue.

DispatchQueueProxy() - Constructor for class org.fusesource.hawtdispatch.DispatchQueueProxy

DispatchQueueProxy.Generator<T> - Class in org.fusesource.hawtdispatch

DispatchSource - Interface in org.fusesource.hawtdispatch

A dispatch source is used to monitor low-level system objects and automatically submit a handler runnable to a dispatch queue in response to events.

dispatchSource - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

dispose() - Method in class org.fusesource.hawtdispatch.BaseRetained

This method will be called once the release retained reaches zero.

dispose - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport.CANCELING

dispose() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

dispose - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport.CANCELING

dispose() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

disposed - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport.CANCELED

disposed - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport.CANCELED

disposer - Variable in class org.fusesource.hawtdispatch.BaseRetained

done() - Method in class org.fusesource.hawtdispatch.transport.ServiceBase.CallbackSupport

drainInbound() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

drainInbound() - Method in class org.fusesource.hawtdispatch.transport.SslTransport

drainInbound() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

drainInbound() - Method in interface org.fusesource.hawtdispatch.transport.Transport

drainInbound() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

drainInbound() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

drainOutboundSource - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

drainOutboundSource - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

drains - Variable in class org.fusesource.hawtdispatch.internal.DispatcherConfig

drains - Variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

drains() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

dumpProxy(Method[]) - Method in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

dumpRunnable(int, Method) - Method in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

durationNS - Variable in class org.fusesource.hawtdispatch.Metrics

How long the metrics gathered

E

enabledCipherSuites - Variable in class org.fusesource.hawtdispatch.transport.SslTransport

encode(Object) - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

engine - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

engine - Variable in class org.fusesource.hawtdispatch.transport.SslTransport

enqueue(Task) - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

enqueued - Variable in class org.fusesource.hawtdispatch.internal.ActiveMetricsCollector

enqueued - Variable in class org.fusesource.hawtdispatch.Metrics

The number of runnable tasks queued.

EOF_TOKEN - Static variable in class org.fusesource.hawtdispatch.transport.PipeTransport

equals(Object) - Method in class org.fusesource.hawtdispatch.internal.util.IntegerCounter

equals(Object) - Method in class org.fusesource.hawtdispatch.TaskWrapper

error(String) - Method in class org.fusesource.hawtdispatch.transport.ServiceBase

EventAggregator<Event,MergedEvent> - Interface in org.fusesource.hawtdispatch

The EventAggregator interface is used by the CustomDispatchSource objects to handle coalescing data before passing it to the application.

EventAggregators - Class in org.fusesource.hawtdispatch

EventAggregators() - Constructor for class org.fusesource.hawtdispatch.EventAggregators

eventHandler - Variable in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

eventHandler - Variable in class org.fusesource.hawtdispatch.internal.NioDispatchSource

execute(Runnable) - Method in class org.fusesource.hawtdispatch.AggregatingExecutor

execute(Runnable) - Method in interface org.fusesource.hawtdispatch.DispatchQueue

Submits a runnable for asynchronous execution on a dispatch queue.

execute(Task) - Method in interface org.fusesource.hawtdispatch.DispatchQueue

Submits a task for asynchronous execution on a dispatch queue.

execute(Runnable) - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

Deprecated.

execute(Task) - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

execute(Task) - Method in class org.fusesource.hawtdispatch.internal.pool.SimplePool

execute(Task) - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

execute(Runnable) - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

Deprecated.

execute(Runnable) - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

Deprecated.

execute(Task) - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

execute(V) - Method in class org.fusesource.hawtdispatch.internal.util.TimerHeap

Subclass must override this to execute ready timers

execute(Task) - Method in interface org.fusesource.hawtdispatch.internal.WorkerPool

executeAfter(long, TimeUnit, Runnable) - Method in interface org.fusesource.hawtdispatch.DispatchQueue

Schedule a runnable for execution on a given queue at a specified time.

executeAfter(long, TimeUnit, Task) - Method in interface org.fusesource.hawtdispatch.DispatchQueue

Schedule a task for execution on a given queue at a specified time.

executeAfter(long, TimeUnit, Runnable) - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

Deprecated.

executeAfter(long, TimeUnit, Task) - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

executeAfter(long, TimeUnit, Runnable) - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

Deprecated.

executeAfter(long, TimeUnit, Task) - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

executeAfter(long, TimeUnit, Runnable) - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

Deprecated.

executeAfter(long, TimeUnit, Task) - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

executeReadyTimers() - Method in class org.fusesource.hawtdispatch.internal.util.TimerHeap

Executes ready timers.

executing - Variable in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

externalQueue - Variable in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

externalQueue - Variable in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

extractProperties(Map, String) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

F

fillString(int, char) - Static method in class org.fusesource.hawtdispatch.internal.util.StringSupport

findSetterMethod(Class<?>, String) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

fire(int) - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

fireConnected() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

firedEvent - Variable in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

fireEvent(MergedEvent) - Method in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

flush() - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

flush() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

flush() - Method in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

Attempts to complete the previous write which did not complete.

flush() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

flush() - Method in class org.fusesource.hawtdispatch.transport.SslTransport

flush() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

flush() - Method in interface org.fusesource.hawtdispatch.transport.Transport

Forces a flush of any output buffers.

flush() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

flush() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

flushNextWriteBuffer() - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

full() - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

full() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

full() - Method in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

Is the codec's buffer full?

full() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

full() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

full() - Method in interface org.fusesource.hawtdispatch.transport.Transport

full() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

full() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

G

generate() - Method in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

Generator(ClassLoader, Class<T>) - Constructor for class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

get() - Method in class org.fusesource.hawtdispatch.internal.util.IntegerCounter

getAndAdd(int) - Method in class org.fusesource.hawtdispatch.internal.util.IntegerCounter

getAndDecrement() - Method in class org.fusesource.hawtdispatch.internal.util.IntegerCounter

getAndIncrement() - Method in class org.fusesource.hawtdispatch.internal.util.IntegerCounter

getAndSet(int) - Method in class org.fusesource.hawtdispatch.internal.util.IntegerCounter

getBacklog() - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

getBlockingExecutor() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

getBlockingExecutor() - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

getBlockingExecutor() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

getBlockingExecutor() - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

getBlockingExecutor() - Method in interface org.fusesource.hawtdispatch.transport.Transport

getBlockingExecutor() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

getBlockingExecutor() - Method in interface org.fusesource.hawtdispatch.transport.TransportServer

getBlockingExecutor() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

getBlockingExecutor() - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

getBoundAddress() - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

getBoundAddress() - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

getBoundAddress() - Method in interface org.fusesource.hawtdispatch.transport.TransportServer

getBoundAddress() - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

getBufferPool(int) - Method in class org.fusesource.hawtdispatch.util.BufferPools

getBufferPools() - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

getBufferSize() - Method in class org.fusesource.hawtdispatch.util.BufferPool

getClientAuth() - Method in class org.fusesource.hawtdispatch.transport.SslTransport

getClientAuth() - Method in class org.fusesource.hawtdispatch.transport.SslTransportServer

getCount() - Method in class org.fusesource.hawtdispatch.internal.util.RunnableCountDownLatch

getCurrentNioManager() - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

getCurrentQueue() - Static method in class org.fusesource.hawtdispatch.Dispatch

Returns the queue on which the currently executing runnable is running.

getCurrentQueue() - Method in interface org.fusesource.hawtdispatch.Dispatcher

Returns the queue on which the currently executing runnable is running.

getCurrentQueue() - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

getCurrentThreadQueue() - Static method in class org.fusesource.hawtdispatch.Dispatch

getCurrentThreadQueue() - Method in interface org.fusesource.hawtdispatch.Dispatcher

getCurrentThreadQueue() - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

getData() - Method in interface org.fusesource.hawtdispatch.CustomDispatchSource

Returns pending data for the dispatch source.

getData() - Method in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

getData() - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

getDatagramChannel() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

getDefaultDispatcher() - Static method in class org.fusesource.hawtdispatch.internal.DispatcherConfig

getDescription(MBeanAttributeInfo) - Method in class org.fusesource.hawtdispatch.jmx.AnnotatedMBean

getDescription(MBeanOperationInfo) - Method in class org.fusesource.hawtdispatch.jmx.AnnotatedMBean

getDisabledCypherSuites() - Method in class org.fusesource.hawtdispatch.transport.SslTransport

getDisabledCypherSuites() - Method in class org.fusesource.hawtdispatch.transport.SslTransportServer

getDispatcher() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

getDispatcher() - Method in interface org.fusesource.hawtdispatch.internal.HawtDispatchQueue

getDispatcher() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

getDispatcher() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

getDispatchQueue() - Method in class org.fusesource.hawtdispatch.internal.pool.SimpleThread

getDispatchQueue() - Method in class org.fusesource.hawtdispatch.internal.WorkerThread

getDispatchQueue() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

getDispatchQueue() - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

getDispatchQueue() - Method in class org.fusesource.hawtdispatch.transport.ServiceBase

getDispatchQueue() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

getDispatchQueue() - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

getDispatchQueue() - Method in interface org.fusesource.hawtdispatch.transport.Transport

Returns the dispatch queue used by the transport

getDispatchQueue() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

getDispatchQueue() - Method in interface org.fusesource.hawtdispatch.transport.TransportServer

Returns the dispatch queue used by the transport

getDispatchQueue() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

getDispatchQueue() - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

getDisposer() - Method in class org.fusesource.hawtdispatch.BaseRetained

getDrains() - Method in class org.fusesource.hawtdispatch.internal.DispatcherConfig

getEnabledCypherSuites() - Method in class org.fusesource.hawtdispatch.transport.SslTransport

getGlobalQueue() - Static method in class org.fusesource.hawtdispatch.Dispatch

Returns the global concurrent queue of default priority.

getGlobalQueue(DispatchPriority) - Static method in class org.fusesource.hawtdispatch.Dispatch

Returns a well-known global concurrent queue of a given priority level.

getGlobalQueue() - Method in interface org.fusesource.hawtdispatch.Dispatcher

Returns the global concurrent queue of default priority.

getGlobalQueue(DispatchPriority) - Method in interface org.fusesource.hawtdispatch.Dispatcher

Returns a well-known global concurrent queue of a given priority level.

getGlobalQueue() - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

getGlobalQueue(DispatchPriority) - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

getInitialReadCheckDelay() - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

getInitialWriteCheckDelay() - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

getLabel() - Method in interface org.fusesource.hawtdispatch.DispatchQueue

Returns the label of the queue.

getLabel() - Method in class org.fusesource.hawtdispatch.internal.DispatcherConfig

getLabel() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

getLabel() - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

getLabel() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

getLabel() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

getLastReadSize() - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

getLastReadSize() - Method in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

getLastReadSize() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

getLastWriteSize() - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

getLastWriteSize() - Method in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

getLastWriteSize() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

getLocalAddress() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

getLocalAddress() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

getLocalAddress() - Method in interface org.fusesource.hawtdispatch.transport.Transport

getLocalAddress() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

getLocalAddress() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

getLocalHost() - Static method in class org.fusesource.hawtdispatch.transport.TcpTransport

getMaxReadRate() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

getMaxWriteRate() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

getMethod(MBeanOperationInfo) - Method in class org.fusesource.hawtdispatch.jmx.AnnotatedMBean

Extracts the Method from the MBeanOperationInfo

getMethod(Class<?>, String, String...) - Static method in class org.fusesource.hawtdispatch.jmx.AnnotatedMBean

Returns the Method with the specified name and parameter types for the given class, null if it doesn't exist.

getMetrics() - Method in class org.fusesource.hawtdispatch.jmx.JmxService.JmxDispatcher

getMetrics() - Method in interface org.fusesource.hawtdispatch.jmx.JmxService.JmxDispatcherMBean

getName() - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

getNext() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

getNext() - Method in interface org.fusesource.hawtdispatch.transport.WrappingProtocolCodec

getNioManager() - Method in class org.fusesource.hawtdispatch.internal.pool.SimpleThread

getNioManager() - Method in class org.fusesource.hawtdispatch.internal.WorkerThread

getOnDead() - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

getOnKeepAlive() - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

getParameterName(MBeanOperationInfo, MBeanParameterInfo, int) - Method in class org.fusesource.hawtdispatch.jmx.AnnotatedMBean

getPeerX509Certificates() - Method in interface org.fusesource.hawtdispatch.transport.SecuredSession

Gets the X509Certificate associated withe the peer.

getPeerX509Certificates() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

getPeerX509Certificates() - Method in class org.fusesource.hawtdispatch.transport.SslTransport

getPool() - Method in class org.fusesource.hawtdispatch.util.ThreadLocalPool

getPriority() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

getPriority() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

getProfile() - Method in class org.fusesource.hawtdispatch.jmx.JmxService.JmxDispatcher

getProfile() - Method in interface org.fusesource.hawtdispatch.jmx.JmxService.JmxDispatcherMBean

getProperties(Object, Map, String) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

getPropertyType(Object, String) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

getProtocolCodec() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

getProtocolCodec() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

getProtocolCodec() - Method in interface org.fusesource.hawtdispatch.transport.Transport

getProtocolCodec() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

getProtocolCodec() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

getProxyClass(ClassLoader, Class<T>) - Static method in class org.fusesource.hawtdispatch.DispatchQueueProxy

getQueueType() - Method in interface org.fusesource.hawtdispatch.DispatchQueue

getQueueType() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

getQueueType() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

getQueueType() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

getReadBufferSize() - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

getReadBufferSize() - Method in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

getReadBufferSize() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

getReadChannel() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

getReadChannel() - Method in class org.fusesource.hawtdispatch.transport.SslTransport

getReadChannel() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

getReadChannel() - Method in interface org.fusesource.hawtdispatch.transport.Transport

getReadChannel() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

getReadChannel() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

getReadCounter() - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

getReadCounter() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

getReadCounter() - Method in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

getReadCounter() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

getReadInterval() - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

getReceiveBufferSize() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

getReceiveBufferSize() - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

getReceiveBufferSize() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

getRegisteredKeyCount() - Method in class org.fusesource.hawtdispatch.internal.NioManager

getRemoteAddress() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

getRemoteAddress() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

getRemoteAddress() - Method in interface org.fusesource.hawtdispatch.transport.Transport

getRemoteAddress() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

getRemoteAddress() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

getSendBufferSize() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

getSendBufferSize() - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

getSendBufferSize() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

getServers() - Static method in class org.fusesource.hawtdispatch.transport.PipeTransportRegistry

getServiceState() - Method in class org.fusesource.hawtdispatch.transport.ServiceBase

getSocketAddress() - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

getSocketAddress() - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

getSocketAddress() - Method in interface org.fusesource.hawtdispatch.transport.TransportServer

getSocketAddress() - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

getSocketChannel() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

getSourceQueue() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

getSourceQueue() - Method in interface org.fusesource.hawtdispatch.internal.HawtDispatchQueue

getSourceQueue() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

getSourceQueue() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

getSSLContext() - Method in class org.fusesource.hawtdispatch.transport.SslTransportServer

getSSLSession() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

getSSLSession() - Method in class org.fusesource.hawtdispatch.transport.SslTransport

getTargetQueue() - Method in interface org.fusesource.hawtdispatch.DispatchObject

Gets the target queue for this object.

getTargetQueue() - Method in class org.fusesource.hawtdispatch.internal.AbstractDispatchObject

getTargetQueue() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

getTargetQueue() - Method in interface org.fusesource.hawtdispatch.internal.HawtDispatchQueue

getTargetQueue() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

getThread() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

getThreadQueues(DispatchPriority) - Static method in class org.fusesource.hawtdispatch.Dispatch

getThreadQueues(DispatchPriority) - Method in interface org.fusesource.hawtdispatch.Dispatcher

getThreadQueues() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

getThreadQueues(DispatchPriority) - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

getThreads() - Method in class org.fusesource.hawtdispatch.internal.DispatcherConfig

getThreads() - Method in class org.fusesource.hawtdispatch.internal.pool.SimplePool

getThreads() - Method in interface org.fusesource.hawtdispatch.internal.WorkerPool

getTimeUnit() - Method in class org.fusesource.hawtdispatch.jmx.JmxService.JmxDispatcher

getTimeUnit() - Method in interface org.fusesource.hawtdispatch.jmx.JmxService.JmxDispatcherMBean

getTrafficClass() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

getTrafficClass() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

getTransport() - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

getTransportListener() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

getTransportListener() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

getTransportListener() - Method in interface org.fusesource.hawtdispatch.transport.Transport

Returns the current transport listener

getTransportListener() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

getTransportListener() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

getUncaughtExceptionHandler() - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

getWriteBufferSize() - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

getWriteBufferSize() - Method in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

getWriteBufferSize() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

getWriteChannel() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

getWriteChannel() - Method in class org.fusesource.hawtdispatch.transport.SslTransport

getWriteChannel() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

getWriteChannel() - Method in interface org.fusesource.hawtdispatch.transport.Transport

getWriteChannel() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

getWriteChannel() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

getWriteCounter() - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

getWriteCounter() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

getWriteCounter() - Method in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

getWriteCounter() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

getWriteInterval() - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

GlobalDispatchQueue - Class in org.fusesource.hawtdispatch.internal

GlobalDispatchQueue(HawtDispatcher, DispatchPriority, int) - Constructor for class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

globalQueue - Variable in class org.fusesource.hawtdispatch.internal.pool.SimplePool

globalQueue - Variable in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

group - Variable in class org.fusesource.hawtdispatch.internal.pool.SimplePool

H

handleSocket(SocketChannel) - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

handshake() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

handshake() - Method in class org.fusesource.hawtdispatch.transport.SslTransport

hashCode() - Method in class org.fusesource.hawtdispatch.internal.util.IntegerCounter

hashCode() - Method in class org.fusesource.hawtdispatch.TaskWrapper

hashSet() - Static method in class org.fusesource.hawtdispatch.EventAggregators

An EventAggregator that coalesces object data obtained via calls to CustomDispatchSource.merge(Object) into a hash set.

HawtCustomDispatchSource<Event,MergedEvent> - Class in org.fusesource.hawtdispatch.internal

HawtCustomDispatchSource(HawtDispatcher, EventAggregator<Event, MergedEvent>, DispatchQueue) - Constructor for class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

HawtDispatcher - Class in org.fusesource.hawtdispatch.internal

Implements a simple dispatch system.

HawtDispatcher(DispatcherConfig) - Constructor for class org.fusesource.hawtdispatch.internal.HawtDispatcher

HawtDispatchQueue - Interface in org.fusesource.hawtdispatch.internal

HawtThreadGroup - Class in org.fusesource.hawtdispatch.internal

HawtThreadGroup(HawtDispatcher, String) - Constructor for class org.fusesource.hawtdispatch.internal.HawtThreadGroup

HeartBeatMonitor - Class in org.fusesource.hawtdispatch.transport

A HeartBeatMonitor can be used to watch the read and write activity of a transport and raise events when the write side or read side has been idle too long.

HeartBeatMonitor() - Constructor for class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

HIGH - Static variable in class org.fusesource.hawtdispatch.Dispatch

HIGH_MUTEX - Variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

HIGH_QUEUE - Variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

hitCounter - Variable in class org.fusesource.hawtdispatch.util.ThreadLocalPool.Pool

I

InactiveMetricsCollector - Class in org.fusesource.hawtdispatch.internal

InactiveMetricsCollector() - Constructor for class org.fusesource.hawtdispatch.internal.InactiveMetricsCollector

incrementAndGet() - Method in class org.fusesource.hawtdispatch.internal.util.IntegerCounter

indent(String, int) - Static method in class org.fusesource.hawtdispatch.internal.util.StringSupport

initialDecodeAction() - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

initializeChannel() - Method in class org.fusesource.hawtdispatch.transport.SslTransport

initializeChannel() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

initializeChannel() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

initializeCodec() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

initializeCodec() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

initializeEngine() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

initialReadCheckDelay - Variable in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

initialWriteCheckDelay - Variable in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

initNext() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

initRateLimitingChannel() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

INSTANCE - Static variable in class org.fusesource.hawtdispatch.internal.InactiveMetricsCollector

INTEGER_ADD - Static variable in class org.fusesource.hawtdispatch.EventAggregators

An EventAggregator that coalesces integer data obtained via calls to CustomDispatchSource.merge(Object).

INTEGER_OR - Static variable in class org.fusesource.hawtdispatch.EventAggregators

An EventAggregator that coalesces integer data obtained via calls to CustomDispatchSource.merge(Object).

IntegerCounter - Class in org.fusesource.hawtdispatch.internal.util

IntegerCounter() - Constructor for class org.fusesource.hawtdispatch.internal.util.IntegerCounter

IntegerCounter(int) - Constructor for class org.fusesource.hawtdispatch.internal.util.IntegerCounter

interestOps - Variable in class org.fusesource.hawtdispatch.internal.NioDispatchSource

interfaceClass - Variable in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

interfaceName - Variable in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

internal_cancel() - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

IntrospectionSupport - Class in org.fusesource.hawtdispatch.internal.util

IntrospectionSupport() - Constructor for class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

intValue() - Method in class org.fusesource.hawtdispatch.internal.util.IntegerCounter

IPTOS_LOWCOST - Static variable in class org.fusesource.hawtdispatch.transport.TcpTransport

IPTOS_LOWCOST - Static variable in class org.fusesource.hawtdispatch.transport.UdpTransport

IPTOS_LOWDELAY - Static variable in class org.fusesource.hawtdispatch.transport.TcpTransport

IPTOS_LOWDELAY - Static variable in class org.fusesource.hawtdispatch.transport.UdpTransport

IPTOS_RELIABILITY - Static variable in class org.fusesource.hawtdispatch.transport.TcpTransport

IPTOS_RELIABILITY - Static variable in class org.fusesource.hawtdispatch.transport.UdpTransport

IPTOS_THROUGHPUT - Static variable in class org.fusesource.hawtdispatch.transport.TcpTransport

IPTOS_THROUGHPUT - Static variable in class org.fusesource.hawtdispatch.transport.UdpTransport

is(Class<? extends TcpTransport.SocketState>) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.SocketState

is(Class<? extends UdpTransport.SocketState>) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport.SocketState

isCanceled() - Method in interface org.fusesource.hawtdispatch.DispatchSource

isCanceled() - Method in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

isCanceled() - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

isClosed() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

isClosed() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

isClosed() - Method in interface org.fusesource.hawtdispatch.transport.Transport

isClosed() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

isClosed() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

isCloseOnCancel() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

isConnected() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

isConnected() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

isConnected() - Method in interface org.fusesource.hawtdispatch.transport.Transport

isConnected() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

isConnected() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

isCurrent(DispatchQueue) - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

isEmpty() - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

isExecuting() - Method in interface org.fusesource.hawtdispatch.DispatchQueue

Returns true if this dispatch queue is executing the caller.

isExecuting() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

isExecuting() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

isExecuting() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

isGlobalDispatchQueue() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

isGlobalDispatchQueue() - Method in interface org.fusesource.hawtdispatch.internal.HawtDispatchQueue

isGlobalDispatchQueue() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

isGlobalDispatchQueue() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

isJmx() - Method in class org.fusesource.hawtdispatch.internal.DispatcherConfig

isKeepAlive() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

isMarshal() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

isMarshal() - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

isOpen() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec.SSLReadChannel

isOpen() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec.SSLWriteChannel

isOpen() - Method in class org.fusesource.hawtdispatch.transport.SslTransport.SSLChannel

isOpen() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

isProfile() - Method in class org.fusesource.hawtdispatch.internal.DispatcherConfig

isSerialDispatchQueue() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

isSerialDispatchQueue() - Method in interface org.fusesource.hawtdispatch.internal.HawtDispatchQueue

isSerialDispatchQueue() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

isSerialDispatchQueue() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

isSettableType(Class<?>) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

isStarted() - Method in class org.fusesource.hawtdispatch.transport.ServiceBase.State

isStarting() - Method in class org.fusesource.hawtdispatch.transport.ServiceBase.STARTING

isStarting() - Method in class org.fusesource.hawtdispatch.transport.ServiceBase.State

isSuspended() - Method in class org.fusesource.hawtdispatch.internal.BaseSuspendable

isSuspended() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

isSuspended() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

isSuspended() - Method in interface org.fusesource.hawtdispatch.Suspendable

isThreadDispatchQueue() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

isThreadDispatchQueue() - Method in interface org.fusesource.hawtdispatch.internal.HawtDispatchQueue

isThreadDispatchQueue() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

isThreadDispatchQueue() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

isTrace() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

isUseLocalHost() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

isUseLocalHost() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

itemDescriptionsList - Variable in class org.fusesource.hawtdispatch.jmx.JmxService.CompositeTypeFactory

itemNamesList - Variable in class org.fusesource.hawtdispatch.jmx.JmxService.CompositeTypeFactory

itemTypesList - Variable in class org.fusesource.hawtdispatch.jmx.JmxService.CompositeTypeFactory

J

jmx - Variable in class org.fusesource.hawtdispatch.internal.DispatcherConfig

jmx - Variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

JmxDispatcher(Dispatcher) - Constructor for class org.fusesource.hawtdispatch.jmx.JmxService.JmxDispatcher

JmxService - Class in org.fusesource.hawtdispatch.jmx

JmxService() - Constructor for class org.fusesource.hawtdispatch.jmx.JmxService

JmxService.CompositeTypeFactory - Class in org.fusesource.hawtdispatch.jmx

JmxService.JmxDispatcher - Class in org.fusesource.hawtdispatch.jmx

JmxService.JmxDispatcherMBean - Interface in org.fusesource.hawtdispatch.jmx

K

keepAlive - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

key - Variable in class org.fusesource.hawtdispatch.internal.NioAttachment

key() - Method in class org.fusesource.hawtdispatch.internal.NioAttachment

key() - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource.KeyState

key_cancel() - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

keyManagers - Variable in class org.fusesource.hawtdispatch.transport.SslTransportServer

keyState - Variable in class org.fusesource.hawtdispatch.internal.NioDispatchSource

KeyState(NioAttachment) - Constructor for class org.fusesource.hawtdispatch.internal.NioDispatchSource.KeyState

L

label - Variable in class org.fusesource.hawtdispatch.internal.DispatcherConfig

label - Variable in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

label - Variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

label - Variable in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

label - Variable in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

lastReadIoSize - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

lastReadSize - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

lastWriteIoSize - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

lastWriteSize - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

latch - Variable in class org.fusesource.hawtdispatch.internal.util.RunnableCountDownLatch

linkedList() - Static method in class org.fusesource.hawtdispatch.EventAggregators

An EventAggregator that coalesces object data obtained via calls to CustomDispatchSource.merge(Object) into a linked list.

listener - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

listener - Variable in class org.fusesource.hawtdispatch.transport.PipeTransportServer

listener - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

listener - Variable in class org.fusesource.hawtdispatch.transport.TcpTransportServer

listener - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

listener - Variable in class org.fusesource.hawtdispatch.transport.UdpTransportServer

loader - Variable in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

localAddress - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

localAddress - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

localhost - Static variable in class org.fusesource.hawtdispatch.transport.TcpTransport

localLocation - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

localLocation - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

localQueue - Variable in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

localTasks - Variable in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

lock - Variable in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

LONG_ADD - Static variable in class org.fusesource.hawtdispatch.EventAggregators

An EventAggregator that coalesces long data obtained via calls to CustomDispatchSource.merge(Object).

LONG_OR - Static variable in class org.fusesource.hawtdispatch.EventAggregators

An EventAggregator that coalesces long data obtained via calls to CustomDispatchSource.merge(Object).

lookup(String) - Static method in class org.fusesource.hawtdispatch.transport.PipeTransportRegistry

LOW - Static variable in class org.fusesource.hawtdispatch.Dispatch

LOW_MUTEX - Variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

LOW_QUEUE - Variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

M

marshal - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

marshal - Variable in class org.fusesource.hawtdispatch.transport.PipeTransportServer

max_run_time - Variable in class org.fusesource.hawtdispatch.internal.ActiveMetricsCollector

MAX_TRACES - Static variable in class org.fusesource.hawtdispatch.BaseRetained

max_wait_time - Variable in class org.fusesource.hawtdispatch.internal.ActiveMetricsCollector

maxOutbound - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

maxPoolSizePerThread() - Method in class org.fusesource.hawtdispatch.util.ThreadLocalPool

maxReadRate - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

maxRunTimeNS - Variable in class org.fusesource.hawtdispatch.Metrics

The long amount of time a runnable task spent executing in nanoseconds.

maxWaitTimeNS - Variable in class org.fusesource.hawtdispatch.Metrics

The longest amount of time at runnable task spent waiting in the queue.

maxWriteRate - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

MBeanInfo - Annotation Type in org.fusesource.hawtdispatch.jmx

merge(Event) - Method in interface org.fusesource.hawtdispatch.CustomDispatchSource

Merges data into a dispatch source and submits its event handler runnable to its target queue.

merge(Event) - Method in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

mergeEvent(MergedEvent, Event) - Method in interface org.fusesource.hawtdispatch.EventAggregator

Merge the given event with the previous event values.

mergeEvents(MergedEvent, MergedEvent) - Method in interface org.fusesource.hawtdispatch.EventAggregator

Merge the given events with the previous event values.

metrics() - Static method in class org.fusesource.hawtdispatch.Dispatch

Used to get profiling metrics for all the queues currently being profiled.

metrics() - Method in interface org.fusesource.hawtdispatch.Dispatcher

Used to get profiling metrics for all the queues currently being profiled.

metrics() - Method in interface org.fusesource.hawtdispatch.DispatchQueue

Returns the usage metrics of this queue.

metrics() - Method in class org.fusesource.hawtdispatch.internal.ActiveMetricsCollector

metrics() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

metrics() - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

metrics() - Method in class org.fusesource.hawtdispatch.internal.InactiveMetricsCollector

metrics() - Method in class org.fusesource.hawtdispatch.internal.MetricsCollector

metrics() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

metrics() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

Metrics - Class in org.fusesource.hawtdispatch

Metrics() - Constructor for class org.fusesource.hawtdispatch.Metrics

METRICS_COMPOSITE_TYPE - Static variable in class org.fusesource.hawtdispatch.jmx.JmxService

MetricsCollector - Class in org.fusesource.hawtdispatch.internal

MetricsCollector() - Constructor for class org.fusesource.hawtdispatch.internal.MetricsCollector

metricsCollector - Variable in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

missCounter - Variable in class org.fusesource.hawtdispatch.util.ThreadLocalPool.Pool

mutex - Variable in class org.fusesource.hawtdispatch.internal.TimerThread

N

name - Variable in class org.fusesource.hawtdispatch.internal.pool.SimplePool

name - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

name - Variable in class org.fusesource.hawtdispatch.transport.PipeTransportServer

next - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

next - Variable in class org.fusesource.hawtdispatch.transport.TransportFilter

nextDecodeAction - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

nextWriteBuffer - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

NioAttachment - Class in org.fusesource.hawtdispatch.internal

NioAttachment(SelectionKey) - Constructor for class org.fusesource.hawtdispatch.internal.NioAttachment

NioDispatchSource - Class in org.fusesource.hawtdispatch.internal

Implements the DispatchSource interface.

NioDispatchSource(HawtDispatcher, SelectableChannel, int, DispatchQueue) - Constructor for class org.fusesource.hawtdispatch.internal.NioDispatchSource

NioDispatchSource.KeyState - Class in org.fusesource.hawtdispatch.internal

NioManager - Class in org.fusesource.hawtdispatch.internal

NioManager() - Constructor for class org.fusesource.hawtdispatch.internal.NioManager

nioManager - Variable in class org.fusesource.hawtdispatch.internal.pool.SimpleThread

NioManager.SelectStrategy - Class in org.fusesource.hawtdispatch.internal

Handles doing a select on a selector.

NioManager.WorkAroundSelectSpin - Class in org.fusesource.hawtdispatch.internal

Workaround for the selector spin bug.

NO_OP - Static variable in class org.fusesource.hawtdispatch.internal.util.RunnableSupport

NOOP - Static variable in class org.fusesource.hawtdispatch.Dispatch

A Runnable task that does nothing.

O

OBJECT_CLASS - Static variable in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

objectName(HawtDispatcher) - Static method in class org.fusesource.hawtdispatch.jmx.JmxService

objects - Variable in class org.fusesource.hawtdispatch.util.ThreadLocalPool.Pool

objectsThreadLocal - Variable in class org.fusesource.hawtdispatch.util.ThreadLocalPool

offer(Object) - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

offer(Object) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

offer(Object) - Method in interface org.fusesource.hawtdispatch.transport.Transport

A one way asynchronous send of a command.

offer(Object) - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

offer(Object) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

onAccept(Transport) - Method in interface org.fusesource.hawtdispatch.transport.TransportServerListener

onAcceptError(Exception) - Method in interface org.fusesource.hawtdispatch.transport.TransportServerListener

onBufferFlushed(ByteBuffer) - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

Called when a buffer is flushed out.

onCanceled() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.CANCELING

onCanceled() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.CONNECTED

onCanceled() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.CONNECTING

onCanceled() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.SocketState

onCanceled() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport.CANCELING

onCanceled() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport.CONNECTED

onCanceled() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport.CONNECTING

onCanceled() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport.SocketState

onConnected() - Method in class org.fusesource.hawtdispatch.transport.SslTransport

onConnected() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

onConnected() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

onDead - Variable in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

onDispose - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

OneWay(Object, Retained) - Constructor for class org.fusesource.hawtdispatch.transport.PipeTransport.OneWay

OneWay(Object, Retained) - Constructor for class org.fusesource.hawtdispatch.transport.TcpTransport.OneWay

OneWay(Object, Retained) - Constructor for class org.fusesource.hawtdispatch.transport.UdpTransport.OneWay

onKeepAlive - Variable in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

onRefill() - Method in class org.fusesource.hawtdispatch.transport.DefaultTransportListener

onRefill() - Method in interface org.fusesource.hawtdispatch.transport.TransportListener

transport can now accept more commands for transmission.

onResume() - Method in class org.fusesource.hawtdispatch.internal.BaseSuspendable

onResume() - Method in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

onResume() - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

onResume() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

onStartup() - Method in class org.fusesource.hawtdispatch.internal.BaseSuspendable

onStartup() - Method in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

onStartup() - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

onStartup() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

onStop(Task) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.CANCELED

onStop(Task) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.CANCELING

onStop(Task) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.CONNECTED

onStop(Task) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.CONNECTING

onStop(Task) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.SocketState

onStop(Task) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport.CANCELED

onStop(Task) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport.CANCELING

onStop(Task) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport.CONNECTED

onStop(Task) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport.CONNECTING

onStop(Task) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport.SocketState

onSuspend() - Method in class org.fusesource.hawtdispatch.internal.BaseSuspendable

onSuspend() - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

onTransportCommand(Object) - Method in class org.fusesource.hawtdispatch.transport.DefaultTransportListener

onTransportCommand(Object) - Method in interface org.fusesource.hawtdispatch.transport.TransportListener

called to process a command

onTransportConnected() - Method in class org.fusesource.hawtdispatch.transport.DefaultTransportListener

onTransportConnected() - Method in interface org.fusesource.hawtdispatch.transport.TransportListener

The transport has been connected.

onTransportDisconnected() - Method in class org.fusesource.hawtdispatch.transport.DefaultTransportListener

onTransportDisconnected() - Method in interface org.fusesource.hawtdispatch.transport.TransportListener

The transport has been disconnected.

onTransportFailure(IOException) - Method in class org.fusesource.hawtdispatch.transport.DefaultTransportListener

onTransportFailure(IOException) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

onTransportFailure(IOException) - Method in interface org.fusesource.hawtdispatch.transport.TransportListener

An unrecoverable exception has occured on the transport

onTransportFailure(IOException) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

opsToString(int) - Static method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

ordered - Variable in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

OrderedEventAggregator<Event,MergedEvent> - Interface in org.fusesource.hawtdispatch

This class should be implemented by Aggregator classes which depend on FIFO ordering of events from the point of view of the serial queue which merges events into it.

org.fusesource.hawtdispatch - package org.fusesource.hawtdispatch

HawtDispatch

org.fusesource.hawtdispatch.internal - package org.fusesource.hawtdispatch.internal

org.fusesource.hawtdispatch.internal.pool - package org.fusesource.hawtdispatch.internal.pool

org.fusesource.hawtdispatch.internal.util - package org.fusesource.hawtdispatch.internal.util

org.fusesource.hawtdispatch.jmx - package org.fusesource.hawtdispatch.jmx

org.fusesource.hawtdispatch.transport - package org.fusesource.hawtdispatch.transport

org.fusesource.hawtdispatch.util - package org.fusesource.hawtdispatch.util

outbound - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

outboundEvent - Variable in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

P

park(SimpleThread) - Method in class org.fusesource.hawtdispatch.internal.pool.SimplePool

peekBytes(int) - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

peer - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

pendingEvent - Variable in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

pickThreadQueue(HawtDispatcher, DispatchQueue) - Static method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

PipeTransport - Class in org.fusesource.hawtdispatch.transport

PipeTransport(PipeTransportServer) - Constructor for class org.fusesource.hawtdispatch.transport.PipeTransport

PipeTransport.OneWay - Class in org.fusesource.hawtdispatch.transport

PipeTransportRegistry - Class in org.fusesource.hawtdispatch.transport

PipeTransportRegistry() - Constructor for class org.fusesource.hawtdispatch.transport.PipeTransportRegistry

PipeTransportServer - Class in org.fusesource.hawtdispatch.transport

PipeTransportServer() - Constructor for class org.fusesource.hawtdispatch.transport.PipeTransportServer

poll() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

pool - Variable in class org.fusesource.hawtdispatch.internal.pool.SimpleThread

Pool() - Constructor for class org.fusesource.hawtdispatch.util.ThreadLocalPool.Pool

pools - Variable in class org.fusesource.hawtdispatch.util.BufferPools

primitives - Static variable in class org.fusesource.hawtdispatch.jmx.AnnotatedMBean

priority - Variable in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

priority - Variable in class org.fusesource.hawtdispatch.internal.pool.SimplePool

priority(DispatchPriority) - Static method in class org.fusesource.hawtdispatch.internal.pool.SimplePool

processSelected() - Method in class org.fusesource.hawtdispatch.internal.NioManager

profile(boolean) - Static method in class org.fusesource.hawtdispatch.Dispatch

If enabled then it enables profiling on the global queues and any newly created queues.

profile(boolean) - Method in interface org.fusesource.hawtdispatch.Dispatcher

If enabled then it enables profiling on the global queues and any newly created queues.

profile() - Method in interface org.fusesource.hawtdispatch.Dispatcher

profile(boolean) - Method in interface org.fusesource.hawtdispatch.DispatchQueue

Enables or disables profiler metric tracking on the queue.

profile() - Method in interface org.fusesource.hawtdispatch.DispatchQueue

profile - Variable in class org.fusesource.hawtdispatch.internal.DispatcherConfig

profile(boolean) - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

profile() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

profile - Variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

profile(boolean) - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

profile() - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

profile - Variable in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

profile(boolean) - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

profile() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

profile(boolean) - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

profile() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

protocol(String) - Static method in class org.fusesource.hawtdispatch.transport.SslTransport

Maps uri schemes to a protocol algorithm names.

protocol - Variable in class org.fusesource.hawtdispatch.transport.SslTransportServer

protocol(String) - Method in class org.fusesource.hawtdispatch.transport.SslTransportServer

protocolCodec - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

ProtocolCodec - Interface in org.fusesource.hawtdispatch.transport

Interface to encode and decode commands in and out of a a non blocking channel.

ProtocolCodec.BufferState - Enum in org.fusesource.hawtdispatch.transport

proxyName - Variable in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

proxyName(Class<?>) - Static method in class org.fusesource.hawtdispatch.DispatchQueueProxy

Q

queue - Variable in class org.fusesource.hawtdispatch.AggregatingExecutor

queue - Variable in class org.fusesource.hawtdispatch.internal.ActiveMetricsCollector

queue - Variable in class org.fusesource.hawtdispatch.Metrics

The dispatch queue associated with the metrics collected.

queueAccept() - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

queues - Static variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

QueueSupport - Class in org.fusesource.hawtdispatch.internal.util

QueueSupport() - Constructor for class org.fusesource.hawtdispatch.internal.util.QueueSupport

QueueType() - Constructor for enum org.fusesource.hawtdispatch.DispatchQueue.QueueType

R

rateLimitingChannel - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

RateLimitingChannel() - Constructor for class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

read() - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

read() - Method in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

Non-blocking channel based decoding.

read() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

read(ByteBuffer) - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec.SSLReadChannel

read(ByteBuffer[], int, int) - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec.SSLReadChannel

read(ByteBuffer[]) - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec.SSLReadChannel

read(ByteBuffer) - Method in class org.fusesource.hawtdispatch.transport.SslTransport.SSLChannel

read(ByteBuffer[], int, int) - Method in class org.fusesource.hawtdispatch.transport.SslTransport.SSLChannel

read(ByteBuffer[]) - Method in class org.fusesource.hawtdispatch.transport.SslTransport.SSLChannel

read(ByteBuffer) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

read(ByteBuffer[], int, int) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

read(ByteBuffer[]) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

read_allowance - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

read_suspended - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

readBuffer - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

readBuffer - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

readBuffer - Variable in class org.fusesource.hawtdispatch.transport.SslTransport

readBufferPool - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

readBufferSize - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

readBytes(int) - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

readChannel - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

readChannel - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

readCounter - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

readCounter - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

readCounter - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

readDirect(ByteBuffer) - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

readEnd - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

readInterval - Variable in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

readOverflowBuffer - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

readOverflowBuffer - Variable in class org.fusesource.hawtdispatch.transport.SslTransport

readSource - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

readSource - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

readStart - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

readSuspendCount - Variable in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

readSuspendedInterval - Variable in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

readUnderflow - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

readUnderflow - Variable in class org.fusesource.hawtdispatch.transport.SslTransport

readUntil(Byte) - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

readUntil(Byte, int) - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

readUntil(Byte, int, String) - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

readyOps - Variable in class org.fusesource.hawtdispatch.internal.NioDispatchSource.KeyState

receiveBufferSize - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

receiveBufferSize - Variable in class org.fusesource.hawtdispatch.transport.TcpTransportServer

receiveBufferSize - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

register(SelectableChannel, int) - Method in class org.fusesource.hawtdispatch.internal.NioManager

register(HawtDispatcher) - Static method in class org.fusesource.hawtdispatch.jmx.JmxService

register_on(DispatchQueue) - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

registeredKeys - Variable in class org.fusesource.hawtdispatch.internal.NioManager

rejectingOffers - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

rejectingOffers - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

release() - Method in class org.fusesource.hawtdispatch.BaseRetained

Decrement the reference count of this object.

release(int) - Method in class org.fusesource.hawtdispatch.BaseRetained

Decrements the reference count by n.

release() - Method in interface org.fusesource.hawtdispatch.Retained

Decrement the reference count of this object.

remaining - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport.CANCELING

remaining - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport.CANCELING

remoteAddress - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

remoteAddress - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

remoteAddress - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

remoteLocation - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

remoteLocation - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

requests - Variable in class org.fusesource.hawtdispatch.internal.TimerThread

reset() - Method in class org.fusesource.hawtdispatch.internal.NioManager.WorkAroundSelectSpin

Called when the buggy condition is detected.

reset_at - Variable in class org.fusesource.hawtdispatch.internal.ActiveMetricsCollector

resetAllowance() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

resolution - Variable in class org.fusesource.hawtdispatch.internal.util.TimerHeap

resolveHostName(String) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

resolveHostName(String) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

restart() - Static method in class org.fusesource.hawtdispatch.Dispatch

Restart default dispatcher instance.

restart() - Method in interface org.fusesource.hawtdispatch.Dispatcher

Restart this dispatcher instance.

restart() - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

resume() - Method in class org.fusesource.hawtdispatch.AggregatingExecutor

resume() - Method in class org.fusesource.hawtdispatch.internal.BaseSuspendable

resume() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

resume() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

resume() - Method in interface org.fusesource.hawtdispatch.Suspendable

Resumes the invocation of tasks on a dispatch object.

resume() - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

resume() - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

resume() - Method in interface org.fusesource.hawtdispatch.transport.TransportServer

resume accepting new transports

resume() - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

resumeRead() - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

resumeRead() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

resumeRead() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

resumeRead() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

resumeRead() - Method in interface org.fusesource.hawtdispatch.transport.Transport

resume delivery of commands.

resumeRead() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

resumeRead() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

resumeWrite() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

resumeWrite() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

retain() - Method in class org.fusesource.hawtdispatch.BaseRetained

Increment the reference count of this object.

retain() - Method in interface org.fusesource.hawtdispatch.Retained

Increment the reference count of this object.

retained - Variable in class org.fusesource.hawtdispatch.BaseRetained

retained() - Method in class org.fusesource.hawtdispatch.BaseRetained

Retained - Interface in org.fusesource.hawtdispatch

Implemented by dispatch objects which use a reference counted life cycle.

retained() - Method in interface org.fusesource.hawtdispatch.Retained

retained - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport.OneWay

retained - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport.OneWay

retained - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport.OneWay

run() - Method in class org.fusesource.hawtdispatch.internal.BaseSuspendable

run() - Method in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

run() - Method in class org.fusesource.hawtdispatch.internal.pool.SimpleThread

run() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

run() - Method in class org.fusesource.hawtdispatch.internal.TimerThread

run() - Method in class org.fusesource.hawtdispatch.internal.util.RunnableCountDownLatch

run() - Method in class org.fusesource.hawtdispatch.Task

run() - Method in class org.fusesource.hawtdispatch.TaskWrapper

runAfter(Runnable, int) - Static method in class org.fusesource.hawtdispatch.internal.util.RunnableSupport

runAfter(Task, int) - Static method in class org.fusesource.hawtdispatch.internal.util.RunnableSupport

runAfter(DispatchQueue, Runnable, int) - Static method in class org.fusesource.hawtdispatch.internal.util.RunnableSupport

runAfter(DispatchQueue, Task, int) - Static method in class org.fusesource.hawtdispatch.internal.util.RunnableSupport

RUNNABLE - Static variable in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

runnable(int, Method) - Method in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

runnable - Variable in class org.fusesource.hawtdispatch.TaskWrapper

RunnableCountDownLatch - Class in org.fusesource.hawtdispatch.internal.util

RunnableCountDownLatch(int) - Constructor for class org.fusesource.hawtdispatch.internal.util.RunnableCountDownLatch

runnables - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport.CANCELING

runnables - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport.CANCELING

RunnableSupport - Class in org.fusesource.hawtdispatch.internal.util

RunnableSupport() - Constructor for class org.fusesource.hawtdispatch.internal.util.RunnableSupport

runNoop() - Static method in class org.fusesource.hawtdispatch.internal.util.RunnableSupport

runOnceAfter(Runnable, int) - Static method in class org.fusesource.hawtdispatch.internal.util.RunnableSupport

runOnceAfter(Task, int) - Static method in class org.fusesource.hawtdispatch.internal.util.RunnableSupport

runOnceAfter(DispatchQueue, Runnable, int) - Static method in class org.fusesource.hawtdispatch.internal.util.RunnableSupport

runOnceAfter(DispatchQueue, Task, int) - Static method in class org.fusesource.hawtdispatch.internal.util.RunnableSupport

S

schedualRateAllowanceReset() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

schedule(short, long, Task) - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

scheduleCheckReads(short) - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

scheduleCheckWrites(short) - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

secure_read(ByteBuffer) - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

secure_read(ByteBuffer) - Method in class org.fusesource.hawtdispatch.transport.SslTransport

secure_write(ByteBuffer) - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

secure_write(ByteBuffer) - Method in class org.fusesource.hawtdispatch.transport.SslTransport

SecuredSession - Interface in org.fusesource.hawtdispatch.transport

select(long) - Method in class org.fusesource.hawtdispatch.internal.NioManager

Selects ready sources, potentially blocking.

select(long) - Method in class org.fusesource.hawtdispatch.internal.NioManager.SelectStrategy

select(long) - Method in class org.fusesource.hawtdispatch.internal.NioManager.WorkAroundSelectSpin

Detects the buggy condition and works around by re-creating the selector when the bug is triggered.

selectCounter - Variable in class org.fusesource.hawtdispatch.internal.NioManager

selected(SelectionKey) - Method in class org.fusesource.hawtdispatch.internal.NioAttachment

selecting - Variable in class org.fusesource.hawtdispatch.internal.NioManager

selector - Variable in class org.fusesource.hawtdispatch.internal.NioManager

selectorQueue - Variable in class org.fusesource.hawtdispatch.internal.NioDispatchSource

selectStrategy - Variable in class org.fusesource.hawtdispatch.internal.NioManager

Set the "hawtdispatch.workaround-select-spin" System property to "true" if your seeing the 100% CPU usage in the Selector.select() call.

SelectStrategy() - Constructor for class org.fusesource.hawtdispatch.internal.NioManager.SelectStrategy

sendBufferSize - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

sendBufferSize - Variable in class org.fusesource.hawtdispatch.transport.TcpTransportServer

sendBufferSize - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

SerialDispatchQueue - Class in org.fusesource.hawtdispatch.internal

SerialDispatchQueue(String) - Constructor for class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

server - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

server(SslProtocolCodec.ClientAuth) - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

servers - Static variable in class org.fusesource.hawtdispatch.transport.PipeTransportRegistry

ServiceBase - Class in org.fusesource.hawtdispatch.transport

The BaseService provides helpers for dealing async service state.

ServiceBase() - Constructor for class org.fusesource.hawtdispatch.transport.ServiceBase

ServiceBase.CallbackSupport - Class in org.fusesource.hawtdispatch.transport

ServiceBase.STARTING - Class in org.fusesource.hawtdispatch.transport

ServiceBase.State - Class in org.fusesource.hawtdispatch.transport

ServiceBase.STOPPING - Class in org.fusesource.hawtdispatch.transport

session - Variable in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

set(int) - Method in class org.fusesource.hawtdispatch.internal.util.IntegerCounter

setBacklog(int) - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

setBlockingExecutor(Executor) - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

setBlockingExecutor(Executor) - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

setBlockingExecutor(Executor) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

setBlockingExecutor(Executor) - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

setBlockingExecutor(Executor) - Method in interface org.fusesource.hawtdispatch.transport.Transport

setBlockingExecutor(Executor) - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

setBlockingExecutor(Executor) - Method in interface org.fusesource.hawtdispatch.transport.TransportServer

setBlockingExecutor(Executor) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

setBlockingExecutor(Executor) - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

setBufferPools(BufferPools) - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

setCancelHandler(Runnable) - Method in interface org.fusesource.hawtdispatch.DispatchSource

Sets the cancellation handler runnable for the given dispatch source.

setCancelHandler(Task) - Method in interface org.fusesource.hawtdispatch.DispatchSource

Sets the cancellation handler task for the given dispatch source.

setCancelHandler(Runnable) - Method in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

Deprecated.

setCancelHandler(Task) - Method in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

setCancelHandler(Runnable) - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

Deprecated.

setCancelHandler(Task) - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

setClientAuth(String) - Method in class org.fusesource.hawtdispatch.transport.SslTransport

setClientAuth(String) - Method in class org.fusesource.hawtdispatch.transport.SslTransportServer

setCloseOnCancel(boolean) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

setConnectURI(String) - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

setDisabledCypherSuites(String) - Method in class org.fusesource.hawtdispatch.transport.SslTransport

setDisabledCypherSuites(String) - Method in class org.fusesource.hawtdispatch.transport.SslTransportServer

setDispatchQueue(DispatchQueue) - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

setDispatchQueue(DispatchQueue) - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

setDispatchQueue(DispatchQueue) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

setDispatchQueue(DispatchQueue) - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

setDispatchQueue(DispatchQueue) - Method in interface org.fusesource.hawtdispatch.transport.Transport

Sets the dispatch queue used by the transport

setDispatchQueue(DispatchQueue) - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

setDispatchQueue(DispatchQueue) - Method in interface org.fusesource.hawtdispatch.transport.TransportServer

Sets the dispatch queue used by the transport

setDispatchQueue(DispatchQueue) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

setDispatchQueue(DispatchQueue) - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

setDisposer(Runnable) - Method in class org.fusesource.hawtdispatch.BaseRetained

Adds a disposer runnable that is executed once the object is disposed.

setDisposer(Task) - Method in class org.fusesource.hawtdispatch.BaseRetained

Adds a disposer runnable that is executed once the object is disposed.

setDrains(int) - Method in class org.fusesource.hawtdispatch.internal.DispatcherConfig

setEnabledCypherSuites(String) - Method in class org.fusesource.hawtdispatch.transport.SslTransport

setEventHandler(Runnable) - Method in interface org.fusesource.hawtdispatch.DispatchSource

Sets the event handler runnable of this dispatch source.

setEventHandler(Task) - Method in interface org.fusesource.hawtdispatch.DispatchSource

Sets the event handler task of this dispatch source.

setEventHandler(Runnable) - Method in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

Deprecated.

setEventHandler(Task) - Method in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

setEventHandler(Runnable) - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

Deprecated.

setEventHandler(Task) - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

setInitialReadCheckDelay(long) - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

setInitialWriteCheckDelay(long) - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

setJmx(boolean) - Method in class org.fusesource.hawtdispatch.internal.DispatcherConfig

setKeepAlive(boolean) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

setKeyManagers(KeyManager[]) - Method in class org.fusesource.hawtdispatch.transport.SslTransportServer

setLabel(String) - Method in interface org.fusesource.hawtdispatch.DispatchQueue

Sets the label of the queue.

setLabel(String) - Method in class org.fusesource.hawtdispatch.internal.DispatcherConfig

setLabel(String) - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

setLabel(String) - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

setLabel(String) - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

setMarshal(boolean) - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

setMarshal(boolean) - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

setMax(AtomicLong, long) - Method in class org.fusesource.hawtdispatch.internal.ActiveMetricsCollector

setMaxReadRate(int) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

setMaxWriteRate(int) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

setName(String) - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

setName(String) - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

setNext(ProtocolCodec) - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

setNext(ProtocolCodec) - Method in interface org.fusesource.hawtdispatch.transport.WrappingProtocolCodec

setOnDead(Task) - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

setOnKeepAlive(Task) - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

setProfile(boolean) - Method in class org.fusesource.hawtdispatch.internal.DispatcherConfig

setProfile(boolean) - Method in class org.fusesource.hawtdispatch.jmx.JmxService.JmxDispatcher

setProfile(boolean) - Method in interface org.fusesource.hawtdispatch.jmx.JmxService.JmxDispatcherMBean

setProperties(Object, Map<String, ?>, String) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

setProperties(Object, Map) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

setProperty(Object, String, Object) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

setProtocolCodec(ProtocolCodec) - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

setProtocolCodec(ProtocolCodec) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

setProtocolCodec(ProtocolCodec) - Method in interface org.fusesource.hawtdispatch.transport.Transport

Sets the protocol codec for the transport

setProtocolCodec(ProtocolCodec) - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

setProtocolCodec(ProtocolCodec) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

setReadInterval(long) - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

setReceiveBufferSize(int) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

setReceiveBufferSize(int) - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

setReceiveBufferSize(int) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

setRemoteAddress(String) - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

setSendBufferSize(int) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

setSendBufferSize(int) - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

setSendBufferSize(int) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

setSSLContext(SSLContext) - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

setSSLContext(SSLContext) - Method in class org.fusesource.hawtdispatch.transport.SslTransport

setSSLContext(SSLContext) - Method in class org.fusesource.hawtdispatch.transport.SslTransportServer

setTargetQueue(DispatchQueue) - Method in interface org.fusesource.hawtdispatch.DispatchObject

Sets the target queue for this object.

setTargetQueue(DispatchQueue) - Method in class org.fusesource.hawtdispatch.internal.AbstractDispatchObject

setTargetQueue(DispatchQueue) - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

setTargetQueue(DispatchQueue) - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

setTargetQueue(DispatchQueue) - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

setThreads(int) - Method in class org.fusesource.hawtdispatch.internal.DispatcherConfig

setTimeUnit(String) - Method in class org.fusesource.hawtdispatch.jmx.JmxService.JmxDispatcher

setTimeUnit(String) - Method in interface org.fusesource.hawtdispatch.jmx.JmxService.JmxDispatcherMBean

setTrace(boolean) - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

setTrafficClass(int) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

setTrafficClass(int) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

setTransport(Transport) - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

setTransport(Transport) - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

setTransport(Transport) - Method in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

setTransport(Transport) - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

setTransportListener(TransportListener) - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

setTransportListener(TransportListener) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

setTransportListener(TransportListener) - Method in interface org.fusesource.hawtdispatch.transport.Transport

Registers an inbound command listener

setTransportListener(TransportListener) - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

setTransportListener(TransportListener) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

setTransportServerListener(TransportServerListener) - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

setTransportServerListener(TransportServerListener) - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

setTransportServerListener(TransportServerListener) - Method in interface org.fusesource.hawtdispatch.transport.TransportServer

Registers an TransportAcceptListener which is notified of accepted channels.

setTransportServerListener(TransportServerListener) - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

setTrustManagers(TrustManager[]) - Method in class org.fusesource.hawtdispatch.transport.SslTransportServer

setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler) - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler) - Method in class org.fusesource.hawtdispatch.internal.WorkerThread

setUseLocalHost(boolean) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

Sets whether 'localhost' or the actual local host name should be used to make local connections.

setUseLocalHost(boolean) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

Sets whether 'localhost' or the actual local host name should be used to make local connections.

setWriteInterval(long) - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

sharedTasks - Variable in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

shutdown() - Static method in class org.fusesource.hawtdispatch.Dispatch

Shutdown default dispatcher instance.

shutdown() - Method in interface org.fusesource.hawtdispatch.Dispatcher

Shutdown this dispatcher instance.

shutdown() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

shutdown() - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

shutdown() - Method in class org.fusesource.hawtdispatch.internal.NioManager

shutdown - Variable in class org.fusesource.hawtdispatch.internal.pool.SimplePool

shutdown() - Method in class org.fusesource.hawtdispatch.internal.pool.SimplePool

shutdown(Task, DispatchQueue) - Method in class org.fusesource.hawtdispatch.internal.TimerThread

shutdown() - Method in interface org.fusesource.hawtdispatch.internal.WorkerPool

ShutdownException - Exception in org.fusesource.hawtdispatch

This exception is thrown when you attempt to use a dispatch object after the dispatch system has been shutdown in OSGi.

ShutdownException() - Constructor for exception org.fusesource.hawtdispatch.ShutdownException

ShutdownException(Throwable) - Constructor for exception org.fusesource.hawtdispatch.ShutdownException

ShutdownException(String, Throwable) - Constructor for exception org.fusesource.hawtdispatch.ShutdownException

ShutdownException(String) - Constructor for exception org.fusesource.hawtdispatch.ShutdownException

shutdownState - Variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

sig(Class<?>[]) - Method in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

sig(Class<?>) - Method in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

sig(String) - Method in class org.fusesource.hawtdispatch.DispatchQueueProxy.Generator

simpleName(Class<?>) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

SimplePool - Class in org.fusesource.hawtdispatch.internal.pool

SimplePool(GlobalDispatchQueue, int, DispatchPriority) - Constructor for class org.fusesource.hawtdispatch.internal.pool.SimplePool

SimpleThread - Class in org.fusesource.hawtdispatch.internal.pool

SimpleThread(SimplePool) - Constructor for class org.fusesource.hawtdispatch.internal.pool.SimpleThread

size - Variable in class org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource

size - Variable in class org.fusesource.hawtdispatch.internal.util.TimerHeap

size() - Method in class org.fusesource.hawtdispatch.internal.util.TimerHeap

sleep(long) - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

socket() - Method in class org.fusesource.hawtdispatch.transport.SslTransport.SSLChannel

socketState - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

SocketState() - Constructor for class org.fusesource.hawtdispatch.transport.TcpTransport.SocketState

socketState - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

SocketState() - Constructor for class org.fusesource.hawtdispatch.transport.UdpTransport.SocketState

source - Variable in class org.fusesource.hawtdispatch.AggregatingExecutor

sourceQueue - Variable in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

sourceQueue - Variable in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

sources - Variable in class org.fusesource.hawtdispatch.internal.NioAttachment

spins - Variable in class org.fusesource.hawtdispatch.internal.NioManager.WorkAroundSelectSpin

splitOnCommas(String) - Method in class org.fusesource.hawtdispatch.transport.SslTransport

squash(StackTraceElement[]) - Static method in class org.fusesource.hawtdispatch.BaseRetained

ssl_channel - Variable in class org.fusesource.hawtdispatch.transport.SslTransport

SSLChannel() - Constructor for class org.fusesource.hawtdispatch.transport.SslTransport.SSLChannel

sslContext - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

sslContext - Variable in class org.fusesource.hawtdispatch.transport.SslTransport

sslContext - Variable in class org.fusesource.hawtdispatch.transport.SslTransportServer

SslProtocolCodec - Class in org.fusesource.hawtdispatch.transport

Implements the SSL protocol as a WrappingProtocolCodec.

SslProtocolCodec() - Constructor for class org.fusesource.hawtdispatch.transport.SslProtocolCodec

SslProtocolCodec.ClientAuth - Enum in org.fusesource.hawtdispatch.transport

SslProtocolCodec.SSLReadChannel - Class in org.fusesource.hawtdispatch.transport

SslProtocolCodec.SSLWriteChannel - Class in org.fusesource.hawtdispatch.transport

sslReadChannel - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

SSLReadChannel() - Constructor for class org.fusesource.hawtdispatch.transport.SslProtocolCodec.SSLReadChannel

SslTransport - Class in org.fusesource.hawtdispatch.transport

An SSL Transport for secure communications.

SslTransport() - Constructor for class org.fusesource.hawtdispatch.transport.SslTransport

SslTransport.ClientAuth - Enum in org.fusesource.hawtdispatch.transport

SslTransport.SSLChannel - Class in org.fusesource.hawtdispatch.transport

SslTransportServer - Class in org.fusesource.hawtdispatch.transport

SslTransportServer(URI) - Constructor for class org.fusesource.hawtdispatch.transport.SslTransportServer

sslWriteChannel - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

SSLWriteChannel() - Constructor for class org.fusesource.hawtdispatch.transport.SslProtocolCodec.SSLWriteChannel

start(BundleContext) - Method in class org.fusesource.hawtdispatch.internal.Activator

start() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

start() - Method in class org.fusesource.hawtdispatch.internal.pool.SimplePool

start() - Method in interface org.fusesource.hawtdispatch.internal.WorkerPool

start() - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

start(Runnable) - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

Deprecated.

start(Task) - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

start(Runnable) - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

Deprecated.

start(Task) - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

start(Runnable) - Method in class org.fusesource.hawtdispatch.transport.ServiceBase

start(Task) - Method in class org.fusesource.hawtdispatch.transport.ServiceBase

start(Task) - Method in class org.fusesource.hawtdispatch.transport.SslTransportServer

start(Runnable) - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

Deprecated.

start(Task) - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

start(Runnable) - Method in interface org.fusesource.hawtdispatch.transport.Transport

Starts the service.

start(Task) - Method in interface org.fusesource.hawtdispatch.transport.Transport

Starts the service.

start(Runnable) - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

start(Task) - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

start(Task) - Method in interface org.fusesource.hawtdispatch.transport.TransportServer

Starts the service.

start(Runnable) - Method in interface org.fusesource.hawtdispatch.transport.TransportServer

STARTED - Static variable in class org.fusesource.hawtdispatch.transport.ServiceBase

STARTING() - Constructor for class org.fusesource.hawtdispatch.transport.ServiceBase.STARTING

startup - Variable in class org.fusesource.hawtdispatch.internal.BaseSuspendable

State() - Constructor for class org.fusesource.hawtdispatch.transport.ServiceBase.State

stop(BundleContext) - Method in class org.fusesource.hawtdispatch.internal.Activator

stop() - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

stop(Runnable) - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

Deprecated.

stop(Task) - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

stop(Runnable) - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

Deprecated.

stop(Task) - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

stop(Runnable) - Method in class org.fusesource.hawtdispatch.transport.ServiceBase

stop(Task) - Method in class org.fusesource.hawtdispatch.transport.ServiceBase

stop(Runnable) - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

Deprecated.

stop(Task) - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

stop(Runnable) - Method in interface org.fusesource.hawtdispatch.transport.Transport

Stops the service.

stop(Task) - Method in interface org.fusesource.hawtdispatch.transport.Transport

Stops the service.

stop(Runnable) - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

stop(Task) - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

stop(Task) - Method in interface org.fusesource.hawtdispatch.transport.TransportServer

Stops the service.

stop(Runnable) - Method in interface org.fusesource.hawtdispatch.transport.TransportServer

STOPPED - Static variable in class org.fusesource.hawtdispatch.transport.ServiceBase

stopping - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

STOPPING() - Constructor for class org.fusesource.hawtdispatch.transport.ServiceBase.STOPPING

StringSupport - Class in org.fusesource.hawtdispatch.internal.util

Helper class to hold common text/string manipulation methods.

StringSupport() - Constructor for class org.fusesource.hawtdispatch.internal.util.StringSupport

suspend() - Method in class org.fusesource.hawtdispatch.AggregatingExecutor

suspend() - Method in class org.fusesource.hawtdispatch.internal.BaseSuspendable

suspend() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

suspend() - Method in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

suspend() - Method in interface org.fusesource.hawtdispatch.Suspendable

Suspends the invocation of tasks on a dispatch object.

suspend() - Method in class org.fusesource.hawtdispatch.transport.PipeTransportServer

suspend() - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

suspend() - Method in interface org.fusesource.hawtdispatch.transport.TransportServer

suspend accepting new transports

suspend() - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

Suspendable - Interface in org.fusesource.hawtdispatch

Implemented by dispatch objects which can suspend the execution of dispatch tasks.

suspended - Variable in class org.fusesource.hawtdispatch.internal.BaseSuspendable

suspendRead() - Method in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

suspendRead() - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

suspendRead() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

suspendRead() - Method in interface org.fusesource.hawtdispatch.transport.Transport

suspend delivery of commands.

suspendRead() - Method in class org.fusesource.hawtdispatch.transport.TransportFilter

suspendRead() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

suspendWrite() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

suspendWrite() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

T

target - Variable in class org.fusesource.hawtdispatch.internal.TimerThread.TimerRequest

targetQueue - Variable in class org.fusesource.hawtdispatch.internal.AbstractDispatchObject

task - Variable in class org.fusesource.hawtdispatch.internal.TimerThread.TimerRequest

Task - Class in org.fusesource.hawtdispatch

We prefer the use of Task over Runnable since the JVM can more efficiently invoke methods of an abstract class than a interface.

Task() - Constructor for class org.fusesource.hawtdispatch.Task

tasks - Variable in class org.fusesource.hawtdispatch.internal.pool.SimplePool

TaskWrapper - Class in org.fusesource.hawtdispatch

TaskWrapper(Runnable) - Constructor for class org.fusesource.hawtdispatch.TaskWrapper

TcpTransport - Class in org.fusesource.hawtdispatch.transport

An implementation of the Transport interface using raw tcp/ip

TcpTransport() - Constructor for class org.fusesource.hawtdispatch.transport.TcpTransport

TcpTransport.CANCELED - Class in org.fusesource.hawtdispatch.transport

TcpTransport.CANCELING - Class in org.fusesource.hawtdispatch.transport

TcpTransport.CONNECTED - Class in org.fusesource.hawtdispatch.transport

TcpTransport.CONNECTING - Class in org.fusesource.hawtdispatch.transport

TcpTransport.DISCONNECTED - Class in org.fusesource.hawtdispatch.transport

TcpTransport.OneWay - Class in org.fusesource.hawtdispatch.transport

TcpTransport.RateLimitingChannel - Class in org.fusesource.hawtdispatch.transport

TcpTransport.SocketState - Class in org.fusesource.hawtdispatch.transport

TcpTransportServer - Class in org.fusesource.hawtdispatch.transport

A TCP based implementation of TransportServer

TcpTransportServer(URI) - Constructor for class org.fusesource.hawtdispatch.transport.TcpTransportServer

thread - Variable in class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

ThreadDispatchQueue - Class in org.fusesource.hawtdispatch.internal

ThreadDispatchQueue(GlobalDispatchQueue, WorkerThread) - Constructor for class org.fusesource.hawtdispatch.internal.ThreadDispatchQueue

ThreadLocalPool<T> - Class in org.fusesource.hawtdispatch.util

ThreadLocalPool() - Constructor for class org.fusesource.hawtdispatch.util.ThreadLocalPool

ThreadLocalPool.Pool - Class in org.fusesource.hawtdispatch.util

threadQueue - Variable in class org.fusesource.hawtdispatch.internal.pool.SimpleThread

threads - Variable in class org.fusesource.hawtdispatch.internal.DispatcherConfig

threads - Variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

threads - Variable in class org.fusesource.hawtdispatch.internal.pool.SimplePool

time - Variable in class org.fusesource.hawtdispatch.internal.TimerThread.TimerRequest

TimerHeap<V> - Class in org.fusesource.hawtdispatch.internal.util

TimerHeap() - Constructor for class org.fusesource.hawtdispatch.internal.util.TimerHeap

TimerRequest() - Constructor for class org.fusesource.hawtdispatch.internal.TimerThread.TimerRequest

timers - Variable in class org.fusesource.hawtdispatch.internal.util.TimerHeap

timerThread - Variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

TimerThread - Class in org.fusesource.hawtdispatch.internal

TimerThread(HawtDispatcher) - Constructor for class org.fusesource.hawtdispatch.internal.TimerThread

TimerThread.TimerRequest - Class in org.fusesource.hawtdispatch.internal

TimerThread.Type - Enum in org.fusesource.hawtdispatch.internal

timeToNext(TimeUnit) - Method in class org.fusesource.hawtdispatch.internal.util.TimerHeap

Returns the time of the next scheduled event.

timeUnit - Variable in class org.fusesource.hawtdispatch.jmx.JmxService.JmxDispatcher

toString() - Method in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

toString() - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource.KeyState

toString() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

toString() - Method in class org.fusesource.hawtdispatch.internal.util.IntegerCounter

toString(Object) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

toString(Object, String...) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

toString(Object, Class<?>) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

toString(Object, Map<String, Object>, String...) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

toString(Object, Class<?>, Map<String, Object>, String[]) - Static method in class org.fusesource.hawtdispatch.internal.util.IntrospectionSupport

toString() - Method in class org.fusesource.hawtdispatch.internal.util.RunnableCountDownLatch

toString() - Method in class org.fusesource.hawtdispatch.Metrics

toString() - Method in class org.fusesource.hawtdispatch.TaskWrapper

toString() - Method in class org.fusesource.hawtdispatch.transport.ServiceBase.State

toString() - Method in class org.fusesource.hawtdispatch.transport.TcpTransportServer

toString() - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

total_run_time - Variable in class org.fusesource.hawtdispatch.internal.ActiveMetricsCollector

total_wait_time - Variable in class org.fusesource.hawtdispatch.internal.ActiveMetricsCollector

totalRunTimeNS - Variable in class org.fusesource.hawtdispatch.Metrics

The sum of all the time spent executing tasks in nanoseconds.

totalWaitTimeNS - Variable in class org.fusesource.hawtdispatch.Metrics

The sum of all the time that tasks spent waiting in the queue in nanoseconds.

TRACE - Static variable in class org.fusesource.hawtdispatch.BaseRetained

trace(String, int) - Method in class org.fusesource.hawtdispatch.BaseRetained

TRACE - Variable in class org.fusesource.hawtdispatch.internal.NioManager

trace(String, Object...) - Method in class org.fusesource.hawtdispatch.internal.NioManager

trace - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

trace(String) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

trace(String) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

traces - Variable in class org.fusesource.hawtdispatch.BaseRetained

traces - Variable in class org.fusesource.hawtdispatch.internal.NioManager

track(Task) - Method in class org.fusesource.hawtdispatch.internal.ActiveMetricsCollector

track(HawtDispatchQueue) - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

track(Task) - Method in class org.fusesource.hawtdispatch.internal.InactiveMetricsCollector

track(Task) - Method in class org.fusesource.hawtdispatch.internal.MetricsCollector

trafficClass - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

trafficClass - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

transmit(Object) - Method in class org.fusesource.hawtdispatch.transport.PipeTransport

transport - Variable in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

transport - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

Transport - Interface in org.fusesource.hawtdispatch.transport

Represents an abstract connection.

transport - Variable in class org.fusesource.hawtdispatch.transport.UdpTransportServer

TransportFilter - Class in org.fusesource.hawtdispatch.transport

TransportFilter(Transport) - Constructor for class org.fusesource.hawtdispatch.transport.TransportFilter

transportFlush() - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

transportFlush() - Method in class org.fusesource.hawtdispatch.transport.SslTransport

transportFlush() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

transportFlush() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

TransportListener - Interface in org.fusesource.hawtdispatch.transport

An asynchronous listener of commands

TransportServer - Interface in org.fusesource.hawtdispatch.transport

A TransportServer asynchronously accepts Transport objects and then delivers those objects to a TransportAcceptListener.

TransportServerListener - Interface in org.fusesource.hawtdispatch.transport

Implemented by object that need to get injected by

triggered - Variable in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

triggerExecution() - Method in class org.fusesource.hawtdispatch.internal.SerialDispatchQueue

trustManagers - Variable in class org.fusesource.hawtdispatch.transport.SslTransportServer

type - Variable in class org.fusesource.hawtdispatch.internal.TimerThread.TimerRequest

Type() - Constructor for enum org.fusesource.hawtdispatch.internal.TimerThread.Type

U

UdpTransport - Class in org.fusesource.hawtdispatch.transport

UdpTransport() - Constructor for class org.fusesource.hawtdispatch.transport.UdpTransport

UdpTransport.CANCELED - Class in org.fusesource.hawtdispatch.transport

UdpTransport.CANCELING - Class in org.fusesource.hawtdispatch.transport

UdpTransport.CONNECTED - Class in org.fusesource.hawtdispatch.transport

UdpTransport.CONNECTING - Class in org.fusesource.hawtdispatch.transport

UdpTransport.DISCONNECTED - Class in org.fusesource.hawtdispatch.transport

UdpTransport.OneWay - Class in org.fusesource.hawtdispatch.transport

UdpTransport.SocketState - Class in org.fusesource.hawtdispatch.transport

UdpTransportServer - Class in org.fusesource.hawtdispatch.transport

UdpTransportServer(URI) - Constructor for class org.fusesource.hawtdispatch.transport.UdpTransportServer

unbind(PipeTransportServer) - Static method in class org.fusesource.hawtdispatch.transport.PipeTransportRegistry

uncaughtException(Thread, Throwable) - Method in class org.fusesource.hawtdispatch.internal.HawtThreadGroup

uncaughtExceptionHandler - Variable in class org.fusesource.hawtdispatch.internal.HawtDispatcher

unit - Variable in class org.fusesource.hawtdispatch.internal.TimerThread.TimerRequest

unpark() - Method in class org.fusesource.hawtdispatch.internal.pool.SimpleThread

unpark() - Method in class org.fusesource.hawtdispatch.internal.WorkerThread

unread(byte[]) - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

unread(byte[]) - Method in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

Pushes back a buffer as being unread.

unread(byte[]) - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

unregister(HawtDispatcher) - Static method in class org.fusesource.hawtdispatch.jmx.JmxService

untrack(HawtDispatchQueue) - Method in class org.fusesource.hawtdispatch.internal.HawtDispatcher

updateInterest() - Method in class org.fusesource.hawtdispatch.internal.NioDispatchSource

updateInterestTask - Variable in class org.fusesource.hawtdispatch.internal.NioDispatchSource

useLocalHost - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

useLocalHost - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

V

valueOf(String) - Static method in enum org.fusesource.hawtdispatch.DispatchPriority

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.fusesource.hawtdispatch.DispatchQueue.QueueType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.fusesource.hawtdispatch.internal.TimerThread.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.fusesource.hawtdispatch.transport.ProtocolCodec.BufferState

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.fusesource.hawtdispatch.transport.SslProtocolCodec.ClientAuth

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.fusesource.hawtdispatch.transport.SslTransport.ClientAuth

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.fusesource.hawtdispatch.DispatchPriority

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.fusesource.hawtdispatch.DispatchQueue.QueueType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.fusesource.hawtdispatch.internal.TimerThread.Type

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.fusesource.hawtdispatch.transport.ProtocolCodec.BufferState

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.fusesource.hawtdispatch.transport.SslProtocolCodec.ClientAuth

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.fusesource.hawtdispatch.transport.SslTransport.ClientAuth

Returns an array containing the constants of this enum type, in the order they are declared.

W

wakeupCounter - Variable in class org.fusesource.hawtdispatch.internal.NioManager

wakeupIfSelecting() - Method in class org.fusesource.hawtdispatch.internal.NioManager

wakeupPending() - Method in class org.fusesource.hawtdispatch.internal.NioManager.WorkAroundSelectSpin

Was a wakeup() issued after we entered the select() ??

WorkAroundSelectSpin() - Constructor for class org.fusesource.hawtdispatch.internal.NioManager.WorkAroundSelectSpin

WorkerPool - Interface in org.fusesource.hawtdispatch.internal

workers - Variable in class org.fusesource.hawtdispatch.internal.GlobalDispatchQueue

WorkerThread - Class in org.fusesource.hawtdispatch.internal

WorkerThread() - Constructor for class org.fusesource.hawtdispatch.internal.WorkerThread

WorkerThread(ThreadGroup, String) - Constructor for class org.fusesource.hawtdispatch.internal.WorkerThread

WorkerThread(String) - Constructor for class org.fusesource.hawtdispatch.internal.WorkerThread

WrappingProtocolCodec - Interface in org.fusesource.hawtdispatch.transport

Interface of protocol codecs that wrap other protocol codecs.

write(Object) - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

write(Object) - Method in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

Non-blocking channel based encoding.

write(ByteBuffer) - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec.SSLWriteChannel

write(ByteBuffer[], int, int) - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec.SSLWriteChannel

write(ByteBuffer[]) - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec.SSLWriteChannel

write(Object) - Method in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

write(ByteBuffer) - Method in class org.fusesource.hawtdispatch.transport.SslTransport.SSLChannel

write(ByteBuffer[], int, int) - Method in class org.fusesource.hawtdispatch.transport.SslTransport.SSLChannel

write(ByteBuffer[]) - Method in class org.fusesource.hawtdispatch.transport.SslTransport.SSLChannel

write(ByteBuffer) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

write(ByteBuffer[], int, int) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

write(ByteBuffer[]) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

write_allowance - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

write_suspended - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

writeBuffer - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

writeBuffer - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

writeBuffer - Variable in class org.fusesource.hawtdispatch.transport.SslTransport

writeBufferPool - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

writeBufferRemaining - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

writeBufferSize - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

writeChannel - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

writeChannel - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

writeCounter - Variable in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

writeCounter - Variable in class org.fusesource.hawtdispatch.transport.PipeTransport

writeCounter - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

writeDirect(ByteBuffer) - Method in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

writeFlushing - Variable in class org.fusesource.hawtdispatch.transport.SslProtocolCodec

writeFlushing - Variable in class org.fusesource.hawtdispatch.transport.SslTransport

writeInterval - Variable in class org.fusesource.hawtdispatch.transport.HeartBeatMonitor

writeResumedForCodecFlush - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

writeResumedForCodecFlush - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

writeSource - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

writeSource - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

Y

yieldSource - Variable in class org.fusesource.hawtdispatch.transport.TcpTransport

yieldSource - Variable in class org.fusesource.hawtdispatch.transport.UdpTransport

_

_resumeRead() - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

_resumeRead() - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

_serviceState - Variable in class org.fusesource.hawtdispatch.transport.ServiceBase

_start(Task) - Method in class org.fusesource.hawtdispatch.transport.ServiceBase

_start(Task) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

_start(Task) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

_start(Task) - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

_stop(Task) - Method in class org.fusesource.hawtdispatch.transport.ServiceBase

_stop(Task) - Method in class org.fusesource.hawtdispatch.transport.TcpTransport

_stop(Task) - Method in class org.fusesource.hawtdispatch.transport.UdpTransport

_stop(Task) - Method in class org.fusesource.hawtdispatch.transport.UdpTransportServer

A B C D E F G H I J K L M N O P Q R S T U V W Y _