(self, dest, tag, **kwargs)
| 82 | time.sleep(sleep) |
| 83 | |
| 84 | def send (self, dest, tag, **kwargs): |
| 85 | data = (tag, kwargs) |
| 86 | rowid = self.db.execute(SEND_MESSAGE, (self.name, dest, |
| 87 | cPickle.dumps(data))).lastrowid |
| 88 | return rowid |
| 89 | |
| 90 | |
| 91 |
no test coverage detected