Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\drivers\aq\AQMsgConsumer.class
?? 1? ? ? ? ? ? ? ? ? ? ? ? ? ? ?!" #$% ?&' ?( ?)* ?+, - ./0 ?12 )3 #45 #6 )78 ?9 ': '; .< .= .> .?@ #A BC #D ?E .F .G HI J: JK ?L ?M )NO DP DQ ?R D- )ST KUV MW ?XY PUZ RU[ TW\ VU] XW^ BX #_` /a #b cF cG ?d ?ef #gh fi fj #k #l ?mn fo pqr ?s ?t ?uv fwx fy z{ |} z~ z z? z?? #? z?? ??? ??? ?? ??? ?????? InnerClasses MgwTibrvMsg_Dequeuer FlatMgwBasicMsg_Dequeuer MgwBasicMsg_Dequeuer RAW_Dequeuer? Dequeuer DEBUG Z ConstantValue m_tracer Loracle/mgw/common/Trace; m_queue Ljava/lang/String; m_subName m_payloadType m_transformation m_transformType m_isLogConsumer m_consId m_mesgType I m_isBrowser m_firstBrowse m_opHandle "Loracle/mgw/drivers/aq/AQOPHandle; m_dequeuer .Loracle/mgw/drivers/aq/AQMsgConsumer$Dequeuer; m_mapper &Loracle/mgw/drivers/aq/MapConsumerMsg; m_logDequeueTiming m_logDeqOpTiming m_testBadMsgs m_checkBadMsgs m_overrideOptions Ljava/util/Hashtable; <init> ?(Loracle/mgw/drivers/aq/AQConsumerParams;Loracle/mgw/common/OPHandle;Loracle/mgw/drivers/aq/TransformData;Loracle/mgw/common/Trace;)V Code LineNumberTable LocalVariableTable this %Loracle/mgw/drivers/aq/AQMsgConsumer; params (Loracle/mgw/drivers/aq/AQConsumerParams; oph Loracle/mgw/common/OPHandle; transformation %Loracle/mgw/drivers/aq/TransformData; tracer ?(Loracle/mgw/drivers/aq/AQConsumerParams;Loracle/mgw/common/OPHandle;Loracle/mgw/drivers/aq/TransformData;Loracle/mgw/common/Trace;Ljava/util/Hashtable;)V overrideOptions toTraceString ()Ljava/lang/String; sb Ljava/lang/StringBuffer; init s aqDest "Loracle/mgw/drivers/aq/AQDestData; initDequeuerMapper ()V flatMgwBasicMsg ()Z getId destroy getTransformation getConnection ()Ljava/sql/Connection; setLogTimingFlags (I)V flags alter &(Loracle/mgw/drivers/ConsumerParams;)V newParams #Loracle/mgw/drivers/ConsumerParams; Exceptions? dequeue ()Loracle/mgw/common/Message; mgwMessage Loracle/mgw/common/MgwMessage;?? :(Loracle/mgw/common/MessageID;)Loracle/mgw/common/Message; msgId Loracle/mgw/common/MessageID; resetBrowser doDequeue =(Loracle/mgw/common/MessageID;)Loracle/mgw/common/MgwMessage; aqMessage !Loracle/mgw/drivers/aq/AQMessage; itmr Loracle/mgw/drivers/aq/ITimer; checkBadMessage !(Loracle/mgw/common/MgwMessage;)V aqHdr Loracle/mgw/common/MsgHeader; message testBadMessage constructLogMessage >(Loracle/mgw/common/MgwMessage;)Loracle/mgw/common/LogMessage; errm jobId logRec [B msgBody Loracle/mgw/common/MsgBody; access$400 9(Loracle/mgw/drivers/aq/AQMsgConsumer;)Ljava/lang/String; x0 access$500 ((Loracle/mgw/drivers/aq/AQMsgConsumer;)Z access$600 access$700 access$800 access$900 @(Loracle/mgw/drivers/aq/AQMsgConsumer;)Loracle/mgw/common/Trace; SourceFile AQMsgConsumer.java ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? java/lang/StringBuffer ? ? object : ???? consId : ? ? logConsumer : ? ??? browser : queue : subName : payload : ? ? transform : ??? dequeuer : ? ? mapper : ? ? ? ? testBadMsgs : ? ? checkBadMsgs: ? ???? oracle/mgw/drivers/aq/AQDestData ? ? oracle/mgw/common/Trace? ??? :?? ?? oracle/mgw/drivers/aq/AQOPHandle ? ?? ?? ?? ?? ?? ? ? ? oracle.mgw.aq_log_timing_events??????? ? ?? ?? ?????? ? ? ? ? ??? java/lang/StringBuilder MsgConsumer created: ?? ? ??? 0oracle/mgw/drivers/aq/AQMsgConsumer$RAW_Dequeuer ?? (oracle/mgw/drivers/aq/MapConsumerMsg_RAW ?? ? ? <oracle/mgw/drivers/aq/AQMsgConsumer$FlatMgwBasicMsg_Dequeuer 8oracle/mgw/drivers/aq/AQMsgConsumer$MgwBasicMsg_Dequeuer 0oracle/mgw/drivers/aq/MapConsumerMsg_MgwBasicMsg 8oracle/mgw/drivers/aq/AQMsgConsumer$MgwTibrvMsg_Dequeuer 0oracle/mgw/drivers/aq/MapConsumerMsg_MgwTibrvMsg oracle.mgw.flat_mgwbasicmsg?? MsgConsumer destroyed: ? ???? ? ? ? ? MessageID?? oracle/mgw/drivers/aq/ITimer entering dequeue???????? after dequeueMessage????? after mapMessage ? ? ? ?? ? leaving dequeue?? dequeue timing (ms): ? ?????? ???? ?? ??? test error: bad source message???? oracle/mgw/common/MgwRawBody?? oracle/mgw/common/MgwBasicBody +conversion to LogMessage not supported for ???? ? oracle/mgw/common/LogMessage ?? #oracle/mgw/drivers/aq/AQMsgConsumer java/lang/Object oracle/mgw/common/MsgConsumer %oracle/mgw/drivers/aq/AQMsgConsumer$1 ,oracle/mgw/drivers/aq/AQMsgConsumer$Dequeuer "oracle/mgw/common/GatewayException "oracle/mgw/common/MessageException oracle/mgw/common/FatalException append ,(Ljava/lang/String;)Ljava/lang/StringBuffer; ,(Ljava/lang/Object;)Ljava/lang/StringBuffer; (Z)Ljava/lang/StringBuffer; oracle/mgw/common/MgwUtil nvl_empty &(Ljava/lang/Object;)Ljava/lang/String; toString &oracle/mgw/drivers/aq/AQConsumerParams getDestination ()Loracle/mgw/common/DestData; getMsgPrefix classNRef concat J(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; .(Loracle/mgw/common/Trace;Ljava/lang/String;)V getFullName getPayloadType getSubName isBrowser isLogConsumer getString M(Ljava/util/Hashtable;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; oracle/mgw/common/MgwConstants AQLogTimingEvents ()I str2int (Ljava/lang/String;I)I testBadMsgs checkBadMsgs #oracle/mgw/drivers/aq/AQMessageType getTypeCode (Ljava/lang/String;)I #oracle/mgw/drivers/aq/TransformData getTargetType isLevel (I)Z -(Ljava/lang/String;)Ljava/lang/StringBuilder; trace (Ljava/lang/String;I)V O(Loracle/mgw/drivers/aq/AQMsgConsumer;Loracle/mgw/drivers/aq/AQMsgConsumer$1;)V (Loracle/mgw/common/Trace;)V str2boolean (Ljava/lang/String;Z)Z isBitSet (II)Z !oracle/mgw/drivers/ConsumerParams GatewayException N(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException; start (Ljava/lang/String;)V `(Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/GatewayException; r(Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/common/GatewayException; dequeueMessage @(Loracle/mgw/common/MessageID;)Loracle/mgw/drivers/aq/AQMessage; mark $oracle/mgw/drivers/aq/MapConsumerMsg mapMessage A(Loracle/mgw/drivers/aq/AQMessage;)Loracle/mgw/common/MgwMessage; freeTempLobs stop eventsToString oracle/mgw/common/MgwMessage getAQHeader ()Loracle/mgw/common/MsgHeader; oracle/mgw/common/MsgHeader getCorrelationId badMsgStringToFlags setBadMsgFlags isBadSourceMessage getMsgId ()Loracle/mgw/common/MessageID; MessageException k(Loracle/mgw/common/MessageID;Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/MessageException; getMsgBody ()Loracle/mgw/common/MsgBody; getRawValue ()[B getClass ()Ljava/lang/Class; java/lang/Class getName 4(Loracle/mgw/common/MessageID;[BLjava/lang/String;)V ! ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? #*? *? *? *? *? *+,-? ? ? ? ? ? ? ? ? "