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 StreamReceiverStreamReceiver. addCredit(int credits)Adds credit to theStreamReceiverlink for use when the receiver has not been configured with a credit window.StreamReceiverConnection. openStreamReceiver(String address)Creates a streaming message receiver used to consume large messages from the given node address.StreamReceiverConnection. openStreamReceiver(String address, StreamReceiverOptions receiverOptions)Creates a streaming message receiver used to consume large messages from the given node address.StreamReceiverStreamDelivery. receiver()StreamReceiverStreamReceiverMessage. 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 thisStreamReceiverlink. -
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 classClientStreamReceiverClient implementation of aStreamReceiver.Methods in org.apache.qpid.protonj2.client.impl that return StreamReceiver Modifier and Type Method Description StreamReceiverClientStreamReceiver. addCredit(int credits)StreamReceiverClientConnection. openStreamReceiver(String address)StreamReceiverClientConnection. openStreamReceiver(String address, StreamReceiverOptions receiverOptions)protected StreamReceiverClientStreamReceiver. 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()
-