gnu.CORBA

Class Asynchron


public class Asynchron
extends Object

Handles the asynchronous dynamic invocations.

Method Summary

Request
get_next_response()
Get the next instance with a response being received.
boolean
poll_next_response()
Find if any of the requests that have been previously sent with send_multiple_requests_deferred(Request[]), have a response yet.
void
send_multiple_requests_deferred(Request[] requests)
Send multiple prepared requests expecting to get a reply.
void
send_multiple_requests_oneway(Request[] requests)
Send multiple prepared requests one way, do not caring about the answer.

Methods inherited from class java.lang.Object

clone, equals, extends Object> getClass, finalize, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

get_next_response

public Request get_next_response()
            throws WrongTransaction
Get the next instance with a response being received. If all currently sent responses not yet processed, this method pauses till at least one of them is complete. If there are no requests currently sent, the method pauses till some request is submitted and the response is received. This strategy is identical to the one accepted by Suns 1.4 ORB implementation. The returned response is removed from the list of the currently submitted responses and is never returned again.
Returns:
the previously sent request that now contains the received response.
Throws:
WrongTransaction - If the method was called from the transaction scope different than the one, used to send the request. The exception can be raised only if the request is implicitly associated with some particular transaction.

poll_next_response

public boolean poll_next_response()
Find if any of the requests that have been previously sent with send_multiple_requests_deferred(Request[]), have a response yet.
Returns:
true if there is at least one response to the previously sent request, false otherwise.

send_multiple_requests_deferred

public void send_multiple_requests_deferred(Request[] requests)
Send multiple prepared requests expecting to get a reply. All requests are send in parallel, each in its own separate thread. When the reply arrives, it is stored in the agreed fields of the corresponing request data structure. If this method is called repeatedly, the new requests are added to the set of the currently sent requests, but the old set is not discarded.
Parameters:
requests - the prepared array of requests.

send_multiple_requests_oneway

public void send_multiple_requests_oneway(Request[] requests)
Send multiple prepared requests one way, do not caring about the answer. The messages, containing requests, will be marked, indicating that the sender is not expecting to get a reply.
Parameters:
requests - the prepared array of requests.

Asynchron.java -- Copyright (C) 2005 Free Software Foundation, Inc. This file is part of GNU Classpath. GNU Classpath is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2, or (at your option) any later version. GNU Classpath is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with GNU Classpath; see the file COPYING. If not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. Linking this library statically or dynamically with other modules is making a combined work based on this library. Thus, the terms and conditions of the GNU General Public License cover the whole combination. As a special exception, the copyright holders of this library give you permission to link this library with independent modules to produce an executable, regardless of the license terms of these independent modules, and to copy and distribute the resulting executable under terms of your choice, provided that you also meet, for each linked independent module, the terms and conditions of the license of that module. An independent module is a module which is not derived from or based on this library. If you modify this library, you may extend this exception to your version of the library, but you are not obligated to do so. If you do not wish to do so, delete this exception statement from your version.