Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\drivers\rv\RVSubscriber.class
?? 1 a F G H I J K L M N O P Q R S T U V W m_subid Ljava/lang/String; m_nativeSubject m_transport Lcom/tibco/tibrv/TibrvTransport; m_options Ljava/util/Hashtable; m_maxCons I m_currCons %Loracle/mgw/drivers/rv/RVMsgConsumer; m_tranQueue 'Loracle/mgw/drivers/rv/RVTransactQueue; FACILITY ConstantValue X WITH_AQPROPERTIES Y LIMIT_POLICY Z MAX_EVENTS [ DISCARD_AMOUNT \ ALLOW_SEND_SUBJECT ] <init> ](Ljava/lang/String;Ljava/lang/String;Lcom/tibco/tibrv/TibrvTransport;Ljava/util/Hashtable;I)V Code LineNumberTable LocalVariableTable this $Loracle/mgw/drivers/rv/RVSubscriber; subid nativeSubject transport options maxCons Exceptions ^ createConsumer '()Loracle/mgw/drivers/rv/RVMsgConsumer; destroy ()V getCount ()I setOptions (Ljava/util/Hashtable;)V opt SourceFile RVSubscriber.java - > %oracle/mgw/drivers/rv/RVTransactQueue - . _ > #oracle/mgw/drivers/rv/RVMsgConsumer - ` = > ? @ A B "oracle/mgw/drivers/rv/RVSubscriber java/lang/Object RVD AQ_MSGPROPERTIES RV_LIMITPOLICY RV_MAXEVENTS RV_DISCARDAMOUNT RV_ALLOWMSGSENDSUBJECT "oracle/mgw/common/GatewayException stopRecv *(Loracle/mgw/drivers/rv/RVTransactQueue;)V ! "