Uses of Class
org.acemq.amqp.core.StreamReader

Packages that use StreamReader

Package	Description
org.acemq.amqp.core	The protocol-agnostic engine.

Uses of StreamReader in org.acemq.amqp.core

Methods in org.acemq.amqp.core that return StreamReader

Modifier and Type	Method	Description
StreamReader<T>	StreamReader.as(Codec codec)
StreamReader<T>	StreamReader.from(Instant timestamp)
StreamReader<T>	StreamReader.from(StreamOffset offset)
StreamReader<T>	StreamReader.fromFirst()
StreamReader<T>	StreamReader.fromLast()
StreamReader<T>	StreamReader.fromLast(Duration age)
StreamReader<T>	StreamReader.fromNext()
StreamReader<T>	StreamReader.fromOffset(long offset)
StreamReader<T>	StreamReader.prefetch(int prefetch)
StreamReader<T>	StreamReader.skipFailures()	Carries on past a message whose handler failed, counting it.
<T> StreamReader<T>	AceMq.stream(String queue, Class<T> payloadType)	Reads a stream, starting where the returned reader is told to.