Uses of Record Class
org.apache.tika.pipes.core.protocol.PipesMessage

Packages that use PipesMessage

Package	Description
org.apache.tika.pipes.core.protocol

Uses of PipesMessage in org.apache.tika.pipes.core.protocol

Methods in org.apache.tika.pipes.core.protocol that return PipesMessage

Modifier and Type	Method	Description
static PipesMessage	PipesMessage.ack()
static PipesMessage	PipesMessage.crash(PipesMessageType crashType, byte[] payload)
static PipesMessage	PipesMessage.finished(byte[] payload)
static PipesMessage	PipesMessage.intermediateResult(byte[] payload)
static PipesMessage	PipesMessage.newRequest(byte[] payload)
static PipesMessage	PipesMessage.ping()
static PipesMessage	PipesMessage.read(DataInputStream in)	Reads one framed message from the stream, enforcing MAX_PAYLOAD_BYTES.
static PipesMessage	PipesMessage.read(DataInputStream in, int maxPayloadBytes)	Reads one framed message from the stream, enforcing the given payload limit.
static PipesMessage	PipesMessage.ready()
static PipesMessage	PipesMessage.shutDown()
static PipesMessage	PipesMessage.startupFailed(byte[] payload)
static PipesMessage	PipesMessage.working()	Creates a WORKING heartbeat.