Uses of Record Class
org.apache.tika.pipes.core.protocol.PipesMessage
Packages that use PipesMessage
-
Uses of PipesMessage in org.apache.tika.pipes.core.protocol
Methods in org.apache.tika.pipes.core.protocol that return PipesMessageModifier and TypeMethodDescriptionstatic PipesMessagePipesMessage.ack()static PipesMessagePipesMessage.crash(PipesMessageType crashType, byte[] payload) static PipesMessagePipesMessage.finished(byte[] payload) static PipesMessagePipesMessage.intermediateResult(byte[] payload) static PipesMessagePipesMessage.newRequest(byte[] payload) static PipesMessagePipesMessage.ping()static PipesMessagePipesMessage.read(DataInputStream in) Reads one framed message from the stream.static PipesMessagePipesMessage.ready()static PipesMessagePipesMessage.shutDown()static PipesMessagePipesMessage.startupFailed(byte[] payload) static PipesMessagePipesMessage.working(long lastProgressMillis) Creates a WORKING heartbeat with the last-progress timestamp in the payload.