Revision 6625258b ncclient/transport/session.py
b/ncclient/transport/session.py | ||
---|---|---|
43 | 43 |
with self._lock: |
44 | 44 |
listeners = list(self._listeners) |
45 | 45 |
for l in listeners: |
46 |
logger.debug('dispatching [%s] to [%s]' % (event, l)) |
|
46 | 47 |
try: |
47 |
logger.debug('dispatching [%s] to [%s]' % (event, l)) |
|
48 | 48 |
getattr(l, event)(*args, **kwds) |
49 |
except AttributeError as e: |
|
50 |
logger.debug('Subject.dispatch: %r' % e) |
|
49 | 51 |
except Exception as e: |
50 |
pass # if a listener doesn't care for some event we don't care
|
|
52 |
logger.warning('Subject.dispatch: %r' % e)
|
|
51 | 53 |
|
52 | 54 |
|
53 | 55 |
class Session(Thread, Subject): |
... | ... | |
90 | 92 |
logger.debug('queueing:%s' % message) |
91 | 93 |
self._q.put(message) |
92 | 94 |
|
93 |
def connect(self): |
|
95 |
def connect(self, *args, **kwds):
|
|
94 | 96 |
raise NotImplementedError |
95 | 97 |
|
96 | 98 |
def run(self): |
Also available in: Unified diff