(self, activity=None, **kw)
return message_list
List messages waiting in queues
List messages waiting in queues
List messages waiting in queues
def getMessageList(self, activity=None, **kw):
      """
        List messages waiting in queues
      """
      if activity:
        return activity_dict[activity].getMessageList(aq_inner(self), **kw)

      message_list = []
      for activity in activity_dict.itervalues():
        try:
          message_list += activity.getMessageList(aq_inner(self), **kw)
        except AttributeError:
          LOG('getMessageList, could not get message from Activity:',0,activity)
      return message_list
def getMessageList ( self , activity = None , * * kw ) : if activity : return activity_dict [ activity ] . getMessageList ( aq_inner ( self ) , * * kw ) message_list = [ ] for activity in activity_dict . itervalues ( ) : try : message_list += activity . getMessageList ( aq_inner ( self ) , * * kw ) except AttributeError : LOG ( 'getMessageList, could not get message from Activity:' , 0 , activity ) return message_list