test_class.declarator: context
test_class.modifier: private static
test_class.original_string: private static ApplicationContext context ;
test_class.type: ApplicationContext
test_class.var_name: context
test_class.declarator: publisher
test_class.modifier: private
test_class.original_string: private InductorPublisher publisher;
test_class.type: InductorPublisher
test_class.var_name: publisher
test_class.file: controller/src/test/java/com/oneops/controller/jms/InductorPublisherTest.java
test_class.identifier: InductorPublisherTest
test_case.body: @Test (priority=2)
  	/** dump stats and close conn */
  	public void cleanupTest() throws Exception{
  		publisher.getConnectionStats();
  		publisher.cleanup();
  	}
test_case.class_method_signature: InductorPublisherTest.cleanupTest()
test_case.full_signature: @Test (priority=2) /** dump stats and close conn */ public void cleanupTest()
test_case.identifier: cleanupTest
test_case.invocations: getConnectionStats cleanup
test_case.modifiers: @Test (priority=2) /** dump stats and close conn */ public
test_case.parameters: ()
test_case.return: void
test_case.signature: void cleanupTest()
focal_class.declarator: DEFAULT_VERSION = "1.0.0"
focal_class.modifier: private static final
focal_class.original_string: private static final String DEFAULT_VERSION = "1.0.0";
focal_class.type: String
focal_class.var_name: DEFAULT_VERSION
focal_class.declarator: QUEUE_SUFFIX = ".ind-wo"
focal_class.modifier: private static final
focal_class.original_string: private static final String QUEUE_SUFFIX = ".ind-wo";
focal_class.type: String
focal_class.var_name: QUEUE_SUFFIX
focal_class.declarator: SHARED_QUEUE = "shared" + QUEUE_SUFFIX
focal_class.modifier: private static final
focal_class.original_string: private static final String SHARED_QUEUE = "shared" + QUEUE_SUFFIX;
focal_class.type: String
focal_class.var_name: SHARED_QUEUE
focal_class.declarator: USE_SHARED_FLAG = "com.oneops.controller.use-shared-queue"
focal_class.modifier: private static final
focal_class.original_string: private static final String USE_SHARED_FLAG = "com.oneops.controller.use-shared-queue";
focal_class.type: String
focal_class.var_name: USE_SHARED_FLAG
focal_class.declarator: SHARED_QUEUE_PREFIX = "com.oneops.controller.queue.prefix."
focal_class.modifier: private static final
focal_class.original_string: private static final String SHARED_QUEUE_PREFIX = "com.oneops.controller.queue.prefix.";
focal_class.type: String
focal_class.var_name: SHARED_QUEUE_PREFIX
focal_class.declarator: CONTROLLLER_VERSION_SEARCH_TAG = "cVersion"
focal_class.modifier: private static final
focal_class.original_string: private static final String CONTROLLLER_VERSION_SEARCH_TAG = "cVersion";
focal_class.type: String
focal_class.var_name: CONTROLLLER_VERSION_SEARCH_TAG
focal_class.declarator: logger = Logger.getLogger(InductorPublisher.class)
focal_class.modifier: private static
focal_class.original_string: private static Logger logger = Logger.getLogger(InductorPublisher.class);
focal_class.type: Logger
focal_class.var_name: logger
focal_class.declarator: gson = new Gson()
focal_class.modifier: final private
focal_class.original_string: final private Gson gson = new Gson();
focal_class.type: Gson
focal_class.var_name: gson
focal_class.declarator: version
focal_class.modifier: @Autowired
focal_class.original_string: @Autowired
      Version version;
