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 CmsListener listener;
test_class.type: CmsListener
test_class.var_name: listener
test_class.declarator: gson = new Gson()
test_class.modifier: private
test_class.original_string: private Gson gson = new Gson();
test_class.type: Gson
test_class.var_name: gson
test_class.file: controller/src/test/java/com/oneops/controller/jms/CmsListenerTest.java
test_class.identifier: CmsListenerTest
test_case.body: @Test 
  	public void msgOpsProcedure() throws Exception{
  		TextMessage message = mock(TextMessage.class);
  		when(message.getStringProperty("source")).thenReturn("opsprocedure");
  		when(message.getJMSCorrelationID()).thenReturn(null);
  
  		String msgJson = gson.toJson(createCmsOpsProcedure(OpsProcedureState.active));
  		when(message.getText()).thenReturn(msgJson);
  
  		listener.onMessage(message);
  		//once more to get a SKIP
  		when(message.getText()).thenReturn(gson.toJson(createCmsOpsProcedure(OpsProcedureState.discarded)));	
  		listener.onMessage(message);
  	}
test_case.class_method_signature: CmsListenerTest.msgOpsProcedure()
test_case.full_signature: @Test public void msgOpsProcedure()
test_case.identifier: msgOpsProcedure
test_case.invocations: mock thenReturn when getStringProperty thenReturn when getJMSCorrelationID toJson createCmsOpsProcedure thenReturn when getText onMessage thenReturn when getText toJson createCmsOpsProcedure onMessage
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void msgOpsProcedure()
focal_class.declarator: logger = Logger.getLogger(CmsListener.class)
focal_class.modifier: private static
focal_class.original_string: private static Logger logger = Logger.getLogger(CmsListener.class);
focal_class.type: Logger
focal_class.var_name: logger
focal_class.declarator: DPMT_STATE_PENDING = "pending"
focal_class.modifier: private static final
focal_class.original_string: private static final String DPMT_STATE_PENDING = "pending";
focal_class.type: String
focal_class.var_name: DPMT_STATE_PENDING
focal_class.declarator: DPMT_STATE_CANCELED = "canceled"
focal_class.modifier: private static final
focal_class.original_string: private static final String DPMT_STATE_CANCELED = "canceled";
focal_class.type: String
focal_class.var_name: DPMT_STATE_CANCELED
focal_class.declarator: DPMT_STATE_PAUSED = "paused"
focal_class.modifier: private static final
focal_class.original_string: private static final String DPMT_STATE_PAUSED = "paused";
focal_class.type: String
focal_class.var_name: DPMT_STATE_PAUSED
focal_class.declarator: dpmtProcessVersion = System
        .getProperty("controller.dpmt.version", "2")
focal_class.modifier: private static final
focal_class.original_string: private static final String dpmtProcessVersion = System
        .getProperty("controller.dpmt.version", "2");
focal_class.type: String
focal_class.var_name: dpmtProcessVersion
focal_class.declarator: processName =
        "1".equals(dpmtProcessVersion) ? "deploybom" : "deploybom" + dpmtProcessVersion
focal_class.modifier: private static final
focal_class.original_string: private static final String processName =
        "1".equals(dpmtProcessVersion) ? "deploybom" : "deploybom" + dpmtProcessVersion;
