io.apiman.gateway.vertx.conversation

Class AbstractServiceListener<E>

java.lang.Object

io.apiman.gateway.vertx.conversation.AbstractServiceListener<E>

Type Parameters:

E - the class to decode to

All Implemented Interfaces:

IResettable

Direct Known Subclasses:

ServiceRequestListener, ServiceResponseListener

public abstract class AbstractServiceListener<E>
extends Object
implements IResettable

Listen for something.

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
AbstractServiceListener(org.vertx.java.core.eventbus.EventBus eb, org.vertx.java.core.logging.Logger logger, String address, Class<E> klazz)

Method Summary

Methods

Modifier and Type	Method and Description
void	bodyHandler(org.vertx.java.core.Handler<org.vertx.java.core.buffer.Buffer> bodyHandler)
protected void	end()
void	endHandler(org.vertx.java.core.Handler<Void> finishHandler)
void	errorHandler(org.vertx.java.core.Handler<Throwable> errorHandler)
boolean	isFinished()
protected void	listen()
void	serviceHandler(org.vertx.java.core.Handler<E> handler)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.apiman.gateway.vertx.io.IResettable

reset

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

AbstractServiceListener

public AbstractServiceListener(org.vertx.java.core.eventbus.EventBus eb,
                       org.vertx.java.core.logging.Logger logger,
                       String address,
                       Class<E> klazz)

Method Detail

listen

protected void listen()

end

protected void end()

serviceHandler

public void serviceHandler(org.vertx.java.core.Handler<E> handler)

bodyHandler

public void bodyHandler(org.vertx.java.core.Handler<org.vertx.java.core.buffer.Buffer> bodyHandler)

endHandler

public void endHandler(org.vertx.java.core.Handler<Void> finishHandler)

errorHandler

public void errorHandler(org.vertx.java.core.Handler<Throwable> errorHandler)

isFinished

public boolean isFinished()

Returns:

the finished