org.apache.qpid.proton.engine

Interface Sender

All Superinterfaces:

Endpoint, Extendable, Link

All Known Implementing Classes:

SenderImpl

public interface Sender
extends Link

Sender

Method Summary

Modifier and Type	Method and Description
void	abort() Abort the current delivery.
boolean	advance() Attempts to advance the current delivery.
void	offer(int credits) indicates pending deliveries
int	send(byte[] bytes, int offset, int length) Sends some data for the current delivery.
int	send(ReadableBuffer buffer) Sends some data for the current delivery.
int	sendNoCopy(ReadableBuffer buffer) Sends data to the current delivery attempting not to copy the data unless a previous send has already added data to the Delivery in which case a copy may occur depending on the implementation.

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

current, delivery, delivery, detach, detached, drained, getCredit, getDesiredCapabilities, getDrain, getMaxMessageSize, getName, getOfferedCapabilities, getProperties, getQueued, getReceiverSettleMode, getRemoteCredit, getRemoteDesiredCapabilities, getRemoteMaxMessageSize, getRemoteOfferedCapabilities, getRemoteProperties, getRemoteReceiverSettleMode, getRemoteSenderSettleMode, getRemoteSource, getRemoteTarget, getSenderSettleMode, getSession, getSource, getTarget, getUnsettled, head, next, setDesiredCapabilities, setMaxMessageSize, setOfferedCapabilities, setProperties, setReceiverSettleMode, setRemoteSenderSettleMode, setSenderSettleMode, setSource, setTarget

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

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

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

attachments

Method Detail

offer

void offer(int credits)

indicates pending deliveries

Parameters:

credits - the number of pending deliveries

send

int send(byte[] bytes,
         int offset,
         int length)

Sends some data for the current delivery. The application may call this method multiple times for the same delivery.

Parameters:

bytes - the byte array containing the data to be sent.

offset - the offset into the given array to start reading.

length - the number of bytes to read from the given byte array.

Returns:

the number of bytes accepted TODO Proton-j current copies all the bytes it has been given so the return value will always be length. Should this be changed? How does Proton-c behave? What should the application do if the number of bytes accepted is smaller than length.

send

int send(ReadableBuffer buffer)

Sends some data for the current delivery. The application may call this method multiple times for the same delivery.

Parameters:

buffer - the buffer to read the data from.

Returns:

the number of bytes read from the provided buffer.

sendNoCopy

int sendNoCopy(ReadableBuffer buffer)

Sends data to the current delivery attempting not to copy the data unless a previous send has already added data to the Delivery in which case a copy may occur depending on the implementation.

Care should be taken when passing ReadableBuffer instances that wrapped pooled bytes as the send does not mean the data will be sent immediately when the transport is flushed so the pooled bytes could be held for longer than expected.

Parameters:

buffer - An immutable ReadableBuffer that can be held until the next transport flush.

Returns:

the number of bytes read from the provided buffer.

abort

void abort()

Abort the current delivery. Note "pn_link_abort" is commented out in the .h

advance

boolean advance()

Attempts to advance the current delivery. Advances it to the next delivery if one exists, else null. The behaviour of this method is different for senders and receivers. Informs the sender that all the bytes of the current Delivery have been written. The application must call this method in order for the delivery to be considered complete.

Specified by:

advance in interface Link

Returns:

true if it can advance, false if it cannot TODO document the meaning of the return value more fully. Currently Senderimpl only returns false if there is no current delivery

See Also:

TODO fully state the rules regarding when you have to call this method, what happens if you don't call it before creating another delivery etc.