org.bravo5.jenkins.vertx

Class EventBusQueueTaskDispatcher

java.lang.Object

hudson.model.queue.QueueTaskDispatcher

org.bravo5.jenkins.vertx.EventBusQueueTaskDispatcher

All Implemented Interfaces:

hudson.ExtensionPoint, org.vertx.java.core.Handler<org.vertx.java.core.eventbus.Message<org.vertx.java.core.json.JsonObject>>

@Extension
public class EventBusQueueTaskDispatcher
extends hudson.model.queue.QueueTaskDispatcher
implements org.vertx.java.core.Handler<org.vertx.java.core.eventbus.Message<org.vertx.java.core.json.JsonObject>>

QueueTaskDispatcher that gets exposed to the EventBus.

Nested Class Summary

Nested classes/interfaces inherited from interface hudson.ExtensionPoint

hudson.ExtensionPoint.LegacyInstancesAreScopedToHudson

Constructor Summary

Constructors

Constructor and Description
EventBusQueueTaskDispatcher()

Method Summary

Methods

Modifier and Type	Method and Description
hudson.model.queue.CauseOfBlockage	canRun(hudson.model.Queue.Item queueItem)
void	close() Called by PluginImpl to shut us down.
void	handle(org.vertx.java.core.eventbus.Message<org.vertx.java.core.json.JsonObject> msg)
void	init()
void	setEventBus(org.vertx.java.core.eventbus.EventBus eventBus) Setter for eventBus.

Methods inherited from class hudson.model.queue.QueueTaskDispatcher

all, canTake, canTake

Methods inherited from class java.lang.Object

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

Constructor Detail

EventBusQueueTaskDispatcher

public EventBusQueueTaskDispatcher()

Method Detail

setEventBus

public void setEventBus(org.vertx.java.core.eventbus.EventBus eventBus)

Setter for eventBus.

Parameters:

eventBus - new value for eventBus

init

public void init()

close

public void close()

Called by PluginImpl to shut us down.

handle

public void handle(org.vertx.java.core.eventbus.Message<org.vertx.java.core.json.JsonObject> msg)

Specified by:

handle in interface org.vertx.java.core.Handler<org.vertx.java.core.eventbus.Message<org.vertx.java.core.json.JsonObject>>

canRun

public hudson.model.queue.CauseOfBlockage canRun(hudson.model.Queue.Item queueItem)

Overrides:

canRun in class hudson.model.queue.QueueTaskDispatcher