IceInternal

Class ProxyOutgoingAsyncBase

java.lang.Object

IceInternal.AsyncResultI

IceInternal.OutgoingAsyncBase

IceInternal.ProxyOutgoingAsyncBase

All Implemented Interfaces:

AsyncResult

Direct Known Subclasses:

OutgoingAsync, ProxyFlushBatch, ProxyGetConnection

public abstract class ProxyOutgoingAsyncBase
extends OutgoingAsyncBase

Field Summary

Fields

Modifier and Type	Field and Description
protected RequestHandler	_handler
protected OperationMode	_mode
protected ObjectPrxHelperBase	_proxy

Fields inherited from class IceInternal.OutgoingAsyncBase

_childObserver, _os

Fields inherited from class IceInternal.AsyncResultI

_cachedConnection, _instance, _observer, _sentSynchronously, _state, StateCachedBuffers, StateDone, StateEndCalled, StateOK, StateSent

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ProxyOutgoingAsyncBase(ObjectPrxHelperBase prx, java.lang.String op, CallbackBase delegate)
protected	ProxyOutgoingAsyncBase(ObjectPrxHelperBase prx, java.lang.String op, CallbackBase delegate, BasicStream os)

Method Summary

Modifier and Type	Method and Description
void	abort(Exception ex)
void	cancelable(CancellationHandler handler)
static ProxyOutgoingAsyncBase	check(AsyncResult r, ObjectPrx prx, java.lang.String operation)
protected static AsyncResult	checkImpl(AsyncResult r, ObjectPrx p, java.lang.String operation)
boolean	completed(Exception exc)
protected boolean	finished(boolean ok)
protected boolean	finished(Exception ex)
ObjectPrx	getProxy() Returns the proxy that was used to call the begin_ method, or nil if this AsyncResult object was not obtained via an asynchronous proxy invocation.
protected int	handleException(Exception exc)
abstract int	invokeCollocated(CollocatedRequestHandler handler)
protected void	invokeImpl(boolean userThread)
abstract int	invokeRemote(ConnectionI con, boolean compress, boolean response)
void	retry()
void	retryException(Exception ex)
protected boolean	sent(boolean done)

Methods inherited from class IceInternal.OutgoingAsyncBase

attachCollocatedObserver, attachRemoteObserver, completed, getOs, sent

Methods inherited from class IceInternal.AsyncResultI

__wait, cacheMessageBuffers, cancel, cancel, check, getCommunicator, getConnection, getObserver, getOperation, invokeCompleted, invokeCompletedAsync, invokeSent, invokeSentAsync, isCompleted, isSent, sentSynchronously, throwLocalException, waitForCompleted, waitForSent

Methods inherited from class java.lang.Object

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

Field Detail

_proxy

protected final ObjectPrxHelperBase _proxy

_handler

protected RequestHandler _handler

_mode

protected OperationMode _mode

Constructor Detail

ProxyOutgoingAsyncBase

protected ProxyOutgoingAsyncBase(ObjectPrxHelperBase prx,
                                 java.lang.String op,
                                 CallbackBase delegate)

ProxyOutgoingAsyncBase

protected ProxyOutgoingAsyncBase(ObjectPrxHelperBase prx,
                                 java.lang.String op,
                                 CallbackBase delegate,
                                 BasicStream os)

Method Detail

check

public static ProxyOutgoingAsyncBase check(AsyncResult r,
                                           ObjectPrx prx,
                                           java.lang.String operation)

invokeRemote

public abstract int invokeRemote(ConnectionI con,
                                 boolean compress,
                                 boolean response)
                          throws RetryException

Throws:

RetryException

invokeCollocated

public abstract int invokeCollocated(CollocatedRequestHandler handler)

getProxy

public ObjectPrx getProxy()

Description copied from interface: AsyncResult

Returns the proxy that was used to call the begin_ method, or nil if this AsyncResult object was not obtained via an asynchronous proxy invocation.

Specified by:

getProxy in interface AsyncResult

Overrides:

getProxy in class AsyncResultI

Returns:

The proxy.

completed

public boolean completed(Exception exc)

Overrides:

completed in class OutgoingAsyncBase

retryException

public void retryException(Exception ex)

retry

public void retry()

cancelable

public void cancelable(CancellationHandler handler)

Overrides:

cancelable in class AsyncResultI

abort

public void abort(Exception ex)

checkImpl

protected static AsyncResult checkImpl(AsyncResult r,
                                       ObjectPrx p,
                                       java.lang.String operation)

invokeImpl

protected void invokeImpl(boolean userThread)

sent

protected boolean sent(boolean done)

Overrides:

sent in class OutgoingAsyncBase

finished

protected boolean finished(Exception ex)

Overrides:

finished in class OutgoingAsyncBase

finished

protected boolean finished(boolean ok)

Overrides:

finished in class AsyncResultI

handleException

protected int handleException(Exception exc)