Ah ben non, en fait y avait pas de typo (quel dommage)
This commit is contained in:
parent
267a3bf393
commit
d7c9f3cf9e
1 changed files with 2 additions and 1 deletions
|
@ -20,7 +20,7 @@ logger = clogger.CLogger("cmbprod", sys.argv[0].split("/")[-1].replace(".py", ""
|
||||||
|
|
||||||
class BasicProducer(object):
|
class BasicProducer(object):
|
||||||
"""
|
"""
|
||||||
This is CMB basic producer, it doesn't have to be asynchronous nor anything,
|
This is CMB basic producer, it doesn't have to be asynchronous or anything,
|
||||||
it's just a basic object that sends messages.
|
it's just a basic object that sends messages.
|
||||||
|
|
||||||
"""
|
"""
|
||||||
|
@ -38,6 +38,7 @@ class BasicProducer(object):
|
||||||
self._port = port
|
self._port = port
|
||||||
self._credentials = credentials
|
self._credentials = credentials
|
||||||
self._ssl = ssl
|
self._ssl = ssl
|
||||||
|
|
||||||
logger.info("Initializing with app_id %s" % (self._app_id,))
|
logger.info("Initializing with app_id %s" % (self._app_id,))
|
||||||
|
|
||||||
def connect(self):
|
def connect(self):
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue