io.apiman.gateway.vertx.worker

Class ServiceWorkerQueue

java.lang.Object

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

io.apiman.gateway.vertx.worker.ServiceWorkerQueue

public class ServiceWorkerQueue
extends WorkerQueue<HttpGatewayStreamer>

A queue of workers ready to handle the execution of some task(s). ServiceWorkers are expected to register themselves via the EventBus at the stated endpoint.

Author:

Marc Savy

Field Summary

Fields inherited from class io.apiman.gateway.vertx.worker.WorkerQueue

eb, logger, policyWorkers, registrationTopic, workerHandler

Constructor Summary

Constructors

Constructor and Description
ServiceWorkerQueue(org.vertx.java.core.Vertx vertx, org.vertx.java.platform.Container container, String registrationTopic, String stripString)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(HttpGatewayStreamer worker) Return a worker to the queue.
protected void	collectRegistrations()
void	poll(org.vertx.java.core.Handler<HttpGatewayStreamer> workerHandler)

Methods inherited from class io.apiman.gateway.vertx.worker.WorkerQueue

getTopic, isEmpty, poll, workerHandler

Methods inherited from class java.lang.Object

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

Constructor Detail

ServiceWorkerQueue

public ServiceWorkerQueue(org.vertx.java.core.Vertx vertx,
                  org.vertx.java.platform.Container container,
                  String registrationTopic,
                  String stripString)

Method Detail

collectRegistrations

protected void collectRegistrations()

Specified by:

collectRegistrations in class WorkerQueue<HttpGatewayStreamer>

poll

public void poll(org.vertx.java.core.Handler<HttpGatewayStreamer> workerHandler)

add

public void add(HttpGatewayStreamer worker)

Description copied from class: WorkerQueue

Return a worker to the queue.

Overrides:

add in class WorkerQueue<HttpGatewayStreamer>

Parameters:

worker - The worker to return