io.apiman.gateway.vertx.conversation

Class SignalRequestExecutor<H>

java.lang.Object

io.apiman.gateway.vertx.conversation.AbstractServiceExecutor<H>

io.apiman.gateway.vertx.conversation.SignalRequestExecutor<H>

Type Parameters:

H - the head type

All Implemented Interfaces:

IReadyExecute<H,ISimpleWriteStream>, ISimpleWriteStream

public class SignalRequestExecutor<H>
extends AbstractServiceExecutor<H>
implements IReadyExecute<H,ISimpleWriteStream>

Send a ServiceRequest over the EventBus.

Author:

Marc Savy

Field Summary

Fields inherited from class io.apiman.gateway.vertx.conversation.AbstractServiceExecutor

address, eb, finished, logger

Constructor Summary

Constructors

Constructor and Description
SignalRequestExecutor(org.vertx.java.core.Vertx vertx, org.vertx.java.platform.Container container, String address)

Method Summary

Methods

Modifier and Type	Method and Description
void	execute(H service, org.vertx.java.core.Handler<ISimpleWriteStream> readyHandler)
void	reset()

Methods inherited from class io.apiman.gateway.vertx.conversation.AbstractServiceExecutor

end, execute, isFinished, write

Methods inherited from class java.lang.Object

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

Constructor Detail

SignalRequestExecutor

public SignalRequestExecutor(org.vertx.java.core.Vertx vertx,
                     org.vertx.java.platform.Container container,
                     String address)

Method Detail

execute

public void execute(H service,
           org.vertx.java.core.Handler<ISimpleWriteStream> readyHandler)

Specified by:

execute in interface IReadyExecute<H,ISimpleWriteStream>

Parameters:

service - object to execute immediately

readyHandler - called when ready

reset

public void reset()

Overrides:

reset in class AbstractServiceExecutor<H>