Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- AbstractChannelWrapperRemote - Class in org.jppf.client.balancer
-
Context associated with a remote channel serving state and tasks submission.
- AbstractChannelWrapperRemote(JPPFClientConnection) - Constructor for class org.jppf.client.balancer.AbstractChannelWrapperRemote
-
Default initializer for remote channel wrapper.
- AbstractClassServerDelegate - Class in org.jppf.client
-
Abstract implementation of the client end of the JPPF distributed class loader.
- AbstractClassServerDelegate(JPPFClientConnection) - Constructor for class org.jppf.client.AbstractClassServerDelegate
-
Default instantiation of this class is not permitted.
- AbstractClientConnectionHandler - Class in org.jppf.client
-
Common abstract superclass for client connections to a server.
- AbstractClientConnectionHandler(JPPFClientConnection, String) - Constructor for class org.jppf.client.AbstractClientConnectionHandler
-
Initialize this connection with the specified owner.
- AbstractClientConnectionPool - Class in org.jppf.client
-
Instances of this class manage a list of client connections with the same pool name, priority and remote driver.
- AbstractClientJob - Class in org.jppf.client.balancer
-
Abstract class that support job state management.
- AbstractClientJob(JPPFJob) - Constructor for class org.jppf.client.balancer.AbstractClientJob
-
Initialized abstract client job with task bundle and list of tasks to execute.
- AbstractComponent<E extends AbstractComponent> - Class in org.jppf.client.monitoring
-
Base superclass for components of a JPPF grid topology.
- AbstractComponent(String) - Constructor for class org.jppf.client.monitoring.AbstractComponent
-
Initialize this component witht he specified uuid.
- AbstractConnectionPool<E extends AutoCloseable> - Class in org.jppf.client
-
An abstract implementation of the
ConnectionPoolinterface. - AbstractConnectionPool(int) - Constructor for class org.jppf.client.AbstractConnectionPool
-
Initialize this pool with the specfiied core size.
- AbstractGenericClient - Class in org.jppf.client
-
This class provides an API to submit execution requests and administration commands, and request server information data.
It has its own unique identifier, used by the nodes, to determine whether classes from the submitting application should be dynamically reloaded or not, depending on whether the uuid has changed or not. - AbstractGenericClient(String, TypedProperties, ConnectionPoolListener...) - Constructor for class org.jppf.client.AbstractGenericClient
-
Initialize this client with a specified application UUID.
- AbstractJobComponent - Class in org.jppf.client.monitoring.jobs
-
Base superclass for components of a JPPF job hierarchy.
- AbstractJPPFClient - Class in org.jppf.client
-
This class provides an API to submit execution requests and administration commands, and request server information data.
It has its own unique identifier, used by the nodes, to determine whether classes from the submitting application should be dynamically reloaded or not, depending on whether the uuid has changed or not. - AbstractJPPFClient(String) - Constructor for class org.jppf.client.AbstractJPPFClient
-
Initialize this client with a specified application UUID.
- AbstractJPPFJob<J extends AbstractJPPFJob<J>> - Class in org.jppf.client
-
Instances of this class represent a JPPF job and hold all the required elements: tasks, execution policy, task listener, data provider, priority, blocking indicator.
- AbstractJPPFJob() - Constructor for class org.jppf.client.AbstractJPPFJob
-
Default constructor, creates a blocking job with no data provider, default SLA values and a priority of 0.
- AbstractJPPFJob(String) - Constructor for class org.jppf.client.AbstractJPPFJob
-
Default constructor, creates a blocking job with no data provider, default SLA values and a priority of 0.
- AbstractJPPFJobStream - Class in org.jppf.client.utils
-
Instances of this class provide a stream of JPPF jobs.
- AbstractJPPFJobStream(int) - Constructor for class org.jppf.client.utils.AbstractJPPFJobStream
-
Initialize this job provider.
- AbstractRefreshHandler - Class in org.jppf.client.monitoring
-
Instances of this class hold information about the associations between JPPF drivers and their attached nodes, for management and monitoring purposes.
- AbstractRefreshHandler(String, long) - Constructor for class org.jppf.client.monitoring.AbstractRefreshHandler
-
Initialize this node handler.
- AbstractTopologyComponent - Class in org.jppf.client.monitoring.topology
-
Base superclass for components of a JPPF grid topology.
- accepts(E) - Method in interface org.jppf.client.ConnectionPoolFilter
-
Determine whether this filter accepts the specified connection pool.
- acceptsChannel(ExecutorChannel<?>) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Determine whether this job can be sent to the specified channel.
- ACTIVE - Enum constant in enum class org.jppf.client.JPPFClientConnectionStatus
-
The connection is successfully connected to the driver.
- add(E) - Method in class org.jppf.client.AbstractConnectionPool
-
Add a connection to this pool.
- add(E) - Method in interface org.jppf.client.ConnectionPool
-
Add a connection to this pool.
- add(E) - Method in class org.jppf.client.monitoring.AbstractComponent
-
Add a child to this component.
- add(Object, Object...) - Method in class org.jppf.client.JPPFJob
-
Add a task to this job.
- add(Runnable) - Method in class org.jppf.client.JPPFJob
-
Add a
Runnabletask to this job. - add(String, Object, Object...) - Method in class org.jppf.client.JPPFJob
-
Add a POJO task to this job.
- add(Callable<?>) - Method in class org.jppf.client.JPPFJob
-
Add a
Callabletask to this job. - add(Task<?>) - Method in class org.jppf.client.JPPFJob
-
Add a
Taskto this job. - add(JPPFCallable<?>) - Method in class org.jppf.client.JPPFJob
-
Add a
Callabletask to this job. - add(JPPFRunnableTask) - Method in class org.jppf.client.JPPFJob
-
Add a
JPPFRunnableTasktask to this job. - addAll(List<Task<?>>) - Method in class org.jppf.client.JPPFJob
-
Add the specified tasks to this job in a bulk operation.
- addBundle(ClientJob) - Method in class org.jppf.client.balancer.queue.JPPFPriorityQueue
-
Add an object to the queue, and notify all listeners about it.
- addChannel(ExecutorChannel<?>) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Add a channel to this job.
- addClientConnectionStatusListener(ClientConnectionStatusListener) - Method in class org.jppf.client.balancer.AbstractChannelWrapperRemote
- addClientConnectionStatusListener(ClientConnectionStatusListener) - Method in class org.jppf.client.balancer.ChannelWrapper
-
Add a connection status listener to this connection's list of listeners.
- addClientConnectionStatusListener(ClientConnectionStatusListener) - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- addClientConnectionStatusListener(ClientConnectionStatusListener) - Method in interface org.jppf.client.event.ClientConnectionStatusHandler
-
Add a connection status listener to this connection's list of listeners.
- addClientConnectionStatusListener(ClientConnectionStatusListener) - Method in class org.jppf.client.JPPFClientConnectionImpl
- addClientQueueListener(ClientQueueListener) - Method in class org.jppf.client.AbstractGenericClient
-
Register the specified listener to receive client queue event notifications.
- addConnection(ChannelWrapper) - Method in class org.jppf.client.balancer.JobManagerClient
-
Add the specified connection wrapper to the list of connections handled by this manager.
- addConnection(JPPFClientConnection) - Method in class org.jppf.client.balancer.JobManagerClient
-
Add the specified client connection to the list of connections handled by this manager.
- addConnectionPoolListener(ConnectionPoolListener) - Method in class org.jppf.client.AbstractJPPFClient
-
Add a listener to the list of listeners to this client.
- addDependencies(Collection<JPPFJob>) - Method in class org.jppf.client.JPPFJob
-
Add the specified jobs as dependencies to this job.
- addDependencies(JPPFJob...) - Method in class org.jppf.client.JPPFJob
-
Add the specified jobs as dependencies to this job.
- addDriverDiscovery(ClientDriverDiscovery) - Method in class org.jppf.client.AbstractGenericClient
-
Add a custom driver discovery mechanism to those already registered, if any.
- addExecutionStatusListener(ExecutorChannelStatusListener) - Method in class org.jppf.client.balancer.ChannelWrapper
- addIdleChannel(ChannelWrapper) - Method in class org.jppf.client.balancer.queue.JobScheduler
-
Add a channel to the list of idle channels.
- addJobListener(JobListener) - Method in interface org.jppf.client.concurrent.JobConfiguration
-
Add a listener to the list of job listeners.
- addJobListener(JobListener) - Method in class org.jppf.client.JPPFJob
-
Add a listener to the list of job listeners.
- addJobMonitoringListener(JobMonitoringListener) - Method in class org.jppf.client.monitoring.jobs.JobMonitor
-
Add a listener to the events emitted by this job monitor.
- addJobStatusListener(JobStatusListener) - Method in class org.jppf.client.AbstractJPPFJob
-
Add a listener to the list of status listeners.
- addOnDone(Runnable) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Registers instance to be called on job finish.
- addResults(List<Task<?>>) - Method in class org.jppf.client.JobResults
-
Add the specified results to this job.
- addTopologyListener(TopologyListener) - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Add a topology change listener.
- allConnections() - Method in class org.jppf.client.debug.Debug
- allConnections() - Method in interface org.jppf.client.debug.DebugMBean
-
Get a list of all the driver connections.
- allKeys() - Method in class org.jppf.client.persistence.DefaultFilePersistenceManager
- allKeys() - Method in interface org.jppf.client.persistence.JobPersistence
-
Get the keys of all jobs in the persistence store.
- allParameters() - Method in class org.jppf.client.debug.Debug
- allParameters() - Method in interface org.jppf.client.debug.DebugMBean
- awaitActiveConnection() - Method in class org.jppf.client.JPPFConnectionPool
-
Wait for the a connection to be in the
ACTIVEstatus. - awaitActiveConnectionPool() - Method in class org.jppf.client.JPPFClient
-
Wait until there is at least one connection pool with at least one connection in the
ACTIVEstatus. - awaitActiveConnections(ComparisonOperator, int) - Method in class org.jppf.client.JPPFConnectionPool
-
Wait for the specified number of connections to be in the
ACTIVEstatus. - awaitConnection(JPPFClientConnectionStatus...) - Method in class org.jppf.client.JPPFConnectionPool
-
Wait for a connection to be in one of the specified states.
- awaitConnectionPool(long, JPPFClientConnectionStatus...) - Method in class org.jppf.client.JPPFClient
-
Wait until at least one connection pool with at least one connection in one of the specified statuses, or until the specified timeout to expire, whichever happens first.
- awaitConnectionPool(JPPFClientConnectionStatus...) - Method in class org.jppf.client.JPPFClient
-
Wait until there is at least one connection pool with at least one connection in one of the specified statuses.
- awaitConnectionPools(long, ConnectionPoolFilter<JPPFConnectionPool>) - Method in class org.jppf.client.JPPFClient
-
Wait until there is at least one connection pool where at least one connections passes the specified filter, or until the specified timeout expires, whichever happens first.
- awaitConnectionPools(long, JPPFClientConnectionStatus...) - Method in class org.jppf.client.JPPFClient
-
Wait until at least one connection pool with at least one connection in one of the specified statuses, or until the specified timeout to expire, whichever happens first.
- awaitConnectionPools(ComparisonOperator, int, long, JPPFClientConnectionStatus...) - Method in class org.jppf.client.JPPFClient
-
Wait until there is at least one connection pool where the number of connections with the specified statuses satisfy the specified condition, or until the specified timeout expires, whichever happens first.
- awaitConnectionPools(ComparisonOperator, int, ComparisonOperator, int, long, JPPFClientConnectionStatus...) - Method in class org.jppf.client.JPPFClient
-
Wait until at least the specified expected connection pools satisfy the condition where the number of connections with the specified statuses satisfy the specified connection operator, or until the specified timeout expires, whichever happens first.
- awaitConnections(ComparisonOperator, int, long, JPPFClientConnectionStatus...) - Method in class org.jppf.client.JPPFConnectionPool
-
Wait for the specified number of connections to be in one of the specified states, or the specified timeout to expire, whichever happens first.
- awaitConnections(ComparisonOperator, int, JPPFClientConnectionStatus...) - Method in class org.jppf.client.JPPFConnectionPool
-
Wait for the specified number of connections to be in one of the specified states.
- awaitEndOfStream() - Method in class org.jppf.client.utils.AbstractJPPFJobStream
-
Wait until this job stream has finished procesing all of its jobs.
- awaitJMXConnection(boolean) - Method in class org.jppf.client.JPPFConnectionPool
-
Wait a JMX connection to be in the specified state.
- awaitJMXConnections(ComparisonOperator, int, boolean) - Method in class org.jppf.client.JPPFConnectionPool
-
Wait for the specified number of JMX connections to be in the specified state.
- awaitJMXConnections(ComparisonOperator, int, long, boolean) - Method in class org.jppf.client.JPPFConnectionPool
-
Wait for the specified number of JMX connections to be in the specified state, or the specified timeout to expire, whichever happens first.
- awaitResults() - Method in class org.jppf.client.JPPFJob
-
Wait until all execution results of the tasks in this job have been collected.
- awaitResults(long) - Method in class org.jppf.client.JPPFJob
-
Wait until all execution results of the tasks in this job have been collected, or the timeout expires, whichever happens first.
- awaitTermination(long, TimeUnit) - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.
- awaitWorkingConnection() - Method in class org.jppf.client.JPPFConnectionPool
- awaitWorkingConnectionPool() - Method in class org.jppf.client.JPPFClient
- awaitWorkingConnectionPools() - Method in class org.jppf.client.JPPFClient
- awaitWorkingConnectionPools(long) - Method in class org.jppf.client.JPPFClient
- awaitWorkingConnections(ComparisonOperator, int) - Method in class org.jppf.client.JPPFConnectionPool
- awaitWorkingJMXConnection() - Method in class org.jppf.client.JPPFConnectionPool
-
Wait an established JMX connection to be available.
B
- broadcastCompleted(ClientJob) - Method in class org.jppf.client.balancer.ClientJob
-
Called to notify that the execution of broadcast job has completed.
- broadcastDispatched(ClientJob) - Method in class org.jppf.client.balancer.ClientJob
-
Called when all or part of broadcast job is dispatched to a driver.
- bundleAdded(QueueEvent<ClientJob, ClientJob, ClientTaskBundle>) - Method in class org.jppf.client.AbstractGenericClient
- bundleAdded(QueueEvent<ClientJob, ClientJob, ClientTaskBundle>) - Method in class org.jppf.client.event.ClientQueueEventDispatcher
- bundleRemoved(QueueEvent<ClientJob, ClientJob, ClientTaskBundle>) - Method in class org.jppf.client.AbstractGenericClient
- bundleRemoved(QueueEvent<ClientJob, ClientJob, ClientTaskBundle>) - Method in class org.jppf.client.event.ClientQueueEventDispatcher
C
- cancel() - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Called when this task bundle is cancelled.
- cancel() - Method in class org.jppf.client.JPPFJob
-
Cancel this job unconditionally.
- cancel(boolean) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Cancels this job.
- cancel(boolean) - Method in class org.jppf.client.balancer.ClientJob
- cancel(boolean) - Method in class org.jppf.client.concurrent.JPPFTaskFuture
-
Attempts to cancel execution of this task.
- cancel(boolean) - Method in class org.jppf.client.JPPFJob
- cancel(ClientTaskBundle) - Method in class org.jppf.client.balancer.AbstractChannelWrapperRemote
- cancel(ClientTaskBundle) - Method in class org.jppf.client.balancer.ChannelWrapper
-
Cancel the currently executing job, if any.
- cancel(ClientTaskBundle) - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- cancelBroadcastJobs(String) - Method in class org.jppf.client.balancer.queue.JPPFPriorityQueue
-
Cancels queued broadcast jobs for connection.
- cancelJob(String) - Method in class org.jppf.client.AbstractGenericClient
-
Cancel the job with the specified id.
- cancelJob(String) - Method in class org.jppf.client.balancer.JobManagerClient
- cancelJob(String) - Method in class org.jppf.client.balancer.queue.JPPFPriorityQueue
-
Cancel the job with the specified UUID.
- cancelJob(String) - Method in interface org.jppf.client.JobManager
-
Cancel the job with the specified id.
- cancelled - Variable in class org.jppf.client.concurrent.JPPFTaskFuture
-
The cancellation status of the task represented by this future.
- CANCELLED - Enum constant in enum class org.jppf.client.balancer.ClientJobStatus
-
Job status is cancelled.
- ChannelWrapper - Class in org.jppf.client.balancer
-
Context associated with a channel serving state and tasks submission.
- ChannelWrapper() - Constructor for class org.jppf.client.balancer.ChannelWrapper
-
Default constructor.
- ChannelWrapperLocal - Class in org.jppf.client.balancer
-
Context associated with a local channel serving state and tasks submission.
- ChannelWrapperLocal(JPPFClient) - Constructor for class org.jppf.client.balancer.ChannelWrapperLocal
-
Default initializer for local channel wrapper.
- ChannelWrapperRemoteAsync - Class in org.jppf.client.balancer
-
Context associated with a remote channel serving state and tasks submission.
- ChannelWrapperRemoteAsync(JPPFClientConnection) - Constructor for class org.jppf.client.balancer.ChannelWrapperRemoteAsync
-
Default initializer for remote channel wrapper.
- checkBundler(JPPFBundlerFactory, JPPFContext) - Method in class org.jppf.client.balancer.ChannelWrapper
-
Check whether the bundler held by this context is up to date by comparison with the specified bundler.
If it is not, then it is replaced with a copy of the specified bundler, with a timestamp taken at creation time. - children - Variable in class org.jppf.client.monitoring.AbstractComponent
-
The children of this component.
- ClasspathCache - Class in org.jppf.client
-
A cache of claspath resources on the client side.
- ClassServerDelegate - Interface in org.jppf.client
-
Interface for all class server clients.
- cleanup() - Method in class org.jppf.client.balancer.ClientExecutionManager
-
Cleanup method invoked when all tasks for the current bundle have completed.
- clear() - Method in class org.jppf.client.balancer.TaskStateMap
- clear() - Method in class org.jppf.client.ClasspathCache
-
Clear the cache.
- clear() - Method in class org.jppf.client.JobResults
-
Clear all results in case the job is manually resubmitted.
- clearChannels() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Clear the channels used to dispatch this job.
- clearChannels() - Method in class org.jppf.client.balancer.queue.JobScheduler
-
Clear all channels from this task queue checker.
- ClientConfigDriverDiscovery - Class in org.jppf.client
-
Built-in driver discovery which creates connections pools based on the client configuration.
- ClientConfigDriverDiscovery(TypedProperties) - Constructor for class org.jppf.client.ClientConfigDriverDiscovery
-
Initialize this discovery with the specified client configuration.
- ClientConnectionStatusEvent - Class in org.jppf.client.event
-
Event sent to notify of a status change for a client connection.
- ClientConnectionStatusEvent(JPPFClientConnection, JPPFClientConnectionStatus) - Constructor for class org.jppf.client.event.ClientConnectionStatusEvent
-
Initialize this event with a client connection as source.
- ClientConnectionStatusHandler - Interface in org.jppf.client.event
-
Interface implemented by all classes that desire to handle a connection status and notify others about status changes.
- ClientConnectionStatusListener - Interface in org.jppf.client.event
-
Instances of this class listen to status change events on client connections.
- ClientExecutionManager - Class in org.jppf.client.balancer
-
Instances of this class manage the execution of JPPF tasks by a node.
- ClientExecutionManager(TypedProperties, JPPFProperty<Integer>) - Constructor for class org.jppf.client.balancer.ClientExecutionManager
-
Initialize this execution manager.
- ClientJob - Class in org.jppf.client.balancer
- ClientJob(JPPFJob, Collection<Task<?>>) - Constructor for class org.jppf.client.balancer.ClientJob
-
Initialized client job with task bundle and list of tasks to execute.
- ClientJob(JPPFJob, Collection<Task<?>>, ClientJob, String) - Constructor for class org.jppf.client.balancer.ClientJob
-
Initialized client job with task bundle and list of tasks to execute.
- ClientJobStatus - Enum Class in org.jppf.client.balancer
- ClientQueueEvent - Class in org.jppf.client.event
-
Instances of this class represent events emitted by the JPPF client job queue whenever a job is added to or removed from the queue.
- ClientQueueEvent(JPPFClient, JPPFJob, JPPFPriorityQueue) - Constructor for class org.jppf.client.event.ClientQueueEvent
-
Initialize this event with the specified source JPPF client and Job.
- ClientQueueEventDispatcher - Class in org.jppf.client.event
- ClientQueueEventDispatcher() - Constructor for class org.jppf.client.event.ClientQueueEventDispatcher
- ClientQueueListener - Interface in org.jppf.client.event
-
Interface for classes that wish to be notified of jobs added to or removed from the job queue.
- ClientQueueListenerAdapter - Class in org.jppf.client.event
-
Client queue listener adapter, providing no-op implementations of the
ClientQueueListenerinterface methods. - ClientQueueListenerAdapter() - Constructor for class org.jppf.client.event.ClientQueueListenerAdapter
- ClientResourceProvider - Class in org.jppf.client
-
A resource provider on the client side which uses an underlying resource cache.
- ClientResourceProvider() - Constructor for class org.jppf.client.ClientResourceProvider
- ClientTaskBundle - Class in org.jppf.client.balancer
-
Instances of this class group tasks from the same client together, so they are sent to the same node, avoiding unnecessary transport overhead.
The goal is to provide a performance enhancement through an adaptive bundling of tasks originating from the same client. - ClientTaskBundle(ClientJob, Collection<Task<?>>) - Constructor for class org.jppf.client.balancer.ClientTaskBundle
-
Initialize this task bundle and set its build number.
- clientUuid - Variable in class org.jppf.client.AbstractClassServerDelegate
-
Unique identifier for this class server delegate, obtained from the local JPPF client.
- close() - Method in class org.jppf.client.AbstractClassServerDelegate
-
Close the socket connection.
- close() - Method in class org.jppf.client.AbstractClientConnectionHandler
- close() - Method in class org.jppf.client.AbstractClientConnectionPool
- close() - Method in class org.jppf.client.AbstractConnectionPool
- close() - Method in class org.jppf.client.AbstractGenericClient
- close() - Method in class org.jppf.client.AbstractJPPFClient
-
Close this client and release all the resources it is using.
- close() - Method in class org.jppf.client.balancer.ChannelWrapper
- close() - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- close() - Method in class org.jppf.client.balancer.ChannelWrapperRemoteAsync
- close() - Method in class org.jppf.client.balancer.JobManagerClient
- close() - Method in class org.jppf.client.balancer.queue.JPPFPriorityQueue
-
Close this queue and all resources it uses.
- close() - Method in interface org.jppf.client.JobManager
-
Close this job manager and all the resources it uses.
- close() - Method in class org.jppf.client.JPPFClient
- close() - Method in interface org.jppf.client.JPPFClientConnection
-
Shutdown this connection and release all the resources it is using.
- close() - Method in class org.jppf.client.JPPFClientConnectionImpl
-
Shutdown this connection and retrieve all pending executions for resubmission.
- close() - Method in class org.jppf.client.JPPFConnectionPool
- close() - Method in class org.jppf.client.monitoring.jobs.JobMonitor
- close() - Method in interface org.jppf.client.monitoring.jobs.JobMonitoringHandler
- close() - Method in class org.jppf.client.monitoring.topology.TopologyManager
- close() - Method in class org.jppf.client.persistence.DefaultFilePersistenceManager
- close() - Method in interface org.jppf.client.persistence.JobPersistence
-
Close this store and release any used resources.
- close() - Method in class org.jppf.client.utils.AbstractJPPFJobStream
-
Close this stream and release the underlying resources it uses.
- CLOSED - Enum constant in enum class org.jppf.client.JPPFClientConnectionStatus
-
The connection was closed by the application.
- compareTo(AbstractClientConnectionPool) - Method in class org.jppf.client.AbstractClientConnectionPool
-
Compares this connection pool with another, based on their respective priorities.
- COMPLETE - Enum constant in enum class org.jppf.client.JobStatus
-
The job execution is complete.
- computeKey(JPPFJob) - Method in class org.jppf.client.persistence.DefaultFilePersistenceManager
-
Compute the key assigned ot the specified job.
- computeKey(JPPFJob) - Method in interface org.jppf.client.persistence.JobPersistence
-
Compute the key for the specified job.
- config - Variable in class org.jppf.client.AbstractJPPFClient
-
The JPPF configuration properties.
- CONNECTING - Enum constant in enum class org.jppf.client.JPPFClientConnectionStatus
-
The connection is currently attempting to connect to the driver.
- connectionAdded(ConnectionPoolEvent) - Method in interface org.jppf.client.event.ConnectionPoolListener
-
Called when a new connection is created.
- connectionAdded(ConnectionPoolEvent) - Method in class org.jppf.client.event.ConnectionPoolListenerAdapter
- connectionAdded(ConnectionPoolEvent) - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Called when a new connection is created.
- connectionCount() - Method in class org.jppf.client.AbstractConnectionPool
- connectionCount() - Method in interface org.jppf.client.ConnectionPool
-
Get the current size of this pool.
- connectionCount(JPPFClientConnectionStatus...) - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get the number of connections in this pool that have one of the psecified statuses.
- ConnectionInitializer - Class in org.jppf.client
-
Wrapper class for the initialization of a client connection.
- ConnectionInitializer(JPPFClientConnectionImpl) - Constructor for class org.jppf.client.ConnectionInitializer
-
Instantiate this connection initializer with the specified client connection.
- ConnectionPool<E extends AutoCloseable> - Interface in org.jppf.client
-
Interface for pools of connections with a maximum size which can be dynamically updated.
- connectionPoolAdded(ConnectionPoolEvent) - Method in interface org.jppf.client.event.ConnectionPoolListener
-
Called when a new connection pool is created.
- connectionPoolAdded(ConnectionPoolEvent) - Method in class org.jppf.client.event.ConnectionPoolListenerAdapter
- ConnectionPoolEvent - Class in org.jppf.client.event
-
Instances of this class represent events in a
JPPFConnectionPool's life cycle. - ConnectionPoolEvent(JPPFConnectionPool) - Constructor for class org.jppf.client.event.ConnectionPoolEvent
-
Initialize this event with the specified source.
- ConnectionPoolEvent(JPPFConnectionPool, JPPFClientConnection) - Constructor for class org.jppf.client.event.ConnectionPoolEvent
-
Initialize this event with the specified source and client connection.
- ConnectionPoolFilter<E extends ConnectionPool<?>> - Interface in org.jppf.client
-
Interface for filtering
connection pools. - ConnectionPoolListener - Interface in org.jppf.client.event
-
Base interface for classes wishing to be notified of connection pool events.
- ConnectionPoolListenerAdapter - Class in org.jppf.client.event
-
This adapter class provides an empty implementation of each method in the
ConnectionPoolListenerinterface. - ConnectionPoolListenerAdapter() - Constructor for class org.jppf.client.event.ConnectionPoolListenerAdapter
- connectionPoolRemoved(ConnectionPoolEvent) - Method in interface org.jppf.client.event.ConnectionPoolListener
-
Called when a connection pool removed.
- connectionPoolRemoved(ConnectionPoolEvent) - Method in class org.jppf.client.event.ConnectionPoolListenerAdapter
- connectionRemoved(ConnectionPoolEvent) - Method in interface org.jppf.client.event.ConnectionPoolListener
-
Called when a connection pool is removed.
- connectionRemoved(ConnectionPoolEvent) - Method in class org.jppf.client.event.ConnectionPoolListenerAdapter
- connectionRemoved(ConnectionPoolEvent) - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Called when a connection pool is removed.
- copy() - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Make a copy of this bundle.
- copy(int) - Method in class org.jppf.client.balancer.ClientJob
-
Make a copy of this client job wrapper containing only the first nbTasks tasks it contains.
- createBroadcastJob(String) - Method in class org.jppf.client.balancer.ClientJob
-
Make a copy of this client job wrapper.
- createJobManager() - Method in class org.jppf.client.JPPFClient
- createNextJob() - Method in class org.jppf.client.utils.AbstractJPPFJobStream
-
Create the next job in the stream, along with its tasks.
- createSSLConnection() - Method in class org.jppf.client.AbstractClientConnectionHandler
-
Create the ssl connection over an established plain connection.
D
- Debug - Class in org.jppf.client.debug
- Debug(JPPFClient) - Constructor for class org.jppf.client.debug.Debug
-
Initialize this MBean instance.
- DebugMBean - Interface in org.jppf.client.debug
- DEFAULT_EXT - Static variable in class org.jppf.client.persistence.DefaultFilePersistenceManager
-
The default extension for the files in the store.
- DEFAULT_PREFIX - Static variable in class org.jppf.client.persistence.DefaultFilePersistenceManager
-
The default prefix for the files in the store.
- DefaultFilePersistenceManager - Class in org.jppf.client.persistence
-
This implementation of
JobPersistencestores jobs on the file system using Java serialization to a file for each job, and uses the jobs uuids as keys to retrieve them. - DefaultFilePersistenceManager(File) - Constructor for class org.jppf.client.persistence.DefaultFilePersistenceManager
-
Initialize this persistence manager with the specified root path, using
DEFAULT_PREFIXas the files prefix andDEFAULT_EXTas the extension. - DefaultFilePersistenceManager(File, String, String) - Constructor for class org.jppf.client.persistence.DefaultFilePersistenceManager
-
Initialize this persistence manager with the specified root path, file prefix and extension.
- DefaultFilePersistenceManager(String) - Constructor for class org.jppf.client.persistence.DefaultFilePersistenceManager
-
Initialize this persistence manager with the specified root path, using "job" as the files prefix and ".ser" as the extension.
- DefaultFilePersistenceManager(String, String, String) - Constructor for class org.jppf.client.persistence.DefaultFilePersistenceManager
-
Initialize this persistence manager with the specified root path.
- DEFERRED_NOTIFICATIONS - Enum constant in enum class org.jppf.client.monitoring.jobs.JobMonitorUpdateMode
-
Updates are computed from JMX notifications and published periodically as job monitor events.
- deleteJob(String) - Method in class org.jppf.client.JPPFDriverJobPersistence
-
Delete the persisted job with the specified uuid.
- deleteJob(String) - Method in class org.jppf.client.persistence.DefaultFilePersistenceManager
- deleteJob(K) - Method in interface org.jppf.client.persistence.JobPersistence
-
Delete the job with the specified key from the persistence store.
- deleteJobs(JobSelector) - Method in class org.jppf.client.JPPFDriverJobPersistence
-
Delete the persisted jobs that match the provided job selector.
- DISCONNECTED - Enum constant in enum class org.jppf.client.JPPFClientConnectionStatus
-
The connection was disconnected from the driver.
- discover() - Method in class org.jppf.client.ClientConfigDriverDiscovery
- dispatch() - Method in class org.jppf.client.balancer.queue.JobScheduler
-
Perform the assignment of tasks.
- done - Variable in class org.jppf.client.concurrent.JPPFTaskFuture
-
The completion status of the task represented by this future.
- done() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Called when task was cancelled or finished.
- DONE - Enum constant in enum class org.jppf.client.balancer.ClientJobStatus
-
Job status is done/complete.
- DOWN - Enum constant in enum class org.jppf.client.monitoring.topology.TopologyNodeStatus
-
The node is down.
- driverAdded(JobMonitoringEvent) - Method in interface org.jppf.client.monitoring.jobs.JobMonitoringListener
-
Called when a new driver is added to the topology.
- driverAdded(JobMonitoringEvent) - Method in class org.jppf.client.monitoring.jobs.JobMonitoringListenerAdapter
- driverAdded(TopologyEvent) - Method in class org.jppf.client.monitoring.jobs.JobMonitor
-
Called when a driver is added.
- driverAdded(TopologyEvent) - Method in interface org.jppf.client.monitoring.topology.TopologyListener
-
Called when a driver is added.
- driverAdded(TopologyEvent) - Method in class org.jppf.client.monitoring.topology.TopologyListenerAdapter
- driverRemoved(JobMonitoringEvent) - Method in interface org.jppf.client.monitoring.jobs.JobMonitoringListener
-
Called when a new driver is added to the topology.
- driverRemoved(JobMonitoringEvent) - Method in class org.jppf.client.monitoring.jobs.JobMonitoringListenerAdapter
- driverRemoved(TopologyEvent) - Method in class org.jppf.client.monitoring.jobs.JobMonitor
-
Called when a driver is removed.
- driverRemoved(TopologyEvent) - Method in interface org.jppf.client.monitoring.topology.TopologyListener
-
Called when a driver is removed.
- driverRemoved(TopologyEvent) - Method in class org.jppf.client.monitoring.topology.TopologyListenerAdapter
- driverUpdated(TopologyEvent) - Method in interface org.jppf.client.monitoring.topology.TopologyListener
-
Called when the state of a driver has changed.
- driverUpdated(TopologyEvent) - Method in class org.jppf.client.monitoring.topology.TopologyListenerAdapter
E
- equals(Object) - Method in class org.jppf.client.AbstractClientConnectionPool
- equals(Object) - Method in class org.jppf.client.AbstractJPPFJob
- equals(Object) - Method in class org.jppf.client.monitoring.AbstractComponent
- execute(Runnable) - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Executes the given command at some time in the future.
- executedTaskCount() - Method in class org.jppf.client.AbstractJPPFJob
-
Get the count of the tasks in this job that haven completed.
- EXECUTING - Enum constant in enum class org.jppf.client.balancer.ClientJobStatus
-
Job status is executing.
- EXECUTING - Enum constant in enum class org.jppf.client.JobStatus
-
The job is being executed.
- EXECUTING - Enum constant in enum class org.jppf.client.JPPFClientConnectionStatus
-
The connection is currently executing a job.
- ExecutorServiceConfiguration - Interface in org.jppf.client.concurrent
-
Interface for the configuration properties of a
JPPFExecutorService.
F
- FAILED - Enum constant in enum class org.jppf.client.JobStatus
-
The job execution has failed.
- FAILED - Enum constant in enum class org.jppf.client.JPPFClientConnectionStatus
-
The connection failed to (re)connect to the driver and no further attempt will be made.
- findConnectionPool(int) - Method in class org.jppf.client.AbstractJPPFClient
-
Find the connection pool with the specified id.
- findConnectionPool(int, int) - Method in class org.jppf.client.AbstractJPPFClient
-
Find the connection pool with the specified priority and id.
- findConnectionPool(String) - Method in class org.jppf.client.AbstractJPPFClient
-
Find the connection pool with the specified id.
- findConnectionPools(String) - Method in class org.jppf.client.AbstractJPPFClient
-
Find the connection pools whose name matches the specified
regular expression. - findConnectionPools(ConnectionPoolFilter<JPPFConnectionPool>) - Method in class org.jppf.client.AbstractJPPFClient
-
Find the connection pools that pass the specified filter.
- findConnectionPools(JPPFClientConnectionStatus...) - Method in class org.jppf.client.AbstractJPPFClient
-
Find the connection pools that have a least one connection matching one of the specified statuses.
- fireExecutionStatusChanged(ExecutorStatus, ExecutorStatus) - Method in class org.jppf.client.balancer.ChannelWrapper
-
Notify all listeners that the execution status of this channel has changed.
- fireJobEvent(JobEvent.Type, ExecutorChannel<ClientTaskBundle>, List<Task<?>>) - Method in class org.jppf.client.JPPFJob
-
Notify all listeners of the specified event type.
- fireQueueEvent(QueueEvent<ClientJob, ClientJob, ClientTaskBundle>, boolean) - Method in class org.jppf.client.AbstractGenericClient
-
Notify all client queue listeners that a queue event has occurred.
- fireStatusChanged(JPPFClientConnectionStatus, JPPFClientConnectionStatus) - Method in class org.jppf.client.balancer.ChannelWrapperLocal
-
Notify all listeners that the status of this connection has changed.
- fireStatusChangeEvent(JobStatus) - Method in class org.jppf.client.AbstractJPPFJob
-
Notify all listeners of a change of status for this job.
- formattedName - Variable in class org.jppf.client.AbstractClassServerDelegate
-
Readable name for this delegate.
G
- get() - Method in class org.jppf.client.concurrent.JPPFTaskFuture
-
Waits if necessary for the computation to complete, and then retrieves its result.
- get() - Method in class org.jppf.client.JPPFJob
- get(long, TimeUnit) - Method in class org.jppf.client.concurrent.JPPFTaskFuture
-
Waits if necessary for at most the given time for the computation to complete, and then retrieves its result, if available.
- get(long, TimeUnit) - Method in class org.jppf.client.JPPFJob
- get(ClassLoader, String) - Method in class org.jppf.client.ClasspathCache
-
Get a resource at the specified path of the specified class loader's classpath.
- getAllConnections() - Method in class org.jppf.client.balancer.JobManagerClient
-
Get all the client connections handled by this manager.
- getAllConnectionsCount() - Method in class org.jppf.client.AbstractJPPFClient
-
Get count of all client connections handled by this JPPFClient.
- getAllJobDispatches(String) - Method in class org.jppf.client.monitoring.jobs.JobMonitor
-
Get the dispatches of the specified job accrosss the entire topology.
- getAllJobListeners() - Method in interface org.jppf.client.concurrent.JobConfiguration
-
Get all the job listeners added to this job configuration.
- getAllResults() - Method in class org.jppf.client.JobResults
-
Get all the tasks received as results for this job.
- getAllResults() - Method in class org.jppf.client.JPPFJob
-
Get the list of currently available task execution results.
- getAvailableConnections() - Method in class org.jppf.client.balancer.JobManagerClient
- getAvailableConnections() - Method in interface org.jppf.client.JobManager
-
Get the list of available connections.
- getAvailableGraphNodeCount() - Method in class org.jppf.client.balancer.ClientJob
- getBatchSize() - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Get the minimum number of tasks that must be submitted before they are sent to the server.
- getBatchTimeout() - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Get the maximum time to wait before the next batch of tasks is to be sent for execution.
- getBroadcastUUID() - Method in class org.jppf.client.balancer.ClientJob
-
Get the broadcast UUID.
- getBroadcastUUID() - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Get the broadcast UUID.
- getBundleId() - Method in class org.jppf.client.balancer.ClientTaskBundle
- getBundler() - Method in class org.jppf.client.balancer.ChannelWrapper
-
Get the bundler used to schedule tasks for the corresponding node.
- getBundlerFactory() - Method in class org.jppf.client.JPPFClient
-
Get the factory that creates load-balancer instances.
- getCacheSize() - Method in class org.jppf.client.ClasspathCache
-
Compute the cache size.
- getCancelledFlag() - Method in class org.jppf.client.AbstractJPPFJob
-
Get the flag that determines whether this job has been cancelled.
- getCancellingFlag() - Method in class org.jppf.client.AbstractJPPFJob
-
Get the flag that determines whether this job is being cancelled.
- getChannel() - Method in class org.jppf.client.balancer.AbstractChannelWrapperRemote
-
Get the wrapped channel.
- getChild(String) - Method in class org.jppf.client.monitoring.AbstractComponent
-
Get the child with the specified uuid.
- getChildCount() - Method in class org.jppf.client.monitoring.AbstractComponent
-
Get the number of children of this topology component.
- getChildren() - Method in class org.jppf.client.monitoring.AbstractComponent
-
Get the children of this component in a thread-safe way.
- getClassLoaders() - Method in interface org.jppf.client.concurrent.JobConfiguration
-
Get all the class loaders added to this job configuration.
- getClient() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get the JPPF client which holds this pool.
- getClient() - Method in class org.jppf.client.JPPFClientConnectionImpl
-
Get the JPPF client that owns this connection.
- getClient() - Method in class org.jppf.client.event.ClientQueueEvent
-
Get the JPPF client source of this event.
- getClientConnection() - Method in class org.jppf.client.event.ClientConnectionStatusEvent
-
Get the source of this event.
- getClientConnection(int, JPPFClientConnectionStatus...) - Method in class org.jppf.client.AbstractJPPFClient
-
Get a connection with the specified priority that matches one of the specified statuses.
- getClientConnectionStatusHandler() - Method in class org.jppf.client.event.ClientConnectionStatusEvent
-
Deprecated.
- getClientConnectionStatusListener() - Method in class org.jppf.client.balancer.JobManagerClient
- getClientConnectionStatusListener() - Method in interface org.jppf.client.JobManager
-
Get a listener to the status of the managed connections.
- getClientJob() - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Get the client job this job is for.
- getClientSLA() - Method in class org.jppf.client.AbstractJPPFJob
-
Get the job SLA for the client side.
- getClientSLA() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Get the service level agreement between the job and the client.
- getClientSLA() - Method in interface org.jppf.client.concurrent.JobConfiguration
-
Get the service level agreement between the job and the client.
- getConfig() - Method in class org.jppf.client.AbstractJPPFClient
-
Get JPPF configuration properties.
- getConfiguration() - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Get the configuration for this executor service.
- getConnection() - Method in class org.jppf.client.AbstractClientConnectionPool
- getConnection() - Method in interface org.jppf.client.ConnectionPool
-
Get the next connection that is connected and available.
- getConnection() - Method in class org.jppf.client.event.ConnectionPoolEvent
-
Get the connection that triggered this event.
- getConnection() - Method in class org.jppf.client.event.JobEvent
-
Get the remote driver connection through which the job dispatch was sent.
- getConnection() - Method in class org.jppf.client.monitoring.topology.TopologyDriver
-
Get the driver connection.
- getConnectionPool() - Method in class org.jppf.client.AbstractJPPFClient
-
Get a pool with at least one
activeconnection and with the highest possible priority. - getConnectionPool() - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- getConnectionPool() - Method in class org.jppf.client.event.ConnectionPoolEvent
-
Get the source of this event.
- getConnectionPool() - Method in interface org.jppf.client.JPPFClientConnection
-
Get the pool this connection belongs to.
- getConnectionPool() - Method in class org.jppf.client.JPPFClientConnectionImpl
- getConnectionPools() - Method in class org.jppf.client.AbstractJPPFClient
-
Get a list of existing connection pools, ordered by descending priority.
- getConnectionPools(int) - Method in class org.jppf.client.AbstractJPPFClient
-
Get a set of existing connection pools with the specified priority.
- getConnections() - Method in class org.jppf.client.AbstractConnectionPool
- getConnections() - Method in interface org.jppf.client.ConnectionPool
-
Get a list of connections held by this pool.
- getConnections(JPPFClientConnectionStatus...) - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get a list of connections held by this pool whose status is one of the specified statuses.
- getConnectionUuid() - Method in class org.jppf.client.balancer.AbstractChannelWrapperRemote
- getConnectionUuid() - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- getConnectionUuid() - Method in class org.jppf.client.JPPFClientConnectionImpl
- getConnectionUuid() - Method in interface org.jppf.client.JPPFClientConnection
-
Get the unique ID for this connection and its two channels.
- getCurrentNbJobs() - Method in class org.jppf.client.balancer.ChannelWrapper
- getDataProvider() - Method in class org.jppf.client.AbstractJPPFJob
-
Get the container for data shared between tasks.
- getDataProvider() - Method in interface org.jppf.client.concurrent.JobConfiguration
-
Get the job's data provider.
- getDataProviderL() - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Get shared data provider for this task.
- getDefaultClientPolicy() - Method in class org.jppf.client.JPPFClient
-
Get the default client-side job execution policy.
- getDefaultPolicy() - Method in class org.jppf.client.JPPFClient
-
Get the default server-side job execution policy.
- getDiagnostics() - Method in class org.jppf.client.monitoring.topology.TopologyDriver
-
Gert the diagnostics mbean for this driver.
- getDisplayName() - Method in class org.jppf.client.monitoring.AbstractComponent
-
Get a user-friendly representation of this topology component.
- getDisplayName() - Method in class org.jppf.client.monitoring.jobs.Job
- getDisplayName() - Method in class org.jppf.client.monitoring.jobs.JobDispatch
- getDisplayName() - Method in class org.jppf.client.monitoring.jobs.JobDriver
- getDisplayName() - Method in class org.jppf.client.monitoring.topology.TopologyDriver
- getDisplayName() - Method in class org.jppf.client.monitoring.topology.TopologyNode
- getDriver() - Method in class org.jppf.client.monitoring.topology.TopologyEvent
-
Get the driver data.
- getDriver() - Method in class org.jppf.client.monitoring.topology.TopologyNode
-
Convenience method to get the driver this node is attached to as a
TopologyDriverinstance. - getDriver(String) - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Get the driver with the specified uuid.
- getDriverCount() - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Get the number of drivers currently handled.
- getDriverHost() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get the host name of the remote driver.
- getDriverIPAddress() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get the ip address of the remote driver.
- getDriverPort() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get the port to use on the remote driver.
- getDrivers() - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Get the drivers currently handled.
- getDriversForJob(String) - Method in class org.jppf.client.monitoring.jobs.JobMonitor
-
Get the drivers to which a job was submitted, either in parallel from the same client, or from one driver to another in a multi-driver topology.
- getDriverUuid() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get the uuid of the driver to which connections in this pool are connected.
- getDriverUuid() - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- getDriverUuid() - Method in class org.jppf.client.JPPFClientConnectionImpl
- getDriverUuid() - Method in interface org.jppf.client.JPPFClientConnection
-
Get the unique identifier of the remote driver.
- getExecutedJobCount() - Method in class org.jppf.client.utils.AbstractJPPFJobStream
-
Get the number of completed jobs.
- getExecutionStatus() - Method in class org.jppf.client.balancer.ChannelWrapper
- getExecutor() - Method in class org.jppf.client.AbstractGenericClient
-
Get the pool of threads used for submitting execution requests.
- getForwarder() - Method in class org.jppf.client.monitoring.topology.TopologyDriver
-
Get the proxy to the driver MBean that forwards node management requests.
- getGraphInfo() - Method in class org.jppf.client.balancer.ClientTaskBundle
- getHealthSnapshot() - Method in class org.jppf.client.monitoring.topology.AbstractTopologyComponent
-
Get the object describing the health of a node or driver.
- getHighestPriority() - Method in class org.jppf.client.balancer.queue.JobScheduler
-
Set the highest priority.
- getHost() - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- getHost() - Method in class org.jppf.client.JPPFClientConnectionImpl
- getHost() - Method in interface org.jppf.client.JPPFClientConnection
-
Get the driver's host name or ip address.
- getId() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get the id of this pool.
- getId(JPPFJob) - Method in interface org.jppf.client.JobDependencyIdSupplier
-
Compute a dependency id from the supplied job.
- getIdleChannels() - Method in class org.jppf.client.balancer.queue.JobScheduler
-
Get the list of idle channels.
- getInstance() - Static method in class org.jppf.client.ClasspathCache
- getJmx() - Method in class org.jppf.client.monitoring.topology.TopologyDriver
-
Get the wrapper holding the connection to the JMX server on a driver or node.
- getJmxConnection() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get a connected JMX connection among those in the JMX pool.
- getJmxConnection(boolean) - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get a JMX connection among those in the JMX pool.
- getJMXConnections() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get the list of connections currently in the JMX pool.
- getJMXPoolMaxSize() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Deprecated.use
AbstractClientConnectionPool.getJMXPoolSize()instead. - getJMXPoolSize() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get the current maximum size of the associated JMX connection pool.
- getJmxPort() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get the jmx port to use on the remote driver.
- getJob() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Get the underlying task bundle.
- getJob() - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Get the job this job is for.
- getJob() - Method in class org.jppf.client.concurrent.JPPFTaskFuture
-
Get the job that holds the task.
- getJob() - Method in class org.jppf.client.event.ClientQueueEvent
-
Get the job that was added or removed.
- getJob() - Method in class org.jppf.client.event.JobEvent
-
Get the source of this event.
- getJob() - Method in class org.jppf.client.monitoring.jobs.JobDispatch
-
Get the job to which this dispatch belongs.
- getJob() - Method in class org.jppf.client.monitoring.jobs.JobMonitoringEvent
-
Get the related job, if any.
- getJob(String) - Method in class org.jppf.client.monitoring.jobs.JobDriver
-
Get a job handled by this driver from its uuid.
- getJobConfiguration() - Method in interface org.jppf.client.concurrent.ExecutorServiceConfiguration
-
Get the configuration to use for the jobs submitted by the executor service.
- getJobCount() - Method in class org.jppf.client.utils.AbstractJPPFJobStream
-
Get the number of submitted jobs.
- getJobDescription(String) - Method in class org.jppf.client.JPPFDriverJobPersistence
-
Get the description of the job with the specified uuid.
- getJobDispatch() - Method in class org.jppf.client.monitoring.jobs.JobMonitoringEvent
-
Get the related job dispatch, if any.
- getJobDispatch(String) - Method in class org.jppf.client.monitoring.jobs.Job
-
Get the dispatch with the specified node uuid for this job.
- getJobDispatches() - Method in class org.jppf.client.monitoring.jobs.Job
-
Get the job dispatches for this job.
- getJobDriver() - Method in class org.jppf.client.monitoring.jobs.Job
-
Get the driver that holds this job.
- getJobDriver() - Method in class org.jppf.client.monitoring.jobs.JobMonitoringEvent
-
Get the job driver from which this event originates.
- getJobDriver(String) - Method in class org.jppf.client.monitoring.jobs.JobMonitor
-
Get the driver with the specified uuid.
- getJobDrivers() - Method in class org.jppf.client.monitoring.jobs.JobMonitor
-
Get the drivers monitored by this job monitor.
- getJobInformation() - Method in class org.jppf.client.monitoring.jobs.Job
-
Get the information on the job.
- getJobInformation() - Method in class org.jppf.client.monitoring.jobs.JobDispatch
-
Get the information on the job.
- getJobManager() - Method in class org.jppf.client.AbstractGenericClient
-
Get the job manager for this JPPF client.
- getJobManager() - Method in class org.jppf.client.monitoring.jobs.JobDriver
-
Get the proxy to the driver MBean that manages and monitors jobs.
- getJobManager() - Method in class org.jppf.client.monitoring.topology.TopologyDriver
-
Get the proxy to the driver MBean that manages and monitors jobs.
- getJobMonitor() - Method in class org.jppf.client.monitoring.jobs.JobMonitoringEvent
-
Get the job monitor which emitted this event.
- getJobReceivedTime() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Get the job received time.
- getJobs() - Method in class org.jppf.client.monitoring.jobs.JobDriver
-
Get the list of jobs handled by this driver.
- getJobScheduler() - Method in class org.jppf.client.balancer.JobManagerClient
- getJobStatus() - Method in class org.jppf.client.balancer.ClientJob
-
Get the status of this job.
- getJobTasks() - Method in class org.jppf.client.event.JobEvent
-
Get the tasks that were dispatched or returned.
- getJobTasks() - Method in class org.jppf.client.JPPFJob
-
Get the list of tasks to execute.
- getJobUuid() - Method in class org.jppf.client.event.JobStatusEvent
-
Get the id of the job.
- getJPPFClient() - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Get the JPPF client.
- getJPPFContext() - Method in class org.jppf.client.balancer.queue.JobScheduler
-
Get the corresponding node's context information.
- getJPPFJobs() - Method in class org.jppf.client.balancer.queue.JPPFPriorityQueue
-
Get all the
JPPFJobs currently in the queue. - getLoadBalancerPersistenceManagement() - Method in class org.jppf.client.AbstractGenericClient
-
Get the object that manages the persisted states of the load-balancers.
- getLoadBalancerSettings() - Method in class org.jppf.client.balancer.JobManagerClient
- getLoadBalancerSettings() - Method in interface org.jppf.client.JobManager
-
Get the current load-balancer settings.
- getLoadBalancerSettings() - Method in class org.jppf.client.JPPFClient
-
Get the current load-balancer settings.
- getManagementInfo() - Method in class org.jppf.client.balancer.ChannelWrapper
- getManagementInfo() - Method in class org.jppf.client.monitoring.topology.AbstractTopologyComponent
-
Get the management informtation on this topology component.
- getMasterUuid() - Method in class org.jppf.client.monitoring.topology.TopologyNode
-
Get the uuid of the node who this node is a slave of.
- getMaxBundleSize() - Method in class org.jppf.client.JPPFContextClient
- getMaxJobs() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get the maximum number of jobs that can be processed concurrently by each connection.
- getMaxJobs() - Method in class org.jppf.client.balancer.ChannelWrapperRemoteAsync
- getMetadata() - Method in class org.jppf.client.AbstractJPPFJob
- getMetadata() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Get the job metadata.
- getMetadata() - Method in interface org.jppf.client.concurrent.JobConfiguration
-
Get the user-defined metadata associated with this job.
- getMonitor() - Method in class org.jppf.client.balancer.ChannelWrapper
- getName() - Method in class org.jppf.client.AbstractClassServerDelegate
-
Get the name of this delegate.
- getName() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get the name of this pool.
- getName() - Method in class org.jppf.client.AbstractJPPFJob
- getName() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Get the user-defined display name for this job.
- getName() - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- getName() - Method in class org.jppf.client.JPPFClientConnectionImpl
- getName() - Method in interface org.jppf.client.ClassServerDelegate
-
Get the name of this delegate.
- getName() - Method in interface org.jppf.client.JPPFClientConnection
-
Get the name assigned to this client connection.
- getNbChannels() - Method in class org.jppf.client.balancer.ClientJob
-
Get count of channels on which this job is executed.
- getNbIdleChannels() - Method in class org.jppf.client.balancer.queue.JobScheduler
-
Get the number of idle channels.
- getNbSlaveNodes() - Method in class org.jppf.client.monitoring.topology.TopologyNode
-
Get the number of slaves for a master node.
- getNode() - Method in class org.jppf.client.monitoring.jobs.JobDispatch
-
Get the information on the node for ths job dispatch.
- getNode(String) - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Get the node with the specified uuid.
- getNodeCount() - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Get the number of nodes currently handled.
- getNodeFilter() - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Get the node selector used to filter the nodes and associated events.
- getNodeOrPeer() - Method in class org.jppf.client.monitoring.topology.TopologyEvent
-
Get the node data.
- getNodeOrPeer(String) - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Get the node with the psecified uuid.
- getNodes() - Method in class org.jppf.client.monitoring.topology.TopologyDriver
-
Convenience method to get the nodes attached to this driver as
TopologyNodeobjects. - getNodes() - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Get the nodes currently handled.
- getNodesAndPeers() - Method in class org.jppf.client.monitoring.topology.TopologyDriver
-
Convenience method to get the nodes and peers connected to this driver as
TopologyNodeobjects. - getNodeState() - Method in class org.jppf.client.monitoring.topology.TopologyNode
-
Get the object describing the current state of a node.
- getOldStatus() - Method in class org.jppf.client.balancer.ChannelWrapper
- getOldStatus() - Method in class org.jppf.client.event.ClientConnectionStatusEvent
-
Get the connection status before the change.
- getOnCancelCallback() - Method in interface org.jppf.client.concurrent.TaskConfiguration
-
Get the delegate for the
onCancel()method. - getOnTimeoutCallback() - Method in interface org.jppf.client.concurrent.TaskConfiguration
-
Get the delegate for the
onTimeout()method. - getParameter(String) - Method in class org.jppf.client.debug.Debug
- getParameter(String) - Method in interface org.jppf.client.debug.DebugMBean
- getParent() - Method in class org.jppf.client.monitoring.AbstractComponent
-
Get the parent of this compponent.
- getPeer(String) - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Get the peer with the specified uuid.
- getPeerCount() - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Get the number of peers currently handled.
- getPeers() - Method in class org.jppf.client.monitoring.topology.TopologyDriver
-
Convenience method to get the peers connected to this driver as
TopologyPeerobjects. - getPeers() - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Get the peers currently handled.
- getPendingAction() - Method in class org.jppf.client.monitoring.topology.TopologyNode
-
Get the currently pending action forthis node, if any.
- getPersistenceManager() - Method in interface org.jppf.client.concurrent.JobConfiguration
-
Get the persistence manager that enables saving and restoring the state of this job.
- getPersistenceManager() - Method in class org.jppf.client.JPPFJob
-
Get the persistence manager that enables saving and restoring the state of this job.
- getPoolPriorities() - Method in class org.jppf.client.AbstractJPPFClient
-
Get a list of all priorities for the currently existing pools, ordered by descending priority.
- getPort() - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- getPort() - Method in class org.jppf.client.JPPFClientConnectionImpl
- getPort() - Method in interface org.jppf.client.JPPFClientConnection
-
Get the port number on which the dirver is listeneing for connections.
- getPriority() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get the priority associated with this pool.
- getPriority() - Method in class org.jppf.client.balancer.ChannelWrapper
-
The priority assigned to this channel.
- getPriority() - Method in interface org.jppf.client.JPPFClientConnection
-
Get the priority assigned to this connection.
- getPriority() - Method in class org.jppf.client.JPPFClientConnectionImpl
-
Get the priority assigned to this connection.
- getQueue() - Method in class org.jppf.client.balancer.JobManagerClient
- getQueuedJobs() - Method in class org.jppf.client.event.ClientQueueEvent
-
Get all the
JPPFJobs currently in the queue. - getQueuedJobs() - Method in class org.jppf.client.JPPFClient
-
Get the list of currently queued jobs.
- getQueuedJobs(JobSelector) - Method in class org.jppf.client.JPPFClient
-
Get a list of currently queued jobs, filtered by a
JobSelector. - getQueuedJobsCount() - Method in class org.jppf.client.JPPFClient
-
Get the current number of queued jobs.
- getQueuedJobsCount(JobSelector) - Method in class org.jppf.client.JPPFClient
-
Get the current number of jobs that satisfy a job selector.
- getQueueEntryTime() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Get the time at which this wrapper was added to the queue.
- getQueueSize() - Method in class org.jppf.client.event.ClientQueueEvent
-
Get the size of this job queue.
- getRegisteredClassLoaders(String) - Method in class org.jppf.client.AbstractGenericClient
-
Get a class loader associated with a job.
- getResource(String, ClassLoader, boolean) - Method in class org.jppf.client.ClientResourceProvider
- getResults() - Method in class org.jppf.client.AbstractJPPFJob
-
Get the object that holds the results of executed tasks.
- getResultsList() - Method in class org.jppf.client.JobResults
-
Get all the tasks received as results for this job.
- getResultTask(int) - Method in class org.jppf.client.JobResults
-
Get the result for the task at the specified position.
- getSerializationHelperClassName() - Method in class org.jppf.client.AbstractJPPFClient
-
Get the name of the serialization helper implementation class name to use.
- getSize() - Method in class org.jppf.client.AbstractConnectionPool
- getSize() - Method in interface org.jppf.client.ConnectionPool
-
Get the maximum size of this connection pool.
- getSize(ClientJob) - Method in class org.jppf.client.balancer.queue.JPPFPriorityQueue
-
Get the bundle size to use for bundle size tuning.
- getSLA() - Method in class org.jppf.client.AbstractJPPFJob
- getSLA() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Get the service level agreement between the job and the server.
- getSLA() - Method in interface org.jppf.client.concurrent.JobConfiguration
-
Get the service level agreement between the job and the server.
- getSlaveNodes(String) - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Get the nodes that are slaves of the specified master node.
- getSocketClient() - Method in class org.jppf.client.AbstractClientConnectionHandler
-
Get the socket client used to communicate over a socket connection.
- getSocketClient() - Method in interface org.jppf.client.ClassServerDelegate
-
Get the socket client uses to communicate over a socket connection.
- getSocketInitializer() - Method in class org.jppf.client.AbstractClientConnectionHandler
-
Get the object that performs connection attempts until the max retry time is reached or connection succeeds.
- getStateCount(TaskState) - Method in class org.jppf.client.balancer.TaskStateMap
-
Get the number of tasks in the specified state.
- getStatus() - Method in class org.jppf.client.AbstractJPPFJob
- getStatus() - Method in class org.jppf.client.balancer.AbstractChannelWrapperRemote
- getStatus() - Method in class org.jppf.client.balancer.ChannelWrapper
-
Get the status of this connection.
- getStatus() - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- getStatus() - Method in interface org.jppf.client.event.ClientConnectionStatusHandler
-
Get the status of this connection.
- getStatus() - Method in class org.jppf.client.event.JobStatusEvent
-
The status of the job.
- getStatus() - Method in interface org.jppf.client.JobStatusHandler
-
Get the status of the job.
- getStatus() - Method in class org.jppf.client.JPPFClientConnectionImpl
- getStatus() - Method in class org.jppf.client.monitoring.topology.TopologyNode
-
Get the status of the node.
- getSystemInfo() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Get the driver's system information.
- getSystemInfo() - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- getSystemInfo() - Method in interface org.jppf.client.JPPFClientConnection
-
Get the system information for the remote driver this connection refers to.
- getSystemInfo() - Method in class org.jppf.client.JPPFClientConnectionImpl
- getSystemInformation() - Method in class org.jppf.client.balancer.ChannelWrapper
- getTask() - Method in class org.jppf.client.concurrent.JPPFTaskFuture
-
Get the task associated with this future.
- getTaskConfiguration() - Method in interface org.jppf.client.concurrent.ExecutorServiceConfiguration
-
Get the configuration to use for the tasks submitted by the executor service.
- getTaskCount() - Method in class org.jppf.client.AbstractJPPFJob
- getTaskCount() - Method in class org.jppf.client.balancer.ClientJob
-
Get the current number of tasks in the job.
- getTaskCount() - Method in class org.jppf.client.utils.AbstractJPPFJobStream
-
Get the number of submitted task.
- getTaskGraph() - Method in class org.jppf.client.balancer.ClientJob
- getTaskServerConnection() - Method in class org.jppf.client.JPPFClientConnectionImpl
-
Get the handler for the connection to the task server.
- getTasksL() - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Get the tasks to be executed by the node.
- getTimeoutSchedule() - Method in interface org.jppf.client.concurrent.TaskConfiguration
-
Get the timeout set on the task.
- getTopologyDriver() - Method in class org.jppf.client.monitoring.jobs.JobDriver
-
Get the associated driver from the topology monitor.
- getTopologyManager() - Method in class org.jppf.client.monitoring.jobs.JobMonitor
-
Get the topology manager associated with this job monitor.
- getTopologyManager() - Method in class org.jppf.client.monitoring.topology.TopologyEvent
-
Get the topology manager which emitted this event.
- getUpdateType() - Method in class org.jppf.client.monitoring.topology.TopologyEvent
-
Get the type of update.
- getUuid() - Method in class org.jppf.client.AbstractJPPFClient
-
Get the unique universal identifier for this JPPF client.
- getUuid() - Method in class org.jppf.client.AbstractJPPFJob
- getUuid() - Method in class org.jppf.client.balancer.AbstractChannelWrapperRemote
- getUuid() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Get the universal unique id for this job.
- getUuid() - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- getUuid() - Method in class org.jppf.client.monitoring.AbstractComponent
-
Get the uuid of this ocmponent.
- getWorkingConnections() - Method in class org.jppf.client.balancer.JobManagerClient
-
Get all the client connections with a working status.
- getWorkingRemoteConnections() - Method in class org.jppf.client.balancer.JobManagerClient
-
Get all the client connections with a working status, excluding the local executor if it is enabled.
H
- handshake() - Method in class org.jppf.client.AbstractClassServerDelegate
-
Perform the handshake with the server.
- handshakeDone - Variable in class org.jppf.client.AbstractClassServerDelegate
-
Determines if the handshake with the server has been performed.
- hasAvailableConnection() - Method in class org.jppf.client.AbstractGenericClient
-
Determine whether there is a client connection available for execution.
- hasAvailableConnection() - Method in class org.jppf.client.balancer.JobManagerClient
- hasAvailableConnection() - Method in interface org.jppf.client.JobManager
-
Determine whether there is a client connection available for execution.
- hasAvvailableGraphNode() - Method in class org.jppf.client.balancer.ClientJob
- hashCode() - Method in class org.jppf.client.AbstractClientConnectionPool
- hashCode() - Method in class org.jppf.client.AbstractJPPFJob
- hashCode() - Method in class org.jppf.client.monitoring.AbstractComponent
- hasIdleChannel() - Method in class org.jppf.client.balancer.queue.JobScheduler
-
Return whether any idle channel is available.
- hasNext() - Method in class org.jppf.client.utils.AbstractJPPFJobStream
-
Determine whether there is at least one more job in the stream.
- hasPending() - Method in class org.jppf.client.balancer.ClientJob
-
Get indicator whether job has pending tasks.
- hasPendingJob() - Method in class org.jppf.client.utils.AbstractJPPFJobStream
-
Determine whether any job is still being executed.
- hasResult(int) - Method in class org.jppf.client.JobResults
-
Determine whether this job received a result for the task at the specified position.
- hasTaskGraph() - Method in class org.jppf.client.JPPFJob
-
Determine whether the tasks in this job form a dependencies graph.
- hasWorkingConnection() - Method in class org.jppf.client.balancer.JobManagerClient
-
Determine whether there is at least one working connection, idle or not.
- healthSnapshot - Variable in class org.jppf.client.monitoring.topology.AbstractTopologyComponent
-
Object describing the current health snapshot of a node or driver.
- heartbeatConnectionFailed(HeartbeatConnectionEvent) - Method in class org.jppf.client.JPPFConnectionPool
I
- IMMEDIATE_NOTIFICATIONS - Enum constant in enum class org.jppf.client.monitoring.jobs.JobMonitorUpdateMode
-
Updates are computed from JMX notifications and pushed immediately as job monitor events.
- init() - Method in interface org.jppf.client.ClassServerDelegate
-
Initialize the connection.
- init() - Method in class org.jppf.client.JPPFClientConnectionImpl
- init() - Method in class org.jppf.client.TaskServerConnectionHandler
-
Initialize the connection.
- init(TypedProperties) - Method in class org.jppf.client.AbstractGenericClient
-
Initialize this client with the specified configuration.
- initChannelID() - Method in class org.jppf.client.balancer.AbstractChannelWrapperRemote
- initChannelID() - Method in class org.jppf.client.balancer.ChannelWrapper
-
Init the channel id for load-balancer persistence.
- initChannelID() - Method in class org.jppf.client.balancer.ChannelWrapperRemoteAsync
- initialTaskCount - Variable in class org.jppf.client.balancer.ClientJob
-
The original number of tasks in the job.
- initPools(TypedProperties) - Method in class org.jppf.client.AbstractGenericClient
- initSocketClient() - Method in class org.jppf.client.AbstractClassServerDelegate
-
Initialize this delegate's resources.
- initSocketClient() - Method in interface org.jppf.client.ClassServerDelegate
-
Initialize the underlying socket connection of this connection handler.
- initSocketClient() - Method in class org.jppf.client.TaskServerConnectionHandler
-
Initialize the underlying socket connection of this connection handler.
- invokeAll(Collection<? extends Callable<T>>) - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Executes the given tasks, returning a list of Futures holding their status and results when all complete.
- invokeAll(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Executes the given tasks, returning a list of Futures holding their status and results when all complete or the timeout expires, whichever happens first.
- invokeAny(Collection<? extends Callable<T>>) - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Executes the given tasks, returning the result of one that has completed successfully (i.e., without throwing an exception), if any do.
- invokeAny(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Executes the given tasks, returning the result of one that has completed successfully (i.e., without throwing an exception), if any do before the given timeout elapses.
- isActive() - Method in class org.jppf.client.balancer.ChannelWrapper
- isAsynchronous() - Method in class org.jppf.client.balancer.ChannelWrapperRemoteAsync
- isBlocking() - Method in class org.jppf.client.AbstractJPPFJob
-
Deprecated.a job should be submittable either synchronously or asynchronously, regardless of its state. The submission mode is the user's choice at the time of submission, using one of
JPPFClient.submit()orJPPFClient.submitAsync(). - isCancelled() - Method in class org.jppf.client.balancer.AbstractClientJob
- isCancelled() - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Get the cancelled indicator.
- isCancelled() - Method in class org.jppf.client.concurrent.JPPFTaskFuture
-
Determine whether this task was cancelled before it completed normally.
- isCancelled() - Method in class org.jppf.client.JPPFJob
- isCancelling() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Whether this job is being cancelled.
- isCancellingOrCancelled() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Whether this job is being cancelled or has already been cancelled.
- isClosed() - Method in class org.jppf.client.AbstractClientConnectionHandler
- isClosed() - Method in class org.jppf.client.AbstractJPPFClient
-
Determine whether this JPPF client is closed.
- isClosed() - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- isClosed() - Method in interface org.jppf.client.ClassServerDelegate
-
Determine whether this connection handler is closed.
- isClosed() - Method in interface org.jppf.client.JPPFClientConnection
-
Determine whether this connection was closed.
- isClosed() - Method in class org.jppf.client.JPPFClientConnectionImpl
- isDone() - Method in class org.jppf.client.balancer.AbstractClientJob
- isDone() - Method in class org.jppf.client.concurrent.JPPFTaskFuture
-
Returns true if this task completed.
- isDone() - Method in enum class org.jppf.client.JobStatus
-
Return whether this status indicates that the job is done, that is, this status is either
JobStatus.COMPLETEorJobStatus.FAILED. - isDone() - Method in class org.jppf.client.JPPFJob
- isDriver() - Method in class org.jppf.client.monitoring.topology.AbstractTopologyComponent
-
Determine whether this object represents a driver.
- isDriver() - Method in class org.jppf.client.monitoring.topology.TopologyDriver
-
This method always returns
true. - isEmpty() - Method in class org.jppf.client.AbstractConnectionPool
- isEmpty() - Method in class org.jppf.client.balancer.queue.JPPFPriorityQueue
- isEmpty() - Method in interface org.jppf.client.ConnectionPool
-
Determine whether this pool is empty.
- isJobComplete(String) - Method in class org.jppf.client.JPPFDriverJobPersistence
-
Determines whether the job has completed and all execution results are available.
- isJobExpired() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Get the job expired indicator.
- isLocal() - Method in class org.jppf.client.balancer.AbstractChannelWrapperRemote
- isLocal() - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- isLocal() - Method in class org.jppf.client.balancer.ChannelWrapperRemoteAsync
- isLocal() - Method in interface org.jppf.client.JPPFClientConnection
-
Determine whether this connection is local, that is, whether it executes jobs in the local JVM.
- isLocalExecutionEnabled() - Method in class org.jppf.client.AbstractGenericClient
-
Determine whether local execution is enabled on this client.
- isLocalExecutionEnabled() - Method in class org.jppf.client.balancer.JobManagerClient
- isLocalExecutionEnabled() - Method in interface org.jppf.client.JobManager
-
Determine whether local execution is enabled on this client.
- isNode() - Method in class org.jppf.client.monitoring.topology.AbstractTopologyComponent
-
Determine whether this object represents a node.
- isNode() - Method in class org.jppf.client.monitoring.topology.TopologyNode
-
This method always returns
true. - isNode() - Method in class org.jppf.client.monitoring.topology.TopologyPeer
-
This method always returns
false. - isOneOf(List<JPPFClientConnectionStatus>) - Method in enum class org.jppf.client.JPPFClientConnectionStatus
-
Determine whether this status is one of those specified as input.
- isPeer() - Method in class org.jppf.client.monitoring.topology.AbstractTopologyComponent
-
Determine whether this object represents a peer driver.
- isPeer() - Method in class org.jppf.client.monitoring.topology.TopologyPeer
-
This method always returns
true. - isPending() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Get the job pending indicator.
- isRemoteExecution() - Method in class org.jppf.client.event.JobEvent
-
Determine whether the current job dispatch is sent to a remote driver.
- isRequeued() - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Get the requeued indicator.
- isResetting() - Method in class org.jppf.client.AbstractJPPFClient
-
Determine whether this client is resetting.
- isResetting() - Method in class org.jppf.client.balancer.ChannelWrapper
-
Determine whether the client is resetting.
- isShutdown() - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Determine whether this executor has been shut down.
- isSslEnabled() - Method in class org.jppf.client.AbstractClientConnectionPool
-
Check whether this pool is for SSL connections.
- isSSLEnabled() - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- isSSLEnabled() - Method in interface org.jppf.client.JPPFClientConnection
-
Determines if this connection is over SSL.
- isSSLEnabled() - Method in class org.jppf.client.JPPFClientConnectionImpl
- isSuspended() - Method in class org.jppf.client.monitoring.AbstractRefreshHandler
-
Determine whether refreshes are currently suspended.
- isSysoutEnabled() - Method in class org.jppf.client.AbstractGenericClient
-
Determine whether the client should print connection events to stdout.
- isTerminated() - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Determine whether all tasks have completed following shut down.
- isTerminatedStatus() - Method in enum class org.jppf.client.JPPFClientConnectionStatus
-
Determine whether this status a working status, that is if it is either
JPPFClientConnectionStatus.FAILEDorJPPFClientConnectionStatus.CLOSED. - isWorkingStatus() - Method in enum class org.jppf.client.JPPFClientConnectionStatus
-
Determine whether this status a working status, that is if it is either
JPPFClientConnectionStatus.ACTIVEorJPPFClientConnectionStatus.EXECUTING. - iterator() - Method in class org.jppf.client.AbstractConnectionPool
- iterator() - Method in class org.jppf.client.JPPFJob
- iterator() - Method in class org.jppf.client.utils.AbstractJPPFJobStream
J
- JCA_SERIALIZATION_HELPER - Static variable in class org.jppf.client.AbstractJPPFClient
-
Name of the SerializationHelper implementation class for the JCA connector.
- job - Variable in class org.jppf.client.balancer.AbstractClientJob
-
The underlying task bundle.
- Job - Class in org.jppf.client.monitoring.jobs
-
Instanes of this class represent a job as seen by a driver.
- JOB_DISPATCH - Enum constant in enum class org.jppf.client.event.JobEvent.Type
-
The job was disatched to a channel.
- JOB_END - Enum constant in enum class org.jppf.client.event.JobEvent.Type
-
The job ended.
- JOB_RETURN - Enum constant in enum class org.jppf.client.event.JobEvent.Type
-
The returnd from a channel.
- JOB_START - Enum constant in enum class org.jppf.client.event.JobEvent.Type
-
The job started.
- jobAdded(ClientQueueEvent) - Method in interface org.jppf.client.event.ClientQueueListener
-
Called to notify that a job was added to the queue.
- jobAdded(ClientQueueEvent) - Method in class org.jppf.client.event.ClientQueueListenerAdapter
- jobAdded(JobMonitoringEvent) - Method in interface org.jppf.client.monitoring.jobs.JobMonitoringListener
-
Called when a job is added to the driver queue.
- jobAdded(JobMonitoringEvent) - Method in class org.jppf.client.monitoring.jobs.JobMonitoringListenerAdapter
- JobConfiguration - Interface in org.jppf.client.concurrent
-
This interface defines the properties that can be provided to a task submitted by a
JPPFExecutorService.. - JobDependencyIdSupplier - Interface in org.jppf.client
-
Interface for computing and supplying a job dependency id from a given
JPPFJob. - JobDispatch - Class in org.jppf.client.monitoring.jobs
-
This class represents the dispatch of a job to a node.
- jobDispatchAdded(JobMonitoringEvent) - Method in interface org.jppf.client.monitoring.jobs.JobMonitoringListener
-
Called when a job is dispatched to a node.
- jobDispatchAdded(JobMonitoringEvent) - Method in class org.jppf.client.monitoring.jobs.JobMonitoringListenerAdapter
- jobDispatched(ChannelWrapper) - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Called when all or part of a job is dispatched to a node.
- jobDispatched(ClientTaskBundle, ChannelWrapper) - Method in class org.jppf.client.balancer.ClientJob
-
Called when all or part of a job is dispatched to a node.
- jobDispatched(JobEvent) - Method in interface org.jppf.client.event.JobListener
-
Called when a job, or a subset of its tasks, is sent to the server, or to the local executor.
- jobDispatched(JobEvent) - Method in class org.jppf.client.event.JobListenerAdapter
- jobDispatchRemoved(JobMonitoringEvent) - Method in interface org.jppf.client.monitoring.jobs.JobMonitoringListener
-
Called when a job dispatch returns from a node.
- jobDispatchRemoved(JobMonitoringEvent) - Method in class org.jppf.client.monitoring.jobs.JobMonitoringListenerAdapter
- JobDriver - Class in org.jppf.client.monitoring.jobs
-
AN instance of this class represents a JPPF driver in the jobs hierarchy.
- jobEnded(JobEvent) - Method in interface org.jppf.client.event.JobListener
-
Called when the execution of a job is complete.
- jobEnded(JobEvent) - Method in class org.jppf.client.event.JobListenerAdapter
- jobEnded(JobEvent) - Method in class org.jppf.client.utils.AbstractJPPFJobStream
-
This implementation of
JobListener.jobEnded(JobEvent)decreases the counter of running jobs, notifies all threads waiting innext()and finally processes the results asynchronously. - JobEvent - Class in org.jppf.client.event
-
Event emitted by a job when its execution starts or completes.
- JobEvent(JPPFJob) - Constructor for class org.jppf.client.event.JobEvent
-
Initialize this event with the specified job as its source.
- JobEvent(JPPFJob, ExecutorChannel<?>, List<Task<?>>) - Constructor for class org.jppf.client.event.JobEvent
-
Initialize this event with the specified job as its source.
- JobEvent.Type - Enum Class in org.jppf.client.event
-
The type of event.
- jobExpired() - Method in class org.jppf.client.balancer.AbstractClientJob
-
Notifies that job has expired.
- JobListener - Interface in org.jppf.client.event
-
Listener interface for receiving job started and job ended event notifications.
- JobListenerAdapter - Class in org.jppf.client.event
-
A convenience class which allows subclassing and implementing only the needed methods of
JobListener. - JobListenerAdapter() - Constructor for class org.jppf.client.event.JobListenerAdapter
- JobManager - Interface in org.jppf.client
-
Interface for an asynchronous job submission manager.
- JobManagerClient - Class in org.jppf.client.balancer
-
This task provides asynchronous management of tasks submitted through the resource adapter.
- JobManagerClient(JPPFClient, JPPFBundlerFactory) - Constructor for class org.jppf.client.balancer.JobManagerClient
-
Instantiates client job manager.
- JobMonitor - Class in org.jppf.client.monitoring.jobs
-
This class provides a representation of the jobs and corresponding node dispatches executing in a JPPF grid.
- JobMonitor(JobMonitorUpdateMode, long, TopologyManager, JobMonitoringListener...) - Constructor for class org.jppf.client.monitoring.jobs.JobMonitor
-
Initialize this job manager with the specified topology manager and event mode.
- JobMonitor(TopologyManager, JobMonitoringListener...) - Constructor for class org.jppf.client.monitoring.jobs.JobMonitor
-
Initialize this job manager with the specified topology manager in
IMMEDIATE_NOTFICATIONSmode. - JobMonitoringEvent - Class in org.jppf.client.monitoring.jobs
-
This class represents an event emitteed by a
JobMonitor. - JobMonitoringHandler - Interface in org.jppf.client.monitoring.jobs
-
Interface implemented by all handlers that monitor and mantain the jobs tree.
- JobMonitoringListener - Interface in org.jppf.client.monitoring.jobs
-
Listener interface for changes in the jobs of one or more drivers.
- JobMonitoringListenerAdapter - Class in org.jppf.client.monitoring.jobs
-
A convenience class for subclasses that wish to subscribe to job monitoring events without having to implement all the methods of the
JobMonitoringListenerinterface. - JobMonitoringListenerAdapter() - Constructor for class org.jppf.client.monitoring.jobs.JobMonitoringListenerAdapter
- JobMonitorUpdateMode - Enum Class in org.jppf.client.monitoring.jobs
-
Enumeration of the possible ways job updates are published as events by the job monitor.
- JobPersistence<K> - Interface in org.jppf.client.persistence
-
Interface for facilities managing the persistence of jobs and their state.
- JobPersistenceException - Exception in org.jppf.client.persistence
-
Exception thrown when an error occurs during a job persistence operation.
- JobPersistenceException(String) - Constructor for exception org.jppf.client.persistence.JobPersistenceException
-
Initialize this exception with a specified message.
- JobPersistenceException(String, Throwable) - Constructor for exception org.jppf.client.persistence.JobPersistenceException
-
Initialize this exception with a specified message and cause exception.
- JobPersistenceException(Throwable) - Constructor for exception org.jppf.client.persistence.JobPersistenceException
-
Initialize this exception with a specified cause exception.
- jobRemoved(ClientQueueEvent) - Method in interface org.jppf.client.event.ClientQueueListener
-
Called to notify that a job was removed from the queue.
- jobRemoved(ClientQueueEvent) - Method in class org.jppf.client.event.ClientQueueListenerAdapter
- jobRemoved(JobMonitoringEvent) - Method in interface org.jppf.client.monitoring.jobs.JobMonitoringListener
-
Called when a job is removed from the driver queue.
- jobRemoved(JobMonitoringEvent) - Method in class org.jppf.client.monitoring.jobs.JobMonitoringListenerAdapter
- jobRequeued() - Method in class org.jppf.client.balancer.ClientJob
-
Notify that this job was requeued.
- JobResults - Class in org.jppf.client
-
Instances of this class hold and manage the results of a job.
- JobResults() - Constructor for class org.jppf.client.JobResults
- jobReturned(JobEvent) - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Called when all results from a job have been received.
- jobReturned(JobEvent) - Method in interface org.jppf.client.event.JobListener
-
Called when the execution of a subset of the tasks of a job is complete.
- jobReturned(JobEvent) - Method in class org.jppf.client.event.JobListenerAdapter
- JobScheduler - Class in org.jppf.client.balancer.queue
-
This class ensures that idle nodes get assigned pending tasks from the job queue.
- JobScheduler(JPPFPriorityQueue, JPPFBundlerFactory) - Constructor for class org.jppf.client.balancer.queue.JobScheduler
-
Initialize this task queue checker with the specified queue.
- jobStarted(JobEvent) - Method in interface org.jppf.client.event.JobListener
-
Called when the execution of a job is starting.
- jobStarted(JobEvent) - Method in class org.jppf.client.event.JobListenerAdapter
- JobStatus - Enum Class in org.jppf.client
-
The status of a job.
- jobStatusChanged(JobStatusEvent) - Method in interface org.jppf.client.event.JobStatusListener
-
Called when the status of a job has changed.
- JobStatusEvent - Class in org.jppf.client.event
-
Instances of this class represent a status change notification for a jppf job.
- JobStatusEvent(String, JobStatus) - Constructor for class org.jppf.client.event.JobStatusEvent
-
Initialize this event with the specified job uuid and status.
- JobStatusHandler - Interface in org.jppf.client
-
Interface implemented by classes that wish to handle job statuses.
- JobStatusListener - Interface in org.jppf.client.event
-
Listener interface for receiving job status change notifications.
- jobUpdated(JobMonitoringEvent) - Method in interface org.jppf.client.monitoring.jobs.JobMonitoringListener
-
Called when the state a job has changed.
- jobUpdated(JobMonitoringEvent) - Method in class org.jppf.client.monitoring.jobs.JobMonitoringListenerAdapter
- JPPFClient - Class in org.jppf.client
-
This class provides an API to submit execution requests and administration commands, and request server information data.
It has its own unique identifier, used by the nodes, to determine whether classes from the submitting application should be dynamically reloaded or not, depending on whether the uuid has changed or not. - JPPFClient() - Constructor for class org.jppf.client.JPPFClient
-
Initialize this client with an automatically generated application UUID.
- JPPFClient(String) - Constructor for class org.jppf.client.JPPFClient
-
Initialize this client with the specified application UUID.
- JPPFClient(String, ConnectionPoolListener...) - Constructor for class org.jppf.client.JPPFClient
-
Initialize this client with the specified application UUID and new connection listeners.
- JPPFClient(String, TypedProperties, ConnectionPoolListener...) - Constructor for class org.jppf.client.JPPFClient
-
Initialize this client with the specified application UUID and new connection listeners.
- JPPFClient(ConnectionPoolListener...) - Constructor for class org.jppf.client.JPPFClient
-
Initialize this client with an automatically generated application UUID.
- JPPFClient(TypedProperties, ConnectionPoolListener...) - Constructor for class org.jppf.client.JPPFClient
-
Initialize this client with the specified configuration and connection listeners.
- JPPFClientConnection - Interface in org.jppf.client
-
Interface for a client connection to a JPPF driver.
- JPPFClientConnectionImpl - Class in org.jppf.client
-
Instances of this class represent connections to remote JPPF drivers.
- JPPFClientConnectionStatus - Enum Class in org.jppf.client
-
Status of the connection between a client and a driver.
- JPPFCompletionService<V> - Class in org.jppf.client.concurrent
-
A
CompletionServicewhich works specifically withJPPFExecutorServices. - JPPFCompletionService(JPPFExecutorService) - Constructor for class org.jppf.client.concurrent.JPPFCompletionService
-
Initialize this completion service with the specified executor.
- JPPFConnectionPool - Class in org.jppf.client
-
Instances of this class manage a list of client connections with the same pool name, priority and remote driver.
- JPPFContextClient - Class in org.jppf.client
-
Context associated with a client.
- JPPFContextClient(JPPFQueue<ClientJob, ClientJob, ClientTaskBundle>) - Constructor for class org.jppf.client.JPPFContextClient
-
Default initializer.
- JPPFDriverJobPersistence - Class in org.jppf.client
-
Instances of this class allow monitoring and managing, on the client side, the jobs persisted in a remote driver.
- JPPFDriverJobPersistence(JMXDriverConnectionWrapper) - Constructor for class org.jppf.client.JPPFDriverJobPersistence
-
Initialize this persisted job manager with the specified driver JMX connection.
- JPPFExecutorService - Class in org.jppf.client.concurrent
-
Implementation of an
ExecutorServicewrapper around aJPPFClient. - JPPFExecutorService(JPPFClient) - Constructor for class org.jppf.client.concurrent.JPPFExecutorService
-
Initialize this executor service with the specified JPPF client.
- JPPFExecutorService(JPPFClient, int, long) - Constructor for class org.jppf.client.concurrent.JPPFExecutorService
-
Initialize this executor service with the specified JPPF client, batch size and batch tiemout.
- JPPFJob - Class in org.jppf.client
-
Instances of this class represent a JPPF job and hold all the required elements: tasks, execution policy, task listener, data provider, priority, blocking indicator.
- JPPFJob() - Constructor for class org.jppf.client.JPPFJob
-
Default constructor, creates a blocking job with no data provider, default SLA values and a priority of 0.
- JPPFJob(String) - Constructor for class org.jppf.client.JPPFJob
-
Default constructor, creates a blocking job with no data provider, default SLA values and a priority of 0.
- JPPFPriorityQueue - Class in org.jppf.client.balancer.queue
-
A JPPF queue whose elements are ordered by decreasing priority.
- JPPFPriorityQueue(JobManagerClient) - Constructor for class org.jppf.client.balancer.queue.JPPFPriorityQueue
-
Initialize this queue.
- JPPFTaskFuture<V> - Class in org.jppf.client.concurrent
-
Implementation of a future handled by a
JPPFExecutorService. - JPPFTaskFuture(JPPFJob, int) - Constructor for class org.jppf.client.concurrent.JPPFTaskFuture
-
Initialize this future with the specified parameters.
- JVM_HEALTH - Enum constant in enum class org.jppf.client.monitoring.topology.TopologyEvent.UpdateType
-
JVM health snapshot was updated.
L
- listJobs(JobSelector) - Method in class org.jppf.client.JPPFDriverJobPersistence
-
List the persisted jobs that match the provided job selector.
- loadJob(String) - Method in class org.jppf.client.persistence.DefaultFilePersistenceManager
- loadJob(K) - Method in interface org.jppf.client.persistence.JobPersistence
-
Load a job from the persistence store given its key.
M
- makeHelper(ClassLoader) - Method in class org.jppf.client.JPPFClientConnectionImpl
-
Instantiate a
SerializationHelperusing the current context class loader. - makeHelper(ClassLoader, String) - Method in class org.jppf.client.JPPFClientConnectionImpl
-
Instantiate a
SerializationHelperusing the current context class loader. - managementInfo - Variable in class org.jppf.client.monitoring.topology.AbstractTopologyComponent
-
The management informtation on this topology component.
- MBEAN_NAME_PREFIX - Static variable in interface org.jppf.client.debug.DebugMBean
- merge(List<Task<?>>) - Method in class org.jppf.client.balancer.ClientJob
-
Merge this client job wrapper with another.
N
- nbAvailableConnections() - Method in class org.jppf.client.balancer.JobManagerClient
-
Get the number of connections available for job scheduling.
- nbIdleCOnnections() - Method in class org.jppf.client.JPPFClient
- NEW - Enum constant in enum class org.jppf.client.balancer.ClientJobStatus
-
Job status is new (just submitted).
- NEW - Enum constant in enum class org.jppf.client.JPPFClientConnectionStatus
-
The connection was just created.
- next() - Method in class org.jppf.client.utils.AbstractJPPFJobStream
-
Get the next job in the stream.
- nextBundle(ClientJob, int, ExecutorChannel<ClientTaskBundle>) - Method in class org.jppf.client.balancer.queue.JPPFPriorityQueue
- nextConnection() - Method in class org.jppf.client.AbstractConnectionPool
-
Get the next connection.
- nextConnection() - Method in interface org.jppf.client.ConnectionPool
-
Get the next connection.
- NODE_STATE - Enum constant in enum class org.jppf.client.monitoring.topology.TopologyEvent.UpdateType
-
Node state was updated.
- nodeAdded(TopologyEvent) - Method in interface org.jppf.client.monitoring.topology.TopologyListener
-
Called when a node is added.
- nodeAdded(TopologyEvent) - Method in class org.jppf.client.monitoring.topology.TopologyListenerAdapter
- nodeRemoved(TopologyEvent) - Method in interface org.jppf.client.monitoring.topology.TopologyListener
-
Called when a node is removed.
- nodeRemoved(TopologyEvent) - Method in class org.jppf.client.monitoring.topology.TopologyListenerAdapter
- nodeUpdated(TopologyEvent) - Method in interface org.jppf.client.monitoring.topology.TopologyListener
-
Called when the data for a node or driver changed.
- nodeUpdated(TopologyEvent) - Method in class org.jppf.client.monitoring.topology.TopologyListenerAdapter
O
- oldStatus - Variable in class org.jppf.client.balancer.ChannelWrapper
-
The previous status, if any.
- org.jppf.client - package org.jppf.client
- org.jppf.client.balancer - package org.jppf.client.balancer
-
Support for the new load-balancing of local versus remote execution on the client side.
- org.jppf.client.balancer.queue - package org.jppf.client.balancer.queue
-
Support for job queuing in the JPPF client.
- org.jppf.client.concurrent - package org.jppf.client.concurrent
-
Classes supporting submission of tasks via distributed executor services as specified in
java.util.concurrent. - org.jppf.client.debug - package org.jppf.client.debug
-
Support for debugging of the JPPFClient instances via JMX.
- org.jppf.client.event - package org.jppf.client.event
-
Support for connection pool events, connection status notifications, job lifecycle events and job queue events in the JPPF client.
- org.jppf.client.monitoring - package org.jppf.client.monitoring
-
Base classes supporting the monitoring of JPPF grid topologies and jobs.
- org.jppf.client.monitoring.jobs - package org.jppf.client.monitoring.jobs
-
Classes supporting the monitoring and refreshing of the JPPF jobs hierarchy.
- org.jppf.client.monitoring.topology - package org.jppf.client.monitoring.topology
-
Classes supporting the monitoring and refreshing of the JPPF grid topology.
- org.jppf.client.persistence - package org.jppf.client.persistence
-
Support for job persistence on the client side.
- org.jppf.client.utils - package org.jppf.client.utils
-
Support for job streaming.
P
- parent - Variable in class org.jppf.client.monitoring.AbstractComponent
-
The parent of this component.
- parentJob - Variable in class org.jppf.client.balancer.AbstractClientJob
-
Instance of parent broadcast job.
- PENDING - Enum constant in enum class org.jppf.client.JobStatus
-
The job is currently in the job queue (on the client side).
- performRefresh() - Method in class org.jppf.client.monitoring.AbstractRefreshHandler
-
Refresh the refresh.
- poll() - Method in class org.jppf.client.concurrent.JPPFCompletionService
- poll(long, TimeUnit) - Method in class org.jppf.client.concurrent.JPPFCompletionService
- POLLING - Enum constant in enum class org.jppf.client.monitoring.jobs.JobMonitorUpdateMode
-
Updates are computed by polling information on the jobs from the drivers at regular intervals.
- preparePolicy(ExecutionPolicy) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Set the parameters needed as bounded variables fro scripted execution policies.
- processNextRequest() - Method in class org.jppf.client.AbstractClassServerDelegate
-
Process the next class laodign request from the server.
- processPendingBroadcasts() - Method in class org.jppf.client.balancer.queue.JPPFPriorityQueue
-
Process the jobs in the pending broadcast queue.
- processResults(JPPFJob) - Method in class org.jppf.client.utils.AbstractJPPFJobStream
-
Callback invoked when a job is complete.
- put(ClassLoader, String, byte[]) - Method in class org.jppf.client.ClasspathCache
-
Add a classpath resource to the cache..
- put(Integer, TaskState) - Method in class org.jppf.client.balancer.TaskStateMap
R
- readResolve() - Method in class org.jppf.client.AbstractJPPFJob
-
Resolve this instance after deserialization.
- readResource() - Method in class org.jppf.client.AbstractClassServerDelegate
-
Read a resource wrapper object from the socket connection.
- receiveBundleAndResults(ObjectSerializer, ClassLoader) - Method in class org.jppf.client.JPPFClientConnectionImpl
-
Receive results of tasks execution.
- receiveHeader(ObjectSerializer, ClassLoader) - Method in class org.jppf.client.JPPFClientConnectionImpl
-
Receive the header part of the results of tasks execution.
- receiveTasks(TaskBundle, ObjectSerializer, ClassLoader) - Method in class org.jppf.client.JPPFClientConnectionImpl
-
Receive results of tasks execution.
- refresh() - Method in class org.jppf.client.monitoring.AbstractRefreshHandler
-
Refresh the tree structure asynchronously (not in the AWT event thread).
- refreshNodeState(JPPFNodeState) - Method in class org.jppf.client.monitoring.topology.TopologyNode
-
Refresh the state of the node represented by this topology data.
- register(JPPFClient) - Static method in class org.jppf.client.debug.Debug
-
Register a debug mbean for the specified JPPF client.
- registerClassLoader(ClassLoader, String) - Method in class org.jppf.client.AbstractGenericClient
-
Register a class loader for the specified job uuid.
- remove() - Method in class org.jppf.client.utils.AbstractJPPFJobStream
-
This operation is not supported and results in an
UnsupportedOperationExceptionbeing thrown. - remove(E) - Method in class org.jppf.client.AbstractConnectionPool
-
Remove a connection from this pool.
- remove(E) - Method in interface org.jppf.client.ConnectionPool
-
Remove a connection from this pool.
- remove(E) - Method in class org.jppf.client.monitoring.AbstractComponent
-
Remove a child from this component.
- remove(Object) - Method in class org.jppf.client.balancer.TaskStateMap
- removeBundle(ClientJob) - Method in class org.jppf.client.balancer.queue.JPPFPriorityQueue
- removeChannel(ExecutorChannel<?>) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Add a channel to this job.
- removeClientConnectionStatusListener(ClientConnectionStatusListener) - Method in class org.jppf.client.balancer.AbstractChannelWrapperRemote
- removeClientConnectionStatusListener(ClientConnectionStatusListener) - Method in class org.jppf.client.balancer.ChannelWrapper
-
Remove a connection status listener from this connection's list of listeners.
- removeClientConnectionStatusListener(ClientConnectionStatusListener) - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- removeClientConnectionStatusListener(ClientConnectionStatusListener) - Method in interface org.jppf.client.event.ClientConnectionStatusHandler
-
Remove a connection status listener from this connection's list of listeners.
- removeClientConnectionStatusListener(ClientConnectionStatusListener) - Method in class org.jppf.client.JPPFClientConnectionImpl
- removeClientQueueListener(ClientQueueListener) - Method in class org.jppf.client.AbstractGenericClient
-
Unregister the specified listener.
- removeConnection(ChannelWrapper) - Method in class org.jppf.client.balancer.JobManagerClient
-
Remove the specified connection wrapper from the list of connections handled by this manager.
- removeConnection(JPPFClientConnection) - Method in class org.jppf.client.balancer.JobManagerClient
-
Remove the specified client connection from the list of connections handled by this manager.
- removeConnectionPoolListener(ConnectionPoolListener) - Method in class org.jppf.client.AbstractJPPFClient
-
Remove a listener from the list of listeners to this client.
- removeDriverDiscovery(ClientDriverDiscovery) - Method in class org.jppf.client.JPPFClient
-
Remove a custom driver discovery mechanism from those already registered.
- removeExecutionStatusListener(ExecutorChannelStatusListener) - Method in class org.jppf.client.balancer.ChannelWrapper
- removeIdleChannel(ChannelWrapper) - Method in class org.jppf.client.balancer.queue.JobScheduler
-
Remove a channel from the list of idle channels.
- removeJobListener(JobListener) - Method in interface org.jppf.client.concurrent.JobConfiguration
-
Remove a listener from the list of job listeners.
- removeJobListener(JobListener) - Method in class org.jppf.client.JPPFJob
-
Remove a listener from the list of job listeners.
- removeJobMonitoringListener(JobMonitoringListener) - Method in class org.jppf.client.monitoring.jobs.JobMonitor
-
Remove a listener to the events emitted by this job monitor.
- removeJobStatusListener(JobStatusListener) - Method in class org.jppf.client.AbstractJPPFJob
-
Remove a listener from the list of status listeners.
- removeOnDone(Runnable) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Deregisters instance to be called on job finish.
- removeParameter(String) - Method in class org.jppf.client.debug.Debug
- removeParameter(String) - Method in interface org.jppf.client.debug.DebugMBean
- removeTopologyListener(TopologyListener) - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Remove a topology change listener.
- requeue(ClientJob) - Method in class org.jppf.client.balancer.queue.JPPFPriorityQueue
-
Handle requeue of the specified job.
- reset() - Method in class org.jppf.client.balancer.JobManagerClient
- reset() - Method in interface org.jppf.client.JobManager
-
Reset this job manager.
- reset() - Method in class org.jppf.client.JPPFClient
-
Reset this client, that is, close it if necessary, reload its configuration, then open it again.
- reset(TypedProperties) - Method in class org.jppf.client.JPPFClient
-
Reset this client, that is, close it if necessary, then open it again, using the specified confguration.
- resetConfiguration() - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Reset the configuration for this executor service to a blank state.
- resourceProvider - Variable in class org.jppf.client.AbstractClassServerDelegate
-
Reads resource files from the classpath.
- resubmit() - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Called when this task bundle should be resubmitted.
- resubmitJob(JPPFJob) - Method in class org.jppf.client.balancer.JobManagerClient
- resubmitJob(JPPFJob) - Method in interface org.jppf.client.JobManager
-
Add an existing job back into the execution queue.
- result - Variable in class org.jppf.client.concurrent.JPPFTaskFuture
-
The execution result.
- resultsReceived(Throwable) - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Called to notify that throwable eventually raised while receiving the results.
- resultsReceived(List<Task<?>>) - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Called to notify that the results of a number of tasks have been received from the server.
- resultsReceived(List<Task<?>>, Throwable, boolean) - Method in class org.jppf.client.JPPFJob
-
Called to notify that the results of a number of tasks have been received from the server.
- resultsReceived(ClientTaskBundle, Throwable) - Method in class org.jppf.client.balancer.ClientJob
-
Called to notify that throwable eventually raised while receiving the results.
- resultsReceived(ClientTaskBundle, List<Task<?>>) - Method in class org.jppf.client.balancer.ClientJob
-
Called to notify that the results of a number of tasks have been received from the server.
- retrieveJob(String) - Method in class org.jppf.client.JPPFDriverJobPersistence
-
Retieve and rebuild the persisted job with the specified uuid.
- run() - Method in class org.jppf.client.balancer.queue.JobScheduler
-
Perform the assignment of tasks.
- run() - Method in class org.jppf.client.ConnectionInitializer
S
- sendTasks(ObjectSerializer, ClassLoader, TaskBundle, ClientTaskBundle) - Method in class org.jppf.client.JPPFClientConnectionImpl
-
Send tasks to the server for execution.
- setBatchSize(int) - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Set the minimum number of tasks that must be submitted before they are sent to the server.
- setBatchTimeout(long) - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Set the maximum time to wait before the next batch of tasks is to be sent for execution.
- setBlocking(boolean) - Method in class org.jppf.client.AbstractJPPFJob
-
Deprecated.a job should be submittable either synchronously or asynchronously, regardless of its state. The submission mode is the user's choice at the time of submission, using one of
JPPFClient.submit()orJPPFClient.submitAsync(). - setBroadcastUUID(String) - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Set the broadcast UUID.
- setCascadeCancellation(boolean) - Method in class org.jppf.client.JPPFJob
-
Set whether cancellation of this job should trigger the cancellation of the jobs that depend on it.
- setClientSLA(JobClientSLA) - Method in class org.jppf.client.AbstractJPPFJob
-
Get the service level agreement between the job and the server.
- setClientSLA(JobClientSLA) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Get the service level agreement between the job and the client.
- setClientSLA(JobClientSLA) - Method in interface org.jppf.client.concurrent.JobConfiguration
-
Get the service level agreement between the job and the server.
- setDataProvider(DataProvider) - Method in class org.jppf.client.AbstractJPPFJob
-
Set the container for data shared between tasks.
- setDataProvider(DataProvider) - Method in interface org.jppf.client.concurrent.JobConfiguration
-
Set the job's data provider.
- setDataProviderL(DataProvider) - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Set shared data provider for this task.
- setDefaultClientPolicy(ExecutionPolicy) - Method in class org.jppf.client.JPPFClient
-
Set the default client-side job execution policy.
- setDefaultPolicy(ExecutionPolicy) - Method in class org.jppf.client.JPPFClient
-
Set the default server-side job execution policy.
- setDependencyId(String) - Method in class org.jppf.client.JPPFJob
-
Set this job's dependency id.
- setDependencyId(Supplier<String>) - Method in class org.jppf.client.JPPFJob
-
Set this job's dependency id from the specified id supplier.
- setDependencyId(JobDependencyIdSupplier) - Method in class org.jppf.client.JPPFJob
-
Set this job's dependency id from a dependency id supplier.
- setGraphRoot(boolean) - Method in class org.jppf.client.JPPFJob
-
Set whether this job is a root in a job dependency graph.
- setHighestPriority(int) - Method in class org.jppf.client.balancer.queue.JobScheduler
-
Set the highest priority.
- setJMXPoolMaxSize(int) - Method in class org.jppf.client.AbstractClientConnectionPool
-
Deprecated.use
AbstractClientConnectionPool.setJMXPoolSize(int)instead. - setJMXPoolSize(int) - Method in class org.jppf.client.AbstractClientConnectionPool
-
Set a new maximum size for the associated pool of JMX connections, adding new or closing existing connections as needed.
- setJobReceivedTime(long) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Set the job received time.
- setJobStatus(JobStatus) - Method in class org.jppf.client.balancer.ClientJob
-
Set the status of this job.
- setLoadBalancerSettings(String, Properties) - Method in class org.jppf.client.balancer.JobManagerClient
- setLoadBalancerSettings(String, Properties) - Method in interface org.jppf.client.JobManager
-
Change the load balancer settings for the client.
- setLoadBalancerSettings(String, Properties) - Method in class org.jppf.client.JPPFClient
-
Change the load balancer settings.
- setLocalExecutionEnabled(boolean) - Method in class org.jppf.client.AbstractGenericClient
-
Specify whether local execution is enabled on this client.
- setLocalExecutionEnabled(boolean) - Method in class org.jppf.client.balancer.JobManagerClient
- setLocalExecutionEnabled(boolean) - Method in interface org.jppf.client.JobManager
-
Specify whether local execution is enabled on this client.
- setManagementInfo(JPPFManagementInfo) - Method in class org.jppf.client.balancer.ChannelWrapper
-
Set the management information.
- setMaxJobs(int) - Method in class org.jppf.client.AbstractClientConnectionPool
-
Set the maximum number of jobs that can be processed concurrently by each connection.
- setMetadata(JobMetadata) - Method in class org.jppf.client.AbstractJPPFJob
-
Set this job's metadata.
- setMetadata(JobMetadata) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Set the job metadata.
- setName(String) - Method in class org.jppf.client.AbstractClassServerDelegate
-
Set the name of this delegate.
- setName(String) - Method in class org.jppf.client.AbstractJPPFJob
-
Set the user-defined display name for this job.
- setName(String) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Set the user-defined display name for this job.
- setName(String) - Method in interface org.jppf.client.ClassServerDelegate
-
Set the name of this delegate.
- setNameAsDependencyId() - Method in class org.jppf.client.JPPFJob
-
Convenience method to set this job's name as dpeendency id.
- setNbSlaveNodes(int) - Method in class org.jppf.client.monitoring.topology.TopologyNode
-
Set the number of slaves for a master node.
- setNodeFilter(NodeSelector) - Method in class org.jppf.client.monitoring.topology.TopologyManager
-
Set the node selector used to filter the nodes and associated events.
- setOldStatus(JPPFClientConnectionStatus) - Method in class org.jppf.client.balancer.ChannelWrapper
- setOnCancelCallback(JPPFTaskCallback<Object>) - Method in interface org.jppf.client.concurrent.TaskConfiguration
-
Set the delegate for the
onCancel()method. - setOnRequeue(Runnable) - Method in class org.jppf.client.balancer.ClientJob
-
Set the requeue handler.
- setOnTimeoutCallback(JPPFTaskCallback<Object>) - Method in interface org.jppf.client.concurrent.TaskConfiguration
-
Set the delegate for the
onTimeout()method. - setParameter(String, String) - Method in class org.jppf.client.debug.Debug
- setParameter(String, String) - Method in interface org.jppf.client.debug.DebugMBean
- setPending(boolean) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Set the job pending indicator.
- setPersistenceManager(JobPersistence<T>) - Method in interface org.jppf.client.concurrent.JobConfiguration
-
Set the persistence manager that enables saving and restoring the state of this job.
- setPersistenceManager(JobPersistence<T>) - Method in class org.jppf.client.JPPFJob
-
Set the persistence manager that enables saving and restoring the state of this job.
- setQueueEntryTime(long) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Set the time at which this wrapper was added to the queue.
- setResetting(boolean) - Method in class org.jppf.client.balancer.ChannelWrapper
-
Specify whether the client is resetting.
- setSize(int) - Method in interface org.jppf.client.ConnectionPool
-
Set the size of this connection pool, starting or stopping connections as needed.
- setSize(int) - Method in class org.jppf.client.JPPFConnectionPool
- setSLA(JobSLA) - Method in class org.jppf.client.AbstractJPPFJob
-
Get the service level agreement between the job and the server.
- setSLA(JobSLA) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Get the service level agreement between the job and the server.
- setSLA(JobSLA) - Method in interface org.jppf.client.concurrent.JobConfiguration
-
Get the service level agreement between the job and the server.
- setStatus(JobStatus) - Method in class org.jppf.client.AbstractJPPFJob
- setStatus(JobStatus) - Method in interface org.jppf.client.JobStatusHandler
-
Set the status of the job.
- setStatus(JPPFClientConnectionStatus) - Method in class org.jppf.client.balancer.AbstractChannelWrapperRemote
- setStatus(JPPFClientConnectionStatus) - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- setStatus(JPPFClientConnectionStatus) - Method in interface org.jppf.client.event.ClientConnectionStatusHandler
-
Set the status of this connection.
- setStatus(JPPFClientConnectionStatus) - Method in class org.jppf.client.JPPFClientConnectionImpl
- setStatus(TopologyNodeStatus) - Method in class org.jppf.client.monitoring.topology.TopologyNode
-
Set the status of the node.
- setSuspended(boolean) - Method in class org.jppf.client.monitoring.AbstractRefreshHandler
-
Specify whether refreshes are currently suspended.
- setSystemInformation(JPPFSystemInformation) - Method in class org.jppf.client.balancer.AbstractChannelWrapperRemote
- setSystemInformation(JPPFSystemInformation) - Method in class org.jppf.client.balancer.ChannelWrapper
-
Set the system information.
- setTimeoutSchedule(JPPFSchedule) - Method in interface org.jppf.client.concurrent.TaskConfiguration
-
Set the timeout set on the task.
- setup(TaskBundle, List<Task<?>>) - Method in class org.jppf.client.balancer.ClientExecutionManager
-
Prepare this execution manager for executing the tasks of a bundle.
- setUuid(String) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Set the universal unique id for this job.
- setUuidAsDependencyId() - Method in class org.jppf.client.JPPFJob
-
Convenience method to set this job's uuid as dependency id.
- shutdown() - Method in class org.jppf.client.ClientConfigDriverDiscovery
- shutdown() - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted.
- shutdownNow() - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.
This implementation simply waits for all submitted tasks to terminate, due to the complexity of stopping remote tasks. - size() - Method in class org.jppf.client.JobResults
-
Get the current number of received results.
- startRefreshTimer() - Method in class org.jppf.client.monitoring.AbstractRefreshHandler
-
Start the automatic refresh of the nodes state through a timer.
- statusChanged(ClientConnectionStatusEvent) - Method in class org.jppf.client.AbstractGenericClient
- statusChanged(ClientConnectionStatusEvent) - Method in class org.jppf.client.AbstractJPPFClient
-
Invoked when the status of a client connection has changed.
- statusChanged(ClientConnectionStatusEvent) - Method in interface org.jppf.client.event.ClientConnectionStatusListener
-
Invoked to notify of a status change event on a client connection.
- stop - Variable in class org.jppf.client.AbstractClassServerDelegate
-
Indicates whether this socket handler should be terminated and stop processing.
- stopRefreshTimer() - Method in class org.jppf.client.monitoring.AbstractRefreshHandler
-
Stop the automatic refresh of the nodes state through a timer.
- storeJob(String, JPPFJob, List<Task<?>>) - Method in class org.jppf.client.persistence.DefaultFilePersistenceManager
-
Store the specified job.
- storeJob(K, JPPFJob, List<Task<?>>) - Method in interface org.jppf.client.persistence.JobPersistence
-
Store the specified tasks of the specified job with the specified key.
- submit(Runnable) - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Submits a Runnable task for execution and returns a Future representing that task.
- submit(Runnable, T) - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Submits a Runnable task for execution and returns a Future representing that task that will upon completion return the given result.
- submit(Runnable, V) - Method in class org.jppf.client.concurrent.JPPFCompletionService
- submit(Callable<T>) - Method in class org.jppf.client.concurrent.JPPFExecutorService
-
Submit a value-returning task for execution and returns a Future representing the pending results of the task.
- submit(Callable<V>) - Method in class org.jppf.client.concurrent.JPPFCompletionService
- submit(ClientTaskBundle) - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- submit(ClientTaskBundle) - Method in class org.jppf.client.balancer.ChannelWrapperRemoteAsync
- submit(JPPFJob) - Method in class org.jppf.client.JPPFClient
-
Submit the specified job for execution and wait for its completion.
- submitAsync(JPPFJob) - Method in class org.jppf.client.JPPFClient
-
Submit the specified job asynchronously for execution, without waiting for the job to complete.
- submitInitialization() - Method in class org.jppf.client.JPPFClientConnectionImpl
-
Submit the initialization of this connetion, some time in the future.
- submitJob(JPPFJob) - Method in class org.jppf.client.balancer.JobManagerClient
- submitJob(JPPFJob) - Method in interface org.jppf.client.JobManager
-
Add a job to the execution queue.
- submitJob(JPPFJob) - Method in class org.jppf.client.JPPFClient
-
Deprecated.a job should be submittable either synchronously or asynchronously, regardless of its state. The way it is submitted is the user's choice at the time of submission, using one of
JPPFClient.submit(JPPFJob)orJPPFClient.submitAsync(JPPFJob). - submitJob(JPPFJob, JobStatusListener) - Method in class org.jppf.client.balancer.JobManagerClient
- submitJob(JPPFJob, JobStatusListener) - Method in interface org.jppf.client.JobManager
-
Add a task job to the execution queue.
- SUBMITTED - Enum constant in enum class org.jppf.client.JobStatus
-
The job was just submitted.
T
- take() - Method in class org.jppf.client.concurrent.JPPFCompletionService
- taskCompleted(Exception) - Method in class org.jppf.client.balancer.ClientTaskBundle
-
Called to notify that the execution of a task has completed.
- taskCompleted(ClientTaskBundle, Exception) - Method in class org.jppf.client.balancer.ClientJob
-
Called to notify that the execution of a task has completed.
- TaskConfiguration - Interface in org.jppf.client.concurrent
-
This interface defines the properties that can be provided to a task submitted by a
JPPFExecutorServiceand that is not aTaskinstance. - TaskServerConnectionHandler - Class in org.jppf.client
-
Instances of this class handle the sending and receiving of jobs to and from a JPPF driver.
- TaskStateMap - Class in org.jppf.client.balancer
-
This map counts the number of each enum value that is put as a map value.
- TaskStateMap() - Constructor for class org.jppf.client.balancer.TaskStateMap
-
Initialize this map.
- terminatedStatuses() - Static method in enum class org.jppf.client.JPPFClientConnectionStatus
-
Get the statuses indicating that a connection is in a terminated state.
- throwable - Variable in class org.jppf.client.concurrent.JPPFTaskFuture
-
An exception that may be raised by the execution of the task.
- timedout - Variable in class org.jppf.client.concurrent.JPPFTaskFuture
-
Determines whether the task execution timed out.
- toDebugString() - Method in class org.jppf.client.JPPFClientConnectionImpl
-
Get a string representing this connection for debugging purposes.
- TOPOLOGY - Enum constant in enum class org.jppf.client.monitoring.topology.TopologyEvent.UpdateType
-
Topology update: driver or node has been added or removed.
- TopologyDriver - Class in org.jppf.client.monitoring.topology
-
Implementation of
TopologyDriverfor JPPF drivers. - TopologyEvent - Class in org.jppf.client.monitoring.topology
-
Instances of this class represent topology events, including addition/removal of a driver, addition/removal/update of a node and addition/removal of a peer driver connected as a node.
- TopologyEvent(TopologyManager, TopologyDriver, TopologyNode, TopologyEvent.UpdateType) - Constructor for class org.jppf.client.monitoring.topology.TopologyEvent
-
Initialize this event.
- TopologyEvent.UpdateType - Enum Class in org.jppf.client.monitoring.topology
-
The types of updates for an event.
- TopologyListener - Interface in org.jppf.client.monitoring.topology
-
Listener interface for changes in the grid topology.
- TopologyListenerAdapter - Class in org.jppf.client.monitoring.topology
-
A convenience class for subclasses that wish to receive topology events without having to implement all the methods of the
TopologyListenerinterface. - TopologyListenerAdapter() - Constructor for class org.jppf.client.monitoring.topology.TopologyListenerAdapter
- TopologyManager - Class in org.jppf.client.monitoring.topology
-
Instances of this class discover and maintain a representation of a JPPF grid topology.
- TopologyManager(long, long, JPPFClient, boolean, TopologyListener...) - Constructor for class org.jppf.client.monitoring.topology.TopologyManager
-
Initialize this topology manager with the specified
JPPFClientand listeners. - TopologyManager(long, long, JPPFClient, TopologyListener...) - Constructor for class org.jppf.client.monitoring.topology.TopologyManager
-
Initialize this topology manager with the specified
JPPFClientand listeners. - TopologyManager(long, long, TopologyListener...) - Constructor for class org.jppf.client.monitoring.topology.TopologyManager
-
Initialize this topology manager with a new
JPPFClientand the specified listeners. - TopologyManager(JPPFClient, TopologyListener...) - Constructor for class org.jppf.client.monitoring.topology.TopologyManager
-
Initialize this topology manager with the specified
JPPFClientand listeners. - TopologyManager(TopologyListener...) - Constructor for class org.jppf.client.monitoring.topology.TopologyManager
-
Initialize this topology manager with a new
JPPFClientand the specified listeners. - TopologyNode - Class in org.jppf.client.monitoring.topology
-
Implementation of
TopologyDriverfor JPPF nodes. - TopologyNode(JPPFManagementInfo) - Constructor for class org.jppf.client.monitoring.topology.TopologyNode
-
Initialize this topology data as holding information about a node.
- TopologyNodeStatus - Enum Class in org.jppf.client.monitoring.topology
-
Used for temporary display of the status of a node, before it is removed.
- TopologyPeer - Class in org.jppf.client.monitoring.topology
-
Instances of this class represent peer drivers as nodes for the driver they are connected to.
- toString() - Method in class org.jppf.client.AbstractConnectionPool
- toString() - Method in class org.jppf.client.AbstractJPPFJob
- toString() - Method in class org.jppf.client.balancer.AbstractChannelWrapperRemote
- toString() - Method in class org.jppf.client.balancer.ChannelWrapperLocal
- toString() - Method in class org.jppf.client.balancer.ChannelWrapperRemoteAsync
- toString() - Method in class org.jppf.client.balancer.ClientJob
- toString() - Method in class org.jppf.client.balancer.ClientTaskBundle
- toString() - Method in class org.jppf.client.ClasspathCache
- toString() - Method in class org.jppf.client.event.ConnectionPoolEvent
- toString() - Method in class org.jppf.client.JobResults
- toString() - Method in class org.jppf.client.JPPFClientConnectionImpl
- toString() - Method in class org.jppf.client.JPPFConnectionPool
- toString() - Method in class org.jppf.client.monitoring.jobs.Job
- toString() - Method in class org.jppf.client.monitoring.jobs.JobDispatch
- toString() - Method in class org.jppf.client.monitoring.jobs.JobDriver
- toString() - Method in class org.jppf.client.monitoring.jobs.JobMonitoringEvent
- toString() - Method in class org.jppf.client.monitoring.topology.AbstractTopologyComponent
- toString() - Method in class org.jppf.client.monitoring.topology.TopologyDriver
- toString() - Method in class org.jppf.client.monitoring.topology.TopologyEvent
- toString() - Method in class org.jppf.client.monitoring.topology.TopologyNode
- toString() - Method in class org.jppf.client.persistence.DefaultFilePersistenceManager
U
- uncaughtException(Thread, Throwable) - Method in class org.jppf.client.AbstractClassServerDelegate
- unexecutedTaskCount() - Method in class org.jppf.client.AbstractJPPFJob
-
Get the count of the tasks in this job that haven't yet been executed.
- unregister(JPPFClient) - Static method in class org.jppf.client.debug.Debug
-
Unregister a debug mbean for the specified JPPF client.
- unregisterClassLoaders(String) - Method in class org.jppf.client.AbstractGenericClient
-
Unregisters the class loader associated with the specified job uuid.
- UP - Enum constant in enum class org.jppf.client.monitoring.topology.TopologyNodeStatus
-
The node is up.
- updatePriority(String, int) - Method in class org.jppf.client.balancer.queue.JPPFPriorityQueue
-
Update the priority of the job with the specified uuid.
- updateStatus(ClientJobStatus, ClientJobStatus) - Method in class org.jppf.client.balancer.AbstractClientJob
-
Updates status to new value if old value is equal to expect.
- uuid - Variable in class org.jppf.client.balancer.AbstractChannelWrapperRemote
-
Unique identifier of the client.
- uuid - Variable in class org.jppf.client.monitoring.AbstractComponent
-
The uuid of this component.
V
- valueOf(String) - Static method in enum class org.jppf.client.balancer.ClientJobStatus
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class org.jppf.client.event.JobEvent.Type
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class org.jppf.client.JobStatus
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class org.jppf.client.JPPFClientConnectionStatus
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class org.jppf.client.monitoring.jobs.JobMonitorUpdateMode
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class org.jppf.client.monitoring.topology.TopologyEvent.UpdateType
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class org.jppf.client.monitoring.topology.TopologyNodeStatus
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class org.jppf.client.balancer.ClientJobStatus
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class org.jppf.client.event.JobEvent.Type
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class org.jppf.client.JobStatus
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class org.jppf.client.JPPFClientConnectionStatus
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class org.jppf.client.monitoring.jobs.JobMonitorUpdateMode
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class org.jppf.client.monitoring.topology.TopologyEvent.UpdateType
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class org.jppf.client.monitoring.topology.TopologyNodeStatus
-
Returns an array containing the constants of this enum class, in the order they are declared.
W
- waitForTask(int) - Method in class org.jppf.client.JobResults
-
Wait for the execution results of the specified task to be received.
- waitForTask(int, long) - Method in class org.jppf.client.JobResults
-
Wait for the execution results of the specified task to be received.
- workingStatuses() - Static method in enum class org.jppf.client.JPPFClientConnectionStatus
-
Get the statuses indicating that a connection is in a working state.
- writeResource(JPPFResourceWrapper) - Method in class org.jppf.client.AbstractClassServerDelegate
-
Write a resource wrapper object to the socket connection.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
ClientConnectionStatusEvent.getClientConnection()instead.