Package com.sun.corba.ee.impl.transport
Class ResponseWaitingRoomImpl
- java.lang.Object
-
- com.sun.corba.ee.impl.transport.ResponseWaitingRoomImpl
-
- All Implemented Interfaces:
ResponseWaitingRoom
public class ResponseWaitingRoomImpl extends java.lang.Object implements ResponseWaitingRoom
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
ResponseWaitingRoomImpl.OutCallDesc
-
Field Summary
Fields Modifier and Type Field Description private Connection
connection
private ORB
orb
private java.util.Map<java.lang.Integer,ResponseWaitingRoomImpl.OutCallDesc>
out_calls
private static ORBUtilSystemException
wrapper
-
Constructor Summary
Constructors Constructor Description ResponseWaitingRoomImpl(ORB orb, Connection connection)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
display(java.lang.String msg)
private void
display(java.lang.String msg, int value)
private void
display(java.lang.String msg, java.lang.Object value)
MessageMediator
getMessageMediator(int requestId)
int
numberRegistered()
void
registerWaiter(MessageMediator messageMediator)
void
responseReceived(CDRInputObject is)
void
signalExceptionToAllWaiters(SystemException systemException)
void
unregisterWaiter(MessageMediator mediator)
CDRInputObject
waitForResponse(MessageMediator messageMediator)
-
-
-
Field Detail
-
wrapper
private static final ORBUtilSystemException wrapper
-
out_calls
private final java.util.Map<java.lang.Integer,ResponseWaitingRoomImpl.OutCallDesc> out_calls
-
orb
private final ORB orb
-
connection
private final Connection connection
-
-
Constructor Detail
-
ResponseWaitingRoomImpl
public ResponseWaitingRoomImpl(ORB orb, Connection connection)
-
-
Method Detail
-
registerWaiter
public void registerWaiter(MessageMediator messageMediator)
- Specified by:
registerWaiter
in interfaceResponseWaitingRoom
-
unregisterWaiter
public void unregisterWaiter(MessageMediator mediator)
- Specified by:
unregisterWaiter
in interfaceResponseWaitingRoom
-
waitForResponse
public CDRInputObject waitForResponse(MessageMediator messageMediator)
- Specified by:
waitForResponse
in interfaceResponseWaitingRoom
-
display
@InfoMethod private void display(java.lang.String msg)
-
display
@InfoMethod private void display(java.lang.String msg, int value)
-
display
@InfoMethod private void display(java.lang.String msg, java.lang.Object value)
-
responseReceived
public void responseReceived(CDRInputObject is)
- Specified by:
responseReceived
in interfaceResponseWaitingRoom
-
numberRegistered
public int numberRegistered()
- Specified by:
numberRegistered
in interfaceResponseWaitingRoom
-
signalExceptionToAllWaiters
public void signalExceptionToAllWaiters(SystemException systemException)
- Specified by:
signalExceptionToAllWaiters
in interfaceResponseWaitingRoom
-
getMessageMediator
public MessageMediator getMessageMediator(int requestId)
- Specified by:
getMessageMediator
in interfaceResponseWaitingRoom
-
-