| /* |
| * Copyright (c) 1998, 2021 Oracle and/or its affiliates. All rights reserved. |
| * |
| * This program and the accompanying materials are made available under the |
| * terms of the Eclipse Public License v. 2.0 which is available at |
| * http://www.eclipse.org/legal/epl-2.0, |
| * or the Eclipse Distribution License v. 1.0 which is available at |
| * http://www.eclipse.org/org/documents/edl-v10.php. |
| * |
| * SPDX-License-Identifier: EPL-2.0 OR BSD-3-Clause |
| */ |
| |
| // Contributors: |
| // Oracle - initial API and implementation from Oracle TopLink |
| package org.eclipse.persistence.sessions.remote.rmi.iiop; |
| |
| |
| // Tie class generated by rmic, do not edit. |
| // Contents subject to change without notice. |
| import java.rmi.Remote; |
| |
| import javax.rmi.CORBA.Tie; |
| |
| import org.eclipse.persistence.internal.sessions.remote.Transporter; |
| import org.omg.CORBA.BAD_OPERATION; |
| import org.omg.CORBA.ORB; |
| import org.omg.CORBA.SystemException; |
| import org.omg.CORBA.portable.InputStream; |
| import org.omg.CORBA.portable.OutputStream; |
| import org.omg.CORBA.portable.ResponseHandler; |
| import org.omg.CORBA.portable.UnknownException; |
| import org.omg.CORBA_2_3.portable.ObjectImpl; |
| |
| /** |
| * INTERNAL: |
| */ |
| public class _RMIRemoteSessionControllerDispatcher_Tie extends ObjectImpl implements Tie { |
| private RMIRemoteSessionControllerDispatcher target = null; |
| private static final String[] _type_ids = { "RMI:org.eclipse.persistence.sessions.remote.rmi.iiop.RMIRemoteSessionController:0000000000000000" }; |
| |
| /** |
| * Default constructor. |
| */ |
| public _RMIRemoteSessionControllerDispatcher_Tie() { |
| } |
| |
| @Override |
| public String[] _ids() { |
| return _type_ids; |
| } |
| |
| @Override |
| @SuppressWarnings({"fallthrough"}) |
| public OutputStream _invoke(String method, InputStream _in, ResponseHandler reply) throws SystemException { |
| try { |
| org.omg.CORBA_2_3.portable.InputStream in = (org.omg.CORBA_2_3.portable.InputStream)_in; |
| switch (method.length()) { |
| case 10: |
| if (method.equals("_get_login")) { |
| Transporter result = target.getLogin(); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 12: |
| if (method.equals("executeQuery")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.executeQuery(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 13: |
| if (method.equals("getDescriptor")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.getDescriptor(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 14: |
| if (method.equals("processCommand")) { |
| Transporter arg0 = (Transporter)in.read_value(Transporter.class); |
| Transporter result = target.processCommand(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| out.write_value(result, Transporter.class); |
| return out; |
| } |
| case 16: |
| if (method.equals("beginTransaction")) { |
| Transporter result = target.beginTransaction(); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 17: |
| if (method.equals("commitTransaction")) { |
| Transporter result = target.commitTransaction(); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } else if (method.equals("executeNamedQuery")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter arg1 = readTransporter(in); |
| Transporter arg2 = readTransporter(in); |
| Transporter result = target.executeNamedQuery(arg0, arg1, arg2); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 18: |
| if (method.equals("cursoredStreamSize")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.cursoredStreamSize(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 19: |
| if (method.equals("cursorSelectObjects")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.cursorSelectObjects(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } else if (method.equals("cursoredStreamClose")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.cursoredStreamClose(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } else if (method.equals("rollbackTransaction")) { |
| Transporter result = target.rollbackTransaction(); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 20: |
| if (method.equals("commitRootUnitOfWork")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.commitRootUnitOfWork(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } else if (method.equals("scrollableCursorLast")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.scrollableCursorLast(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } else if (method.equals("scrollableCursorSize")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.scrollableCursorSize(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 21: |
| if (method.equals("scrollableCursorClose")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.scrollableCursorClose(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } else if (method.equals("scrollableCursorFirst")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.scrollableCursorFirst(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } else if (method.equals("getDescriptorForAlias")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.getDescriptorForAlias(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } else if (method.equals("beginEarlyTransaction")) { |
| Transporter result = target.beginEarlyTransaction(); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 22: |
| if (method.equals("cursoredStreamNextPage")) { |
| Transporter arg0 = readTransporter(in); |
| int arg1 = in.read_long(); |
| Transporter result = target.cursoredStreamNextPage(arg0, arg1); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } else if (method.equals("getSequenceNumberNamed")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.getSequenceNumberNamed(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } else if (method.equals("scrollableCursorIsLast")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.scrollableCursorIsLast(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 23: |
| if (method.equals("scrollableCursorIsFirst")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.scrollableCursorIsFirst(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 24: |
| if (method.equals("scrollableCursorAbsolute")) { |
| Transporter arg0 = readTransporter(in); |
| int arg1 = in.read_long(); |
| Transporter result = target.scrollableCursorAbsolute(arg0, arg1); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } else if (method.equals("scrollableCursorRelative")) { |
| Transporter arg0 = readTransporter(in); |
| int arg1 = in.read_long(); |
| Transporter result = target.scrollableCursorRelative(arg0, arg1); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 25: |
| if (method.equals("scrollableCursorAfterLast")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.scrollableCursorAfterLast(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 26: |
| if (method.equals("scrollableCursorNextObject")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.scrollableCursorNextObject(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } else if (method.equals("getDefaultReadOnlyClasses")) { |
| Transporter result = target.getDefaultReadOnlyClasses(); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 27: |
| if (method.equals("scrollableCursorBeforeFirst")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.scrollableCursorBeforeFirst(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } else if (method.equals("scrollableCursorIsAfterLast")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.scrollableCursorIsAfterLast(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 28: |
| if (method.equals("scrollableCursorCurrentIndex")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.scrollableCursorCurrentIndex(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 29: |
| if (method.equals("scrollableCursorIsBeforeFirst")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.scrollableCursorIsBeforeFirst(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 30: |
| if (method.equals("scrollableCursorPreviousObject")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.scrollableCursorPreviousObject(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 36: |
| if (method.equals("instantiateRemoteValueHolderOnServer")) { |
| Transporter arg0 = readTransporter(in); |
| Transporter result = target.instantiateRemoteValueHolderOnServer(arg0); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| case 37: |
| if (method.equals("initializeIdentityMapsOnServerSession")) { |
| Transporter result = target.initializeIdentityMapsOnServerSession(); |
| org.omg.CORBA_2_3.portable.OutputStream out = (org.omg.CORBA_2_3.portable.OutputStream)reply.createReply(); |
| writeTransporter(result, out); |
| return out; |
| } |
| default: |
| throw new BAD_OPERATION(); |
| } |
| } catch (SystemException ex) { |
| throw ex; |
| } catch (Throwable ex) { |
| throw new UnknownException(ex); |
| } |
| } |
| |
| @Override |
| public void deactivate() { |
| _orb().disconnect(this); |
| _set_delegate(null); |
| target = null; |
| } |
| |
| @Override |
| public Remote getTarget() { |
| return target; |
| } |
| |
| @Override |
| public ORB orb() { |
| return _orb(); |
| } |
| |
| @Override |
| public void orb(ORB orb) { |
| orb.connect(this); |
| } |
| |
| /** |
| * Insert the method's description here. |
| * Creation date: (8/15/00 9:07:19 AM) |
| * @return org.eclipse.persistence.internal.sessions.remote.Transporter |
| * @param stream org.omg.CORBA_2_3.portable.InputStream |
| */ |
| public static org.eclipse.persistence.internal.sessions.remote.Transporter readTransporter(org.omg.CORBA.portable.InputStream stream) { |
| int length = stream.read_ulong(); |
| |
| byte[] bytes = new byte[length]; |
| stream.read_octet_array(bytes, 0, length); |
| |
| java.io.ByteArrayInputStream byteIn = new java.io.ByteArrayInputStream(bytes); |
| org.eclipse.persistence.internal.sessions.remote.Transporter transporter = null; |
| if (bytes.length == 0) { |
| return null; |
| } |
| try { |
| java.io.ObjectInputStream objectIn = new java.io.ObjectInputStream(byteIn); |
| transporter = (org.eclipse.persistence.internal.sessions.remote.Transporter)objectIn.readObject(); |
| } catch (Exception exception) { |
| exception.printStackTrace(); |
| return null; |
| } |
| |
| return transporter; |
| } |
| |
| @Override |
| public void setTarget(Remote target) { |
| this.target = (RMIRemoteSessionControllerDispatcher)target; |
| } |
| |
| @Override |
| public org.omg.CORBA.Object thisObject() { |
| return this; |
| } |
| |
| /** |
| * Insert the method's description here. |
| * Creation date: (8/15/00 9:05:39 AM) |
| * @param stream org.omg.CORBA_2_3.portable.OutputStream |
| * @param transporter org.eclipse.persistence.internal.sessions.remote.Transporter |
| */ |
| public static void writeTransporter(org.eclipse.persistence.internal.sessions.remote.Transporter transporter, org.omg.CORBA.portable.OutputStream stream) { |
| java.io.ByteArrayOutputStream byteOut = new java.io.ByteArrayOutputStream(); |
| try { |
| java.io.ObjectOutputStream objectOut = new java.io.ObjectOutputStream(byteOut); |
| objectOut.writeObject(transporter); |
| // objectOut.writeBoolean(wasOperationSuccessful); |
| // objectOut.writeObject(query); |
| // objectOut.writeObject(object); |
| // objectOut.writeObject(objectDescriptors); |
| objectOut.flush(); |
| stream.write_ulong(byteOut.size()); |
| stream.write_octet_array(byteOut.toByteArray(), 0, byteOut.size()); |
| } catch (java.io.IOException exception) { |
| } |
| } |
| } |
