net.bluemind.core.rest.vertx

Class VertxStreamConsumerControlHandler

java.lang.Object

net.bluemind.core.rest.vertx.VertxStreamConsumerControlHandler

public class VertxStreamConsumerControlHandler
extends java.lang.Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

VertxStreamConsumerControlHandler

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

Method Detail

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()