focal_class.type: String
focal_class.var_name: processName
focal_class.declarator: queueName = "CONTROLLER.WO"
focal_class.modifier: private
focal_class.original_string: private String queueName = "CONTROLLER.WO";
focal_class.type: String
focal_class.var_name: queueName
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: consumerName = "ControllerCMSListener"
focal_class.modifier: private
focal_class.original_string: private String consumerName = "ControllerCMSListener";
focal_class.type: String
focal_class.var_name: consumerName
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: wfController
focal_class.modifier: private
focal_class.original_string: private WorkflowController wfController;
focal_class.type: WorkflowController
focal_class.var_name: wfController
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: notifier
focal_class.modifier: private
focal_class.original_string: private DeploymentNotifier notifier;
focal_class.type: DeploymentNotifier
focal_class.var_name: notifier
focal_class.declarator: cmsClient
focal_class.modifier: private
focal_class.original_string: private CMSClient cmsClient;
focal_class.type: CMSClient
focal_class.var_name: cmsClient
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.declarator: isDeployerEnabled
focal_class.modifier: private
focal_class.original_string: private boolean isDeployerEnabled;
focal_class.type: boolean
focal_class.var_name: isDeployerEnabled
focal_class.file: controller/src/main/java/com/oneops/controller/jms/CmsListener.java
focal_class.identifier: CmsListener
focal_class.interfaces: implements MessageListener
focal_class.class_method_signature: CmsListener.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: CmsListener.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: CmsListener.processMessage(TextMessage message)
focal_class.full_signature: private void processMessage(TextMessage message)
focal_class.identifier: processMessage
focal_class.modifiers: private
focal_class.parameters: (TextMessage message)
focal_class.return: void
focal_class.signature: void processMessage(TextMessage message)
focal_class.class_method_signature: CmsListener.startDeployment(CmsDeployment dpmt)
focal_class.full_signature: private void startDeployment(CmsDeployment dpmt)
focal_class.identifier: startDeployment
focal_class.modifiers: private
focal_class.parameters: (CmsDeployment dpmt)
focal_class.return: void
focal_class.signature: void startDeployment(CmsDeployment dpmt)
focal_class.class_method_signature: CmsListener.startProcedure(CmsOpsProcedure procedure)
focal_class.full_signature: private void startProcedure(CmsOpsProcedure procedure)
focal_class.identifier: startProcedure
focal_class.modifiers: private
focal_class.parameters: (CmsOpsProcedure procedure)
focal_class.return: void
focal_class.signature: void startProcedure(CmsOpsProcedure procedure)
focal_class.class_method_signature: CmsListener.notifyIfRequired(CmsDeployment dpmt)
focal_class.full_signature: private void notifyIfRequired(CmsDeployment dpmt)
focal_class.identifier: notifyIfRequired
focal_class.modifiers: private
focal_class.parameters: (CmsDeployment dpmt)
focal_class.return: void
focal_class.signature: void notifyIfRequired(CmsDeployment dpmt)
focal_class.class_method_signature: CmsListener.sendDeploymentPendingNotification(CmsDeployment dpmt)
focal_class.full_signature: private void sendDeploymentPendingNotification(CmsDeployment dpmt)
focal_class.identifier: sendDeploymentPendingNotification
focal_class.modifiers: private
focal_class.parameters: (CmsDeployment dpmt)
focal_class.return: void
focal_class.signature: void sendDeploymentPendingNotification(CmsDeployment dpmt)
focal_class.class_method_signature: CmsListener.sendDeploymentCancelleddNotification(CmsDeployment dpmt)
focal_class.full_signature: private void sendDeploymentCancelleddNotification(CmsDeployment dpmt)
focal_class.identifier: sendDeploymentCancelleddNotification
focal_class.modifiers: private
focal_class.parameters: (CmsDeployment dpmt)
focal_class.return: void
focal_class.signature: void sendDeploymentCancelleddNotification(CmsDeployment dpmt)
focal_class.class_method_signature: CmsListener.sendDeploymentPausedNotification(CmsDeployment dpmt)
focal_class.full_signature: private void sendDeploymentPausedNotification(CmsDeployment dpmt)
focal_class.identifier: sendDeploymentPausedNotification
focal_class.modifiers: private
focal_class.parameters: (CmsDeployment dpmt)
focal_class.return: void
focal_class.signature: void sendDeploymentPausedNotification(CmsDeployment dpmt)
focal_class.class_method_signature: CmsListener.getDpmtProcessKey(CmsDeployment dpmt)
focal_class.full_signature: private String getDpmtProcessKey(CmsDeployment dpmt)
focal_class.identifier: getDpmtProcessKey
focal_class.modifiers: private
focal_class.parameters: (CmsDeployment dpmt)
focal_class.return: String
focal_class.signature: String getDpmtProcessKey(CmsDeployment dpmt)
focal_class.class_method_signature: CmsListener.isDeployerEnabled(String nsPath)
focal_class.full_signature: private boolean isDeployerEnabled(String nsPath)
focal_class.identifier: isDeployerEnabled
focal_class.modifiers: private
focal_class.parameters: (String nsPath)
focal_class.return: boolean
focal_class.signature: boolean isDeployerEnabled(String nsPath)
focal_class.class_method_signature: CmsListener.getOpsProcedureProcessKey(CmsOpsProcedure proc)
focal_class.full_signature: private String getOpsProcedureProcessKey(CmsOpsProcedure proc)
focal_class.identifier: getOpsProcedureProcessKey
focal_class.modifiers: private
focal_class.parameters: (CmsOpsProcedure proc)
focal_class.return: String
focal_class.signature: String getOpsProcedureProcessKey(CmsOpsProcedure proc)
focal_class.class_method_signature: CmsListener.getDeployReleaseProcessKey(CmsRelease release)
focal_class.full_signature: private String getDeployReleaseProcessKey(CmsRelease release)
focal_class.identifier: getDeployReleaseProcessKey
focal_class.modifiers: private
focal_class.parameters: (CmsRelease release)
focal_class.return: String
focal_class.signature: String getDeployReleaseProcessKey(CmsRelease release)
focal_class.class_method_signature: CmsListener.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: CmsListener.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: CmsListener.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: CmsListener.setConsumerName(String consumerName)
focal_class.full_signature: public void setConsumerName(String consumerName)
focal_class.identifier: setConsumerName
focal_class.modifiers: public
focal_class.parameters: (String consumerName)
focal_class.return: void
focal_class.signature: void setConsumerName(String consumerName)
focal_class.class_method_signature: CmsListener.setCmsClient(CMSClient cmsClient)
focal_class.full_signature: public void setCmsClient(CMSClient cmsClient)
focal_class.identifier: setCmsClient
focal_class.modifiers: public
focal_class.parameters: (CMSClient cmsClient)
focal_class.return: void
focal_class.signature: void setCmsClient(CMSClient cmsClient)
focal_class.class_method_signature: CmsListener.setDeployerEnabled(boolean deployerEnabled)
focal_class.full_signature: public void setDeployerEnabled(boolean deployerEnabled)
focal_class.identifier: setDeployerEnabled
focal_class.modifiers: public
focal_class.parameters: (boolean deployerEnabled)
focal_class.return: void
focal_class.signature: void setDeployerEnabled(boolean deployerEnabled)
focal_class.class_method_signature: CmsListener.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_class.class_method_signature: CmsListener.setNotifier(DeploymentNotifier notifier)
focal_class.full_signature: public void setNotifier(DeploymentNotifier notifier)
focal_class.identifier: setNotifier
focal_class.modifiers: public
focal_class.parameters: (DeploymentNotifier notifier)
focal_class.return: void
focal_class.signature: void setNotifier(DeploymentNotifier notifier)
focal_class.class_method_signature: CmsListener.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: CmsListener.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_method.body: public void onMessage(Message message) {
      try {
        if (message instanceof TextMessage) {
          try {
            logger.info("got message: " + ((TextMessage) message).getText());
            processMessage((TextMessage) message);
            //session.commit();
          } catch (ActivitiException ae) {
            logger.error("ActivityException in onMessage", ae);
            //session.rollback();
            throw ae;
          }
        }
      } catch (JMSException e) {
        logger.error("JMSException in onMessage", e);
      }
    }
focal_method.class_method_signature: CmsListener.onMessage(Message message)
focal_method.full_signature: public void onMessage(Message message)
focal_method.identifier: onMessage
focal_method.invocations: info getText processMessage error error
focal_method.modifiers: public
focal_method.parameters: (Message message)
focal_method.return: void
focal_method.signature: void onMessage(Message message)