IceInternal

Class OutgoingAsync

java.lang.Object

IceInternal.AsyncResultI

IceInternal.OutgoingAsyncBase

IceInternal.ProxyOutgoingAsyncBase

IceInternal.OutgoingAsync

All Implemented Interfaces:

AsyncResult

public class OutgoingAsync
extends ProxyOutgoingAsyncBase

Field Summary

Fields inherited from class IceInternal.ProxyOutgoingAsyncBase

_handler, _mode, _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

Constructor and Description
OutgoingAsync(ObjectPrx prx, java.lang.String operation, CallbackBase cb)
OutgoingAsync(ObjectPrx prx, java.lang.String operation, CallbackBase cb, BasicStream is, BasicStream os)

Method Summary

Modifier and Type	Method and Description
void	abort(Exception ex)
void	cacheMessageBuffers()
static OutgoingAsync	check(AsyncResult r, ObjectPrx prx, java.lang.String operation)
boolean	completed(BasicStream is)
void	endReadParams()
void	endWriteParams()
void	invoke()
int	invokeCollocated(CollocatedRequestHandler handler)
int	invokeRemote(ConnectionI connection, boolean compress, boolean response)
void	prepare(java.lang.String operation, OperationMode mode, java.util.Map<java.lang.String,java.lang.String> ctx, boolean explicitCtx, boolean synchronous)
void	readEmptyParams()
byte[]	readParamEncaps()
boolean	sent()
BasicStream	startReadParams()
BasicStream	startWriteParams(FormatType format)
void	throwUserException()
void	writeEmptyParams()
void	writeParamEncaps(byte[] encaps)

Methods inherited from class IceInternal.ProxyOutgoingAsyncBase

cancelable, checkImpl, completed, finished, finished, getProxy, handleException, invokeImpl, retry, retryException, sent

Methods inherited from class IceInternal.OutgoingAsyncBase

attachCollocatedObserver, attachRemoteObserver, getOs

Methods inherited from class IceInternal.AsyncResultI

__wait, 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

Constructor Detail

OutgoingAsync

public OutgoingAsync(ObjectPrx prx,
                     java.lang.String operation,
                     CallbackBase cb)

OutgoingAsync

public OutgoingAsync(ObjectPrx prx,
                     java.lang.String operation,
                     CallbackBase cb,
                     BasicStream is,
                     BasicStream os)

Method Detail

check

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

prepare

public void prepare(java.lang.String operation,
                    OperationMode mode,
                    java.util.Map<java.lang.String,java.lang.String> ctx,
                    boolean explicitCtx,
                    boolean synchronous)

sent

public boolean sent()

Overrides:

sent in class OutgoingAsyncBase

invokeRemote

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

Specified by:

invokeRemote in class ProxyOutgoingAsyncBase

Throws:

RetryException

invokeCollocated

public int invokeCollocated(CollocatedRequestHandler handler)

Specified by:

invokeCollocated in class ProxyOutgoingAsyncBase

abort

public void abort(Exception ex)

Overrides:

abort in class ProxyOutgoingAsyncBase

invoke

public void invoke()

completed

public final boolean completed(BasicStream is)

Overrides:

completed in class OutgoingAsyncBase

startWriteParams

public BasicStream startWriteParams(FormatType format)

endWriteParams

public void endWriteParams()

writeEmptyParams

public void writeEmptyParams()

writeParamEncaps

public void writeParamEncaps(byte[] encaps)

startReadParams

public BasicStream startReadParams()

endReadParams

public void endReadParams()

readEmptyParams

public void readEmptyParams()

readParamEncaps

public byte[] readParamEncaps()

throwUserException

public final void throwUserException()
                              throws UserException

Throws:

UserException

cacheMessageBuffers

public void cacheMessageBuffers()

Overrides:

cacheMessageBuffers in class AsyncResultI