/* */ package org.jboss.tm.iiop;
/* */
/* */ import org.omg.CORBA.UNKNOWN;
/* */ import org.omg.CORBA.portable.ApplicationException;
/* */ import org.omg.CORBA.portable.InputStream;
/* */ import org.omg.CORBA.portable.ObjectImpl;
/* */ import org.omg.CORBA.portable.OutputStream;
/* */ import org.omg.CORBA.portable.RemarshalException;
/* */ import org.omg.CORBA.portable.ServantObject;
/* */ import org.omg.CosTransactions.Control;
/* */ import org.omg.CosTransactions.ControlHelper;
/* */ import org.omg.CosTransactions.Coordinator;
/* */ import org.omg.CosTransactions.CoordinatorHelper;
/* */ import org.omg.CosTransactions.Inactive;
/* */ import org.omg.CosTransactions.InactiveHelper;
/* */ import org.omg.CosTransactions.NotSubtransaction;
/* */ import org.omg.CosTransactions.NotSubtransactionHelper;
/* */ import org.omg.CosTransactions.PropagationContext;
/* */ import org.omg.CosTransactions.PropagationContextHelper;
/* */ import org.omg.CosTransactions.RecoveryCoordinator;
/* */ import org.omg.CosTransactions.RecoveryCoordinatorHelper;
/* */ import org.omg.CosTransactions.Resource;
/* */ import org.omg.CosTransactions.ResourceHelper;
/* */ import org.omg.CosTransactions.Status;
/* */ import org.omg.CosTransactions.StatusHelper;
/* */ import org.omg.CosTransactions.SubtransactionAwareResource;
/* */ import org.omg.CosTransactions.SubtransactionAwareResourceHelper;
/* */ import org.omg.CosTransactions.SubtransactionsUnavailable;
/* */ import org.omg.CosTransactions.SubtransactionsUnavailableHelper;
/* */ import org.omg.CosTransactions.Synchronization;
/* */ import org.omg.CosTransactions.SynchronizationHelper;
/* */ import org.omg.CosTransactions.SynchronizationUnavailable;
/* */ import org.omg.CosTransactions.SynchronizationUnavailableHelper;
/* */ import org.omg.CosTransactions.Unavailable;
/* */ import org.omg.CosTransactions.UnavailableHelper;
/* */
/* */ public class _CoordinatorExtStub extends ObjectImpl
/* */ implements CoordinatorExt
/* */ {
/* 15 */ private String[] ids = { "IDL:org/jboss/tm/iiop/CoordinatorExt:1.0", "IDL:omg.org/CosTransactions/Coordinator:1.0" };
/* */
/* 21 */ public static final Class _opsClass = CoordinatorExtOperations.class;
/* */
/* */ public String[] _ids()
/* */ {
/* 18 */ return this.ids;
/* */ }
/* */
/* */ public Status get_top_level_status()
/* */ {
/* 26 */ while (!_is_local())
/* */ {
/* 28 */ InputStream _is = null;
/* */ try
/* */ {
/* 31 */ OutputStream _os = _request("get_top_level_status", true);
/* 32 */ _is = _invoke(_os);
/* 33 */ Status _result = StatusHelper.read(_is);
/* 34 */ Status localStatus1 = _result;
/* */ return localStatus1;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 39 */ String _id = _ax.getId();
/* 40 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 44 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 49 */ ServantObject _so = _servant_preinvoke("get_top_level_status", _opsClass);
/* 50 */ if (_so == null)
/* 51 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ Status _result;
/* */ try {
/* 56 */ _result = _localServant.get_top_level_status();
/* */ }
/* */ finally
/* */ {
/* 60 */ _servant_postinvoke(_so);
/* */ }
/* 62 */ return _result;
/* */ }
/* */
/* */ public RecoveryCoordinator register_resource(Resource r)
/* */ throws Inactive
/* */ {
/* 73 */ while (!_is_local())
/* */ {
/* 75 */ InputStream _is = null;
/* */ try
/* */ {
/* 78 */ OutputStream _os = _request("register_resource", true);
/* 79 */ ResourceHelper.write(_os, r);
/* 80 */ _is = _invoke(_os);
/* 81 */ RecoveryCoordinator _result = RecoveryCoordinatorHelper.read(_is);
/* 82 */ RecoveryCoordinator localRecoveryCoordinator1 = _result;
/* */ return localRecoveryCoordinator1;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 87 */ String _id = _ax.getId();
/* 88 */ if (_id.equals("IDL:omg.org/CosTransactions/Inactive:1.0"))
/* */ {
/* 90 */ throw InactiveHelper.read(_ax.getInputStream());
/* */ }
/* 92 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 96 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 101 */ ServantObject _so = _servant_preinvoke("register_resource", _opsClass);
/* 102 */ if (_so == null)
/* 103 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ RecoveryCoordinator _result;
/* */ try {
/* 108 */ _result = _localServant.register_resource(r);
/* */ }
/* */ finally
/* */ {
/* 112 */ _servant_postinvoke(_so);
/* */ }
/* 114 */ return _result;
/* */ }
/* */
/* */ public Control create_subtransaction()
/* */ throws SubtransactionsUnavailable, Inactive
/* */ {
/* 125 */ while (!_is_local())
/* */ {
/* 127 */ InputStream _is = null;
/* */ try
/* */ {
/* 130 */ OutputStream _os = _request("create_subtransaction", true);
/* 131 */ _is = _invoke(_os);
/* 132 */ Control _result = ControlHelper.read(_is);
/* 133 */ Control localControl1 = _result;
/* */ return localControl1;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 138 */ String _id = _ax.getId();
/* 139 */ if (_id.equals("IDL:omg.org/CosTransactions/SubtransactionsUnavailable:1.0"))
/* */ {
/* 141 */ throw SubtransactionsUnavailableHelper.read(_ax.getInputStream());
/* */ }
/* 143 */ if (_id.equals("IDL:omg.org/CosTransactions/Inactive:1.0"))
/* */ {
/* 145 */ throw InactiveHelper.read(_ax.getInputStream());
/* */ }
/* 147 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 151 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 156 */ ServantObject _so = _servant_preinvoke("create_subtransaction", _opsClass);
/* 157 */ if (_so == null)
/* 158 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ Control _result;
/* */ try {
/* 163 */ _result = _localServant.create_subtransaction();
/* */ }
/* */ finally
/* */ {
/* 167 */ _servant_postinvoke(_so);
/* */ }
/* 169 */ return _result;
/* */ }
/* */
/* */ public boolean is_related_transaction(Coordinator tc)
/* */ {
/* 180 */ while (!_is_local())
/* */ {
/* 182 */ InputStream _is = null;
/* */ try
/* */ {
/* 185 */ OutputStream _os = _request("is_related_transaction", true);
/* 186 */ CoordinatorHelper.write(_os, tc);
/* 187 */ _is = _invoke(_os);
/* 188 */ boolean _result = _is.read_boolean();
/* 189 */ boolean bool1 = _result;
/* */ return bool1;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 194 */ String _id = _ax.getId();
/* 195 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 199 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 204 */ ServantObject _so = _servant_preinvoke("is_related_transaction", _opsClass);
/* 205 */ if (_so == null)
/* 206 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ boolean _result;
/* */ try {
/* 211 */ _result = _localServant.is_related_transaction(tc);
/* */ }
/* */ finally
/* */ {
/* 215 */ _servant_postinvoke(_so);
/* */ }
/* 217 */ return _result;
/* */ }
/* */
/* */ public void rollback_only()
/* */ throws Inactive
/* */ {
/* 228 */ while (!_is_local())
/* */ {
/* 230 */ InputStream _is = null;
/* */ try {
/* 233 */ OutputStream _os = _request("rollback_only", true);
/* 234 */ _is = _invoke(_os);
/* */ return;
/* */ } catch (RemarshalException _rx) {
/* */ } catch (ApplicationException _ax) {
/* 240 */ String _id = _ax.getId();
/* 241 */ if (_id.equals("IDL:omg.org/CosTransactions/Inactive:1.0"))
/* */ {
/* 243 */ throw InactiveHelper.read(_ax.getInputStream());
/* */ }
/* 245 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 249 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 254 */ ServantObject _so = _servant_preinvoke("rollback_only", _opsClass);
/* 255 */ if (_so == null)
/* 256 */ throw new UNKNOWN("local invocations not supported!");
/* 257 */ CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ try
/* */ {
/* 260 */ _localServant.rollback_only();
/* */ }
/* */ finally
/* */ {
/* 264 */ _servant_postinvoke(_so);
/* */ }
/* */ }
/* */
/* */ public boolean is_ancestor_transaction(Coordinator tc)
/* */ {
/* 277 */ while (!_is_local())
/* */ {
/* 279 */ InputStream _is = null;
/* */ try
/* */ {
/* 282 */ OutputStream _os = _request("is_ancestor_transaction", true);
/* 283 */ CoordinatorHelper.write(_os, tc);
/* 284 */ _is = _invoke(_os);
/* 285 */ boolean _result = _is.read_boolean();
/* 286 */ boolean bool1 = _result;
/* */ return bool1;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 291 */ String _id = _ax.getId();
/* 292 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 296 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 301 */ ServantObject _so = _servant_preinvoke("is_ancestor_transaction", _opsClass);
/* 302 */ if (_so == null)
/* 303 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ boolean _result;
/* */ try {
/* 308 */ _result = _localServant.is_ancestor_transaction(tc);
/* */ }
/* */ finally
/* */ {
/* 312 */ _servant_postinvoke(_so);
/* */ }
/* 314 */ return _result;
/* */ }
/* */
/* */ public boolean is_same_transaction(Coordinator tc)
/* */ {
/* 325 */ while (!_is_local())
/* */ {
/* 327 */ InputStream _is = null;
/* */ try
/* */ {
/* 330 */ OutputStream _os = _request("is_same_transaction", true);
/* 331 */ CoordinatorHelper.write(_os, tc);
/* 332 */ _is = _invoke(_os);
/* 333 */ boolean _result = _is.read_boolean();
/* 334 */ boolean bool1 = _result;
/* */ return bool1;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 339 */ String _id = _ax.getId();
/* 340 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 344 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 349 */ ServantObject _so = _servant_preinvoke("is_same_transaction", _opsClass);
/* 350 */ if (_so == null)
/* 351 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ boolean _result;
/* */ try {
/* 356 */ _result = _localServant.is_same_transaction(tc);
/* */ }
/* */ finally
/* */ {
/* 360 */ _servant_postinvoke(_so);
/* */ }
/* 362 */ return _result;
/* */ }
/* */
/* */ public int hash_transaction()
/* */ {
/* 373 */ while (!_is_local())
/* */ {
/* 375 */ InputStream _is = null;
/* */ try
/* */ {
/* 378 */ OutputStream _os = _request("hash_transaction", true);
/* 379 */ _is = _invoke(_os);
/* 380 */ int _result = _is.read_ulong();
/* 381 */ int i = _result;
/* */ return i;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 386 */ String _id = _ax.getId();
/* 387 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 391 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 396 */ ServantObject _so = _servant_preinvoke("hash_transaction", _opsClass);
/* 397 */ if (_so == null)
/* 398 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ int _result;
/* */ try {
/* 403 */ _result = _localServant.hash_transaction();
/* */ }
/* */ finally
/* */ {
/* 407 */ _servant_postinvoke(_so);
/* */ }
/* 409 */ return _result;
/* */ }
/* */
/* */ public Status get_status()
/* */ {
/* 420 */ while (!_is_local())
/* */ {
/* 422 */ InputStream _is = null;
/* */ try
/* */ {
/* 425 */ OutputStream _os = _request("get_status", true);
/* 426 */ _is = _invoke(_os);
/* 427 */ Status _result = StatusHelper.read(_is);
/* 428 */ Status localStatus1 = _result;
/* */ return localStatus1;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 433 */ String _id = _ax.getId();
/* 434 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 438 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 443 */ ServantObject _so = _servant_preinvoke("get_status", _opsClass);
/* 444 */ if (_so == null)
/* 445 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ Status _result;
/* */ try {
/* 450 */ _result = _localServant.get_status();
/* */ }
/* */ finally
/* */ {
/* 454 */ _servant_postinvoke(_so);
/* */ }
/* 456 */ return _result;
/* */ }
/* */
/* */ public int hash_top_level_tran()
/* */ {
/* 467 */ while (!_is_local())
/* */ {
/* 469 */ InputStream _is = null;
/* */ try
/* */ {
/* 472 */ OutputStream _os = _request("hash_top_level_tran", true);
/* 473 */ _is = _invoke(_os);
/* 474 */ int _result = _is.read_ulong();
/* 475 */ int i = _result;
/* */ return i;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 480 */ String _id = _ax.getId();
/* 481 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 485 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 490 */ ServantObject _so = _servant_preinvoke("hash_top_level_tran", _opsClass);
/* 491 */ if (_so == null)
/* 492 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ int _result;
/* */ try {
/* 497 */ _result = _localServant.hash_top_level_tran();
/* */ }
/* */ finally
/* */ {
/* 501 */ _servant_postinvoke(_so);
/* */ }
/* 503 */ return _result;
/* */ }
/* */
/* */ public void register_synchronization(Synchronization sync)
/* */ throws SynchronizationUnavailable, Inactive
/* */ {
/* 514 */ while (!_is_local())
/* */ {
/* 516 */ InputStream _is = null;
/* */ try {
/* 519 */ OutputStream _os = _request("register_synchronization", true);
/* 520 */ SynchronizationHelper.write(_os, sync);
/* 521 */ _is = _invoke(_os);
/* */ return; } catch (RemarshalException _rx) {
/* */ } catch (ApplicationException _ax) {
/* 527 */ String _id = _ax.getId();
/* 528 */ if (_id.equals("IDL:omg.org/CosTransactions/SynchronizationUnavailable:1.0"))
/* */ {
/* 530 */ throw SynchronizationUnavailableHelper.read(_ax.getInputStream());
/* */ }
/* 532 */ if (_id.equals("IDL:omg.org/CosTransactions/Inactive:1.0"))
/* */ {
/* 534 */ throw InactiveHelper.read(_ax.getInputStream());
/* */ }
/* 536 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 540 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 545 */ ServantObject _so = _servant_preinvoke("register_synchronization", _opsClass);
/* 546 */ if (_so == null)
/* 547 */ throw new UNKNOWN("local invocations not supported!");
/* 548 */ CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ try
/* */ {
/* 551 */ _localServant.register_synchronization(sync);
/* */ }
/* */ finally
/* */ {
/* 555 */ _servant_postinvoke(_so);
/* */ }
/* */ }
/* */
/* */ public boolean is_top_level_transaction()
/* */ {
/* 568 */ while (!_is_local())
/* */ {
/* 570 */ InputStream _is = null;
/* */ try
/* */ {
/* 573 */ OutputStream _os = _request("is_top_level_transaction", true);
/* 574 */ _is = _invoke(_os);
/* 575 */ boolean _result = _is.read_boolean();
/* 576 */ boolean bool1 = _result;
/* */ return bool1;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 581 */ String _id = _ax.getId();
/* 582 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 586 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 591 */ ServantObject _so = _servant_preinvoke("is_top_level_transaction", _opsClass);
/* 592 */ if (_so == null)
/* 593 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ boolean _result;
/* */ try {
/* 598 */ _result = _localServant.is_top_level_transaction();
/* */ }
/* */ finally
/* */ {
/* 602 */ _servant_postinvoke(_so);
/* */ }
/* 604 */ return _result;
/* */ }
/* */
/* */ public Status get_parent_status()
/* */ {
/* 615 */ while (!_is_local())
/* */ {
/* 617 */ InputStream _is = null;
/* */ try
/* */ {
/* 620 */ OutputStream _os = _request("get_parent_status", true);
/* 621 */ _is = _invoke(_os);
/* 622 */ Status _result = StatusHelper.read(_is);
/* 623 */ Status localStatus1 = _result;
/* */ return localStatus1;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 628 */ String _id = _ax.getId();
/* 629 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 633 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 638 */ ServantObject _so = _servant_preinvoke("get_parent_status", _opsClass);
/* 639 */ if (_so == null)
/* 640 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ Status _result;
/* */ try {
/* 645 */ _result = _localServant.get_parent_status();
/* */ }
/* */ finally
/* */ {
/* 649 */ _servant_postinvoke(_so);
/* */ }
/* 651 */ return _result;
/* */ }
/* */
/* */ public PropagationContext get_txcontext()
/* */ throws Unavailable
/* */ {
/* 662 */ while (!_is_local())
/* */ {
/* 664 */ InputStream _is = null;
/* */ try
/* */ {
/* 667 */ OutputStream _os = _request("get_txcontext", true);
/* 668 */ _is = _invoke(_os);
/* 669 */ PropagationContext _result = PropagationContextHelper.read(_is);
/* 670 */ PropagationContext localPropagationContext1 = _result;
/* */ return localPropagationContext1;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 675 */ String _id = _ax.getId();
/* 676 */ if (_id.equals("IDL:omg.org/CosTransactions/Unavailable:1.0"))
/* */ {
/* 678 */ throw UnavailableHelper.read(_ax.getInputStream());
/* */ }
/* 680 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 684 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 689 */ ServantObject _so = _servant_preinvoke("get_txcontext", _opsClass);
/* 690 */ if (_so == null)
/* 691 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ PropagationContext _result;
/* */ try {
/* 696 */ _result = _localServant.get_txcontext();
/* */ }
/* */ finally
/* */ {
/* 700 */ _servant_postinvoke(_so);
/* */ }
/* 702 */ return _result;
/* */ }
/* */
/* */ public TransactionId get_transaction_id()
/* */ {
/* 713 */ while (!_is_local())
/* */ {
/* 715 */ InputStream _is = null;
/* */ try
/* */ {
/* 718 */ OutputStream _os = _request("get_transaction_id", true);
/* 719 */ _is = _invoke(_os);
/* 720 */ TransactionId _result = TransactionIdHelper.read(_is);
/* 721 */ TransactionId localTransactionId1 = _result;
/* */ return localTransactionId1;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 726 */ String _id = _ax.getId();
/* 727 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 731 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 736 */ ServantObject _so = _servant_preinvoke("get_transaction_id", _opsClass);
/* 737 */ if (_so == null)
/* 738 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ TransactionId _result;
/* */ try {
/* 743 */ _result = _localServant.get_transaction_id();
/* */ }
/* */ finally
/* */ {
/* 747 */ _servant_postinvoke(_so);
/* */ }
/* 749 */ return _result;
/* */ }
/* */
/* */ public String get_transaction_name()
/* */ {
/* 760 */ while (!_is_local())
/* */ {
/* 762 */ InputStream _is = null;
/* */ try
/* */ {
/* 765 */ OutputStream _os = _request("get_transaction_name", true);
/* 766 */ _is = _invoke(_os);
/* 767 */ String _result = _is.read_string();
/* 768 */ String str1 = _result;
/* */ return str1;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 773 */ String _id = _ax.getId();
/* 774 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 778 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 783 */ ServantObject _so = _servant_preinvoke("get_transaction_name", _opsClass);
/* 784 */ if (_so == null)
/* 785 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ String _result;
/* */ try {
/* 790 */ _result = _localServant.get_transaction_name();
/* */ }
/* */ finally
/* */ {
/* 794 */ _servant_postinvoke(_so);
/* */ }
/* 796 */ return _result;
/* */ }
/* */
/* */ public void register_subtran_aware(SubtransactionAwareResource r)
/* */ throws NotSubtransaction, Inactive
/* */ {
/* 807 */ while (!_is_local())
/* */ {
/* 809 */ InputStream _is = null;
/* */ try {
/* 812 */ OutputStream _os = _request("register_subtran_aware", true);
/* 813 */ SubtransactionAwareResourceHelper.write(_os, r);
/* 814 */ _is = _invoke(_os);
/* */ return; } catch (RemarshalException _rx) {
/* */ } catch (ApplicationException _ax) {
/* 820 */ String _id = _ax.getId();
/* 821 */ if (_id.equals("IDL:omg.org/CosTransactions/NotSubtransaction:1.0"))
/* */ {
/* 823 */ throw NotSubtransactionHelper.read(_ax.getInputStream());
/* */ }
/* 825 */ if (_id.equals("IDL:omg.org/CosTransactions/Inactive:1.0"))
/* */ {
/* 827 */ throw InactiveHelper.read(_ax.getInputStream());
/* */ }
/* 829 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 833 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 838 */ ServantObject _so = _servant_preinvoke("register_subtran_aware", _opsClass);
/* 839 */ if (_so == null)
/* 840 */ throw new UNKNOWN("local invocations not supported!");
/* 841 */ CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ try
/* */ {
/* 844 */ _localServant.register_subtran_aware(r);
/* */ }
/* */ finally
/* */ {
/* 848 */ _servant_postinvoke(_so);
/* */ }
/* */ }
/* */
/* */ public boolean is_descendant_transaction(Coordinator tc)
/* */ {
/* 861 */ while (!_is_local())
/* */ {
/* 863 */ InputStream _is = null;
/* */ try
/* */ {
/* 866 */ OutputStream _os = _request("is_descendant_transaction", true);
/* 867 */ CoordinatorHelper.write(_os, tc);
/* 868 */ _is = _invoke(_os);
/* 869 */ boolean _result = _is.read_boolean();
/* 870 */ boolean bool1 = _result;
/* */ return bool1;
/* */ }
/* */ catch (RemarshalException _rx)
/* */ {
/* */ }
/* */ catch (ApplicationException _ax)
/* */ {
/* 875 */ String _id = _ax.getId();
/* 876 */ throw new RuntimeException("Unexpected exception " + _id);
/* */ }
/* */ finally
/* */ {
/* 880 */ _releaseReply(_is);
/* */ }
/* */
/* */ }
/* */
/* 885 */ ServantObject _so = _servant_preinvoke("is_descendant_transaction", _opsClass);
/* 886 */ if (_so == null)
/* 887 */ throw new UNKNOWN("local invocations not supported!"); CoordinatorExtOperations _localServant = (CoordinatorExtOperations)_so.servant;
/* */ boolean _result;
/* */ try {
/* 892 */ _result = _localServant.is_descendant_transaction(tc);
/* */ }
/* */ finally
/* */ {
/* 896 */ _servant_postinvoke(_so);
/* */ }
/* 898 */ return _result;
/* */ }
/* */ }
/* Location: /home/mnovotny/projects/EMBEDDED_JBOSS_BETA3_COMMUNITY/embedded/output/lib/embedded-jboss/lib/jboss-embedded-all.jar
* Qualified Name: org.jboss.tm.iiop._CoordinatorExtStub
* JD-Core Version: 0.6.0
*/