
from Trigger.Registry import registerAction
from Trigger.Actions.ActionInterface import ActionInterface


class TestAction(ActionInterface):

   def __init__(self):
      ActionInterface.__init__(self)
      self.args={}

   def invoke(self,jobSpecId):
      self.messageService.publish("testEvent","none")
      print('-->Action Test Action is being Invoked for jobSpecID: '+jobSpecId)
      self.messageService.commit()

registerAction(TestAction(),"testAction")
