Uses of Interface
org.apache.qpid.protonj2.client.StreamReceiverMessage

Packages that use StreamReceiverMessage

Package	Description
org.apache.qpid.protonj2.client
org.apache.qpid.protonj2.client.impl

Uses of StreamReceiverMessage in org.apache.qpid.protonj2.client

Methods in org.apache.qpid.protonj2.client that return StreamReceiverMessage

Modifier and Type	Method	Description
StreamReceiverMessage	StreamDelivery.message()	Decode the StreamDelivery payload and return an Message object.

Uses of StreamReceiverMessage in org.apache.qpid.protonj2.client.impl

Classes in org.apache.qpid.protonj2.client.impl that implement StreamReceiverMessage

Modifier and Type	Class	Description
class	ClientStreamReceiverMessage	Streamed message delivery context used to request reads of possible split framed Transfer payload's that comprise a single large overall message.

Methods in org.apache.qpid.protonj2.client.impl that return StreamReceiverMessage

Modifier and Type	Method	Description
StreamReceiverMessage	ClientStreamReceiverMessage.absoluteExpiryTime(long expiryTime)
StreamReceiverMessage	ClientStreamReceiverMessage.addBodySection(Section<?> bodySection)
StreamReceiverMessage	ClientStreamReceiverMessage.annotation(String key, Object value)
StreamReceiverMessage	ClientStreamReceiverMessage.annotations(MessageAnnotations messageAnnotations)
StreamReceiverMessage	ClientStreamReceiverMessage.applicationProperties(ApplicationProperties applicationProperties)
StreamReceiverMessage	ClientStreamReceiverMessage.body(InputStream value)
StreamReceiverMessage	ClientStreamReceiverMessage.bodySections(Collection<Section<?>> sections)
StreamReceiverMessage	ClientStreamReceiverMessage.clearBodySections()
StreamReceiverMessage	ClientStreamReceiverMessage.contentType(String contentType)
StreamReceiverMessage	ClientStreamReceiverMessage.correlationId(Object correlationId)
StreamReceiverMessage	ClientStreamReceiverMessage.creationTime(long createTime)
StreamReceiverMessage	ClientStreamReceiverMessage.deliveryCount(long deliveryCount)
StreamReceiverMessage	ClientStreamReceiverMessage.durable(boolean durable)
StreamReceiverMessage	ClientStreamReceiverMessage.firstAcquirer(boolean firstAcquirer)
StreamReceiverMessage	ClientStreamReceiverMessage.footer(String key, Object value)
StreamReceiverMessage	ClientStreamReceiverMessage.footer(Footer footer)
StreamReceiverMessage	ClientStreamReceiverMessage.forEachAnnotation(BiConsumer<String,Object> action)
StreamReceiverMessage	ClientStreamReceiverMessage.forEachBodySection(Consumer<Section<?>> consumer)
StreamReceiverMessage	ClientStreamReceiverMessage.forEachFooter(BiConsumer<String,Object> action)
StreamReceiverMessage	ClientStreamReceiverMessage.forEachProperty(BiConsumer<String,Object> action)
StreamReceiverMessage	ClientStreamReceiverMessage.groupId(String groupId)
StreamReceiverMessage	ClientStreamReceiverMessage.groupSequence(int groupSequence)
StreamReceiverMessage	ClientStreamReceiverMessage.header(Header header)
StreamReceiverMessage	ClientStreamReceiverMessage.messageFormat(int messageFormat)
StreamReceiverMessage	ClientStreamReceiverMessage.messageId(Object messageId)
StreamReceiverMessage	ClientStreamReceiverMessage.priority(byte priority)
StreamReceiverMessage	ClientStreamReceiverMessage.properties(Properties properties)
StreamReceiverMessage	ClientStreamReceiverMessage.property(String key, Object value)
StreamReceiverMessage	ClientStreamReceiverMessage.replyTo(String replyTo)
StreamReceiverMessage	ClientStreamReceiverMessage.replyToGroupId(String replyToGroupId)
StreamReceiverMessage	ClientStreamReceiverMessage.subject(String subject)
StreamReceiverMessage	ClientStreamReceiverMessage.timeToLive(long timeToLive)
StreamReceiverMessage	ClientStreamReceiverMessage.to(String to)
StreamReceiverMessage	ClientStreamReceiverMessage.userId(byte[] userId)