Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\engine\JobData.class
?? 1? ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ??? ? ?? ??? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ??? #? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?????????? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ??? Y? ?? Y?? ?? Y? s? ?? ??? ? ? ? ? ? ? ? ? # ? Y ?! " ?# ?$ %& ' ?( ?) * + , ?- ./0 ?12 ?345 ?6 ?7 s8 9 ?: ; ?< = ?> ?? .@ ?A .BCD E F G HI JK JL JM ?NO YPQR ?S ?TU pid Ljava/lang/String; guid srcName destName exName srcQ Loracle/mgw/common/DestData; targetQ exQ isInbound Z isJmsJob selector tranFunc subOptions Ljava/util/Hashtable; latency J lastPollingTime srcLink Loracle/mgw/common/MsgLink; destLink agent Loracle/mgw/engine/Agent; destMgr Loracle/mgw/engine/DestMgr; jobMutex Ljava/lang/Object; jobState I jobStatus numWorkers batchSize lastDeqTxSeqNo lastEnqTxSeqNo lastComTxSeqNo deqLogRecs enqLogRec Loracle/mgw/engine/EnqLogRec; totalNumberMsgs totalNumberExMsgs lastWriteTime lastRetryTime retryCount lastErrorTime lastErrorCode missingMsgReq ignoreMissingMsgs missingLogs dumpLogRecs cleanLogRecs syncCount msgCount logger Loracle/mgw/common/MgwLog; subCreated subAltered consRegistered consAltered prodRegistered prodAltered srcLogIds Loracle/mgw/common/LogIdSet; destLogIds srcLogCons srcLogBrow srcLogProd destLogCons destLogBrow destLogProd srcLogSubCreated destLogSubCreated dupData Loracle/mgw/engine/DupData; srcTopicLogCount destTopicLogCount STATISTIC_INTERVAL ConstantValue ? JOB_DEACTIVATED JOB_ACTIVATED JOB_DELETED JOB_IDLE JOB_DEQUEUEING JOB_ENQUEUEING JOB_COMMITTING JOB_RECOVERING JOB_QUIESCENT JOB_TO_FAIL JOB_FAILED @ JOB_TO_CLEAN ? JOB_CLEANED JOB_POLLING MAX_LOG_CLEANING_TIME ' FACILITY <init> U(Loracle/mgw/common/SubParams;Loracle/mgw/engine/DestMgr;Loracle/mgw/engine/Agent;Z)V Code LineNumberTable LocalVariableTable this Loracle/mgw/engine/JobData; subp Loracle/mgw/common/SubParams; dm isDel ExceptionsV init ()Z dp Loracle/mgw/common/DestParams; tempname ge $Loracle/mgw/common/GatewayException; ne !Ljava/lang/NumberFormatException; batchStr ret activate ()V e Ljava/lang/InterruptedException; deactivate waitTime startTime setFailed (ILjava/lang/String;)V errCode info close (Z)Z $Loracle/mgw/admin/MgwAdminException; forced succeed update (Loracle/mgw/common/SubParams;)V getMsgCount ()I setMsgCount (I)V count sendNotif getSrcLink ()Loracle/mgw/common/MsgLink; getTargetLink setEnqLogRec (Loracle/mgw/engine/EnqLogRec;)V log getDeqLogRec (J)Loracle/mgw/engine/DeqLogRec; seqno recid Ljava/lang/Long; rec Loracle/mgw/engine/DeqLogRec; addDeqLogRec (Loracle/mgw/engine/DeqLogRec;)V delDeqLogRec (J)V no cleanDeqLogRecs getDeqSeqNo ()J setDeqSeqNo getEnqSeqNo setEnqSeqNo setComSeqNo getComSeqNo getNumLogs writeStatistics ex writeFailureInfo (Ljava/lang/String;)V errinfo setTotalNumMsgs num incTotalNumMsgs inc getTotalNumMsgs setTotalNumExMsgs incTotalNumExMsgs getTotalNumExMsgs initLoggingIds loggingRet loggingDesc isNotPipelinable srcNotAllowDeqByMsgId hasTopicAsSrcLog hasTopicAsDestLog setLatency lan getLatency setLastPollingTime lastPoll getLastPollingTime unsetToIgnoreMissingMsgs setToIgnoreMissingMsgs toIgnoreMissingMsgs (J)Z unsetMissingMsgReq setMissingMsgReq getDumpLogRecs setDumpLogRecs (Z)V val getCleanLogRecs setCleanLogRecs setMissingLogs unsubDestLog unsubSrcLog resetLoggingInfo needCreateAlterSub createAlterNativeSub SourceFile JobData.java !: ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? java/util/Hashtable ? ? ? ? java/lang/Object ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? oracle/mgw/engine/DupData ? ? ? ? ?W XY ? ? ZY ? ? [Y ? ? \Y ? ? ]Y ? ? ?/ ? ? ^Y _Y `a b/ ? ?c ?L ? ? ? ?d ef gR hR ? ? ? ?i jk ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?l me ? ? ? ? l:n opq r: s: t: uv wxy z{ java/lang/StringBuilder| }Y ~ @ ?Y ?Y ?? ?? Engine ?? y/? ?? ?? ?? ?? ?/ ?o "oracle/mgw/common/GatewayException ?? ?o ~/ / MSGBATCHSIZE ?? java/lang/String? ?? ? ? ? ? java/lang/NumberFormatException ?:? ?? ? ? ?a java/lang/InterruptedException unknown subscriber state ~? ?? ?: ?? ?/ ? ? ? ?? ?: ?o ?/ ?/ ?o ?o ?? ??? ?o "oracle/mgw/admin/MgwAdminException no java/lang/Long !a oracle/mgw/engine/DeqLogRec missing log record in memory ? ? ? ? ?? ?? ? ? ?? ? ? ?L uL xL ?? ?L ?? ( ) ?L ?? ??? ?Y? ?Y ?Y ?Y ? ? multiple requests( ~? , ) with missing messages. ?? ?? oracle/mgw/engine/JobData oracle/mgw/common/FatalException oracle/mgw/common/SubParams getSubscriberID ()Ljava/lang/String; getGuid getSrcQueueName getDestQueueName getExQueueName getSelector getTransformation getOptions ()Ljava/util/Hashtable; jmsSubscriber oracle/mgw/common/MgwConstants oracle/mgw/engine/DestMgr getForeignDestLink /(Ljava/lang/String;)Loracle/mgw/common/MsgLink; getAqJmsLink getAqLink oracle/mgw/common/MgwLog getMgwLogger ()Loracle/mgw/common/MgwLog; java/lang/System currentTimeMillis oracle/mgw/engine/Agent getScheduler ()Loracle/mgw/engine/Scheduler; oracle/mgw/engine/Scheduler notifyDeqWaiting notifyEnqWaiting notifyComWaiting getForeignDest 0(Ljava/lang/String;)Loracle/mgw/common/DestData; getAQDest 1(Ljava/lang/String;Z)Loracle/mgw/common/DestData; oracle/mgw/common/DestData getDestParams ()Loracle/mgw/common/DestParams; oracle/mgw/common/DestParams getDestID append -(Ljava/lang/String;)Ljava/lang/StringBuilder; getLinkName toString equals (Ljava/lang/Object;)Z ungetAQDest (Ljava/lang/String;Z)V logMsg :(Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;)V oracle/mgw/common/MsgLink registerConsumer }(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZLjava/util/Hashtable;)V alterConsumer N(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)V registerProducer X(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/util/Hashtable;)V alterProducer <(Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)V isTopic subscribe logMsgEx =(Ljava/lang/String;ILjava/lang/String;Ljava/lang/Throwable;)V updateSub get &(Ljava/lang/Object;)Ljava/lang/Object; java/lang/Integer parseInt (Ljava/lang/String;)I MIN_BATCH_SIZE MAX_BATCH_SIZE clear oracle/mgw/common/MgwUtil GatewayException N(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException; wait (I)Ljava/lang/StringBuilder; FatalException L(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/FatalException; notifyAll ((Ljava/lang/String;ILjava/lang/String;)V isEmpty java/lang/Thread yield unsubscribe unregisterConsumer unregisterProducer unregisterLogSet (Loracle/mgw/common/LogIdSet;)V getAdminMgr ()Loracle/mgw/admin/AdminMgr; oracle/mgw/admin/AdminMgr removeSubscriber logseqNo valueOf (J)Ljava/lang/String; put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; remove size setSubStatistic (Ljava/lang/String;II)V getCode setSubInfo loggingSupport registerLogSet C(ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/LogIdSet; getLinkParamsNFactory +()Loracle/mgw/common/MsgLinkParamsNFactory; 'oracle/mgw/common/MsgLinkParamsNFactory getName oracle/mgw/common/LogIdSet getConsumerId getBrowserId getProducerId (J)Ljava/lang/StringBuilder; getMsg 9(ILjava/lang/String;Ljava/lang/String;)Ljava/lang/String; '(ILjava/lang/String;)Ljava/lang/String; ! ? P ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? c 7 !" # j ?*? *? *? *? *? *? *? * ? *? *? *? *? Y? ? *? *? Y? ? *? *? *? *? *? *? *? *? *? *? *? *? *? *? *? *? !*? "*? #Y? $? %*? &*? '*+? (? )*+? *? +*+? ,? -*+? .? /*+? 0? 1*+? 2? 3*+? 4? *+? 5? *+? 6? *+? 7? 8*? 9? :*,? ;*? 3? 5**? ;*? -? <? *? 8? **? ;? =? ? @**? ;? >? ? 2*? 8? **? ;? =? ? **? ;? >? **? ;*? /? <? *? Y? ? ?*? ? ? @*? A? B*? C* ? D* E? G*? H*? I*? J*? K*? L*? M*? N? O*-? P*? Q-? R? S-? R? T-? R? U? $ * J ? " ' , 1 $ 6 / A 0 F D Q E V H [ I ` J e K j L o M t O y P ~ R ? S ? T ? U ? V ? W ? Y ? Z ? b ? e ? f ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?- ?4 ?B ?P ?W ?e ?p ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?% 4 ?&' ?() ?* ? ? ? ? ?+ ? , - ./ # ? ?<*? 3? ?*? ? **? ;*? -? V? *? ? **? ;*? /*? 8? W? *? 1? _*? ? F*? ? XM? YY? Z,? [? \]? \,? ^? \? _N*? 1-? `? **? ;*? 1? V? ? ?**? ;*? 1? V? ? ?*? ? ?*? ? **? ;*? -*? 8? W? *? ? **? ;*? /? V? *? 1? C*? ? &*? 1*? ? a? `? *? ;*? ? a*? 8? b**? ;*? 1*? 8? W? ? !*? ? *? ;*? ? a*? 8? b*? *? ? "*? C*? Bc?*? -*? )? d<? G*? ? *? Bc?*? /*? )? d<? '*? 1? *? ? *? Bc?*? 1*? )? d<*? e? <*? ? Y*? ? -*? *? +*? *? )*? *? *? ? f *? ? (*? ? !*? *? +*? *? *? ? g *? *? ? L*? ? $*? *? +*? *? *? ? h *? ? $*? ? *? *? +*? *? ? i *? *? ? ?*? ? j? u*? ? 5*? *? +? k *? ? cM*? C<*? Bc?*? ),? m? F*? ? ?*? *? +? n *? ? *M*? C<*? Bc?*? ),? m? *? *? *? ? :*? o? 3*? !? ,*? *? ? k *? !? M<*? Bc?*? ),? m*? ? :*? p? 3*? "? ,*? *? ? k *? "? M<*? Bc?*? ),? m*? ? E*? q? r? sM,? 4*,? t? :*? :? u? *? u? :? *? :? v? *? v? :? N*? %? x? q?? l??? l? l9KN lz?? w $ ? c ? ? ? ? ? & ? 9 ? @ ? G ? O ? m ? x ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?" ?4 ?9 ?@ ?F ?Z _fz?? ? ??????? 0 8!?"T#Y/`0j1q4~5?;?6?7?8?9?;?=?@?A?G?B?C?D?E?G?L?M?R?TU [VWX$^9`FaKgNbOcQdbkilvnzp?r?s?t?u?v?{?}% f O 801 m 2 ? ? 34 ? 34 34 O 34 ? 56 v 57 ? ?&' ?8 ? , - 9: # B ?*? ?YL?*? @? ?*? )? y?*? @? /*? z~? *? ? ? {????*? @*@? z*? ? 8*? @? ? - ? YY? Z}? \*? @? ~? \*? )? \? _? ??*? ?? ?+? N+?-?*? P? R? S*? Bc*? )? ? , 4 7 | ? ? ? ? ? $ N ? ? ? ? "? ,? 4? ;? @? F? K? N? V? Y? ?? ?? ?? ?? ??% 8 ;< ?&' , l- =: # ? ?*? ?YL? NA*? @? }*? @? v*? z@? ? j*? @? - ? YY? Z}? \*? @? ~? \*? )? \? _? ??*Y? z?? z 7*? z? *? ? ? ? *? ?? {? :??*? @? *? @*? Bc*? )? ?*? ?? ?+? :+??*? P? R? S*? P? R? T*? P? R? U? | ? ? | ? ? ? ? ? $ ^ ? ? ? #? &? .? X? c? f? o? y? |? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ??% * ? ;< f $> ? ?? ? ?&' , - @A # B ?*? ?YN?*? @? F*? @? ?*? z@? ? 3*Y? z?? z*? z? *? z0? ? *? ? ? {??:??*? @? *@? z*? N? ?*? ?*? ?? ?-? :-??*? P? R? S*? P? R? T*? P? R? U? B J M | u x x | x $ J ? ? ? "? -? ?? B? J? R? Z? `? g? l? s? ? ? ?% * O ;< ?&' ?B ? ?C ? DE # / =*? ?Y:? NB*? @? ? ?*? @? *? z~? ?*? ? ? {??:??*? @? D*? z@? ? b*Y? z?? z 7*? z? *? ? ? ? >*? ?? {? : ?? ? YY? Z}? \*? @? ~? \*? )? \? _? ??*? @*? e? *? z=? * ?? z? : ? ?*? P? R? S*? P? R? T*? P? R? U? ?*? ?Y:?*? ? *? z ?~? *? ? ? {??:??*? z ~? =*? ? H*? 3? **? ;*? -? V? ? **? ;*? -*? 8? W? *? ? *? Bc?*? )? ?=*? ? a*? ? j? W*? ? **? *? +*? *? )*? *? *? ? f *? *? *? +? ? ? :*? Bc?*? )? m=*? ? *? p? *? ? =*? ? *? o? *? ? =*? ? *? *? +? ? *? *? ? *? *? +? ? *? *? ? *? *? ? ? *? *? ? *? *? ? ? *? ? **? P? ?*? +? ? :*? Bc?*? )? m= ? ? X*? 3? *? ? J*? ;*? ? a*? 8? b? 5*? ? *? ;*? ? a*? 8? b*? ? *? ;*? ? a*? 8? b? : ? ? ? * 2 5 | r { ~ | ? ? ? ? ? |??? lw?? ?? $ ^ W *! 2" :* B+ K, N. Y0 \1 e7 o8 r< {= ?? ?A ?E ?K ?L ?M ?O ?Q ?W ?X ?Y ?[ ?iqtu#~.0?7?>?P?c?j?z?|?????????????????????????? ???#?(?/?<?A?H?U?Z?a?n?s?w??????????????????????????? ?% f 7 ;< ? ;< \ $> ? ;< ? 54 ? 3F &' G ? H ? ?? ? , - IJ # ? ?*? ?YM?*? @? I*? z@? ? =*? @? *? z~? ? )*Y? z?? z*? z? ? *? ? ? {????+? *? C*? ? G*+? 4? *+? 5? *+? 0? 1*+? 6? *? ? *? *? ? *? *? ? *? *@? z*? ?? ?,? :,??*? P? R? S*? P? R? T*? P? R? U? F N Q | ? ? ? ? ? $ z ? ? ? ? ,? /? :? C? F? N? U? Y? ^ f n v ~ ? ? ? ? ? ? ? ? ? ?! ?" ?# ?$% R ;< ?&' ?() , - KL # U *? YL?*? +?M+?,? $ ' ( )% &' MN # ? Y=*? YN?? *? v`? =? %? *? ? *? ? *? ? *? =-? :-?? ? *? P? R? S? @ C C G C $ > . / 0 1 2 4 5 (7 /8 7: <; >> J? N@ XA% Y&' YO ? WP ? QR # / *? ? $ D% &' SR # / *? ? $ H% &' TU # > *+? ? $ L M% &' V ? WX # ? (? ? ? ?*? -? r? ?:? ?? ??? $ P Q R S %V% * (&' (Y ? Z[ \] , - ^_ # ? E+? ?*? ? a? ?+? ? ? ?? ?+? ? ?*? ,+? ? ?+? ? ? ?? $ Z [ ^ )_ 5` Db% E&' EV] ) Z[ , - `a # ? 8 *? ? a? ? ? ? ?? ? ? ?*? -? ? ? ? ? ?? $ e f i j +k 7m% 8&' 8b ? Z[ , - c: # 6 *? ? ? $ p q% &' de # / *? ? $ t% &' fa # > * ? ? $ x y% &' b ? ge # / *? ? $ |% &' ha # > * ? ? $ ? ?% &' b ? ia # > * ? ? $ ? ?% &' b ? je # / *? ? $ ?% &' kL # 2 *? ? ? $ ?% &' l: # y -*? P? ?*? +*? ?*? ? ? L*? Bc+? ?*? )+? m? ? $ ? ? ? ? ,?% mF -&' no # ? H*? P? ?*? +*? C+? ? 4M*? Bc,? ? YY? Z*? )? \? \*? +? \? \? _,? m? ? $ ? ? ? ? G?% 0mF H&' Hp ? qN # > *? L? $ ? ?% &' r ? sN # C *Y? L`? L? $ ? ?% &' t ? uL # / *? L? $ ?% &' vN # > *? M? $ ? ?% &' r ? wN # C *Y? M`? M? $ ? ?% &' t ? xL # / *? M? $ ?% &' y/ # ? ?<*? ? ? = ~? ?*? ? ?**? *? )*? +? ? ? ? BN*? 3? *? Bc?*? ? ? ? ?-? m? *? Bc?*? ? ? ? ?-? m<*? ? B*? 3? *? Bc?*? ? ? ? ? ? *? Bc?*? ? ? ? ? ?<? $**? ? ? **? ? ? **? ? ? *? ? ? = ~? ?*? ? ?**? *? )*? +? ? ? ? BN*? 3? *? Bc?*? ? ? ? ?-? m? *? Bc?*? ? ? ? ?-? m<*? ? B*? 3? *? Bc?*? ? ? ? ? ? *? Bc?*? ? ? ? ? ?<? $**? ? ? **? ? ? **? ? ? ? / 2 l ? l $ ? & ? ? ? ? ? /? 2? 3? :? V? o? q? x? ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ,E GNUp?? ? ? ?"% 4 3 >34 >34 ?&' ?z ? ?{ ? , - |/ # A *? 8? *? ? j? ? ? $ )% &' }/ # A *? 8? *? ? j? ? ? $ -% &' ~/ # D *? ? ? ~? ?? $ 4 5 7% &' / # D *? ? ? ~? ?? $ > ? A% &' ?a # > * ? ? $ F G% &' ? ? ?e # / *? ? $ J% &' ?a # > * ? ? $ N O% &' ? ? ?e # / *? ? $ R% &' ?: # 4 *? H? $ W X% &' ?/ # e *? G ? <? *? H<? $ \ ] ` a c% 8 ? &' 8 ? ?? # J *? H? *? G? ? ? $ g% &' Y ? ?: # 6 * E? G? $ k l% &' ?a # ? K*? G ? * ? G? <*? G ? 3*? Bc ? YY? Z? \*? G? ?? \ ? ?? \? _? ? $ p q s t Jy% K&' KY ? , - ?/ # / *? J? $ }% &' ?? # > *? J? $ ? ?% &' ? ? ?/ # / *? K? $ ?% &' ?E # ? %=? *? I? *? K=? =? *? K= ? $ & ? ? ? ? ? ? ? !? #?% %&' %? ? #8 ? ?? # > *? I? $ ? ?% &' ? ? ?/ # ? -<*? *? ? ? *? "? M*? Bc?*? ),? m<? l $ " ? ? ? ? ? ? )? +?% 54 -&' +8 ? ?/ # ? -<*? *? ? ? *? !? M*? Bc?*? ),? m<? l $ " ? ? ? ? ? ? )? +?% 54 -&' +8 ? ?: # S *? *? ? ?* E? G*? H? $ ? ? ? ? ?% &' ?/ # G *? ? *? ? *? C? ? ? $ ?% &' ?: # ^ jL*? ? d*? 3? **? ;*? -? V? ? **? ;*? -*? 8? W? *? ? 1*? C*? Bc?*? -*? )? d*? B?*? -*? )? ??*? ? j? ?*? ? -*? *? +*? *? )*? *? *? ? f *? ? (*? ? !*? *? +*? *? *? ? g *? *? ? B*? *? +? k *? ? }M*? C*? Bc?*? ),? m*? B?*? )? ?? S*? ? L*? *? +? n *? ? 7M*? C*? Bc?*? ),? m*? B?*? )? ?? *? *? +? *+? ? ? ? ? l), l $ ? ( ? ? ? ? "? 5? <? B? V? i? j? t? {? ?? ?? ?? ?? ?? ?? ? ? ? ? ? ? $ ),-3DSV[` d i % * ? &34 - &34 j&' hp ? , - ? ?
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de