focal_class.type: Version
focal_class.var_name: version
focal_class.declarator: bindingQueusMap = new ConcurrentHashMap<>()
focal_class.modifier: private
focal_class.original_string: private Map<String, MessageProducer> bindingQueusMap = new ConcurrentHashMap<>();
focal_class.type: Map<String, MessageProducer>
focal_class.var_name: bindingQueusMap
focal_class.declarator: connection = null
focal_class.modifier: private
focal_class.original_string: private Connection connection = null;
focal_class.type: Connection
focal_class.var_name: connection
focal_class.declarator: session = null
focal_class.modifier: private
focal_class.original_string: private Session session = null;
focal_class.type: Session
focal_class.var_name: session
focal_class.declarator: connFactory
focal_class.modifier: private
focal_class.original_string: private ActiveMQConnectionFactory connFactory;
focal_class.type: ActiveMQConnectionFactory
focal_class.var_name: connFactory
focal_class.file: controller/src/main/java/com/oneops/controller/jms/InductorPublisher.java
focal_class.identifier: InductorPublisher
focal_class.class_method_signature: InductorPublisher.setConnFactory(ActiveMQConnectionFactory connFactory)
focal_class.full_signature: public void setConnFactory(ActiveMQConnectionFactory connFactory)
focal_class.identifier: setConnFactory
focal_class.modifiers: public
focal_class.parameters: (ActiveMQConnectionFactory connFactory)
focal_class.return: void
focal_class.signature: void setConnFactory(ActiveMQConnectionFactory connFactory)
focal_class.class_method_signature: InductorPublisher.init()
focal_class.full_signature: public void init()
focal_class.identifier: init
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void init()
focal_class.class_method_signature: InductorPublisher.publishMessage(DelegateExecution exec, String waitTaskName, String woType)
focal_class.full_signature: public void publishMessage(DelegateExecution exec, String waitTaskName, String woType)
focal_class.identifier: publishMessage
focal_class.modifiers: public
focal_class.parameters: (DelegateExecution exec, String waitTaskName, String woType)
focal_class.return: void
focal_class.signature: void publishMessage(DelegateExecution exec, String waitTaskName, String woType)
focal_class.class_method_signature: InductorPublisher.publishMessage(String processId, String execId, CmsWorkOrderSimpleBase wo, String waitTaskName, String woType)
focal_class.full_signature: public void publishMessage(String processId, String execId, CmsWorkOrderSimpleBase wo, String waitTaskName, String woType)
focal_class.identifier: publishMessage
focal_class.modifiers: public
focal_class.parameters: (String processId, String execId, CmsWorkOrderSimpleBase wo, String waitTaskName, String woType)
focal_class.return: void
focal_class.signature: void publishMessage(String processId, String execId, CmsWorkOrderSimpleBase wo, String waitTaskName, String woType)
focal_class.class_method_signature: InductorPublisher.getQueue(CmsWorkOrderSimpleBase wo)
focal_class.full_signature:  String getQueue(CmsWorkOrderSimpleBase wo)
focal_class.identifier: getQueue
focal_class.parameters: (CmsWorkOrderSimpleBase wo)
focal_class.return: String
focal_class.signature: String getQueue(CmsWorkOrderSimpleBase wo)
focal_class.class_method_signature: InductorPublisher.getCtxtId(CmsWorkOrderSimpleBase wo)
focal_class.full_signature: protected String getCtxtId(CmsWorkOrderSimpleBase wo)
focal_class.identifier: getCtxtId
focal_class.modifiers: protected
focal_class.parameters: (CmsWorkOrderSimpleBase wo)
focal_class.return: String
focal_class.signature: String getCtxtId(CmsWorkOrderSimpleBase wo)
focal_class.class_method_signature: InductorPublisher.newMessageProducer(String queueName)
focal_class.full_signature: private MessageProducer newMessageProducer(String queueName)
focal_class.identifier: newMessageProducer
focal_class.modifiers: private
focal_class.parameters: (String queueName)
focal_class.return: MessageProducer
focal_class.signature: MessageProducer newMessageProducer(String queueName)
focal_class.class_method_signature: InductorPublisher.getConnectionStats()
focal_class.full_signature: public void getConnectionStats()
focal_class.identifier: getConnectionStats
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void getConnectionStats()
focal_class.class_method_signature: InductorPublisher.cleanup()
focal_class.full_signature: public void cleanup()
focal_class.identifier: cleanup
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void cleanup()
focal_class.class_method_signature: InductorPublisher.closeConnection()
focal_class.full_signature: public void closeConnection()
focal_class.identifier: closeConnection
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void closeConnection()
focal_method.body: public void cleanup() {
          logger.info("Closing AMQ connection");
          closeConnection();
      }
focal_method.class_method_signature: InductorPublisher.cleanup()
focal_method.full_signature: public void cleanup()
focal_method.identifier: cleanup
focal_method.invocations: info closeConnection
focal_method.modifiers: public
focal_method.parameters: ()
focal_method.return: void
focal_method.signature: void cleanup()