Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\drivers\aq\AQBaseLink.class
?? 1( ? > ? = ? = ? = ? = ? ? ? = ? ? ? > ? ? ? ? ? ? ? = ? ? ? ? ? ? ? = ? ? ? ? = ? = ? = ? ? = ? ? ? ? ? > ? ? ? ? ? ? = ? ? ? = ? ? = ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? CLASS_PREFIX Ljava/lang/String; ConstantValue ? ALTER_DATABASE I ALTER_OCI_POOL m_linkMgr !Loracle/mgw/drivers/aq/AQLinkMgr; m_ociPoolHolder %Loracle/mgw/drivers/aq/OCIPoolHolder; m_ociPool *Loracle/jdbc/pool/OracleOCIConnectionPool; <init> d(Loracle/mgw/drivers/aq/AQLinkMgr;Loracle/mgw/drivers/aq/AQLinkParamsNFactory;IILjava/lang/String;)V Code LineNumberTable LocalVariableTable this "Loracle/mgw/drivers/aq/AQBaseLink; linkMgr params ,Loracle/mgw/drivers/aq/AQLinkParamsNFactory; maxThreads component facility aqLinkParams .()Loracle/mgw/drivers/aq/AQLinkParamsNFactory; closeLink ()V method getLogQDest 0(Ljava/lang/String;)Loracle/mgw/common/DestData; qname dp Loracle/mgw/common/DestParams; dest Loracle/mgw/common/DestData; Exceptions getAQDest <(Loracle/mgw/common/DestParams;)Loracle/mgw/common/DestData; alterLinkParams -(Loracle/mgw/common/MsgLinkParamsNFactory;I)V oldParams )Loracle/mgw/common/MsgLinkParamsNFactory; gwE $Loracle/mgw/common/GatewayException; newParams alter alterLinkCompare U(Loracle/mgw/common/MsgLinkParamsNFactory;Loracle/mgw/common/MsgLinkParamsNFactory;)I newAQParams oldAQParams isAlter_resetHandles (I)Z setMsgPoolSize maxHandles requestOCIPool ,()Loracle/jdbc/pool/OracleOCIConnectionPool; releaseOCIPool e Ljava/lang/Exception; retrieveQueueNTableData <(Ljava/sql/Connection;Ljava/lang/String;)[Ljava/lang/Object; array [Ljava/lang/String; sqlE Ljava/sql/SQLException; qtbl connection Ljava/sql/Connection; queue qData !Loracle/mgw/drivers/aq/QueueData; qtData "Loracle/mgw/drivers/aq/QTableData; retrieveTransformData N(Ljava/sql/Connection;Ljava/lang/String;)Loracle/mgw/drivers/aq/TransformData; transformation tdata %Loracle/mgw/drivers/aq/TransformData; SourceFile AQBaseLink.java ? ? N ? H I J K L M ? m *oracle/mgw/drivers/aq/AQLinkParamsNFactory AQBaseLink.closeLink ? ? ? ? ? ] ^ ? ? ? ? ? oracle/mgw/common/DestParams N ? h i AQ ? ? ? AQBaseLink.alterLinkParams ? ? ? ^ MsgLinkParamsNFactory ? ? ? ? ? ? ? ? "oracle/mgw/common/GatewayException ? ? ? ? ? ? ? r s ? ? ? [ \ D { 2requestOCIPool: pool reference is already non-NULL ^ java/lang/Exception w ? java/sql/SQLException ? ? ? !"# $% java/lang/Object & ?' oracle/mgw/drivers/aq/AQBaseLink oracle/mgw/drivers/BaseLink AQBaseLink. isForeignLink ()Z A(Loracle/mgw/common/MsgLinkParamsNFactory;IZILjava/lang/String;)V m_linkParams m_apiTracer Loracle/mgw/common/ApiTrace; oracle/mgw/common/ApiTrace methodEntry ((Ljava/lang/String;Ljava/lang/String;I)V oracle/mgw/drivers/aq/AQLinkMgr linkClose (Loracle/mgw/common/MsgLink;)V methodExit s(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Boolean;Ljava/util/Hashtable;)V oracle/mgw/common/MgwUtil GatewayException `(Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/GatewayException; (Ljava/lang/String;)V checkValidLink N(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException; m_syncLogQ Ljava/lang/Object; m_msgOphPool !Loracle/mgw/drivers/OPHandlePool; alterLink V(Loracle/mgw/common/MsgLinkParamsNFactory;Loracle/mgw/common/MsgLinkParamsNFactory;I)V m_tracer Loracle/mgw/common/Trace; oracle/mgw/common/Trace exception (Ljava/lang/Throwable;)V getDatabase ()Ljava/lang/String; isEqual ((Ljava/lang/String;Ljava/lang/String;Z)Z isBitSet (II)Z 'oracle/mgw/common/MsgLinkParamsNFactory getConns ()I getOCIPoolHolder '()Loracle/mgw/drivers/aq/OCIPoolHolder; m_maxThreads java/lang/Math min (II)I oracle/mgw/drivers/OPHandlePool setMaxPoolSize (I)V #oracle/mgw/drivers/aq/OCIPoolHolder requestPool trace (Ljava/lang/String;I)V releasePool oracle/mgw/drivers/aq/AQUtil parseFullName '(Ljava/lang/String;)[Ljava/lang/String; oracle/mgw/drivers/aq/AQAdminMgr describeQueue \(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/drivers/aq/QueueData; isLevel oracle/mgw/drivers/aq/QueueData toTraceString java/lang/String toUpperCase getOwner getQueueTable describeQueueTable ](Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/drivers/aq/QTableData; oracle/mgw/drivers/aq/QTableData fullName 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; describeTransformation #oracle/mgw/drivers/aq/TransformData! = > ? @ A B C D A E F D A G H I J K L M N O P ? *, ,? ? *+? *? *? ? Q ? R > S T U I V W X D Y D Z @ [ \ P 2 *? ? ? Q R S T ] ^ P z .L*? ? *? *? ? *? *? *? ? ? Q & ' * . / "1 -2 R . S T + _ @ ` a P ~ &? Y+? M*,? N-? ?+? ?-? Q N O P Q $S R * & S T & b @ c d e f g h i g j k P 1 qN*? ? *? +? ?? ?*? Y:?*? Y:?*? :*+ ? ? :??? :?? :*? ? *? ? ? / @ C C H C ' N Q Q V Q Y \ Q B ? ? ? ? ? ? '? /? 5? =? K? Y? \? ^? g? p? R > 5 l m ^ n o q S T q p m q q D n _ @ r s P ? ,*+,? >+? :,? :? ? ? !? ?> ? Q ? ? ? ? $? *? R > , S T , p m , l m % q D t W u W v w P < ? "? Q ? R S T q D x ^ P ? =*? #? *? ? $<? %*? %? &? *? '<? *? '*? ? $? (<*? ? )? Q ? ? ? ? %? 4 < R * y D " y D = S T 4 y D z { P v 8*? ? $**? %? &? *? ? **? ? *? ? *? +? ,*? ? Q 9 ; < = )@ 3C R 8 S T g | ^ P ~ &*? ? *? ? -? L*? +? *? *? ? . Q " V Z _ \ ^ a b %d R } ~ & S T ? P ? ?,? ?,? /:+22? 0N-? *? ? 1? *? -? 2? ,? :?,? 4? ?-? ?+-? 5-? 6? 7:? *? ? 1? *? ? 8? ,? :-? 5-? 6? 9:?? ?? -? 5-? 6? 9:?? ?? :Y-SYS? 6 9 3 O { ~ 3 Q Z ? ? ? ? ? *? 6? 9? ;? H? M? O? ]? n? {? ~? ?? ?? ?? ?? ?? ?? R f ) ? ? ; ? ? ? ? @ ? ? ? ? ? @ ? S T ? ? ? ? ? @ ? ? ? ] f ? ? g ? ? P ? <N,? ?+,? ;N-? *? ? 1? *? -? <? ,? :?,? ?-? + . 3 Q * ? ? ? ? ? ? +? .? 0? :? R 4 0 ? ? < S T < ? ? < ? @ : ? ? g ? ?
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de