io.apiman.gateway.vertx.conversation

Class AbstractServiceExecutor<H>

java.lang.Object

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

Type Parameters:

H - the head type

All Implemented Interfaces:

ISimpleWriteStream

Direct Known Subclasses:

SignalRequestExecutor

public abstract class AbstractServiceExecutor<H>
extends Object
implements ISimpleWriteStream

Execute a service

Author:

Marc Savy

Field Summary

Fields

Modifier and Type	Field and Description
protected String	address
protected org.vertx.java.core.eventbus.EventBus	eb
protected boolean	finished
protected org.vertx.java.core.logging.Logger	logger

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	end() Finished writing chunks.
protected void	execute(H service)
boolean	isFinished()
void	reset()
void	write(org.vertx.java.core.buffer.Buffer chunk) Write a chunk

Methods inherited from class java.lang.Object

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

Field Detail

eb

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

logger

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

address

protected String address

finished

protected boolean finished

Constructor Detail

AbstractServiceExecutor

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

Method Detail

execute

protected void execute(H service)

write

public void write(org.vertx.java.core.buffer.Buffer chunk)

Description copied from interface: ISimpleWriteStream

Write a chunk

Specified by:

write in interface ISimpleWriteStream

Parameters:

chunk - the buffer data chunk

end

public void end()

Description copied from interface: ISimpleWriteStream

Finished writing chunks. No further calls to ISimpleWriteStream.write(Buffer) should occur.

Specified by:

end in interface ISimpleWriteStream

isFinished

public boolean isFinished()

Returns:

the finished

reset

public void reset()