Uses of Interface
org.apache.qpid.protonj2.client.StreamReceiver
-
Packages that use StreamReceiver Package Description org.apache.qpid.protonj2.client org.apache.qpid.protonj2.client.impl -
-
Uses of StreamReceiver in org.apache.qpid.protonj2.client
Methods in org.apache.qpid.protonj2.client that return StreamReceiver Modifier and Type Method Description StreamReceiver
StreamReceiver. addCredit(int credits)
Adds credit to theStreamReceiver
link for use when the receiver has not been configured with a credit window.StreamReceiver
Connection. openStreamReceiver(String address)
Creates a streaming message receiver used to consume large messages from the given node address.StreamReceiver
Connection. openStreamReceiver(String address, StreamReceiverOptions receiverOptions)
Creates a streaming message receiver used to consume large messages from the given node address.StreamReceiver
StreamDelivery. receiver()
StreamReceiver
StreamReceiverMessage. receiver()
Methods in org.apache.qpid.protonj2.client that return types with arguments of type StreamReceiver Modifier and Type Method Description Future<StreamReceiver>
StreamReceiver. drain()
Requests the remote to drain previously granted credit for thisStreamReceiver
link. -
Uses of StreamReceiver in org.apache.qpid.protonj2.client.impl
Classes in org.apache.qpid.protonj2.client.impl that implement StreamReceiver Modifier and Type Class Description class
ClientStreamReceiver
Client implementation of aStreamReceiver
.Methods in org.apache.qpid.protonj2.client.impl that return StreamReceiver Modifier and Type Method Description StreamReceiver
ClientStreamReceiver. addCredit(int credits)
StreamReceiver
ClientConnection. openStreamReceiver(String address)
StreamReceiver
ClientConnection. openStreamReceiver(String address, StreamReceiverOptions receiverOptions)
protected StreamReceiver
ClientStreamReceiver. self()
Methods in org.apache.qpid.protonj2.client.impl that return types with arguments of type StreamReceiver Modifier and Type Method Description Future<StreamReceiver>
ClientStreamReceiver. drain()
-