io.apiman.gateway.vertx.worker

Class WorkerQueue<T extends Registrant>

java.lang.Object

io.apiman.gateway.vertx.worker.WorkerQueue<T>

Type Parameters:

T - the registrant type

Direct Known Subclasses:

ServiceWorkerQueue

public abstract class WorkerQueue<T extends Registrant>
extends Object

Contains a queue of Registrant workers, which are collected by collectRegistrations(),

Author:

Marc Savy

Field Summary

Fields

Modifier and Type	Field and Description
protected org.vertx.java.core.eventbus.EventBus	eb
protected org.vertx.java.core.logging.Logger	logger
protected Deque<T>	policyWorkers
protected String	registrationTopic
protected org.vertx.java.core.Handler<Void>	workerHandler

Constructor Summary

Constructors

Constructor and Description
WorkerQueue(String topic, org.vertx.java.core.eventbus.EventBus eb, org.vertx.java.core.logging.Logger logger)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(T pinnedWorker) Return a worker to the queue.
protected abstract void	collectRegistrations()
String	getTopic()
boolean	isEmpty()
T	poll()
protected void	workerHandler(org.vertx.java.core.Handler<Void> workerHandler)

Methods inherited from class java.lang.Object

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

Field Detail

policyWorkers

protected Deque<T extends Registrant> policyWorkers

eb

protected org.vertx.java.core.eventbus.EventBus eb

logger

protected org.vertx.java.core.logging.Logger logger

registrationTopic

protected String registrationTopic

workerHandler

protected org.vertx.java.core.Handler<Void> workerHandler

Constructor Detail

WorkerQueue

public WorkerQueue(String topic,
           org.vertx.java.core.eventbus.EventBus eb,
           org.vertx.java.core.logging.Logger logger)

Method Detail

collectRegistrations

protected abstract void collectRegistrations()

workerHandler

protected void workerHandler(org.vertx.java.core.Handler<Void> workerHandler)

getTopic

public String getTopic()

Returns:

Topic being listened to.

poll

public T poll()

Returns:

A worker if available, otherwise null.

add

public void add(T pinnedWorker)

Return a worker to the queue.

Parameters:

pinnedWorker - The worker to return

isEmpty

public boolean isEmpty()

Returns:

true if queue is empty; else false.