Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\drivers\aq\AQMsgProducer.class
?? 1K ?6 ?7 ?8 ?9 ?: ?; ?< ?=> ?? ?@A BC D EF ?GH ?I JKL ?MN OPQ ?RS ?T ?UV ?WXYZ ?[ \]^_` ?a Obcde f ghi ?jk 4l Omn Oo 4pq ?r 2s 2t gu gvw Ox yz O{ ?| g} g~ ? ?? ?s ?? ?? ?? 4?? N9? N? ?? Nf 4?? U?? W?? Y?? ?? [?? ^?? `?? y? O?? :? O? ?} ?~? O???? ??? O? ??? s9? s? O? ?? ?? ??? s? ?? l? ??? ??? s?? s? ?? l? l? ??? 4? l?? O? m?? ??? m? ?? l?? O??? ???? O?? ????? l?? ?? ?????? ?????? InnerClasses MgwTibrvMsg_Enqueuer MgwBasicMsg_Enqueuer RAW_Enqueuer? Enqueuer DEBUG Z ConstantValue m_tracer Loracle/mgw/common/Trace; m_queue Ljava/lang/String; m_schema m_payloadType m_transformation m_transformType m_isLogProducer m_prodId m_mesgType I m_opHandle "Loracle/mgw/drivers/aq/AQOPHandle; m_enqueuer .Loracle/mgw/drivers/aq/AQMsgProducer$Enqueuer; m_mapper &Loracle/mgw/drivers/aq/MapProducerMsg; m_logEnqueueTiming m_logEnqOpTiming m_testBadMsgs m_checkBadMsgs m_overrideOptions Ljava/util/Hashtable; m_testCharacterMapError_enabled !m_testCharacterMapError_appendStr <init> ?(Loracle/mgw/drivers/aq/AQProducerParams;Loracle/mgw/common/OPHandle;Loracle/mgw/drivers/aq/TransformData;Loracle/mgw/common/Trace;)V Code LineNumberTable LocalVariableTable this %Loracle/mgw/drivers/aq/AQMsgProducer; params (Loracle/mgw/drivers/aq/AQProducerParams; oph Loracle/mgw/common/OPHandle; transformation %Loracle/mgw/drivers/aq/TransformData; tracer ?(Loracle/mgw/drivers/aq/AQProducerParams;Loracle/mgw/common/OPHandle;Loracle/mgw/drivers/aq/TransformData;Loracle/mgw/common/Trace;Ljava/util/Hashtable;)V overrideOptions toTraceString ()Ljava/lang/String; appendStr uee &Ljava/io/UnsupportedEncodingException; sb Ljava/lang/StringBuffer; init s aqDest "Loracle/mgw/drivers/aq/AQDestData; initEnqueuerMapper ()V flatMgwBasicMsg ()Z getId destroy getTransformation getConnection ()Ljava/sql/Connection; setLogTimingFlags (I)V flags alter &(Loracle/mgw/drivers/ProducerParams;)V newParams #Loracle/mgw/drivers/ProducerParams; Exceptions? enqueue :(Loracle/mgw/common/Message;)Loracle/mgw/common/MessageID; message Loracle/mgw/common/Message; mgwMessage Loracle/mgw/common/MgwMessage;? doEnqueue =(Loracle/mgw/common/MgwMessage;)Loracle/mgw/common/MessageID; msgId Loracle/mgw/common/MessageID; aqMessage !Loracle/mgw/drivers/aq/AQMessage; itmr Loracle/mgw/drivers/aq/ITimer; checkBadMessage B(Loracle/mgw/common/MgwMessage;Loracle/mgw/drivers/aq/AQMessage;)V sqlE Ljava/sql/SQLException; aqProps 0Loracle/mgw/drivers/aq/sqlj/MgwAqMessageProps_T; testBadMessage !(Loracle/mgw/common/MgwMessage;)V constructLogMessage >(Loracle/mgw/common/LogMessage;)Loracle/mgw/common/MgwMessage; Loracle/mgw/common/LogMessage; jobId msgHdr Loracle/mgw/common/MsgHeader; msgBody Loracle/mgw/common/MgwRawBody; testCharacterMapError_init cs ba [B cbh "testCharacterMapError_alterMessage appendLen newValue newsub body Loracle/mgw/common/MgwBasicBody; oldValue msg access$300 9(Loracle/mgw/drivers/aq/AQMsgProducer;)Ljava/lang/String; x0 access$400 access$500 @(Loracle/mgw/drivers/aq/AQMsgProducer;)Loracle/mgw/common/Trace; SourceFile AQMsgProducer.java ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? java/lang/StringBuffer ? ? object : ?? ?? prodId : ? ? logProducer : ? ? ?? queue : payload : ? ? transform : ? ?? enqueuer : ? ? mapper : ? ? ? ? testBadMsgs : ? ? checkBadMsgs: testCharacterMapError : length : ?? ?? String : < > UTF-8 bytes : UTF-8 ?? ?? UTF-16 bytes: UTF-16 $java/io/UnsupportedEncodingException ? ?? ?? oracle/mgw/drivers/aq/AQDestData ? ? oracle/mgw/common/Trace ? ? ?? : ?? ?? oracle/mgw/drivers/aq/AQOPHandle ? ? ? ? ? ? ? ? oracle.mgw.aq_log_timing_events ? ? ? ? ? ! ? ? ? ? ? ? java/lang/StringBuilder MsgProducer created: ? ? ? 0oracle/mgw/drivers/aq/AQMsgProducer$RAW_Enqueuer ? (oracle/mgw/drivers/aq/MapProducerMsg_RAW ? 8oracle/mgw/drivers/aq/AQMsgProducer$MgwBasicMsg_Enqueuer 0oracle/mgw/drivers/aq/MapProducerMsg_MgwBasicMsg ? ? ? 8oracle/mgw/drivers/aq/AQMsgProducer$MgwTibrvMsg_Enqueuer 0oracle/mgw/drivers/aq/MapProducerMsg_MgwTibrvMsg oracle.mgw.flat_mgwbasicmsg ? ? MsgProducer destroyed: Message oracle/mgw/common/MgwMessage oracle/mgw/common/LogMessage -MsgProducer is not configured as log producer MgwMessage oracle/mgw/drivers/aq/ITimer entering enqueue ! &" #$ after mapMessage % &' () after enqueueMessage * ? leaving enqueue + enqueue timing (ms): , ?- ./ 0? 123 4 java/sql/SQLException 56 7 ? #test error: bad destination message 89 : ? oracle/mgw/common/MsgHeader ?; oracle/mgw/common/MgwRawBody <= ?> ?? #oracle.mgw.aq_testCharacterMapError @ testCharacterMapError enabled -oracle.mgw.aq_testCharacterMapError_charBytesA BC +oracle.mgw.aq_testCharacterMapError_charSet UTF-16BE D? java/lang/String ?E charSet : charBytes: append text: FG oracle/mgw/common/MgwBasicBody H ? I2 $testCharacterMapError_alterMessage: oldLen: newLen: 2 last 3 chars of original text plus appended text: J #oracle/mgw/drivers/aq/AQMsgProducer java/lang/Object oracle/mgw/common/MsgProducer %oracle/mgw/drivers/aq/AQMsgProducer$1 ,oracle/mgw/drivers/aq/AQMsgProducer$Enqueuer "oracle/mgw/common/GatewayException "oracle/mgw/common/MessageException 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; length ()I (I)Ljava/lang/StringBuffer; getBytes (Ljava/lang/String;)[B bytesToHex ([B)Ljava/lang/String; toString &oracle/mgw/drivers/aq/AQProducerParams 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 isLogProducer getString M(Ljava/util/Hashtable;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; oracle/mgw/common/MgwConstants AQLogTimingEvents str2int (Ljava/lang/String;I)I testBadMsgs checkBadMsgs #oracle/mgw/drivers/aq/AQMessageType getTypeCode (Ljava/lang/String;)I #oracle/mgw/drivers/aq/TransformData getSourceType isLevel (I)Z -(Ljava/lang/String;)Ljava/lang/StringBuilder; trace (Ljava/lang/String;I)V O(Loracle/mgw/drivers/aq/AQMsgProducer;Loracle/mgw/drivers/aq/AQMsgProducer$1;)V (Loracle/mgw/common/Trace;)V 1(Ljava/sql/Connection;Loracle/mgw/common/Trace;)V str2boolean (Ljava/lang/String;Z)Z isBitSet (II)Z !oracle/mgw/drivers/ProducerParams GatewayException N(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException; `(Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/GatewayException; start (Ljava/lang/String;)V r(Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/common/GatewayException; $oracle/mgw/drivers/aq/MapProducerMsg mapMessage A(Loracle/mgw/common/MgwMessage;)Loracle/mgw/drivers/aq/AQMessage; mark getMsgId ()Loracle/mgw/common/MessageID; enqueueMessage ?(Loracle/mgw/drivers/aq/AQMessage;Loracle/mgw/common/MessageID;Loracle/mgw/drivers/aq/MapProducerMsg;)Loracle/mgw/drivers/aq/AQMessageID; freeTempLobs stop eventsToString oracle/mgw/drivers/aq/AQMessage getMessageProps 2()Loracle/mgw/drivers/aq/sqlj/MgwAqMessageProps_T; getBadMsgFlags badMsgFlagsToString (I)Ljava/lang/String; .oracle/mgw/drivers/aq/sqlj/MgwAqMessageProps_T setCorrelation exception (Ljava/lang/Throwable;)V isBadDestinationMessage MessageException k(Loracle/mgw/common/MessageID;Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/MessageException; getJobId [(IILjava/lang/String;ILjava/lang/String;Ljava/sql/Timestamp;Loracle/mgw/common/MessageID;)V getRawLog ()[B ([B)V [(Loracle/mgw/common/MessageID;Loracle/mgw/common/MsgHeader;Loracle/mgw/common/MsgBody;ZIZ)V getBoolProperty java/lang/System getProperty 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; hexToBytes ([BLjava/lang/String;)V getMsgBody ()Loracle/mgw/common/MsgBody; getTextValue substring setTextValue ! ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? )*? *? *? *? *? * ? *+,-? ? ? " ? ? ? ? ? ? ? (? ? 4 ) ? ? ) ? ? ) ? ? ) ? ? ) ? ? ? ? ? ? **? *? *? *? *? * ? *+,-? ? ? " ? ? ? ? ? ? ? )? ? > * ? ? * ? ? * ? ? * ? ? * ? ? * ? ? ? ? ? o ? Y? ? *? ? *? ? ? *? ? ? *? ? ? *? ? ? *? ? ? ? *? ? ? ? *? ? ? L*? ? + ? *? ? W*? !? +"? *? !? W*? ? S*? M+#? ? $? ,? %? &'? ,? (? )? ,*? +? ,? -? ,.? +? ,? W? M+? 0? ? ? ? / ? . ? q? x? ?? ?? ? ? ? ? ? ? ? * ? G ? ? ? ? ? ? ? ? q ? ? ? ? ? ? ? ?+? 1? 2:*? 3*? 4Y? 5*? 67? 8? 9? *,? :? ;*? <? *? =? *+? >? *+? ?? *? 3@? A:*? B? C? D*+? E? *+? F? !*? ? *? G-? **? ? H? ? *-? I? *-? J? K**? K? H? *? L*? ? M? !*? ? NY? OP? Q*? R? Q? S? T? ? ^ 7 9 < *@ 2A ;B DC LD TH `J lM tN |Q ?R ?X ?[ ?` ?a ?b ?f ?h ?i ?k ? R ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ` ? ? ? ? ? ? ? ? ? ? ?*? *? *? ? 9 \*? UY*? V? *? WY*? ? X? ? I*? YY*? Z? *? [Y*? \*? ? ]? ? &*? ^Y*? _? *? `Y*? \*? ? a? ? ? ? 6 v w y (| 5} D~ G? T? g? j? w? ?? ?? ? ? ? ? ? ? ? K *? 3b? AL+? c? d? ? ? ? ? ? ? ? ? ? ? ? / *? ? ? ? ? ? ? ? ? ? ? q*? ;*? *? *? ? M? Y? Y? ? *? ? *? ? ? *? ? ? *? ? L*? ? NY? Oe? Q+? 0? Q? S? T? ? ? ? ? ? ? R? p? ? R ? ? q ? ? ? ? ? / *? ? ? ? ? ? ? ? ? ? D *? ;? ?*? ;? f? ? ? ? ? ? ? ? ? ? ? P *? g? *? g? ? ? ? ? ? ? ? ? ? ? ? M *+? h? *+? i? !? ? ? ? ? ? ? ? ? U+? ?j? k?M+? l? +? lM? 2+? m? *? ? ?n? k?+? m? oM? ?jp? q?*,? r? ? . = > @ B D F 'I .K 8O CS OW ? U ? ? U D ? ? MN:*? ? ? sY? t:u? v+? ?p? k?*? ? *? ? /*? ? ?*? *? ? q??*? K*? *? ? w?*? ? *+? x*? ? *+? y*? +? zN*? ? {? |*? !? *? ? *+-? }*? -+? ~*? ? M*? ? ?? |*? ? ? :*? ? ??*? ? )? ?*? ? NY? O? Q? ? Q? S? T,? ? ? ? ? ? ? ? ~ ? ? ? ? ? ? ? #? -? =? E? U? i? p? u? |? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ??? ? 4 ? ? ? ? (,? ?-? +? ?6-? ? ? :*? ? ? ? ? " ? ? ? ? ? ? ? '? ? > ? ? ( ? ? ( ( # ? [ +? +? ? +? ~ ?? ?? ? ? ? ? ? ? 5*? ?*? ?? ?+? ?? ?*? ? ?? lY,-? ? ? 7 8 ; = G 'J ? * 5 ) ? ' ! ? ? } ??? ? ? Y ? ? L*? M?? ?-? 3?? ?:-? ?:? ?? ?+? ? ? -? W+? $? ,? %? &'? ,? (? )? ,*? +? ,? -? ,.? +? ,? W*? ? M? *? +? 0? T*? *,? ? L*? +? ? ? ? / ? J V [ _ b %d *f 3i 9j El Zp ?x ?y ?| ?} ?? ? ?? ?? ? H 3 '" ? 9 !#$ ? ? ? ? ? ? % ?% ? ? ? ? ? ? ? & ? ? ?+? ?*? ? +? ? ? ?+? ? ?,? ?-? ?*? :? %6? NY? O-? Q? Q? S:? %`d? ?:? Y? ? ? -? %? &? ? %? &? '? ? (? )? *? +? ,? -? .? +? ,? :*? ? M? *? ? 0? T? :,? ? [ ? ? / ? F ? ? ? ? ? $? (? .? 5? J? [? ?? ?? ?? ?? ?? ?? ? f ? ? ? ? ? ? . ? ? ? 5 ?' ? J ?( ? [ ?) ? ?*+ $ ?, ? ? ? ? ?- ./ ? / *? ? ? ? ? 0 ? 1/ ? / *? ? ? ? ? 0 ? 23 ? / *? ? ? ? ? 0 ? 4 5 ? * ? ? ^ ? ? Y ? ? U ? ? ? ? ?
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de