Edit C:\Users\Admin\.m2\repository\org\dspace\handle\6.2\net\handle\server\TransactionQueue.class
???? 0? ? ? ? ? ? ? ? ? ? ? ? ? ??????? ! " <# $% $&'( $)* )+ ), )-. )/ )0 12 3 45 467 &8 9 : ; <= <???????? <> <? <@ <A <BC <D ?EFG IH HI HJ KL KM NO PQ RS TUVWXY 'Z [ Z \] \H K^ _` _ab cd <e fg ?hi g ?j ?k l gm ?n ?o p ?qr s qt Ku )v Kwx qy qa a )z {|} K~ ? K? {??? '8 ???? ?? ???? Shutdown InnerClasses QueueScanner QueueFileEntry queueDir Ljava/io/File; queueIndexFile queueFiles Ljava/util/Vector; calendar Ljava/util/Calendar; lockFile queueListeners haveLock Z initialized <init> (Ljava/io/File;)V Code LineNumberTable LocalVariableTable this $Lnet/handle/server/TransactionQueue; Exceptions getFirstDate ()J entry 3Lnet/handle/server/TransactionQueue$QueueFileEntry; getLastTxnId txn Lnet/handle/hdllib/Transaction; scanner 1Lnet/handle/server/TransactionQueue$QueueScanner; t Ljava/lang/Throwable; e Ljava/lang/Exception; txnId J addQueueListener /(Lnet/handle/hdllib/TransactionQueueListener;)V l ,Lnet/handle/hdllib/TransactionQueueListener; removeQueueListener notifyQueueListeners "(Lnet/handle/hdllib/Transaction;)V i I getQueueFileName (Ljava/util/Date;)I dt Ljava/util/Date; initQueueIndex ()V dummyTxn line Ljava/lang/String; startDate firstTxnId queueNumber reader Ljava/io/BufferedReader; getLock out Ljava/io/OutputStream; releaseLock getCurrentQueue 5()Lnet/handle/server/TransactionQueue$QueueFileEntry; addTransaction (J[BBJ)V handle [B action B date now qnum currentQueue createNewQueue 8(JJI)Lnet/handle/server/TransactionQueue$QueueFileEntry; queueNum writer Ljava/io/FileWriter; newQueue record closeCurrentQueue qfe getNextQueue h(Lnet/handle/server/TransactionQueue$QueueFileEntry;)Lnet/handle/server/TransactionQueue$QueueFileEntry; presentQueue encodeTransaction 3(Lnet/handle/hdllib/Transaction;)Ljava/lang/String; sb Ljava/lang/StringBuffer; nextField (ILjava/lang/String;)I currPos txnStr decodeTransaction 3(Ljava/lang/String;)Lnet/handle/hdllib/Transaction; sepIdx finalize shutdown getScanner 2(J)Lnet/handle/hdllib/TransactionScannerInterface; nextEntry lastTxnID queueEntry access$000 4(Lnet/handle/server/TransactionQueue;)Ljava/io/File; x0 Synthetic access$300 ?(Lnet/handle/server/TransactionQueue;Lnet/handle/server/TransactionQueue$QueueFileEntry;)Lnet/handle/server/TransactionQueue$QueueFileEntry; x1 SourceFile TransactionQueue.java ? ? ? ? ? ? ? ? ? ? java/io/File lock ?? ? ? index ? ? java/util/Vector ? ???? ? ? ? ???? java/lang/Thread +net/handle/server/TransactionQueue$Shutdown ?? ???? ? ? ? ????? 1net/handle/server/TransactionQueue$QueueFileEntry?? /net/handle/server/TransactionQueue$QueueScanner ???? ? ??? ?? ? java/lang/Throwable java/lang/Exception?? java/lang/StringBuffer Error getting transaction ID: ???? using ??????????? *net/handle/hdllib/TransactionQueueListener? ? !error notifying queue listeners: ????????? ? net/handle/hdllib/Transaction ? ? ? ?? ?? ?? ? net/handle/hdllib/HandleValue?? ? ? java/io/BufferedReader java/io/FileReader ? ? ?????????????????? ?? Error: lock file ( ) exists. If you are sure Athat another server is not running, remove this file and restart the server Queue files are locked ?????? java/io/FileOutputStream?????? ? Cannot create lock file: ?? ,Error removing transaction queue lock file: ? ???? ? ? java/util/Date ? ? ? ?? ?? ? ? ? ? ??? ? ? java/io/FileWriter?? ???????? ??????? No more fields in transaction?? ? ????? #Exception decoding transaction: ? ? Error finalizing txn queue: 'Error shutting down transaction queue: ? ??? "net/handle/server/TransactionQueue java/lang/Object +net/handle/hdllib/TransactionQueueInterface #(Ljava/io/File;Ljava/lang/String;)V java/util/Calendar getInstance ()Ljava/util/Calendar; java/lang/Runtime getRuntime ()Ljava/lang/Runtime; '(Lnet/handle/server/TransactionQueue;)V (Ljava/lang/Runnable;)V addShutdownHook (Ljava/lang/Thread;)V size ()I elementAt (I)Ljava/lang/Object; access$100 6(Lnet/handle/server/TransactionQueue$QueueFileEntry;)J Z(Lnet/handle/server/TransactionQueue;Lnet/handle/server/TransactionQueue$QueueFileEntry;)V nextTransaction !()Lnet/handle/hdllib/Transaction; java/lang/System gc runFinalization err Ljava/io/PrintStream; append ,(Ljava/lang/String;)Ljava/lang/StringBuffer; ,(Ljava/lang/Object;)Ljava/lang/StringBuffer; (J)Ljava/lang/StringBuffer; toString ()Ljava/lang/String; java/io/PrintStream println (Ljava/lang/String;)V addElement (Ljava/lang/Object;)V removeElement (Ljava/lang/Object;)Z transactionAdded printStackTrace (Ljava/io/PrintStream;)V setTime (Ljava/util/Date;)V get (I)I exists ()Z length hashOnAll hashOnNA hashOnId values [Lnet/handle/hdllib/HandleValue; (Ljava/io/Reader;)V readLine java/lang/String trim net/handle/util/StringUtils fieldIndex ((Ljava/lang/String;CI)Ljava/lang/String; java/lang/Long parseLong (Ljava/lang/String;)J java/lang/Integer parseInt (Ljava/lang/String;)I *(Lnet/handle/server/TransactionQueue;JJI)V getParent mkdirs getBytes ()[B java/io/OutputStream write ([B)V close delete net/handle/hdllib/SiteInfo getHandleHash ([BI)I getQueueNumber getTime writeRecord getAbsolutePath (Ljava/lang/String;Z)V valueOf (J)Ljava/lang/String; (C)Ljava/lang/StringBuffer; (I)Ljava/lang/String; (I)Ljava/lang/StringBuffer; net/handle/hdllib/Util decodeHexString ([BZ)Ljava/lang/String; charAt (I)C substring (II)Ljava/lang/String; encodeHexString (Ljava/lang/String;)[B access$200 ! ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? d*? *? *? *+? *? Y+? ? *? Y+ ? ? *? Y? ? *? ? *? ? ? Y? Y*? ? ? *? *? ? ? 6 f + , g h ! i / j : l A n E r Z t ^ u c v ? d ? ? d ? ? ? ' ! ? ? ? [ *? ? ? ?*? ? ? L+? ? ? y z { ? ? ? ? ? ! ? ? ? ? ?*? ? ? ? @? Y**? *? ? d? ? ? !N-? ":? ? #@? ? ??? $? %? GN? CN? (? )Y? *+? ,-? -.? ,? /? 0? 1? $? %? N? :? $? %? :?? F L O &