com.amazon.carbonado.capability

Interface RemoteProcedure.Request<R,D>

Type Parameters:

R - reply object type

D - request data object type

Enclosing interface:

RemoteProcedure<R,D>

public static interface RemoteProcedure.Request<R,D>

Request into a remote procedure, as seen by procedure implementation. To avoid leaking resources, the request or reply object must always be finished. If an exception is thrown by a method defined in this interface, resources are automatically released.

Method Summary

Methods

Modifier and Type	Method and Description
RemoteProcedure.Reply<R>	beginReply() Begin a reply after receiving all data.
void	finish() Reply and immediately finish, without sending any data to caller.
D	receive() Receive data from caller.
int	receiveInto(java.util.Collection<? super D> c) Receive all remaining data from caller.

Method Detail

receive

D receive()
          throws RepositoryException

Receive data from caller.

Returns:

null if no more data

Throws:

RepositoryException

receiveInto

int receiveInto(java.util.Collection<? super D> c)
                throws RepositoryException

Receive all remaining data from caller.

Parameters:

c - collection to receive data

Returns:

amount received

Throws:

RepositoryException

beginReply

RemoteProcedure.Reply<R> beginReply()
                                    throws RepositoryException

Begin a reply after receiving all data. If no data is expected, reply can be made without calling receive.

Throws:

java.lang.IllegalStateException - if reply was already begun, or if request is finished, or if more data must be received

RepositoryException

finish

void finish()
            throws RepositoryException

Reply and immediately finish, without sending any data to caller.

Throws:

java.lang.IllegalStateException - if a reply was already begun or if more data must be received

RepositoryException