Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\drivers\mq\MQMsgProducer.class
?? 1p ?C ?D EFG HI JK LM LN ?O JP EQ ER ES ET ?UV WXYZ [ \] ^_ ?` ?a ?b ?c ?d ?e ?f ^ghi !Cj !kl !m !n ^o pq rs ?tu ,v pwx Hyz{ ?n| }~ ^?? 8? H? ^???? ??? ?? ?? ?? ?? ?? @? ?? @? ?? @?? H? @? b?? >? O? >? @??? UC U? }?? b? Y?? @?? ^?? ??? bC ?? ?? ?? @? ?? b? @????????? b? ??? b? b? ???? b??? b?? b?? b?? b?? b?? b?? b?? b?? b?? b?? b??? b?? b?? b?? b?? b?? b?? b?? O? ?? ^? ^? H? ^? ^?? ?? b?? H?? b???? ??? ?? ?? ????? s_loggedEncodingError Z AQMSGID_PAD [B AQMSGID_PAD_LEN I MQ_CORRELATIONID_LEN ConstantValue m_logger Loracle/mgw/common/MgwLog; m_logMsgPrefix Ljava/lang/String; m_qName m_queue Lcom/ibm/mq/MQQueue; m_session "Loracle/mgw/drivers/mq/MQOPHandle; m_isLogProducer m_testBadMsgs m_checkBadMsgs m_preserveMsgID <init> Z(Loracle/mgw/drivers/ProducerParams;Loracle/mgw/drivers/mq/MQOPHandle;Ljava/lang/String;)V Code LineNumberTable LocalVariableTable this %Loracle/mgw/drivers/mq/MQMsgProducer; params #Loracle/mgw/drivers/ProducerParams; oph logMsgPrefix dest Loracle/mgw/common/DestData; qname destOptions Ljava/util/Hashtable; openFlags Exceptions getOpenFlags (Ljava/util/Hashtable;)I nfe !Ljava/lang/NumberFormatException; iv obj Ljava/lang/Object; b(Ljava/lang/String;Loracle/mgw/drivers/mq/MQOPHandle;ZLjava/util/Hashtable;Ljava/lang/String;ZZZ)V isTx options isLogProducer testBadMsgs checkBadMsgs N(Ljava/lang/String;Loracle/mgw/drivers/mq/MQOPHandle;ZILjava/lang/String;ZZZ)V init O(Ljava/lang/String;Loracle/mgw/drivers/mq/MQOPHandle;ZILjava/lang/String;ZZZZ)V mqe Lcom/ibm/mq/MQException; preserveMsgID destroy ()V alter &(Loracle/mgw/drivers/ProducerParams;)V send @(Loracle/mgw/common/Message;)Loracle/mgw/drivers/mq/MQMessageID; msg Loracle/mgw/common/Message; isLogMsg mmsg Loracle/mgw/common/MgwMessage; mqMsg Lcom/ibm/mq/MQMessage; pmo Lcom/ibm/mq/MQPutMessageOptions; midError Loracle/mgw/common/MessageID;? testBadMessage !(Loracle/mgw/common/MgwMessage;)V preserveBadMessage (Lcom/ibm/mq/MQMessage;I)V badMsgFlags logToRaw >(Loracle/mgw/common/LogMessage;)Loracle/mgw/common/MgwMessage; Loracle/mgw/common/LogMessage; body Loracle/mgw/common/MgwRawBody; mqSend x(Lcom/ibm/mq/MQMessage;Lcom/ibm/mq/MQPutMessageOptions;Loracle/mgw/common/MessageID;)Loracle/mgw/drivers/mq/MQMessageID; mide $Loracle/mgw/common/GatewayException; mid #Loracle/mgw/drivers/mq/MQMessageID; setPutOptions @(Loracle/mgw/common/MgwMessage;)Lcom/ibm/mq/MQPutMessageOptions; Ljava/lang/Integer; Loracle/mgw/common/MsgBody; hdr Loracle/mgw/common/MsgExtHeader; toMQMsg 7(Loracle/mgw/common/MgwMessage;Z)Lcom/ibm/mq/MQMessage; toMQHdr 7(Lcom/ibm/mq/MQMessage;Loracle/mgw/common/MgwMessage;)V priority exp J Loracle/mgw/common/MsgHeader; ttl getInteger <(Ljava/util/Hashtable;Ljava/lang/String;)Ljava/lang/Integer; ht name intVal getBytes +(Ljava/util/Hashtable;Ljava/lang/String;)[B getString ;(Ljava/util/Hashtable;Ljava/lang/String;)Ljava/lang/String; setOtherHeaderInfo V(Lcom/ibm/mq/MQMessage;Loracle/mgw/common/MsgExtHeader;Loracle/mgw/common/MessageID;)V strVal bytes toMQBody Loracle/mgw/common/MgwBasicBody; ioe Ljava/io/IOException; hasTextValue hasRawValue strBody rawBody bdy preserveAQMsgID midBytes padLen correlID midSrc <clinit> SourceFile MQMsgProducer.java ? ? ? ???? DestData? ? ? ? ? ? ? ? MQ_OPENOPTIONS java/lang/String java/lang/Integer ? java/lang/NumberFormatException ? ? ? ? ? ? ? ? ? ? ? ? ? ? MQD java/lang/StringBuilder 3MQMsgProducer -- open options used to access queue : !"# ? ? com/ibm/mq/MQException$ ?% ? MQSeries & MQMsgProducer -- created queue: object: MQMsgProducer -- closing queue: '( ?) .MQMsgProducer.alter: setting testBadMsgs = {0} java/lang/Boolean ?*+,- /MQMsgProducer.alter: setting checkBadMsgs = {0} Internal message is null oracle/mgw/common/LogMessage oracle/mgw/common/MgwMessage./012 345 7Testing Exception: message is a bad destination message6789+ ? oracle/mgw/common/MgwRawBody:; ?< ?= Internal MQ message is null com/ibm/mq/MQPutMessageOptions ? ?>? !oracle/mgw/drivers/mq/MQMessageID@ ? "oracle/mgw/common/GatewayExceptionAB oracle/mgw/common/MgwBasicBodyCD MGW_MQ_putMessageOptionsEFG com/ibm/mq/MQMessage;2HIJK ?LM ?N ?O ? MGW_MQ_expiry MGW_MQ_priority MGW_MQ_reportP ? MGW_MQ_messageType MGW_MQ_feedbackQ ? MGW_MQ_encodingR ? MGW_MQ_characterSetS ? MGW_MQ_backoutCountT ? MGW_MQ_putApplicationTypeU ? MGW_MQ_messageSequenceNumberV ? MGW_MQ_offsetW ? MGW_MQ_messageFlagsX ? MGW_MQ_originalLengthY ? MGW_MQ_replyToQueueNameZ ? MGW_MQ_replyToQueueManagerName[ ? MGW_MQ_format MGW_MQ_userId\ ? MGW_MQ_applicationIdData] ? MGW_MQ_putApplicationName^ ? MGW_MQ_applicationOriginData_ ? MGW_MQ_correlationId` ? MGW_MQ_accountingTokena ? MGW_MQ_groupIdb ? MGW_MQ_messageIdc;./676de fg MQSTR h java/io/IOException6i MGW_Bytej< source messageID is nullkl; ? ? source messageID size is wrongmno ? ? ? ? #oracle/mgw/drivers/mq/MQMsgProducer java/lang/Object oracle/mgw/common/MsgProducer "oracle/mgw/common/MessageException !oracle/mgw/drivers/ProducerParams getDestination ()Loracle/mgw/common/DestData; oracle/mgw/common/MgwUtil GatewayException N(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException; oracle/mgw/common/DestData getDestParams ()Loracle/mgw/common/DestParams; oracle/mgw/common/DestParams getNativeName ()Ljava/lang/String; getOptions ()Ljava/util/Hashtable; isTransactional ()Z isPreserveMsgID java/util/Hashtable get &(Ljava/lang/Object;)Ljava/lang/Object; (Ljava/lang/String;)V intValue ()I oracle/mgw/common/MgwLog getMgwLogger ()Loracle/mgw/common/MgwLog; isTRACE_HIGH (I)Z append -(Ljava/lang/String;)Ljava/lang/StringBuilder; (I)Ljava/lang/StringBuilder; toString trace ;(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;II)V oracle/mgw/drivers/mq/MQOPHandle getQueueManager ()Lcom/ibm/mq/MQQueueManager; com/ibm/mq/MQQueueManager accessQueue _(Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lcom/ibm/mq/MQQueue; reasonCode markInvalid `(Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/GatewayException; com/ibm/mq/MQQueue close isTRACE_DEBUG (Z)V format 8(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/String; )(Ljava/lang/String;Ljava/lang/String;II)V getClass ()Ljava/lang/Class; java/lang/Class getName getBadMsgFlags getMsgId ()Loracle/mgw/common/MessageID; isBadDestinationMessage MessageException k(Loracle/mgw/common/MessageID;Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/MessageException; badMsgFlagsToString (I)Ljava/lang/String; getRawLog ()[B ([B)V [(Loracle/mgw/common/MessageID;Loracle/mgw/common/MsgHeader;Loracle/mgw/common/MsgBody;ZIZ)V put 9(Lcom/ibm/mq/MQMessage;Lcom/ibm/mq/MQPutMessageOptions;)V messageId getMsgBody ()Loracle/mgw/common/MsgBody; getForeignHdr "()Loracle/mgw/common/MsgExtHeader; oracle/mgw/common/MsgExtHeader getValueForType '(Ljava/lang/String;I)Ljava/lang/Object; getAQHeader ()Loracle/mgw/common/MsgHeader; oracle/mgw/common/MsgHeader getPriority getTimeToLive expiry persistence messageType report feedback encoding characterSet backoutCount putApplicationType messageSequenceNumber offset messageFlags originalLength replyToQueueName replyToQueueManagerName userId applicationIdData putApplicationName applicationOriginData correlationId accountingToken groupId getRawValue Y(Loracle/mgw/common/MessageID;Ljava/lang/Throwable;I)Loracle/mgw/common/MessageException; getTextValue equals (Ljava/lang/Object;)Z writeString }(Loracle/mgw/common/MessageID;Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/MessageException; write oracle/mgw/common/MessageID getIDAsBytes java/lang/System arraycopy *(Ljava/lang/Object;ILjava/lang/Object;II)V ! ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? Z*? *? +? :? ?? ?? ? :? ? :*? 6*,? -+? +? +? +? ? ? ? * i M j k l n ( p 2 q : s Y v ? R Z ? ? Z ? ? Z ? ? Z ? ? K ? ? ( 2 ? ? 2 ( ? ? : ? ? ? \ ? ? ? ? 6=+? 1>+? :? ? ? ? Y? ? ? >? :=? - 0 ? * z | ~ ? ? - ? 0 ? 2 ? 4 ? ? >