Package net.bluemind.core.rest.vertx

Class VertxStreamConsumerControlHandler

java.lang.Object

net.bluemind.core.rest.vertx.VertxStreamConsumerControlHandler

public class VertxStreamConsumerControlHandler
extends Object

Constructor Summary

Constructors

Constructor	Description
VertxStreamConsumerControlHandler(io.vertx.core.Vertx vertx, VertxStreamConsumer vertxStreamConsumer, String controlAddress)

Method Summary

Modifier and Type	Method	Description
protected void	handleStreamObject(io.vertx.core.eventbus.Message<VertxRestStreamObject> event)
void	pause()
void	resume()
void	sendClose()
void	start(boolean andResume)

Methods inherited from class java.lang.Object

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

Constructor Details

VertxStreamConsumerControlHandler

public VertxStreamConsumerControlHandler(io.vertx.core.Vertx vertx,
 VertxStreamConsumer vertxStreamConsumer,
 String controlAddress)

Method Details

start

public void start(boolean andResume)

handleStreamObject

protected void handleStreamObject(io.vertx.core.eventbus.Message<VertxRestStreamObject> event)

pause

public void pause()

resume

public void resume()

sendClose

public void sendClose()