org.apache.qpid.proton.engine.impl

Class ReceiverImpl

java.lang.Object

org.apache.qpid.proton.engine.impl.EndpointImpl

org.apache.qpid.proton.engine.impl.LinkImpl

org.apache.qpid.proton.engine.impl.ReceiverImpl

All Implemented Interfaces:

Endpoint, Link, ProtonJEndpoint, Receiver

public class ReceiverImpl
extends LinkImpl
implements Receiver

Method Summary

Methods

Modifier and Type	Method and Description
boolean	advance()
void	drain(int credit)
boolean	draining()
void	flow(int credits)
void	free()
int	recv(byte[] bytes, int offset, int size)
void	setDrain(boolean drain)
java.util.Iterator<Delivery>	unsettled()

Methods inherited from class org.apache.qpid.proton.engine.impl.LinkImpl

addCredit, close, current, delivery, delivery, drained, getConnectionImpl, getCredit, getDrain, getName, getQueued, getReceiverSettleMode, getRemoteCredit, getRemoteReceiverSettleMode, getRemoteSenderSettleMode, getRemoteSource, getRemoteTarget, getSenderSettleMode, getSession, getSource, getTarget, getUnsettled, next, open, remove, setCredit, setReceiverSettleMode, setRemoteSenderSettleMode, setSenderSettleMode, setSource, setTarget

Methods inherited from class org.apache.qpid.proton.engine.impl.EndpointImpl

getCondition, getContext, getLocalState, getRemoteCondition, getRemoteState, setCondition, setContext, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.qpid.proton.engine.Link

current, delivery, delivery, drained, getCredit, getDrain, getName, getQueued, getReceiverSettleMode, getRemoteCredit, getRemoteReceiverSettleMode, getRemoteSenderSettleMode, getRemoteSource, getRemoteTarget, getSenderSettleMode, getSession, getSource, getTarget, getUnsettled, next, setReceiverSettleMode, setRemoteSenderSettleMode, setSenderSettleMode, setSource, setTarget

Methods inherited from interface org.apache.qpid.proton.engine.Endpoint

close, getCondition, getContext, getLocalState, getRemoteCondition, getRemoteState, open, setCondition, setContext

Method Detail

advance

public boolean advance()

Specified by:

advance in interface Link

Specified by:

advance in interface Receiver

Overrides:

advance in class LinkImpl

flow

public void flow(int credits)

Specified by:

flow in interface Receiver

recv

public int recv(byte[] bytes,
       int offset,
       int size)

Specified by:

recv in interface Receiver

unsettled

public java.util.Iterator<Delivery> unsettled()

Specified by:

unsettled in interface Link

free

public void free()

Specified by:

free in interface Endpoint

Overrides:

free in class LinkImpl

drain

public void drain(int credit)

Specified by:

drain in interface Receiver

draining

public boolean draining()

Specified by:

draining in interface Receiver

setDrain

public void setDrain(boolean drain)

Specified by:

setDrain in interface Receiver