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 TUpidLjava/lang/String;guidsrcNamedestNameexNamesrcQLoracle/mgw/common/DestData;targetQexQ isInboundZisJmsJobselectortranFunc subOptionsLjava/util/Hashtable;latencyJlastPollingTimesrcLinkLoracle/mgw/common/MsgLink;destLinkagentLoracle/mgw/engine/Agent;destMgrLoracle/mgw/engine/DestMgr;jobMutexLjava/lang/Object;jobStateI jobStatus numWorkers batchSizelastDeqTxSeqNolastEnqTxSeqNolastComTxSeqNo deqLogRecs enqLogRecLoracle/mgw/engine/EnqLogRec;totalNumberMsgstotalNumberExMsgs lastWriteTime lastRetryTime retryCount lastErrorTime lastErrorCode missingMsgReqignoreMissingMsgs missingLogs dumpLogRecs cleanLogRecs syncCountmsgCountloggerLoracle/mgw/common/MgwLog; subCreated subAlteredconsRegistered consAlteredprodRegistered prodAltered srcLogIdsLoracle/mgw/common/LogIdSet; destLogIds srcLogCons srcLogBrow srcLogProd destLogCons destLogBrow destLogProdsrcLogSubCreateddestLogSubCreateddupDataLoracle/mgw/engine/DupData;srcTopicLogCountdestTopicLogCountSTATISTIC_INTERVAL ConstantValueJOB_DEACTIVATED JOB_ACTIVATED JOB_DELETEDJOB_IDLEJOB_DEQUEUEINGJOB_ENQUEUEINGJOB_COMMITTINGJOB_RECOVERING JOB_QUIESCENT JOB_TO_FAIL  JOB_FAILED@ JOB_TO_CLEAN JOB_CLEANED JOB_POLLINGMAX_LOG_CLEANING_TIME'FACILITYU(Loracle/mgw/common/SubParams;Loracle/mgw/engine/DestMgr;Loracle/mgw/engine/Agent;Z)VCodeLineNumberTableLocalVariableTablethisLoracle/mgw/engine/JobData;subpLoracle/mgw/common/SubParams;dmisDel ExceptionsVinit()ZdpLoracle/mgw/common/DestParams;tempnamege$Loracle/mgw/common/GatewayException;ne!Ljava/lang/NumberFormatException;batchStrretactivate()Ve Ljava/lang/InterruptedException; deactivatewaitTime startTime setFailed(ILjava/lang/String;)VerrCodeinfoclose(Z)Z$Loracle/mgw/admin/MgwAdminException;forcedsucceedupdate (Loracle/mgw/common/SubParams;)V getMsgCount()I setMsgCount(I)Vcount sendNotif getSrcLink()Loracle/mgw/common/MsgLink; getTargetLink setEnqLogRec (Loracle/mgw/engine/EnqLogRec;)Vlog getDeqLogRec (J)Loracle/mgw/engine/DeqLogRec;seqnorecidLjava/lang/Long;recLoracle/mgw/engine/DeqLogRec; addDeqLogRec (Loracle/mgw/engine/DeqLogRec;)V delDeqLogRec(J)VnocleanDeqLogRecs getDeqSeqNo()J setDeqSeqNo getEnqSeqNo setEnqSeqNo setComSeqNo getComSeqNo getNumLogswriteStatisticsexwriteFailureInfo(Ljava/lang/String;)VerrinfosetTotalNumMsgsnumincTotalNumMsgsincgetTotalNumMsgssetTotalNumExMsgsincTotalNumExMsgsgetTotalNumExMsgsinitLoggingIds loggingRet loggingDescisNotPipelinablesrcNotAllowDeqByMsgIdhasTopicAsSrcLoghasTopicAsDestLog setLatencylan getLatencysetLastPollingTimelastPollgetLastPollingTimeunsetToIgnoreMissingMsgssetToIgnoreMissingMsgstoIgnoreMissingMsgs(J)ZunsetMissingMsgReqsetMissingMsgReqgetDumpLogRecssetDumpLogRecs(Z)VvalgetCleanLogRecssetCleanLogRecssetMissingLogs unsubDestLog unsubSrcLogresetLoggingInfoneedCreateAlterSubcreateAlterNativeSub 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 :  ajava/lang/InterruptedExceptionunknown subscriber state ~  :  /  : o / / o o   o"oracle/mgw/admin/MgwAdminException nojava/lang/Long !aoracle/mgw/engine/DeqLogRecmissing 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/FatalExceptionoracle/mgw/common/SubParamsgetSubscriberID()Ljava/lang/String;getGuidgetSrcQueueNamegetDestQueueNamegetExQueueName getSelectorgetTransformation getOptions()Ljava/util/Hashtable; jmsSubscriberoracle/mgw/common/MgwConstantsoracle/mgw/engine/DestMgrgetForeignDestLink/(Ljava/lang/String;)Loracle/mgw/common/MsgLink; getAqJmsLink getAqLinkoracle/mgw/common/MgwLog getMgwLogger()Loracle/mgw/common/MgwLog;java/lang/SystemcurrentTimeMillisoracle/mgw/engine/Agent getScheduler()Loracle/mgw/engine/Scheduler;oracle/mgw/engine/SchedulernotifyDeqWaitingnotifyEnqWaitingnotifyComWaitinggetForeignDest0(Ljava/lang/String;)Loracle/mgw/common/DestData; getAQDest1(Ljava/lang/String;Z)Loracle/mgw/common/DestData;oracle/mgw/common/DestData getDestParams ()Loracle/mgw/common/DestParams;oracle/mgw/common/DestParams getDestIDappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; getLinkNametoStringequals(Ljava/lang/Object;)Z ungetAQDest(Ljava/lang/String;Z)VlogMsg:(Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;)Voracle/mgw/common/MsgLinkregisterConsumer}(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZLjava/util/Hashtable;)V alterConsumerN(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)VregisterProducerX(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/util/Hashtable;)V alterProducer<(Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)VisTopic subscribelogMsgEx=(Ljava/lang/String;ILjava/lang/String;Ljava/lang/Throwable;)V updateSubget&(Ljava/lang/Object;)Ljava/lang/Object;java/lang/IntegerparseInt(Ljava/lang/String;)IMIN_BATCH_SIZEMAX_BATCH_SIZEclearoracle/mgw/common/MgwUtilGatewayExceptionN(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException;wait(I)Ljava/lang/StringBuilder;FatalExceptionL(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/FatalException; notifyAll((Ljava/lang/String;ILjava/lang/String;)VisEmptyjava/lang/Threadyield unsubscribeunregisterConsumerunregisterProducerunregisterLogSet(Loracle/mgw/common/LogIdSet;)V getAdminMgr()Loracle/mgw/admin/AdminMgr;oracle/mgw/admin/AdminMgrremoveSubscriberlogseqNovalueOf(J)Ljava/lang/String;put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;removesizesetSubStatistic(Ljava/lang/String;II)VgetCode setSubInfologgingSupportregisterLogSetC(ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/LogIdSet;getLinkParamsNFactory+()Loracle/mgw/common/MsgLinkParamsNFactory;'oracle/mgw/common/MsgLinkParamsNFactorygetNameoracle/mgw/common/LogIdSet getConsumerId getBrowserId getProducerId(J)Ljava/lang/StringBuilder;getMsg9(ILjava/lang/String;Ljava/lang/String;)Ljava/lang/String;'(ILjava/lang/String;)Ljava/lang/String;!P       c7!"#j******** * * * * Y **Y*************** *!*"*#Y$%*&*'*+()*+*+*+,-*+./*+01*+23*+4*+5*+6*+78*9:*,;*35**;*-< *8**;= @**;> 2*8**;= **;> **;*/< *Y?*@*AB*C* D*EG*H*I*J*K*L*M*NO*-P*Q-RS-RT-RU$*J "',1$6/A0FDQEVH[I`JeKjLoMtOyP~RSTUVWYZbef -4BPWep%4&'()*+,-./#<*3***;*-V***;*/*8W*1_*F*XMYYZ,[\]\,^\_N*1-`**;*1V**;*1V****;*-*8W***;*/V*1C*&*1*a`*;*a*8b**;*1*8W!**;*a*8b**"*C*Bc*-*)d<G**Bc*/*)d<'*1 **Bc*1*)d<*e<*Y*-* *+**)***f*(*!* *+***g**L*$* *+***h*$** *+**i***ju*5* *+k*cM*C<*Bc*),mF*?* *+n**M*C<*Bc*),m ***:*o3*!,* *k*!M<*Bc*),m*:*p3*",* *k*"M<*Bc*),m*E*qrsM,4*,t:*:u *u:*:v *v:N*%xqll l9KNlzw$c &9@GOmx"49@FZ_fz   08!?"T#Y/`0j1q4~5;6789;=@AGBCDEGLMRTU [VWX$^9`FaKgNbOcQdbkilvnzprstuv{}%f O801m2343434O3456v57&'8,-9:#B*?YL*@*)y*@/*z~*? {M*@*@z*8*@-ɻYYZ}\*@~\*)\_*?+çN+-*PRS*Bc*),47|$N",4;@FKNVY%8;<&',l-=:#*?YL¸NA*@}*@v*z@j*@-ɻYYZ}\*@~\*)\_*Yzz 7*z**?{:*@*@*Bc*)*?+ç :+*PRS*PRT*PRU||$^ #&.Xcfoy|%*;<f$> ?&',-@A#B*?YN*@F*@?*z@3*Yzz*z*z0*? {:*@*@z*N**?-ç :-*PRS*PRT*PRUBJM|uxx|x$J"-?BJRZ`gls%*O;<&'BCDE#/  =*?Y:¸NB*@*@*z~*? {:*@D*z@b*Yzz 7*z*>*?{: ɻYYZ}\*@~\*)\_*@*e *z= *zç :  *PRS*PRT*PRU*?Y:* *z~*? {:*z~=*H*3**;*-V**;*-*8W**Bc*)=*a*jW*** *+**)***f** *+:*Bc*)m=**p *=**o *=** *+*** *+*** **** ****P*+:*Bc*)m=X*3*J*;*a*8b5**;*a*8b**;*a*8bç :   *25|r{~| |lw$^W  *!2":*B+K,N.Y0\1e7o8r<{=?AEKLMOQWXY[iqtu#~.07>Pcjz| #(/<AHUZansw %f 7;<;< \$> ;<543F &' G H?,-IJ#*?YM*@I*z@=*@*z~)*Yzz*z*? {N+*C*G*+4*+5*+01*+6*******@z*?,ç :,*PRS*PRT*PRUFNQ|$z,/:CFNUY^fnv ~   !"#$% R;<&'(),-KL#U*YL*+ìM+, $'()% &'MN#Y=*YN*v`=% ** * *=-ç :- *PRS @CCGC$>./ 0124 5(7/87:<;>>J?N@XA% Y&'YOWPQR#/* $D% &'SR#/* $H% &'TU#>*+$ LM%&'VWX#(YN*-r: $P QRS%V%*(&'(Y Z[\],-^_#E+* a+Y+M*,++$Z[^)_5`Db% E&'EV])Z[,-`a#8* aYN*-$e fi j+k7m% 8&'8b Z[,-c:#6*$ pq% &'de#/*$t% &'fa#>*$ xy%&'bge#/*$|% &'ha#>*$ %&'bia#>*$ %&'bje#/*$% &'kL#2*$% &'l:#y-*P*+**L*Bc+*)+m$,%mF-&'no#H*P*+*C+4M*Bc,YYZ*)\\*+\\_,m$G% 0mFH&'HpqN#>*L$ %&'rsN#C *YL`L$  % &' tuL#/*L$% &'vN#>*M$ %&'rwN#C *YM`M$  % &' txL#/*M$% &'y/#<* =~*** *)*+BN*3*Bc* -m*Bc* -m<*B*3*Bc* *Bc* <$******* =~*** *)*+BN*3*Bc* -m*Bc* -m<*B*3*Bc* *Bc* <$****** /2ll$& /23:Voqx ,E GNUp"%43>34 >34&'z {,-|/#A*8*j$)% &'}/#A*8*j$-% &'~/#D* ~$457% &'/#D* ~$>?A% &'a#>*$ FG%&'e#/*$J% &'a#>*$ NO%&'e#/*$R% &':#4*H$ WX% &'/#e*G < *H<$\ ]`ac%  8&'8#J*H*G$g%&'Y:#6*EG$ kl% &'a#K*G *G<*G3*BcɻYYZ\*G\\_$p qstJy%K&'KY,-/#/*J$}% &'#>*J$ %&'/#/*K$% &'E#%=*I *K== *K=$&  !#% %&'%#8#>*I$ %&'/#-<* **"M*Bc*),m<l$")+% 54-&'+8/#-<* **!M*Bc*),m<l$")+% 54-&'+8:#S***EG*H$ % &'/#G* **C$% &':#^jL*d*3**;*-V**;*-*8W*1*C*Bc*-*)d*B*-*)L*j*-* *+**)***f*(*!* *+***g**B* *+k*}M*C*Bc*),m*B*)LS*L* *+n*7M*C*Bc*),m*B*)L **+*+l),l$( "5<BVijt{   $ ),-3DSV[`di%*&34-&34j&'hp,-