org.jacorb.orb

Class ReplyReceiver

java.lang.Object

org.jacorb.orb.giop.ReplyPlaceholder

org.jacorb.orb.ReplyReceiver

All Implemented Interfaces:

Configurable

public final class ReplyReceiver
extends ReplyPlaceholder
implements Configurable

A special ReplyPlaceholder that receives replies to normal requests, either synchronously or asynchronously. A ReplyReceiver handles all ORB-internal work that needs to be done for the reply, such as checking for exceptions and invoking the interceptors. The client stub can either do a blocking wait on the ReplyReceiver (via getReply()), or a ReplyHandler can be supplied when the ReplyReceiver is created; then the reply is delivered to that ReplyHandler.

Author:

Andre Spiegel <spiegel@gnu.org>

Field Summary

Fields inherited from class org.jacorb.orb.giop.ReplyPlaceholder

communicationException, exceptionCause, in, lock, ready, remarshalException, timeout, timeoutException

Constructor Summary

Constructors

Constructor and Description
ReplyReceiver(Delegate delegate, ReplyGroup group, String operation, org.omg.TimeBase.UtcT replyEndTime, ClientInterceptorHandler interceptors, ReplyHandler replyHandler, SelectorManager selectorManager)

Method Summary

Methods

Modifier and Type	Method and Description
void	configure(Configuration configuration)
ReplyInputStream	getReply() This method blocks until a reply becomes available.
void	replyReceived(MessageInputStream in)

Methods inherited from class org.jacorb.orb.giop.ReplyPlaceholder

cancel, getInputStream, retry

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplyReceiver

public ReplyReceiver(Delegate delegate,
             ReplyGroup group,
             String operation,
             org.omg.TimeBase.UtcT replyEndTime,
             ClientInterceptorHandler interceptors,
             ReplyHandler replyHandler,
             SelectorManager selectorManager)

Method Detail

configure

public void configure(Configuration configuration)
               throws ConfigurationException

Specified by:

configure in interface Configurable

Overrides:

configure in class ReplyPlaceholder

Throws:

ConfigurationException

replyReceived

public void replyReceived(MessageInputStream in)

Overrides:

replyReceived in class ReplyPlaceholder

getReply

public ReplyInputStream getReply()
                          throws RemarshalException,
                                 ApplicationException

This method blocks until a reply becomes available. If the reply contains any exceptions, they are rethrown.

Throws:

RemarshalException

ApplicationException