=org/compiere/util/Trxjava/lang/Objects_cacheLjava/util/Map; Signature:Ljava/util/Map; s_monitor"Lorg/compiere/util/Trx$TrxMonitor; listeners,Ljava/util/concurrent/ConcurrentLinkedQueue;RLjava/util/concurrent/ConcurrentLinkedQueue;traceLjava/lang/Exception; m_displayNameLjava/lang/String;m_changesMadeByEventListenerZlogLorg/compiere/util/CLogger; m_connectionLjava/sql/Connection; m_trxNamem_active m_startTimeJ m_timeoutIm_lastWFSavepointLjava/sql/Savepoint;()VCode$&java/util/concurrent/ConcurrentHashMap #& '! ) + org/compiere/util/Trx$TrxMonitor *& . LineNumberTableLocalVariableTableget,(Ljava/lang/String;Z)Lorg/compiere/util/Trx; 465java/lang/String 78length()I:"java/lang/IllegalArgumentException<No Transaction Name 9> '?(Ljava/lang/String;)V ACB java/util/Map 1D&(Ljava/lang/Object;)Ljava/lang/Object; > AG HIput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;trxName createNewretValueLorg/compiere/util/Trx; StackMapTableA(Ljava/lang/String;ZLjava/sql/Connection;)Lorg/compiere/util/Trx; DeprecatedRuntimeVisibleAnnotationsLjava/lang/Deprecated; T 'U*(Ljava/lang/String;Ljava/sql/Connection;)VconstartTrxMonitor Y[Zorg/compiere/Adempiere \]getThreadPoolExecutor4()Ljava/util/concurrent/ScheduledThreadPoolExecutor; acbjava/util/concurrent/TimeUnit deMINUTESLjava/util/concurrent/TimeUnit; gih0java/util/concurrent/ScheduledThreadPoolExecutor jkscheduleWithFixedDelay](Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture; createTrxName&(Ljava/lang/String;)Ljava/lang/String;oTrxqTRX_AUTOSET_DISPLAY_NAME sutorg/compiere/model/MSysConfig vwgetBooleanValue(Ljava/lang/String;Z)Z y{zjava/lang/StackWalker$Option |}RETAIN_CLASS_REFERENCELjava/lang/StackWalker$Option; java/lang/StackWalker  getInstance7(Ljava/lang/StackWalker$Option;)Ljava/lang/StackWalker; apply()Ljava/util/function/Function;  walk1(Ljava/util/function/Function;)Ljava/lang/Object;java/util/Optional DorElse java/util/UUID  randomUUID()Ljava/util/UUID; 4 valueOf&(Ljava/lang/Object;)Ljava/lang/String; makeConcatWithConstants8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;  12  ?setDisplayNameprefix displayNamewalkerLjava/lang/StackWalker; stackNameLjava/util/Optional;trxLocalVariableTypeTable(Ljava/util/Optional;()Ljava/lang/String;  lm &*java/util/concurrent/ConcurrentLinkedQueue &     getClass()Ljava/lang/Class; org/compiere/util/CLogger  getCLogger.(Ljava/lang/Class;)Lorg/compiere/util/CLogger;              ? setTrxName m java/util/logging/Level SEVERELjava/util/logging/Level;java/lang/Exception > C(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)Vthismsg   setConnection(Ljava/sql/Connection;)V getConnection()Ljava/sql/Connection;  (Z)Ljava/sql/Connection; ALL  isLoggable(Ljava/util/logging/Level;)Z  isActive()Z '(ZLjava/lang/String;)Ljava/lang/String; .(Ljava/util/logging/Level;Ljava/lang/String;)V A  containsKey(Ljava/lang/Object;)Z6Illegal to getConnection for Trx that is not register.  !printStackTrace org/compiere/util/DB  createConnection(ZI)Ljava/sql/Connection;   startTRACE_ALL_TRX_CONNECTION_GET &    FINEST  ?finest java/sql/Connection  setAutoCommit(Z)V  connection"java/sql/SQLExceptionconneLjava/sql/SQLException; getTrxName ) *?warning ,.-java/lang/System /0currentTimeMillis()J 2  getStartTime()Ljava/util/Date;6java/util/Date 58 '9(J)Vrollback(Z)Z Exceptions > :! @ AB isLocalTrx(Ljava/lang/String;)Z D EFINE G HINFO K LfireAfterRollbackEventthrowException O PQiterator()Ljava/util/Iterator; SUTjava/util/Iterator VWnext()Ljava/lang/Object;Y"org/compiere/util/TrxEventListener X[ \] afterRollback(Lorg/compiere/util/Trx;Z)V S_ `hasNextsuccessl$Lorg/compiere/util/TrxEventListener; e :;(Ljava/sql/Savepoint;)Z h :i(Ljava/sql/Savepoint;)V l m?info savepointcommit q o! t ufireAfterCommitEvent wyx$org/adempiere/exceptions/DBException z{getDefaultDBExceptionMessage)(Ljava/lang/Exception;)Ljava/lang/String; !} ~getLocalizedMessage   saveError*(Ljava/lang/String;Ljava/lang/Exception;)Z X ] afterCommit  o;rollbackAndCloseOnTimeout  closejava/lang/Throwable  & A Dremove   isReadOnly  o   setReadOnly  !  !fireAfterCloseEvent  CONFIG  ?config X  afterClose(Lorg/compiere/util/Trx;)V setSavepoint((Ljava/lang/String;)Ljava/sql/Savepoint;     ()Ljava/sql/Savepoint;namesetLastWFSavepointgetLastWFSavepointreleaseSavepoint  isOracle  itoStringjava/lang/StringBuilderTrx[ >  getDisplayName  append-(Ljava/lang/String;)Ljava/lang/StringBuilder;,Active=  (Z)Ljava/lang/StringBuilder;]  sbLjava/lang/StringBuilder;getOpenTransactions()[Lorg/compiere/util/Trx; A values()Ljava/util/Collection; java/util/Collection 8size  toArray(([Ljava/lang/Object;)[Ljava/lang/Object; collectionsLjava/util/Collection;trxs[Lorg/compiere/util/Trx;/Ljava/util/Collection;getActiveTransactions  run"(Lorg/compiere/util/TrxRunnable;)V  4(Ljava/lang/String;Lorg/compiere/util/TrxRunnable;)VrLorg/compiere/util/TrxRunnable;TrxRun  org/compiere/util/TrxRunnable ?  :  :fjava/lang/RuntimeException+org/adempiere/exceptions/AdempiereException  '(Ljava/lang/Throwable;)VlocalTrxLjava/lang/Throwable;java/sql/Savepoint getTimeout setTimeout(I)VtimeoutaddTrxEventListener'(Lorg/compiere/util/TrxEventListener;)V  addlistenerremoveTrxEventListener'(Lorg/compiere/util/TrxEventListener;)Z  getStrackTracejava/io/StringWriter &java/io/PrintWriter  '(Ljava/io/Writer;)V  !(Ljava/io/PrintWriter;)V # $% getBuffer()Ljava/lang/StringBuffer; '(java/lang/StringBuffer* stringWriterLjava/io/StringWriter; printWriterLjava/io/PrintWriter; 0 setChangesMadeByEventListener changesMadehasChangesMadeByEventListener5POSave 47 8B startsWithfinalize;org/compiere/util/Trx$1 := '>1(Lorg/compiere/util/Trx;Lorg/compiere/util/Trx;)V aB CeSECONDS gE FGschedule\(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;meregisterNullTrx    nullTrxNamenullTrxunregisterNullTrxlambda$0/(Ljava/util/stream/Stream;)Ljava/util/Optional; TVUjava/util/stream/Stream WXmap8(Ljava/util/function/Function;)Ljava/util/stream/Stream; Z [\test ()Ljava/util/function/Predicate; T^ _`filter9(Ljava/util/function/Predicate;)Ljava/util/stream/Stream; Tb cd findFirst()Ljava/util/Optional;framesLjava/util/stream/Stream;=Ljava/util/stream/Stream;lambda$3 Zlambda$16(Ljava/lang/StackWalker$StackFrame;)Ljava/lang/String; npo java/lang/StackWalker$StackFrame q getClassName ns t getMethodName nv w8 getLineNumbery z9(Ljava/lang/String;Ljava/lang/String;I)Ljava/lang/String; stackFrame"Ljava/lang/StackWalker$StackFrame;lambda$2 java/lang/Class getNameflambda$4ylambda$5org/compiere/db/StatementProxy jdk.proxyorg.compiere.util.DB. SourceFileTrx.javaBootstrapMethods "java/lang/invoke/LambdaMetafactory  metafactory(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;D  PQQ $java/lang/invoke/StringConcatFactory (Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;_;Illegal transaction name format, not prefix+UUID or UUID: Active=, Connection= Connection=Trx in progress ****  NullTrx_D  hQQD  kll  }BBD  ll  BB.:. InnerClassesOption StackFrame%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandlesLookup TrxMonitor NestMembers!    6 !"9#Y%(*Y,-/ m o0 12"@* *3 9Y;=(*@M,Y*EM(*,FW,/J KM"N*P3Q>S0 @J@K"LMN  ( 1OPQR"A* *3 9Y;=(*@N-Y*,SN(*-FW-/` ac"d*f4g?i0*AJAKAV"LMN  ) W!"8X-^^`fW/ ~0 lm"TL* *3,nKpr x~M,N-4L*K*M+,+*/2   -6CIMR04TR - I M - N 4( l"%/0'?"c**Y******* **++3$+M*²,Y,۶ܱ/:qw$).5@:?HOb0 cMcJONb4'UPQR"Q *+E*,/ 0  M J V"0*/0 M!"*²*²**ĸ*2,(*ƹY۶*** W r*Y*İ/:'.2AMOX[]dis~0MKN''  "O+*+*²*+*M*²,*Y'14!/*  '145CN0 OMO#5$%N !L!?"e+ +3 9Y;=*+Ʊ/ 0MJN &"/*ư/0 M "w,*ș**ƺ'(**+1*/#%&()%**+0 ,MN34"6 5Y*17/30  M"/*Ȭ/<0 M!:;<!" l*\*Ĺ=***ƶ? CF*ƺI**JM*²*,**J,**J>@!/>IKL4M9N>O@RATPUTWYX^Y`\e]j^0 lMlMA$%NeW!L"'*NN-RXM,*Z-^/fgf&i0 'M'abcN S:"O *dW!/rst0  MNF!:f<!"I*C*+g*²F**ƺjk*M*²*,,35!/& .356EG0 IMIn6$%N.F!!o;<!"P*o*Ĺp*²F**ƺrk**sM*²*,**s,,vN*--,|,W**s79!/F-279:IMRWY^sx}0*MM:9$%^N;-K!!!4!44u"'*NN-RXM,*-^/&0 'M'abcN So"O *W!/0  MNF!"2<*dW#M*²*,*<N*<-*< !#/.   #$)+00 2M0a $%N !W!"B(*W***Ĺ *WW*W*Ĺ *M*²*,*ĹM*²*,ܧL*Ĺ *M*²*,*ĹM*²*,+*Ĺ *M*²*,*ĹM*²*,*****²**ƶ .1!2<?!@VY!iru!2@!!!!/, ).2<?@ L V YZiruv      $(@ 0HBMZ$%$%$%v$%$%$%N=Z!L!Y!K!R!K!X!K!*!"}&*NM,RXL+*,^/'('%*0&MbcN S!<!".**W*+*+*Ĺ/34 678":,<0.M.N  !i">*+̱/ HI0Mn!"/*̰/Q0 M!i<!"|%**W* *+/\cegik$n0%M%nN "p,YL+*¶ɶ*ζW+а/w xy z'{0,M ! "o(K*L*+W+/ 0     P"$/0 "4*/ 0  "=* K=*N: -:+*V-WM: -W-WW Y:- -WN- -WN47JQT!mm/  #*.479=BEJQTU]cmow|~0>J|Myn94$Nc S N! 4448"/*ʬ/0 M  ">*ʱ/ 0M   "B *+W/  0 M c"= *+/0 M c",*$YLY+M*,+"&)/    (0 ,M+,-.N("J*/ */*ư/0 MNC4?">*+// #$0M1">*/ ,-0M23"/*/50 MAB"W++46/[\[0MJN9!<"x'*"**LX:Y*+<?ADW/bcdm"d&o0'MHMN& I" ^JKKY*EL+Y++1Mx~N-L:4M,+,(*+FW*/2 v wx y'z){0|>HLQ\04 RMINM)50.>  > NQ44 O?"f"(*@L++(*W/ !0"M NM PQ"g*RSY]a/ 0 ef eg hQ"g*iSj]a/|}| 0 ef eg kl"R*m*r*ux/ 0 {| }B"L*~6/0 N@ l"R*m*r*u/}~ }0 {| B"s=*~6)*~6*6 *6/0 =N7@*y@n :* :*