I want to get a long connection. about stomp.py

[xinghailong]

http://pythonhosted.org//stompy/reference/stompy.stomp.html

[jasonrbriggs]

Sorry, no idea what you mean by a "long connection".

In addition, you've got the wrong project. stompy (the page you reference above) is nothing to do with stomp.py.

Think you should probably be directing your question to the owner of that project: https://bitbucket.org/benjaminws/python-stomp/

[xinghailong]

Hi, stompy can use "clientid" to connect old connection, but I can not find the relevant parameter of stom.py. So I want to know how can I find that ?

[xinghailong]

I want to use the persistent connection to send message, I do not want the "start" "connect" "disconnect" appear frequently.

[jasonrbriggs]

I believe clientid is something activemq specific. It's not a stomp header. So there is no relevant parameter. I you check the API documentation (http://jasonrbriggs.github.io/stomp.py/classstomp_1_1protocol_1_1_protocol12.html) you'll see that you can send arbitrary headers using the headers parameter.

As for persistent connections, the connection will stay open as long as the server allows.

[xinghailong]

class MyListener(object):
    def __init__(self,conn):
        self.conn = conn

    def on_message(self, headers, message):
        # some data processing for message
        send_msg = json.dumps(send_msg)

        # send to next queue
        dest = '/queue/smtp'
        ef.sendMessage(send_msg,dest,self.conn)


def branch(i,stomp_host):
    if stomp_host != None:
        #get message from JMS
        conn = stomp.Connection([(stomp_host[0],stomp_host[1])],user=stomp_host[2],passcode=stomp_host[3])
        conn.set_listener('', MyListener(conn))
        conn.start()
        conn.connect(wait=True)
        conn.subscribe(headers={'destination':'/queue/edm','activemq.prefetchSize':1, 'ack':'auto'})
        time.sleep(1)
        #conn.disconnect()
        while True:
            try:  
                time.sleep(1)  
            except:  
                break
    else:
        ef.edmLogs('stomp_host error branch','sysLog.log')

def sendMessage(send_msg,dest,conn=False):
    if conn:
        conn.send(send_msg, destination=dest)
    else:
        stomp_host = MQSelect()
        if stomp_host == None :
            edmLogs('error about mq ','runlog.log',True,False)
        else :
            conn = stomp.Connection([(stomp_host[0], stomp_host[1])],user=stomp_host[2],passcode=stomp_host[3])
            conn.start()
            conn.connect(wait=True)
            conn.send(send_msg, destination=dest)
            conn.disconnect() 

Use “conn” to send message，but sometimes it do not work. Can you give me some suggestions?

测试环境没问题，正式环境不行，还真是头疼！