See: Description
| Interface | Description |
|---|---|
| AgeOutCache.Handler<K> | |
| Command |
The Command patttern (see Gamma et al.).
|
| SchedulerListener |
Provides callback for use with a
Scheduler. |
| Streamable |
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
| ThreadDecorator |
An object that can alter the state of a thread when it receives a callback from a
ThreadManager notifying
it that the thread has been created or released from use. |
| ThreadFactory | |
| ThreadManager |
An object that manages threads and provides callbacks to a
ThreadDecorator to allow it to alter their state. |
| TimeScheduler.Task |
The interface that submitted tasks must implement
|
| Class | Description |
|---|---|
| AckCollector | |
| AgeOutCache<K> |
Cache which removes its elements after a certain time
|
| BoundedList<T> |
A bounded subclass of LinkedList, oldest elements are removed once max capacity is exceeded.
|
| Buffer |
Buffer with an offset and length.
|
| ContextObjectInputStream |
ObjectInputStream which sets a contact classloader for reading bytes into objects.
|
| DefaultThreadFactory |
Thread factory mainly responsible for naming of threads.
|
| Digest |
A message digest, which is used by the PBCAST layer for gossiping (also used by NAKACK for
keeping track of current seqnos for all members).
|
| Digest.Entry |
Class keeping track of the lowest and highest sequence numbers delivered, and the highest
sequence numbers received, per member.
|
| DirectExecutor | |
| ExposedBufferedInputStream | |
| ExposedBufferedOutputStream | |
| ExposedByteArrayInputStream | |
| ExposedByteArrayOutputStream |
Extends ByteArrayOutputStream, but exposes the internal buffer.
|
| ExposedDataOutputStream | |
| FIFOMessageQueue<K,V> |
Blocking queue which can only process 1 message per service concurrently, establishing FIFO order per sender.
|
| GetNetworkInterfaces |
Lists all network interfaces on a system
|
| Headers |
Open addressing based implementation of a hashmap (not supporting the Map interface though) for message
headers.
|
| LazyThreadFactory |
Lazily names threads: whenever the address or cluster name is changed, all threads are renamed
|
| MagicObjectInputStream |
Uses magic numbers for class descriptors
|
| MagicObjectOutputStream |
Uses magic numbers for class descriptors
|
| Marshaller |
Title: JGroups Communications
Description: Contact me at mail@filip.net
Copyright: Copyright (c) 2002
Company: www.filip.net
|
| MutableDigest |
A mutable version of Digest (which is immutable
|
| OutgoingBufferPool |
Maintains a pool of ExposedDataOutputStreams.
|
| PortsManager |
Maintains a list of ports used on this host, associated with time stamps.
|
| Promise<T> |
Allows a thread to submit an asynchronous request and to wait for the result.
|
| Proxy |
Redirects incoming TCP connections to other hosts/ports.
|
| Queue |
Elements are added at the tail and removed from the head.
|
| Range | |
| ResponseCollector<T> |
Similar to AckCollector, but collects responses, not just acks.
|
| ReusableThread |
Reusable thread class.
|
| Rsp |
class that represents a response from a communication
|
| RspList |
Contains responses from all members.
|
| Scheduler |
Implementation of a priority scheduler.
|
| Scheduler.Task | |
| SeqnoTable |
Maintains the highest received and highest delivered seqno per member
|
| ShutdownRejectedExecutionHandler |
ShutdownRejectedExecutionHandler is a decorator RejectedExecutionHandler used
in all JGroups ThreadPoolExecutor(s).
|
| SizeBoundedQueue |
Queue as described in http://jira.jboss.com/jira/browse/JGRP-376.
|
| ThreadManagerThreadPoolExecutor |
ThreadPoolExecutor subclass that implements @{link ThreadManager}.
|
| ThreadPool |
Maintains a set of ReusableThreads.
|
| TimedWriter |
Waits until the buffer has been written to the output stream, or until timeout msecs have elapsed,
whichever comes first.
|
| TimeScheduler |
Fixed-delay & fixed-rate single thread scheduler
The scheduler supports varying scheduling intervals by asking the task
every time for its next preferred scheduling interval.
|
| Triple<V1,V2,V3> |
Holds 3 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate
holder object for the values, and don't want to pass the values as a list or array.
|
| Tuple<V1,V2> |
Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate
holder object for the values, and don't want to pass the values as a list or array.
|
| UnmodifiableVector |
Vector which cannot be modified
|
| Util |
Collection of various utility routines that can not be assigned to other classes.
|
| Exception | Description |
|---|---|
| QueueClosedException |
Copyright ? 1998-2008 Bela Ban. All Rights Reserved.