[Mod]修改MainEngineProxy的exit函数
This commit is contained in:
parent
d2f80c86c9
commit
9e71df1ebd
@ -99,10 +99,8 @@ class Gateway(Resource):
|
|||||||
"""查询"""
|
"""查询"""
|
||||||
args = self.parser.parse_args()
|
args = self.parser.parse_args()
|
||||||
token = args['token']
|
token = args['token']
|
||||||
print token
|
|
||||||
print TOKEN
|
|
||||||
if token != TOKEN:
|
if token != TOKEN:
|
||||||
print 'token error'
|
|
||||||
return {'result_code':'error','message':'token error'}
|
return {'result_code':'error','message':'token error'}
|
||||||
|
|
||||||
l = me.getAllGatewayDetails()
|
l = me.getAllGatewayDetails()
|
||||||
|
@ -298,8 +298,7 @@ class RpcClient(RpcObject):
|
|||||||
注意topic必须是ascii编码
|
注意topic必须是ascii编码
|
||||||
"""
|
"""
|
||||||
self.__socketSUB.setsockopt(zmq.SUBSCRIBE, topic)
|
self.__socketSUB.setsockopt(zmq.SUBSCRIBE, topic)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
########################################################################
|
########################################################################
|
||||||
class RemoteException(Exception):
|
class RemoteException(Exception):
|
||||||
|
@ -107,6 +107,7 @@ class MainEngineProxy(object):
|
|||||||
|
|
||||||
#----------------------------------------------------------------------
|
#----------------------------------------------------------------------
|
||||||
def exit(self):
|
def exit(self):
|
||||||
self.eventEvent.stop()
|
self.eventEngine.stop()
|
||||||
|
|
||||||
if self.client:
|
if self.client:
|
||||||
self.client.stop()
|
self.client.stop()
|
||||||
|
Loading…
Reference in New Issue
Block a user