Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\drivers\rv\RVLink.class
?? 1? ?? ? ?? ?? ?? ?? ??? ?? ??? ? ?? ?? 9? ?? 9? ?? 9? ?? 9? ?? ?? ?? ?? ?? ?? ?? ???? ?? ? 9?? ? ? ?? ??? ??? ??? ?? ^?? ?? ?????? ????? ??? ?? ?? ?? ?? ???? ?? ???? ??? ????? N????? R? R? R?? ?? ?? W?? ?? ??? ^??? b? ????? ??? ?????? ??? ?? ? v ~ ~ ?? ? ? ? !"#$% ?&'()* ?+,-. ?+/01234567 v8 ?9:; ?<=> ?? ?@A ?BCD ?EF ?GHIJKL ?MN ~O PQ ?RSTUV ?W ?X ?? vYZ[ v?\] v+^_` m_rvLPF ,Loracle/mgw/drivers/rv/RVLinkParamsNFactory; m_service Ljava/lang/String; m_network m_daemon m_version m_options Ljava/util/Hashtable; m_dests m_transport Lcom/tibco/tibrv/TibrvTransport; m_logger Loracle/mgw/common/MgwLog; m_consParams m_prodParams m_subscribers m_maxHandles I m_handleCount m_handleSync Ljava/lang/Object; m_syncObj m_tranAdvListeners Ljava/util/Vector; FACILITY ConstantValue COMPONENT c_syncObj c_rvlinkCount c_encodingSet Z c_advHandler "Lcom/tibco/tibrv/TibrvMsgCallback; c_intraAdvSet c_intraAdvListeners c_dispatcher !Lcom/tibco/tibrv/TibrvDispatcher; <init> 0(Loracle/mgw/drivers/rv/RVLinkParamsNFactory;I)V Code LineNumberTable LocalVariableTable ge $Loracle/mgw/common/GatewayException; this Loracle/mgw/drivers/rv/RVLink; params maxThreads close ()V Lcom/tibco/tibrv/TibrvException; getLinkParamsNFactory +()Loracle/mgw/common/MsgLinkParamsNFactory; alterLinkParams ,(Loracle/mgw/common/MsgLinkParamsNFactory;)V )Loracle/mgw/common/MsgLinkParamsNFactory; checkConnection ()Z makeConnection se &Ljava/io/UnsupportedEncodingException; obj className advl Lcom/tibco/tibrv/TibrvListener; ae advTopic st Ljava/util/StringTokenizer; code advStr lkadvl te Exceptions loggingSupport ()I registerLogSet C(ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/LogIdSet; whichLog subName subGuid unregisterLogSet (Loracle/mgw/common/LogIdSet;)V idSet Loracle/mgw/common/LogIdSet; startLogOperation ()Loracle/mgw/common/OPHandle; makeMessageID !([B)Loracle/mgw/common/MessageID; mid [B getMsgCount (Ljava/lang/String;)I consId sub $Loracle/mgw/drivers/rv/RVSubscriber; registerDestination <(Loracle/mgw/common/DestParams;)Loracle/mgw/common/DestData; rdata Loracle/mgw/common/DestData; dest Loracle/mgw/common/DestParams; unregisterDestination (Loracle/mgw/common/DestData;)V startOperation commit (Loracle/mgw/common/OPHandle;)V oph Loracle/mgw/common/OPHandle;a rollback registerConsumer }(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZLjava/util/Hashtable;)V subname filter transformation isBrowser options consInfo (Loracle/mgw/drivers/rv/RVConsumerParams; registerProducer X(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/util/Hashtable;)V prodId prodInfo (Loracle/mgw/drivers/rv/RVProducerParams; alterConsumer N(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)V alterProducer <(Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)V unregisterConsumer (Ljava/lang/String;)V unregisterProducer getConsumer O(Ljava/lang/String;Loracle/mgw/common/OPHandle;)Loracle/mgw/common/MsgConsumer; consID consumer %Loracle/mgw/drivers/rv/RVMsgConsumer; getProducer O(Ljava/lang/String;Loracle/mgw/common/OPHandle;)Loracle/mgw/common/MsgProducer; prodID producer %Loracle/mgw/drivers/rv/RVMsgProducer; send Y(Loracle/mgw/common/Message;Loracle/mgw/common/MsgProducer;)Loracle/mgw/common/MessageID; msg Loracle/mgw/common/Message; pr Loracle/mgw/common/MsgProducer;b receive <(Loracle/mgw/common/MsgConsumer;)Loracle/mgw/common/Message; cons Loracle/mgw/common/MsgConsumer; Y(Loracle/mgw/common/MsgConsumer;Loracle/mgw/common/MessageID;)Loracle/mgw/common/Message; Loracle/mgw/common/MessageID; removeMsg N(Loracle/mgw/common/OPHandle;Ljava/lang/String;Loracle/mgw/common/MessageID;)Z rvOph "Loracle/mgw/drivers/rv/RVOPHandle; moveToExceptionQueue ?(Loracle/mgw/common/OPHandle;Ljava/lang/String;Loracle/mgw/common/DestData;Loracle/mgw/common/MessageID;)Loracle/mgw/common/MessageID; subject sendToExceptionQueue r(Loracle/mgw/common/OPHandle;Loracle/mgw/common/DestData;Loracle/mgw/common/Message;)Loracle/mgw/common/MessageID; subscribe nativeName unsubscribe updateSub handleEvent (Loracle/mgw/common/Event;)V event Loracle/mgw/common/Event; destroy <clinit> SourceFile RVLink.java java/util/Hashtable ? ? ? ?c de ? ? ? ? java/lang/Object ? ? ? ? java/util/Vector ? ? ? ? fg ? ? hg ? ? ig ? ? jk ? ? ? ? ? ? ? ? ? ? ? ? ? ? lm RVD java/lang/StringBuilder created a new RVLink: no pg , total number of RVlinks: nq rg st "oracle/mgw/common/GatewayException uv entering close w ? closed RVLink: ? "destroyed the advisory dispatcher.x y closed tibrv machinery. com/tibco/tibrv/TibrvException leaving close entering alterLinkParams z *oracle/mgw/drivers/rv/RVLinkParamsNFactory MsgLinkParamsNFactory MQLinkParamsNFactory {| leaving alterLinkParams }~ ? ? ? ? ? ? start tibrv machinery. oracle.mgw.tibrv.encoding ??? ?^ set RV encoding to $java/io/UnsupportedEncodingException? ?? oracle.mgw.tibrv.advMsgCallback ?? com/tibco/tibrv/TibrvMsgCallback set advisory msg handler to 'oracle/mgw/drivers/rv/RVAdvisoryHandler 'set advisory msg handler to the default %oracle.mgw.tibrv.intraProcAdvSubjects java/util/StringTokenizer : ? ? ?g com/tibco/tibrv/TibrvListener ?? ?? ? $listening on system advisory topic: ? ? ?? com/tibco/tibrv/TibrvDispatcher MGW_Intraproc_Adv_Dispatcher ? started advisory dispachter. !com/tibco/tibrv/TibrvRvdTransport ? ? "creating tibrv transport: service: network: daemon: for link: ?^ RV_ADVSUBJECTS ?? java/lang/String 0listening on transport specific advisory topic: for link :TIBRV does not support logging.registerLogSet() is called. :TIBRV does not support logging.unregisterLogSet is called. {? ;TIBRV does not support logging.startLogOperation is called.? ?? ?m entering getMsgCount "oracle/mgw/drivers/rv/RVSubscriber *subscriber for get polling does not exist: leaving getMsgCount ?' entering registerDestination ? ?g ?? destination already registered: oracle/mgw/common/DestData ? ?? leaving registerDestination entering unregisterDestination ?? destination not registered: leaving unregisterDestination entering startOperation too many opHandles leaving startOperation oracle/mgw/drivers/rv/RVOPHandle entering commit E opHandle count error leaving commit entering rollback J leaving rollback entering registerConsumer &oracle/mgw/drivers/rv/RVConsumerParams L ?? consumer ID already registered: leaving registerConsumer entering registerProducer &oracle/mgw/drivers/rv/RVProducerParams U producer ID already registered: leaving registerProducer entering alterConsumer "consumer to alter does not exist: ?? leaving alterConsumer entering alterProducer "producer to alter does not exist: leaving alterProducer entering unregisterConsumer 'consumer to unregister does not exist: leaving unregisterConsumer entering unregisterProducer 'producer to unregister does not exist: leaving unregisterProducer entering getConsumer subscriber does not exist: ?? ?? leaving getConsumer entering getProducer producerId does not exist: #oracle/mgw/drivers/rv/RVMsgProducer ? ?? leaving getProducer j? MsgProducer RVMsgProducer ?? #oracle/mgw/drivers/rv/RVMsgConsumer q? MsgConsumer RVMsgConsumer (TIBRV does not support receive by msgid. entering removeMsg leaving removeMsg w? entering moveToExceptionQueue ?? ?g leaving moveToExceptionQueue ?? ,TIBRV does not support sendToExceptionQueue. entering subscribe consumer does not exist: subscriber already exists: ?g ?g ? leaving subscribe. entering unsubscribe leaving unsubscribe. entering updateSub. leaving updateSub. oracle/mgw/drivers/rv/RVLink oracle/mgw/common/MsgLink oracle/mgw/common/FatalException "oracle/mgw/common/MessageException oracle/mgw/common/MgwLog getMgwLogger ()Loracle/mgw/common/MgwLog; getService ()Ljava/lang/String; getNetwork getDaemon getOptions ()Ljava/util/Hashtable; isTRACE_LITE (I)Z append -(Ljava/lang/String;)Ljava/lang/StringBuilder; getName (I)Ljava/lang/StringBuilder; toString trace )(Ljava/lang/String;Ljava/lang/String;II)V logMsgEx =(Ljava/lang/String;ILjava/lang/String;Ljava/lang/Throwable;)V com/tibco/tibrv/TibrvTransport com/tibco/tibrv/Tibrv isValid 'oracle/mgw/common/MsgLinkParamsNFactory logMsg :(Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;)V open (I)V java/lang/System getProperty &(Ljava/lang/String;)Ljava/lang/String; com/tibco/tibrv/TibrvMsg setStringEncoding oracle/mgw/common/MgwUtil GatewayException N(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException; getObjInstance &(Ljava/lang/String;)Ljava/lang/Object; '(Ljava/lang/String;Ljava/lang/String;)V hasMoreTokens nextToken defaultQueue ()Lcom/tibco/tibrv/TibrvQueue; processTransport )()Lcom/tibco/tibrv/TibrvProcessTransport; ?(Lcom/tibco/tibrv/TibrvQueue;Lcom/tibco/tibrv/TibrvMsgCallback;Lcom/tibco/tibrv/TibrvTransport;Ljava/lang/String;Ljava/lang/Object;)V add (Ljava/lang/Object;)Z 8(Ljava/lang/String;Lcom/tibco/tibrv/TibrvDispatchable;)V 9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V clear setDescription get &(Ljava/lang/Object;)Ljava/lang/Object; ((Ljava/lang/String;ILjava/lang/String;)V !oracle/mgw/drivers/rv/RVMessageID makeRVMsgID '([B)Loracle/mgw/drivers/rv/RVMessageID; isTRACE_HIGH getCount oracle/mgw/common/DestParams getDestID containsKey >(Loracle/mgw/common/DestParams;Loracle/mgw/common/MsgLink;ZZ)V put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; remove contains setOptions (Ljava/util/Hashtable;)V createConsumer '()Loracle/mgw/drivers/rv/RVMsgConsumer; addConsumer ((Loracle/mgw/drivers/rv/RVMsgConsumer;)V K(Lcom/tibco/tibrv/TibrvTransport;Loracle/mgw/drivers/rv/RVProducerParams;)V addProducer ((Loracle/mgw/drivers/rv/RVMsgProducer;)V :(Loracle/mgw/common/Message;)Loracle/mgw/common/MessageID; `(Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/GatewayException; ()Loracle/mgw/common/Message; D(Loracle/mgw/common/MessageID;Loracle/mgw/drivers/rv/RVSubscriber;)Z getDestParams ()Loracle/mgw/common/DestParams; getNativeName moveMessage r(Ljava/lang/String;Loracle/mgw/common/MessageID;Loracle/mgw/drivers/rv/RVSubscriber;)Loracle/mgw/common/MessageID; getDestNativeName getSubName ](Ljava/lang/String;Ljava/lang/String;Lcom/tibco/tibrv/TibrvTransport;Ljava/util/Hashtable;I)V ! ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? % ? *? *? Y? ? *? *? ? *? *? Y? ? *? Y? ? *? Y? ? *+? *+? ? *+? ? *+? ? *+? ? * ? *? Y? ? *? Y? ? *? Y? ? ? YN? `? *? ? ? 4*? ? Y? !"? #*? ? $? #%? #? ? &? ' ? (-? :-??*? )? N*? ?*? ? $-? +? ? ? ? ? ? ? ? ? ? * n e I J K R S + U 6 V A f F g N h V i ^ j f l k m v n ? o ? q ? r ? t ? u ? z ? } ? ? ? ~ ? ? * ? ? ? G*? ? ? )*? ? Y? !,? #*? ? $? #? ' ? (*? YL?*? ? *? ? -+? M+?,? YL? d? *? ? ? 4*? ? Y? !.? #*? ? $? #%? #? ? &? ' ? (? ? h? /? %? /? 0*? ? ? *? 1 ? (? 2? :? 3*? ? ? *? 4 ? (? M*? ?*? ? $,? ++? N+?-?*? ? ? )*? ? Y? !6? #*? ? $? #? ' ? (? : J M M P M ? ? ? 5 X j ? ? 3 ? : ? A ? H ? R ? X ? ` ? m ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?F ? ? G / *? ? ? ?*? ? ? &*? ? Y? !7? #+? 8? #? ' ? (+? 9? *? ?:;? <?*? )? M*? ?*? ? $,? +*? ? ? &*? ? Y? !=? #+? 8? #? ' ? (? H L O * 2 ? ? 0 ? 7 ? G ? H ? L ? O ? P ? d ? q ? ? ? P ? ? g %*? YL?*? ? *? ? >? ? +?M+?,? # ? ? ? % ? b? YL? 2? ?? ?? @? A? B? /? ? /? 0? /*? ? ? *? C ? (D? EM,? K? @? E,? F? @*? ? ? #*? ? Y? !G? #,? #? ' ? (? N-?,? I? A? ?J? EN-? U-? K:? L? ? L? A? ?-? I?*? ? ? #*? ? Y? !M? #-? #? ' ? (? )? NY? O? A*? ? ? *? P ? (Q? EN-? ? B? ? RY-S? T:? U? n? V:? WY? X? A? Y? Z:*? ? ? $*? ? Y? ![? #? #? ' ? (? \? ]W? :*? ?? +??? B? /? .? ^Y_? X? `? /*? ? ? *? a ? (+? :+??*? YL?*? ? *? ? >?;*? ? *? ? -*? bY*? *? *? ? c? *? ? d*? ? ? M*? ? Y? !e? #*? ? #f? #*? ? #g? #*? ? #h? #*? ? $? #? ' ? (*? *? ? $? iM*? ? *? j? k? lM,? ? RY,S? TN-? U? ~-? V:? WY? X? A*? ? Z:*? ? ]W*? ? ? 3*? ? Y? !m? #? #n? #*? ? $? #? ' ? (? :*? ?? +??+? :+?? L+?*? ? $? I? X ? ? HM?? 5 ?? ??? ?*- 5?DG GKG NQ 5 F Q ? ? ? ? ? ? ? " ? ( ? , ? 9 ? H N X \ ` m ? ? ? ? ? ? ? ? ? ? ?$ ?% ?) ?+-."6(82;><F=M@bFoG?L?R?N?O?S?U?Y?Z?^?_?d?f?g hik/o6qCr?{??????????????????????*?-?/???B?N?Q?R?a? ? ? ? I ? ? | ? b 7 ? M a ? > w N?! ? ( ?" ? ? G# / ? r ? ? ? ? ?" ? R $ b % * &' , ? ? () R ?o? I? ? * * ? + ? , ? % * -. G *? ?p? q? ? ? /0 12 4 ?r? I? ? % * 34 9 +? s? ? 56 % * 78 ? h*? ? t? *? u ? (*? +? k? vM,? ? Y? !w? #+? #? '? I?*? ? t? *? x ? (,? y? " ? ? ? (? ,? G? T? c? h h9 ? ( @:; % * <= ?*? ? ? &*? ? Y? !z? #+? {? #? ' ? (*? YM?*? +? {? |? %*? ? Y? !}? #+? {? #? '? q? ~Y+*? N*? +? {-? ?W*? ? ? *? ? ? (-,?:,?? 7 ? ? ? ? ? . ? ? 0? 7? E? g? s? ?? ?? ?? ?? s ->? ? ?@A % * BC ? ?*? ? ? &*? ? Y? !? #+? ? #? ' ? (*? YM?*? +? ? ? %*? ? Y? !? #+? ? #? '? q,? N,?-?*? ? ? *? ? ? (? 7 i l l o l & 0 7 E g q ~ ? ? ?@? D2 ? p*? ? ? *? ? ? (*? YL?*? *? ? ?? I?*Y? `? +? M+?,?*? ? ? *? ? ? (? ?? ? # D G G J G * # . 8! B" L$ Y% h) p % * EF ? l*? ? ? *? ? ? (+? ? ?*? YM?*? ? ?? I?*Y? d? ,? N,?-?*? ? ? *? ? ? (? * G J J M J . . / 3 #5 *6 17 ;: E; O= \> kA l lGH % *I JF ? l*? ? ? *? ? ? (+? ? ?*? YM?*? ? ?? I?*Y? d? ,? N,?-?*? ? ? *? ? ? (? * G J J M J . E F J #L *M 1N ;Q ER OT \U kX l lGH % *I KL M ?*? ? ? *? ? ? (? ?+,-? ?:*? Y: ?*? +? ? %*? ? Y? !? #+? #? '? q? *? +? ?W ? : ? ?*? ? ? *? ? ? (? 8 s v v { v . ` a e 0l 8m Cn eq pr ~t ?u ?x \ ? ?9 ? ?@? ?M ? ?N ? ?O ? ?P ? ?Q ? 0 kRS TU ) ?*? ? ? *? ? ? (? ?+,-? ?:*? Y:?*? +? ? %*? ? Y? !? #+? #? '? q? *? +? ?W? :??*? ? ? *? ? ? (? 2 m p p u p . } ~ ? *? 2? =? _? j? x? ?? ?? > ? ?V ? ?@? ?O ? ?Q ? * kWX YZ ?*? ? ? *? ? ? (*? Y:?*? +? k? ?:? "*? ? Y? !? #+? #? '? q? ?? :??*? ? ? *? ? ? (? $ _ b b g b . ? ? ? $? 1? 6? U? \? j? w? ?? > 1 +RS ? ?9 ? ?N ? ?O ? ?Q ? [\ ?*? ? ? *? ? ? (*? Y:?*? +? k? ?:? "*? ? Y? !? #+? #? '? q-? ?? :??*? ? ? *? ? ? (? $ ^ a a f a . ? ? ? $? 1? 6? U? [? i? v? ?? 4 1 *WX ? ?V ? ?O ? ?Q ? ]^ ? c*? ? ? *? ? ? (*? +? ? "*? ? Y? !? #+? #? '? q*? ? ? *? ? ? (? ? ? ? '? F? S? b? c c9 ? _^ ? c*? ? ? *? ? ? (*? +? ? "*? ? Y? !? #+? #? '? q*? ? ? *? ? ? (? ? ? ? '? F? S? b? c cV ? `a ? u*? ? ? *? ? ? (*? +? k? vN-? ? Y? !? #+? #? '? I?-? ?:,? ?? ?*? ? ? *? ? ? (? * ? ? ? (? ,? G? M? V? c? r? 4 u ub ? uGH ( M:; M (cd % * ef ?*? ? ? *? ? ? (*? ? *? )*? +? k? ?-? "*? ? Y? !? #+? #? '? q? ?*? -? ?:,? ?? ?*? ? ? *? ? ? (? 2 # ' 3 7 V d m z ? 4 ? ?g ? ?GH 3 YWX d (hi % * jk b ,? ? ,? ?+? ? ??? ? lm no % p * qr W +? ? +? ? ? ??? ? ) * , st % p *I qu H ?? I? 4 st 5v % p *I wx ? t*? ? ? *? ? ? (*? ,? k? v:? ? Y? !? #,? #? '? I?+? ?:*? ? ? *? ? ? (-? ? & < = A )B .C IF OH \I kN > t tGH t9 ? t5v ) K:; O %yz % *I {| H ?*? ? ? *? ? ? (*? -? ? |? ! ? Y? !? #-? ? #? '? I?-? ? ?:*? ,? k? v:? ? Y? !? #,? #? '? I?+? ?:*? ? ? *? ? ? (? ? 2 W X \ *] H` Qb ^c cd ~g ?i ?j ?o R ? ?GH ?9 ? ?@? ?5v Q [} ? ^ N:; ? (yz % *I ~ R ?? I? v * GH @? lm % *I ?^ I ?*? ? ? *? ? ? (*? ? *? )*? +? k? ?,? ? Y? !? #+? #? '? I?*? +? ? ? Y? !? #+? #? '? I?,? ?? vY,? ?-*? ,? ?*? ? ?:*? +? ?W*? ? ? *? ? ? (? > | } ? #? '? 3? 7? R? ]? x? }? ?? ?? ?? ?? 4 ? ?9 ? 3 ?RS } B? ? ? (:; % * ?^ ? M*? ? ? *? ? ? (*? +? ? vM,? ,? ?*? ? ? *? ? ? (? " ? ? ? (? ,? 0? =? L? M M9 ? ( %:; % * ?^ ?*? ? ? *? ? ? (*? +? k? ?,? ? Y? !? #+? #? '? I?*? +? k? vN-? ? Y? !? #+? #? '? I?-,? ? ?*? ? ? *? ? ? (? 2 ? ? ? (? ,? G? S? W? r? z? ?? ?? * ? ?9 ? ( oRS S D:; % * ?? 5 ? ? ?? ? - ? /? ? /? 0? ? ? ? ? Y )? Y? ? ? ? @? A? B? Y? ? \? /? \ ] ^ _ ` a $ b ? ?
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de