added log class
This commit is contained in:
parent
b47daa2a53
commit
26c70b466d
@ -10,7 +10,7 @@ class RPCWampManager(ApplicationSession):
|
|||||||
|
|
||||||
def __init__(self, config=None):
|
def __init__(self, config=None):
|
||||||
ApplicationSession.__init__(self, config)
|
ApplicationSession.__init__(self, config)
|
||||||
LOG.info("component created")
|
LOG.info("RPC wamp manager created")
|
||||||
|
|
||||||
'''
|
'''
|
||||||
#unused methods
|
#unused methods
|
||||||
@ -32,13 +32,13 @@ class RPCWampManager(ApplicationSession):
|
|||||||
|
|
||||||
@inlineCallbacks
|
@inlineCallbacks
|
||||||
def onJoin(self, details):
|
def onJoin(self, details):
|
||||||
LOG.info('session ready')
|
LOG.info('RPC Wamp Session ready')
|
||||||
import iotronic.wamp.functions as fun
|
import iotronic.wamp.functions as fun
|
||||||
try:
|
try:
|
||||||
yield self.register(fun.test, u'stack4things.conductor.rpc.test')
|
yield self.register(fun.test, u'stack4things.conductor.rpc.test')
|
||||||
yield self.register(fun.registration, u'stack4things.conductor.rpc.registration')
|
yield self.register(fun.registration, u'stack4things.conductor.rpc.registration')
|
||||||
|
|
||||||
LOG.info("procedure registered")
|
LOG.info("Procedures registered")
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
print("could not register procedure: {0}".format(e))
|
print("could not register procedure: {0}".format(e))
|
||||||
|
|
||||||
@ -62,7 +62,7 @@ class RPC_Wamp_Server:
|
|||||||
def __init__(self,ip,port,realm):
|
def __init__(self,ip,port,realm):
|
||||||
server = RPCWampServer(ip,port,realm)
|
server = RPCWampServer(ip,port,realm)
|
||||||
server.start()
|
server.start()
|
||||||
multi = multiprocessing.Process(target=reactor.run, name='reactor',args=())
|
multi = multiprocessing.Process(target=reactor.run,args=())
|
||||||
multi.start()
|
multi.start()
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user