Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\drivers\rv\RVTransactQueue.class
?? 1} e ? e ? e ? f ? e ? e ? e ? ? ? e ? e ? e ? e ? e ? ? ? ? ? ? ? ? ? ? ? ? e ? ? ? ? ? ? ? ? e ? ? ? ? ? ? ? ? ? ? ? ? ? , ? , , ? ? e e e e e e < < ? ? < < ? !" <#$% &'()* ?+,-. ,/01234 ,5 6789: ?; <=>? MessageHandler InnerClasses m_subID Ljava/lang/String; m_subject m_transport Lcom/tibco/tibrv/TibrvTransport; m_options Ljava/util/Hashtable; m_queue Lcom/tibco/tibrv/TibrvQueue; m_listener Lcom/tibco/tibrv/TibrvListener; m_withAQProp Z m_testBadMsg m_checkBadMsg m_limit I m_maxEvent m_discard m_msgBuffer '[Loracle/mgw/drivers/rv/RVQueueElement; m_head m_next m_tail m_bufsize m_logger Loracle/mgw/common/MgwLog; FACILITY ConstantValue COMPONENT MAX_NUM_MSGS_IN_REQUEST <init> ](Ljava/lang/String;Ljava/lang/String;Lcom/tibco/tibrv/TibrvTransport;Ljava/util/Hashtable;I)V Code LineNumberTable LocalVariableTable te Lcom/tibco/tibrv/TibrvException; ne !Ljava/lang/NumberFormatException; i this 'Loracle/mgw/drivers/rv/RVTransactQueue; subID subject transport options maxCons aqPropStr limitStr maxEventStr discardStr testBadStr checkBadStr Exceptions@ moveMsg N(Ljava/lang/String;Loracle/mgw/common/MessageID;)Loracle/mgw/common/MessageID; errMsg msg Lcom/tibco/tibrv/TibrvMsg; ex_subject mid Loracle/mgw/common/MessageID; receiveByID :(Loracle/mgw/common/MessageID;)Loracle/mgw/common/Message; Loracle/mgw/common/Message; elem &Loracle/mgw/drivers/rv/RVQueueElement;A receiveMsg ()Loracle/mgw/common/Message; ie Ljava/lang/InterruptedException; dispatched commit (II)V startPos numElems idxB rollback allRollback getNextPosition ()I getCount numInBuf numInQueue destroy ()V setOptions (Ljava/util/Hashtable;)V s opt access$000 P(Loracle/mgw/drivers/rv/RVTransactQueue;)[Loracle/mgw/drivers/rv/RVQueueElement; x0 access$108 *(Loracle/mgw/drivers/rv/RVTransactQueue;)I access$100 access$200 access$102 +(Loracle/mgw/drivers/rv/RVTransactQueue;I)I x1 <clinit> SourceFile RVTransactQueue.java ? y ? y | } ? ? x y z y { yC DE ? ? i j k j l m n o AQ_MSGPROPERTIESF GH java/lang/String RV_LIMITPOLICY RV_MAXEVENTS RV_DISCARDAMOUNT TEST_BAD_MESSAGES CHECK_BAD_MESSAGES com/tibco/tibrv/TibrvQueue p q com/tibco/tibrv/TibrvExceptionI JK com/tibco/tibrv/TibrvListener 4oracle/mgw/drivers/rv/RVTransactQueue$MessageHandler ?L ?M r s ? ? DISCARD_NONE NO DISCARD_FIRST DISCARD_LAST DISCARD_NEWP QR java/lang/NumberFormatException ST UV RVD java/lang/StringBuilder :listener and event queue have been created for subscriber WX limitPolicy = MaxEvent = discardAmount = YZ [\ ]^ t u v u w u ? y ~ y y $oracle/mgw/drivers/rv/RVQueueElement _` abc $the message to move with messgae id d eZ is not in the buffer Jf ghi jkl mn op qV #moved a message to exception queue for subscriber rs 2receiveByID is returning a message for subscriber %dispatching a message for subscriber t` java/lang/InterruptedException 2receive is NOT returning a message for subscriber .receive is returning a message for subscriber RV driver commits out of order. uv RV commit error. %commit a transaction for subscriber with startPost = Ww numElems = RV rollback error. 'rollback a transaction for subscriber m_next = allRollback = Wx ? ? msgs in buffer, msgs in event queue for subscriber 3listener and event queue are closed for subscriber yz{ | y %oracle/mgw/drivers/rv/RVTransactQueue java/lang/Object "oracle/mgw/common/GatewayException "oracle/mgw/common/MessageException oracle/mgw/common/FatalException oracle/mgw/common/MgwLog getMgwLogger ()Loracle/mgw/common/MgwLog; java/util/Hashtable get &(Ljava/lang/Object;)Ljava/lang/Object; oracle/mgw/common/MgwUtil GatewayException `(Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/GatewayException; *(Loracle/mgw/drivers/rv/RVTransactQueue;)V ?(Lcom/tibco/tibrv/TibrvQueue;Lcom/tibco/tibrv/TibrvMsgCallback;Lcom/tibco/tibrv/TibrvTransport;Ljava/lang/String;Ljava/lang/Object;)V equals (Ljava/lang/Object;)Z java/lang/Integer parseInt (Ljava/lang/String;)I setLimitPolicy (III)V isTRACE_LITE (I)Z append -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; trace )(Ljava/lang/String;Ljava/lang/String;II)V str2boolean (Ljava/lang/String;Z)Z isConsumed ()Z getID %()Loracle/mgw/drivers/rv/RVMessageID; !oracle/mgw/drivers/rv/RVMessageID oracle/mgw/common/MessageID getIDAsString N(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException; getRVMsg ()Lcom/tibco/tibrv/TibrvMsg; com/tibco/tibrv/TibrvMsg setSendSubject (Ljava/lang/String;)V com/tibco/tibrv/TibrvTransport send (Lcom/tibco/tibrv/TibrvMsg;)V setConsumed (Z)V isTRACE_HIGH getMessage (ZZZ)Loracle/mgw/common/Message; poll FatalException L(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/FatalException; (I)Ljava/lang/StringBuilder; (Z)Ljava/lang/StringBuilder; getString M(Ljava/util/Hashtable;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; oracle/mgw/common/MgwConstants MAX_BATCH_SIZE e f i j k j l m n o p q r s t u v u w u x y z y { y | } ~ y y ? y ? y ? ? ? j ? + ? y ? ? ? y ? ? ? }*? *? *? *? *? ? :::: : : *+? *,? *-? *? *? ? K? ? :? ? :? ? :? ? : ? ? : ? ? : *? Y? ? ? : ?*? *? ? ?*? Y*? ? Y*? *? *? ? ? ? : *? ? ?*? *? ? ?? !? "? *? ? W#? "? *? ? E$? "? *? ? 3%? "? *? ? !*? ? &*? ? ?*? *? ? ?? *? '? ? * ? '? ? $: *? ? &*? ? ?*? *? ? ?*? *? *? *? ? )? $: *? ? &*? ? ?*? *? ? ?*? ? *? D*? +? ,Y? -.? /*? ? /0? /? /1? /? /2? / ? /? 3 ? 4*? 5? 6* ? 5? 7* ? 5? 8*? 9h`? *? :*? ;*? **? ? <? 6 *? ? *? S? ?? ? ? ? ? ? ? Yux (??? ? G T ; < = H V W X # Y & Z ) [ , ] 1 ^ 6 _ ; ` A b H f T g ` h l i x j ? l ? q ? w ? r ? s ? z ? ? ? ? ? ? ? ? ? ? ? ? ? ?! ?) ?3 ?; ?B ?I ?Y ?^ ?g ?l ?u ?x ?z ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ? ?( ?2 ?< ?H ?M ?R ?W ?b ?n ?v ?| ? ? ? ? ? ? ? ? ? z ? ? ? ? ? e ? y } ? ? } ? j } ? j } ? m } ? o } ? y ` ? j ] ? j #Z ? j &W ? j )T ? j ,Q ? j ? ? ? ? ? w ?*? *? ;2? %*? *? ;2? =? *? *? ;2? >,? ?? *? ,Y? -@? /,? A ? /B? /? 3N ?-? C?*? *? ;2? DN-+? E*? -? F*? *? ;2? G*Y? ;`? ;*? ;*? ? *? ;*? ? H? /*? +? ,Y? -I? /+? /J? /*? ? /? 3 ? 4,?-?+? C? U ? ? ? > ? . ? L ? U ? b ? g ? o ? | ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? > L ? j b o ? ? ? ? ? ? ? ? ? ? j ? ? ? ? ? ? ? ? ? ?M*? *? ;2N-? u-? =? n-? >+? ?? c-*? 6*? 7*? 8? KM-? G*Y? ;`? ;*? ;*? ? *? ;*? ? H? &*? +? ,Y? -L? /*? ? /? 3 ? 4,? ? . ? ? ? " ? 3 ? 8 ? B ? M ? R ? _ ? ? ? * ? ? ? ? ? ? ? ? ? x ? ? ? ? ? ? ? ? ? L*? *? ;2M>,? d*? ? H? &*? +? ,Y? -M? /*? ? /? 3 ? 4*? ? N>? ):?*? *? ? ?:?*? *? ? ? ? =*? *? ;2M,*? 6*? 7*? 8? KL,? G*Y? ;`? ;*? ;*? ? *? ;*? ? H? P+? )*? +? ,Y? -P? /*? ? /? 3 ? 4? &*? +? ,Y? -Q? /*? ? /? 3 ? 4+? B J M B J ` O ? b B J M O ` b s" w# ?$ ?% ?& ?' ?( ?+ ?, ?- ?1 5 ? > O ? ? b ? ? ? ? ? ? ? ? ? ? u ? ? ? ? ? ? P ?*? :? ?R? S?*? :>6 ? ? *? ? >*? 2:? ? =? *? S? ?T? S????* ? :*? :*? ? *? :*? ? H? 8*? +? ,Y? -U? /*? ? /V? /? WX? / ? W? 3 ? 4? ? F : ; > ? @ (A *C 2D ?E IG S? \L aM lN qP ~Q ?V ? > 2 ! ? ? B ? y ? ? ? ? ? y ? ? y ? ? y ? ? ? ? ? ? ?>6 ? > *? ? >*? 2:? ? =? ? G? ?Y? S????6*? :6? 1*? ? 6*? ;? ? *? 2? =? 6???? **? :? ;*? ? H? N*? +? ,Y? -Z? /*? ? /V? /? WX? / ? W[? /*? ;? W\? /? ]? 3 ? 4? ? ^ Z [ \ ] _ ` *a 3c =[ Fn Io Tp ]q `x iy l{ y| |o ? ?? ?? ?? ?? ? R ? ? A ? y O 3 ? y ? ? ? ? ? y ? ? y ? ? y I ? ? u ? ? ? ? ? / *? ;? ? ? ? ? ? ? ? ? ?*? *? ;? *? *? ;d<? *? *? ;d*? `<*? ? ^=? N-?*? ? C?*? ? H? 8*? +? ,Y? -? W_? / ? W`? /a? /*? ? /? 3 ? 4 `? ' / 2 ? * ? ? ? '? /? 2? 3? ?? L? ?? ? 4 ? y 3 ? ? ? ? ? ' ^ ? y / V ? y ? ? ? ? ? y ?*? ? *? &*? +? ,Y? -b? /*? ? /? 3 ? 4*? ? &*? ? ? ? ? ? 0? 7? >? ? ? ? ? ? ? ? ? @*+? *? ? 6+? cM*,? 5? 6+? cM*,? 5? 7+? cM*,? 5? 8? ? & ? ? ? ? ? %? .? 6? ?? ? + ? j @ ? ? @ ? o ? ? ? / *? ? ? 0 ? ? ? ? ? ? 6 *Y? Z`? ? ? 0 ? ? ? ? ? ? / *? ? ? 0 ? ? ? ? ? ? / *? ? ? 0 ? ? ? ? ? ? ; *Z? ? ? 0 ? ? ? ? y ? ? ? ? d? 9? ? M ? ? h e g
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de