1     $  # # # # # # # # # # #   #   # # # # # # # #         ! #" ## #$ #% &' ()*  +  ,-./ 0 1 q q2 2 3 q  45 6 (7 8 9: q ; <  = >  ? 9@A B CDEFGHI J 9K L 9M N OP #Q R OS TU 9V W X YZ[ b\ b] c^ b_`a b c de m f gh qi 9j qk #l #m #no xp qrs tu v 4w xyz { 9| 9}~    k     #  9    \ ]     x  x  x       9  # q   9   #  c\    #   #    # #     #     # # # # # #     c]      2    Y   q q O # O # #  9 9  T T O 9         agentLoracle/mgw/engine/Agent; schedulerLoracle/mgw/engine/Scheduler;msgs[Loracle/mgw/common/Message;msgids[Loracle/mgw/common/MessageID;isPers[Z msgExDeqMsgidLoracle/mgw/common/MessageID; msgExCountImsgExidsmsgExEx Loracle/mgw/common/MGWException;msgCount msgDeqCount msgDupCountsrclinkLoracle/mgw/common/MsgLink; targetlinksrchdLoracle/mgw/common/OPHandle;targethddeqLogidenqLogid logsToCommit[Loracle/mgw/engine/LogId;logsToCommitCountnumExMsgsToCommitloggerLoracle/mgw/common/MgwLog; MAX_BYTES ConstantValueLOG_CLEANING_THREADSHOLDFACILITYLjava/lang/String; COMPONENT(ILoracle/mgw/engine/Agent;)VCodeLineNumberTableLocalVariableTablethisLoracle/mgw/engine/Worker;idmyRun()VijobLoracle/mgw/engine/JobData;jobFoundLoracle/mgw/engine/SchRet;fe"Loracle/mgw/common/FatalException;rtExLjava/lang/RuntimeException;erLjava/lang/Error; moveDupMsgsX(Loracle/mgw/engine/JobData;Loracle/mgw/engine/DeqLogRec;Loracle/mgw/engine/EnqLogRec;)Vjmid incExCountZexistingfoundMatchMsgIddeRecLoracle/mgw/engine/DeqLogRec;enRecLoracle/mgw/engine/EnqLogRec; Exceptions avoidDupMsgs;(Loracle/mgw/engine/JobData;Loracle/mgw/engine/DeqLogRec;)V deqMessages(Loracle/mgw/engine/JobData;)J byteCountexmidelemLoracle/mgw/engine/DupMsg;msge$Loracle/mgw/common/MessageException;messageLoracle/mgw/common/Message;consLoracle/mgw/common/MsgConsumer; nextDeqSeqNoJdeqRecmsgsLeftge$Loracle/mgw/common/GatewayException;faeexceptionRecvd enqMessages (Loracle/mgw/engine/JobData;JZ)V enqEndMarklogProdLoracle/mgw/common/MsgProducer;memsgProdenqRecffeseqno isRecovery msgsProcessed enqLogUpdatedcommitMessages!(Loracle/mgw/engine/JobData;JZZ)V exqEndMark deqEndMark updateSequnsetMissingMsgcleanJob(Loracle/mgw/engine/JobData;)Vlogretdlogs[Loracle/mgw/engine/DeqLogRec;exelogs[Loracle/mgw/engine/EnqLogRec;succeed recoverJob smallestSeqnok firstSeqnoenqLogse$Loracle/mgw/common/SkipJobException;edeqLogswriteInitialEnqLogRec:(Loracle/mgw/engine/JobData;)Loracle/mgw/engine/EnqLogRec;reccollectEnqLogReclogmsgLoracle/mgw/common/LogMessage;logrecLoracle/mgw/engine/LogRec;logmidlogConsenqlogcollectDeqLogRecsX(Loracle/mgw/engine/JobData;Loracle/mgw/engine/EnqLogRec;)[Loracle/mgw/engine/DeqLogRec;trecntrec1objLjava/lang/Object;obj1deqTmplrec perStatusexqLogm reqHasExRecereclargestExLogSeqnoen_log tempdeqlogsLjava/util/ArrayList; tempexqlogs logsToKeep lastEnqedSeqres processJobggeunScheduleProcessingJob returnHandleU(Loracle/mgw/common/MsgLink;Loracle/mgw/common/OPHandle;Loracle/mgw/engine/JobData;)Verridlinkhd setHandles(Z)Vinbound writeDeqLogp(Loracle/mgw/common/MsgLink;Loracle/mgw/common/Message;Loracle/mgw/engine/JobData;)Loracle/mgw/common/MessageID;lProdloghdloglinkretMsgid forceStopfindAllRemovableLogs8(Loracle/mgw/engine/JobData;Loracle/mgw/engine/DupMsg;)V lastSeqnocurrElemlidscompleteSending msgToSendmsgCons startingIdxgetDeqLogRecsForClean;(Loracle/mgw/engine/JobData;)[Loracle/mgw/engine/DeqLogRec;getEnqLogRecsForClean;(Loracle/mgw/engine/JobData;)[Loracle/mgw/engine/EnqLogRec;dumpJobLogRecscleanJobLogRecscreateDurableSub SourceFile Worker.javajava/lang/StringBuilder OXworker       O 2oracle/mgw/common/Message )*oracle/mgw/common/MessageID +, -. 3, 9: ;: <= >= AB D2 %&  '(  EF  62 72 82 /0 12 45 Enginelooking for a job   ! "[# $% &% '2    ( )*+ ,- oracle/mgw/common/FatalException .* /0java/lang/RuntimeExceptionjava/lang/Errorentering moveDupMsgs for job 1L 2 3 425 67 89 :; <L= >? @A B CD EF CG HIremoved a message for JK LFleaving moveDupMsgs for job entering avoidDupMsgs for job %avoidDupMsgs is called for topic src.forwent an expired message for leaving avoidDupMsgs for job entering deqMessages for job Mi NO P2 QR STU VW  XY Z[\ ]2 ^_ ` a bW"oracle/mgw/common/MessageException"oracle/mgw/common/GatewayException cW d Oe f0!MessageException with null msgid.$MessageException with null msg body. gh i2 j"oracle/mgw/common/SkipJobException k lmoracle/mgw/engine/DeqLogRec On oW pq  ?0 C2oracle/mgw/engine/LogId Or sWleaving deqMessages for job  with seqno  t deqMsgCount = u2 vX wXentering enqMessages for job  with request xy z{ |}oracle/mgw/engine/EnqLogRec O~ L  2 L o 0 @0 unexpected MessageException   F h Xleaving enqMessages for job  entering commitMessages for job y  L  2 0 L 0 X X h F F Xleaving commitMessages for job entering cleanJob for job  X  Y!a deqlog being removed gets lost. C   "an enqlog being removed gets lost. 2leaving cleanJob for job entering recoverJob for job         i   L L 2 2  W m inconsistent in-memory logsfound  enq logs,  deq logs for job X  qr recovering job  deqseq= enqseq= e de  X  Xunexpected SkipJobException  errorcode = leaving recoverJob for job Loracle/mgw/common/LogMessage 'unexpected destination log record type java/util/ArrayList L 7  "unexpected source log record type entering processJob for job  failed to get opHandles for job W st  caught SkipJobException.leaving processJob for job  (failed to get a logging connection from   i !entering completeSending for job Q X  leaving completeSending for job  Dumping sending log records for 9failed to get source side connection for dumping logs of &Dumping receiving log records for job >failed to get destination side connection for dumping logs of @failed to get destination side connections for cleaning logs of #an enqlog being removed gets lost. ;failed to get source side connections for cleaning logs of #an deqlog being removed gets lost. X"entering createDurableSub for job X!leaving createDurableSub for job oracle/mgw/engine/Workeroracle/mgw/engine/ManagedThrappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;(I)Ljava/lang/StringBuilder;toString()Ljava/lang/String;(Ljava/lang/String;)Voracle/mgw/common/MgwConstantsMAX_BATCH_SIZEoracle/mgw/engine/Agent getScheduler()Loracle/mgw/engine/Scheduler;oracle/mgw/common/MgwLog getMgwLogger()Loracle/mgw/common/MgwLog;getStop()Z isTRACE_LITE(I)Ztrace)(Ljava/lang/String;Ljava/lang/String;II)Voracle/mgw/engine/Scheduler findReadyJob()Loracle/mgw/engine/SchRet;oracle/mgw/engine/SchRetschJoboracle/mgw/engine/JobData getSrcLink()Loracle/mgw/common/MsgLink; getTargetLinkactionjava/lang/StringvalueOf(I)Ljava/lang/String;oracle/mgw/common/MgwUtilFatalExceptionL(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/FatalException;getMsgshutdown*(Ljava/lang/String;Ljava/lang/Throwable;)VpidsrcNotAllowDeqByMsgIdlogseqNo msgidCountjava/lang/Objectequals(Ljava/lang/Object;)ZexQLoracle/mgw/common/DestData;GatewayExceptionN(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException;guidoracle/mgw/common/MsgLinkmoveToExceptionQueue(Loracle/mgw/common/OPHandle;Ljava/lang/String;Loracle/mgw/common/DestData;Loracle/mgw/common/MessageID;)Loracle/mgw/common/MessageID;toIgnoreMissingMsgs(J)Z getIDAsStringlogMsg:(Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;)VsetMissingMsgReq(J)VL(Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;)V removeMsgN(Loracle/mgw/common/OPHandle;Ljava/lang/String;Loracle/mgw/common/MessageID;)Z addDeqLogRec (Loracle/mgw/engine/DeqLogRec;)V setDeqSeqNoisJmsJob getConsumerO(Ljava/lang/String;Loracle/mgw/common/OPHandle;)Loracle/mgw/common/MsgConsumer; batchSizereceive<(Loracle/mgw/common/MsgConsumer;)Loracle/mgw/common/Message;dupDataLoracle/mgw/engine/DupData;oracle/mgw/engine/DupData numDupMsgs()IgetMsgId()Loracle/mgw/common/MessageID; getDupMsg9(Loracle/mgw/common/MessageID;)Loracle/mgw/engine/DupMsg;oracle/mgw/engine/DupMsgm_actionsendToExceptionQueuer(Loracle/mgw/common/OPHandle;Loracle/mgw/common/DestData;Loracle/mgw/common/Message;)Loracle/mgw/common/MessageID; isPersistentexpiressizegetCode getReason+(ILjava/lang/String;Ljava/lang/Throwable;)Vmsgid setMsgCount(I)V retryCountwriteFailureInfojobMutex getDeqSeqNo()JJ(Ljava/lang/String;Ljava/lang/String;JI[Loracle/mgw/common/MessageID;[ZI)VloggingSupport toLogMessage ()Loracle/mgw/common/LogMessage;>(JLoracle/mgw/common/MessageID;Loracle/mgw/common/MessageID;)V getMsgCount(J)Ljava/lang/StringBuilder; jobStatus notifyAllnotifyDeqWaitingwaitForEnqueue(Loracle/mgw/engine/JobData;J)Z getProducerO(Ljava/lang/String;Loracle/mgw/common/OPHandle;)Loracle/mgw/common/MsgProducer;sendY(Loracle/mgw/common/Message;Loracle/mgw/common/MsgProducer;)Loracle/mgw/common/MessageID;I(Ljava/lang/String;Ljava/lang/String;JII[Loracle/mgw/common/MessageID;I)V destLogProdhasTopicAsDestLogdestTopicLogCount destLogCons enqLogReclogmsgid setLogMsgid (Loracle/mgw/common/MessageID;)Vcommit(Loracle/mgw/common/OPHandle;)V setEnqLogRec (Loracle/mgw/engine/EnqLogRec;)V setEnqSeqNoincTotalNumMsgsoracle/mgw/common/MGWExceptionnotifyEnqWaiting waitForCommithasTopicAsSrcLog srcLogProdm_seqnosrcTopicLogCount m_exqLogMsgid srcLogCons m_deqLogMsgidunsetMissingMsgRequnsetToIgnoreMissingMsgsincTotalNumExMsgs delDeqLogRec setComSeqNonotifyComWaitingstartOperation()Loracle/mgw/common/OPHandle;java/lang/Threadyield getLogMsgid((Ljava/lang/String;ILjava/lang/String;)VrollbacklogMsgEx=(Ljava/lang/String;ILjava/lang/String;Ljava/lang/Throwable;)V numWorkersinitgetDumpLogRecssetDumpLogRecsgetCleanLogRecssetCleanLogRecs(Z)ZsetMissingLogs isInboundlogpidlogguid numMsgEnqedlogtype getNumLogs getComSeqNo getDeqLogRec (J)Loracle/mgw/engine/DeqLogRec;cleanDeqLogRecswriteStatistics getPoller ()Loracle/mgw/engine/PollingThr;oracle/mgw/engine/PollingThrnotifyPollWaiting'(Ljava/lang/String;Ljava/lang/String;)V destLogBroworacle/mgw/engine/LogRectoLogRec(Loracle/mgw/common/LogMessage;Loracle/mgw/common/MsgLink;Ljava/lang/String;Loracle/mgw/common/MsgLink;Z)Loracle/mgw/engine/LogRec; srcLogBrowaddget(I)Ljava/lang/Object;remove addDupMsg?(Loracle/mgw/engine/DeqLogRec;IILoracle/mgw/common/MessageID;)V numDupReqs setFailed(ILjava/lang/String;)VstartLogOperationgetLinkParamsNFactory+()Loracle/mgw/common/MsgLinkParamsNFactory;'oracle/mgw/common/MsgLinkParamsNFactorygetNamem_isLastremoveDupMsgsNReqs(J)[Loracle/mgw/engine/LogId;Y(Loracle/mgw/common/MsgConsumer;Loracle/mgw/common/MessageID;)Loracle/mgw/common/Message;incProcessedCountincExMsgsCount unsubDestLog unsubSrcLogresetLoggingInfocreateAlterNativeSub!#$%&'()*+,-./0123,456272829:;:<=>=?0@0ABC2D2EFG2HVI2HJKLH"M2HNOPQq*Y* * * * *******,*,*R>2 !+4>CHMR$W&\3a4i5p6S qTUqV2q%&WXQ2*L***=* S***** *!*"#$*%M,,&L*+'*+(,) *+*B,) *++2,) *+,",) *+-,)./,A!B(A.D3E8G=HBIGKSLaPiSmTpVuX}Y[\]^_`abdgnhinjknlmoSHY2 Z[ik\]^_`abcTUdeQ1*!%*"Y5+6$6+7,86,9-:16-;% ,<2-=2>6+?+6@**+A+?,<2B:6M,C3C+,9D$*"1,<2E+6F6+,9G+6@ *Y`%*".+6,<2EEH**+A,<2I6J,C3@+,9D!*"1,<2E+6F+,9G+6@*!%*"YJ+6$[+,K+,9L*!%*"YM+6$R'{ |.ADPaux~ <?YhsSf S+f2g0hiYzjiDki1Y2TUZ[lmnopc0qrQM*!%*"YN+6$+7 O/>,8**+A,<2I6y,C3?+,9D *"1,<2E+6Fv+,9G+6@*!V*"YP+6$1*!%*"YJ+6$3+,K+,9L*!%*"YQ+6$RZ .5?Ib g p { !" '(**+L.S4bjiAY2MTUMZ[Mlmpc0stQ9 s*!%*"YR+6$+S==>*+A*T:*+UJVD*=:*W:+7+XY *+Z:+7+XY+X[\:t]W+?+6@**+?^:*Y`*".+6[EEH*+Z*Y`d* *[S* *S_`* *T * *T*Y`+S a`=:+?cYdefgh@:+7+XY+Xg\:q]Ti@**+?^:*Y`*".+6[EEH*+Z*Y`>* *gS* *S* *T*Y`*g* *Y`*!+j+k +k+lmYn:+oY:+p a7qY+6+A** * r:+K+Lç :  *s6***t+uv**YwZ`wxY*vyS*v+z*d6+j*!;*"Y{+6|}~*$7 +oY: +Y~+@+Y +~ +o ç :   * :>:>: +oY:+Y~+@+Y +~ +oç :* lbb    >c>0>'^aafaRh4 5.:5;:=<?>AQOiRlUy^~_acuvxz{|}%2BManx%GN[is}!3 TYds#$'(*+,0 !#'$2'?(J*T+[,i0S7u2,v0wx,v0wxyzl4{|Q}~4Dmd2_sTUsZ[<7u2>5ipmc0Q e*!.*"Y+6 }$666*+ mYn*+A*:6  **  2}**  2Wd: +?cY d e f g h@**YZ`*  2[S*  S* *  p***YZ`*SY+6+A ***: *s*+*: +9Y+6+A e: *  W+Y`***++I+6@**   *:  /***+ +oY: +  ç :   +**d6*cY* * * f}:]*sQLY+6+A **: +*d+ +oY: +  ç :   6:6::+oY:+Y~+@+Y +~ +oç :***!.*"Y+6| }$ bKb@SYc@S0@VYR>O7 87=:>=?@BQCYElFxIZl\]^bchijkmFr st w?K^e}"/29SVY[lq$ + 7 dS_yz oY2 }o ^  z l?o ,o [e_eTUeZ[eei:+i=(2@%ipmc0Q *!.*"Y+6 }$66*+ mYn*s_+*+*:6  *wqY+6+A* 2r: * tW+Y`* 2>qY+6+A* 2r: * tW+Y`+* 2D6:  / N6*w~**+*2I+6@*2-**+*2I+6@+*2D6*** +++*+oY:+ + +k +k+lç :  :6:6:  :+oY:+Y~+@+Y +~ +oç :***!.*"Y+6| }$ !b=!c=)0=1!61C{~~~RC 7:= N!V$b&i'|*,4578@A DEK!G#H.*4M7OCPaTmXzY\`aOhilmnqvwy{ !#&)+.1CN\gqxSm wm # z Y2 |:Y2#+_TUZ[ii:i=ipmc0Qtr*!%*"Y+6$=*s+> *** *+6@*+N6-:-2:**+I6*"***GN****:*"+6*"+6-=*s+> *** *+6@*+N6-:-2:**+I6*"***QN****:*"+6-*"+6-=+oYN ++Yd+o-ç :-*!%*"Y+6$Ccc0cc9<<@<RC .0CJW^agnz 07DKNT[gpz    &"0%7&C'O(q+SE"Y2+mi>Y2SC2"Y2+ois>Y2pSMrTUrZ[0Bip0Q s *!%*"Y+6$M++6@+ *+++*++W+*+ŷ* * +k +Ykdk+6@N*s *+NC+<Y+++:++;+=+˷N****s*+-MD+ͽqM+ a76+͢(,+aS,2 и@*!@*"YѶ-Ҷ,Ӷ+6$***,D+7=,2976,+,29a++6@+*+ŷ* * +k +Ykdk+6@-2,!*+W+ֶL+ֶ+ֶ+*s++6@6,,2:*v*x*w***YwZ`wxY9*vyS+9 eL+9 e6*+ŷ* * +k +Ykdk+6@*+****+9لAY+6+A+:+++ζ,#+-+-:L+-:+-:+-+-:6,,2:*v+9 eL+9 e6*+ŷ* * +k +Ykdk+6@*!>*"Yڶ+6۶9}ܶ-:}$*x*w**s{9-:n8-ʤb*+-*******+ŷ* * +k +Ykdk+6@***9-:B*+-+7$**YwZ`wxY9*vyS*+9٧0**YwZ`wxY9*vyS*+9,S,+-:L+-:***+***+++oY:+Y~+Y~+~ +oç :*N-/N*"--*"+6-+Y--l*s3,/6,%,2+,29 eL+,2K***+***++oY:+~ +o+@ç :*!%*"Y+6$0m0cR6 7.;0>7?CBJCODTJ[K`LfMkPsQSTV\]^`aklop r(s0t<uJvQw[ta}m~#-9=BHOV`lq} +0<B[ailqv~   L%T&Y)^38;<BCFHJKMTUW[ ^_1e@hammsrxuvz{ $EU_fs{S3.Y201/22mY2[omY2Mo X)Y2TUZ[0p0Q xY+6+AM*s?*+*N**,-:/,****+,,5GJbR2 #5GJLW_lqvS4L z5*xTUxZ[aopc0Q^6MN+*+*TM*+*TM*,W:*+A*:!- Nb++6@*--:씚N2++6@ɻY+6@X:/+A-=*+*:*-:-:/+-2FbIbbeb"bR"  2AFI] benr{ !%'-412:<>@D"A$B/G4ISf A]} z0$ z6TU6Z[4~2opc0Q SNY:Y:+*+*TN*+*TN*-W:|*+A*:*&*1*W:6  / q:  9씚 : ++6@+7!ɻY+6@W+7!ɻY+6@: 6  / q:  9씚 :  2++6@ɻY+6@:/6q:*+*:7 , ,:7 6  d q: +A 9 @* t:    S:  / S +q: 6     2S +77 .+?+6@dq:97 ,,;,: +?+6@,;:6,;TqY,,,:,;,=r:*t::/W6 2:9 6:6+&q:99668x`668'"<2<2>6+X+X+X$ BVbYrbub,ORb=VYbRsPQ RTU0WB[Q^V_Ybmirjulnorwxyz{w~"*-4RUbn|!,>EORT_iou| =OVY[fnx &')*+,-.+123456489'=4@7BD1JPJS(m 62 nm X62 Um QqmU z>0 T z Om kY2 f2 mY2O0[ zi.=1m2f2.2Wki2mimqY2 STUSZ[SoQ~ H?~2ta\ | pc0Qv*!%*"Y+6$*+ŷƧ M*+,* *T*!%*"Y+6$*+***+***+ߨ+X*x*+X`x*w**+A*+ *+ ++ + +M***+***+*!*"$TM***+***++,,*"+6,+,ll::+oY:+Yd+oç :**!&*"Y+6$ .69c. m m.FcFc. CFR2P Q.V6Z9W:X?YA\O][^}abcdjkmnpsvx{  %1@CFGTam~S>:/ 5G?TUZ[p0Q.+oYM+Y~+~ +o,çN,-%((+(R#-S.TU.Z[Q5+, +,%:- -6:*"cR$4S>$L 5TU5:5=5Z[p0Q< ********R!.;S<TU<ipcQ :+Y::+:'ɻY+@+-:+,::/+:+- -Y`ð:  JUXb<mpcRR <JUXZem pr z } S\ Z zJ#r  =TU:|Z[0pc0XQ+RS TUQR,  B, , B , eB+X! :6**YwZ`w2SR* "# $%'!*+,6-K,Q.SR.#Y2RTURZ[Rx!1+'BeQb b*!&*"Y+6$*+A*T:*+A*:-66,8*,<2:*W+J,C3@+,9D!*"1,<2E+6F+,9G+6@-+-E:+?cYdefgh@--g+-0*!&*"Y+6$hbRzA B/FBGUH[JhL|NOPSTU[]bcxeklpquv'w,J2{>|aSf |k|@yz_Y2bTUbZ[blmbnoB ~U [2pc0QhMYN*+*TM*,W:6*+A*:-W:/-q:6--qS0Yb3LYbOVYbRJ +03GLOVY[fo{S\ ++G[ zrY2TUZ[~ o#pc0QhMYN*+*TM*,W:6*+A*:-W:/-:6--S0Yb3LYbOVYbRJ +03GLOVY[fo{S\ ++G[ zrY2TUZ[~ o#pc0QF MN:*"Y+6*sI+ a76+͢2+a: и@*"˧***"ȻY+6@+*+*TM*+*TM*,WN-?:@-*+A*:*"****"Y+6*s+*"+***"ȻY+6@+*+*TM*+*TM*,WN-?:/-*+A*:*"***&KM*"+6,3:: ***+***+** bbGMcJeMbeejeR@'3;GSXbpvy         + 8 = ] i p   ! " & ' ) - . / 3 0 1 5 :! ;$ =5 @B AG DJ LM DN E_ Gb Le H| I J K MSf >8Y2;; z zE~C@NTUZ[p0Q*s+++6@***"ɻY+6@*+M>,J,2:**+I6"ɻY+6@****s+++6@***"ɻY+6@*+M>,J,2:**+I6"ɻY+6@***+3::***+***+**R( c d e f& j3 k: lY qb rj so t w x r ~   % - 2 J O n t          Sf o<o$idMY2ba2<mJ$i'MY2%aTUZ[pc0Q*!&*"Y +6$+!+oYM+Y~+o,çN,-**!&*"Y"+6$:NQQTQR. / 3 : E L V ] i STUZ[p0