org.apache.nifi.controller

Class EventDrivenWorkerQueue

java.lang.Object

org.apache.nifi.controller.EventDrivenWorkerQueue

All Implemented Interfaces:

WorkerQueue

public class EventDrivenWorkerQueue
extends java.lang.Object
implements WorkerQueue

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EventDrivenWorkerQueue.Worker

Constructor Summary

Constructors

Constructor and Description
EventDrivenWorkerQueue(boolean clustered, boolean primary, ProcessScheduler scheduler)

Method Summary

Modifier and Type	Method and Description
void	offer(Connectable connectable)
EventDrivenWorkerQueue.Worker	poll(long timeout, java.util.concurrent.TimeUnit timeUnit)
void	resumeWork(Connectable connectable)
void	setClustered(boolean clustered)
void	setPrimary(boolean primary)
void	suspendWork(Connectable connectable)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventDrivenWorkerQueue

public EventDrivenWorkerQueue(boolean clustered,
                              boolean primary,
                              ProcessScheduler scheduler)

Method Detail

setClustered

public void setClustered(boolean clustered)

Specified by:

setClustered in interface WorkerQueue

setPrimary

public void setPrimary(boolean primary)

Specified by:

setPrimary in interface WorkerQueue

poll

public EventDrivenWorkerQueue.Worker poll(long timeout,
                                          java.util.concurrent.TimeUnit timeUnit)

Specified by:

poll in interface WorkerQueue

offer

public void offer(Connectable connectable)

Specified by:

offer in interface WorkerQueue

resumeWork

public void resumeWork(Connectable connectable)

Specified by:

resumeWork in interface WorkerQueue

suspendWork

public void suspendWork(Connectable connectable)

Specified by:

suspendWork in interface WorkerQueue