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: listener
test_class.modifier: private
test_class.original_string: private InductorListener listener;
test_class.type: InductorListener
test_class.var_name: listener
test_class.file: controller/src/test/java/com/oneops/controller/jms/InductorListenerTest.java
test_class.identifier: InductorListenerTest
test_case.body: @Test
  	/** test with message where JMSException is forced to happend
  	 * but we effectively are asserting it must get swallowed*/
  	public void testBadMessage() throws JMSException {
  		TextMessage message = mock(TextMessage.class);
  		when(message.getJMSCorrelationID()).thenThrow(new JMSException("mock-force"));
  		listener.onMessage(message);
  	}
test_case.class_method_signature: InductorListenerTest.testBadMessage()
test_case.full_signature: @Test /** test with message where JMSException is forced to happend * but we effectively are asserting it must get swallowed*/ public void testBadMessage()
test_case.identifier: testBadMessage
test_case.invocations: mock thenThrow when getJMSCorrelationID onMessage
test_case.modifiers: @Test /** test with message where JMSException is forced to happend * but we effectively are asserting it must get swallowed*/ public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testBadMessage()
focal_class.declarator: logger = Logger.getLogger(InductorListener.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger logger = Logger.getLogger(InductorListener.class);
focal_class.type: Logger
focal_class.var_name: logger
focal_class.declarator: OK_RESPONSE = "200"
focal_class.modifier: private static final
focal_class.original_string: private static final String OK_RESPONSE = "200";
focal_class.type: String
focal_class.var_name: OK_RESPONSE
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: ctrlrQueueName = "controller.response"
focal_class.modifier: private final
focal_class.original_string: private final String ctrlrQueueName = "controller.response";
focal_class.type: String
focal_class.var_name: ctrlrQueueName
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.declarator: wfController
focal_class.modifier: private
focal_class.original_string: private WorkflowController wfController;
focal_class.type: WorkflowController
focal_class.var_name: wfController
focal_class.declarator: woPublisher
focal_class.modifier: private
focal_class.original_string: private WoPublisher woPublisher;
focal_class.type: WoPublisher
focal_class.var_name: woPublisher
focal_class.declarator: sensorClient
focal_class.modifier: private
focal_class.original_string: private SensorClient sensorClient;
focal_class.type: SensorClient
focal_class.var_name: sensorClient
focal_class.declarator: controllerUtil
focal_class.modifier: private
focal_class.original_string: private ControllerUtil controllerUtil;
focal_class.type: ControllerUtil
focal_class.var_name: controllerUtil
focal_class.declarator: executionManager
focal_class.modifier: private
focal_class.original_string: private ExecutionManager executionManager;
focal_class.type: ExecutionManager
focal_class.var_name: executionManager
focal_class.file: controller/src/main/java/com/oneops/controller/jms/InductorListener.java
focal_class.identifier: InductorListener
focal_class.interfaces: implements MessageListener
focal_class.class_method_signature: InductorListener.getSensorClient()
focal_class.full_signature: public SensorClient getSensorClient()
focal_class.identifier: getSensorClient
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: SensorClient
focal_class.signature: SensorClient getSensorClient()
focal_class.class_method_signature: InductorListener.setSensorClient(SensorClient sensorClient)
focal_class.full_signature: public void setSensorClient(SensorClient sensorClient)
focal_class.identifier: setSensorClient
focal_class.modifiers: public
focal_class.parameters: (SensorClient sensorClient)
focal_class.return: void
focal_class.signature: void setSensorClient(SensorClient sensorClient)
focal_class.class_method_signature: InductorListener.setControllerUtil(ControllerUtil controllerUtil)
focal_class.full_signature: public void setControllerUtil(ControllerUtil controllerUtil)
focal_class.identifier: setControllerUtil
focal_class.modifiers: public
focal_class.parameters: (ControllerUtil controllerUtil)
focal_class.return: void
focal_class.signature: void setControllerUtil(ControllerUtil controllerUtil)
focal_class.class_method_signature: InductorListener.setWfController(WorkflowController wfController)
focal_class.full_signature: public void setWfController(WorkflowController wfController)
focal_class.identifier: setWfController
focal_class.modifiers: public
focal_class.parameters: (WorkflowController wfController)
focal_class.return: void
focal_class.signature: void setWfController(WorkflowController wfController)
focal_class.class_method_signature: InductorListener.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: InductorListener.setWoPublisher(WoPublisher woPublisher)
focal_class.full_signature: public void setWoPublisher(WoPublisher woPublisher)
focal_class.identifier: setWoPublisher
focal_class.modifiers: public
focal_class.parameters: (WoPublisher woPublisher)
focal_class.return: void
focal_class.signature: void setWoPublisher(WoPublisher woPublisher)
focal_class.class_method_signature: InductorListener.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: InductorListener.onMessage(Message message)
focal_class.full_signature: public void onMessage(Message message)
focal_class.identifier: onMessage
focal_class.modifiers: public
focal_class.parameters: (Message message)
focal_class.return: void
focal_class.signature: void onMessage(Message message)
focal_class.class_method_signature: InductorListener.processResponseMessage(TextMessage msg)
focal_class.full_signature: private void processResponseMessage(TextMessage msg)
focal_class.identifier: processResponseMessage
focal_class.modifiers: private
focal_class.parameters: (TextMessage msg)
focal_class.return: void
focal_class.signature: void processResponseMessage(TextMessage msg)
focal_class.class_method_signature: InductorListener.handleWorkOrderFlow(String processId, String executionId, Map<String,
            Object> params, CmsWorkOrderSimpleBase wo)
focal_class.full_signature: private void handleWorkOrderFlow(String processId, String executionId, Map<String,
            Object> params, CmsWorkOrderSimpleBase wo)
focal_class.identifier: handleWorkOrderFlow
focal_class.modifiers: private
focal_class.parameters: (String processId, String executionId, Map<String,
            Object> params, CmsWorkOrderSimpleBase wo)
focal_class.return: void
focal_class.signature: void handleWorkOrderFlow(String processId, String executionId, Map<String,
            Object> params, CmsWorkOrderSimpleBase wo)
focal_class.class_method_signature: InductorListener.isRunByDeployer(CmsWorkOrderSimpleBase wo)
focal_class.full_signature: private boolean isRunByDeployer(CmsWorkOrderSimpleBase wo)
focal_class.identifier: isRunByDeployer
focal_class.modifiers: private
focal_class.parameters: (CmsWorkOrderSimpleBase wo)
focal_class.return: boolean
focal_class.signature: boolean isRunByDeployer(CmsWorkOrderSimpleBase wo)
focal_class.class_method_signature: InductorListener.setWoTimeStamps(CmsWorkOrderSimpleBase<T> wo)
focal_class.full_signature: private void setWoTimeStamps(CmsWorkOrderSimpleBase<T> wo)
focal_class.identifier: setWoTimeStamps
focal_class.modifiers: private
focal_class.parameters: (CmsWorkOrderSimpleBase<T> wo)
focal_class.return: void
focal_class.signature: void setWoTimeStamps(CmsWorkOrderSimpleBase<T> wo)
focal_class.class_method_signature: InductorListener.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: InductorListener.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: InductorListener.closeConnection()
focal_class.full_signature: private void closeConnection()
focal_class.identifier: closeConnection
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void closeConnection()
focal_class.class_method_signature: InductorListener.setExecutionManager(ExecutionManager executionManager)
focal_class.full_signature: public void setExecutionManager(ExecutionManager executionManager)
focal_class.identifier: setExecutionManager
focal_class.modifiers: public
focal_class.parameters: (ExecutionManager executionManager)
focal_class.return: void
focal_class.signature: void setExecutionManager(ExecutionManager executionManager)
focal_method.body: public void onMessage(Message message) {
      try {
        if (message instanceof TextMessage) {
          if (logger.isDebugEnabled()) {
            logger.debug("got message: " + ((TextMessage) message).getText());
          }
          try {
            processResponseMessage((TextMessage) message);
          } catch (ActivitiException ae) {
            logger.error("ActivityException in onMessage ", ae);
            logger.error("Will retry in 10 seconds \n" + ((TextMessage) message).getText());
            throw ae;
          }
        }
      } catch (JMSException e) {
        logger.error("JMSException in onMessage", e);
      }
    }
focal_method.class_method_signature: InductorListener.onMessage(Message message)
focal_method.full_signature: public void onMessage(Message message)
focal_method.identifier: onMessage
focal_method.invocations: isDebugEnabled debug getText processResponseMessage error error getText error
focal_method.modifiers: public
focal_method.parameters: (Message message)
focal_method.return: void
focal_method.signature: void onMessage(Message message)