stompest consumer is slow for activemq about stompest HOT 4 CLOSED

 class ActiveMQConsumer(object):
def __init__(self, dest, uri, login, passcode, message_type=None):
    self.dest = dest
    self.config = StompConfig(uri=uri, login=login, passcode=passcode)
    self.message_type = message_type
    self.client = Stomp(self.config)
    self.parser = StompParser('1.0')
    self.client.connect()

    headers = {
        StompSpec.ACK_HEADER: StompSpec.ACK_CLIENT_INDIVIDUAL,
        'activemq.prefetchSize': '1000',
    }
    if message_type == 'MapMessage':
        headers['transformation'] = 'jms-map-json'
    self.client.subscribe(self.dest, headers)

def __map_json_to_dict(self, body):
    ret_dict = {}
    body_dict = json.loads(body)
    for entry in body_dict['map']['entry']:
        key = entry['string'][0]
        value = entry['string'][1]
        ret_dict[key] = value
    return ret_dict

def recv(self):
    if self.client.canRead(0):
        self.frame = self.client.receiveFrame()
        self.client.ack(self.frame)
        if self.message_type == 'MapMessage':
            body = self.__map_json_to_dict(self.frame.body)
        else:
            body = json.loads(self.frame.body)
        return body
    else:
        return None

def ack(self):
    self.client.ack(self.frame)

def __del__(self):
    self.client.disconnect()

mq_consumer = ActiveMQConsumer(dest=config.get('activemq', 'document_audit_consumer_dest'),
                               uri=config.get('activemq', 'document_audit_uri'),
                               login=config.get('activemq', 'document_audit_login'),
                               passcode=config.get('activemq', 'document_audit_passcode'),
                               message_type='MapMessage')
while True:
    try:
        msg = mq_consumer.recv()
        if msg:
            # LOG.debug(msg)
            msg_queue.put(msg)
    except Exception, e:
        LOG.error(e, exc_info=True)