diff options
Diffstat (limited to 'router.html')
| -rw-r--r-- | router.html | 22 |
1 files changed, 17 insertions, 5 deletions
diff --git a/router.html b/router.html index 930bf38..8c8c96b 100644 --- a/router.html +++ b/router.html | |||
| @@ -148,11 +148,10 @@ | |||
| 148 | <em class="property">class </em><code class="descclassname">eventmq.router.</code><code class="descname">Router</code><span class="sig-paren">(</span><em>*args</em>, <em>**kwargs</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.router.Router" title="Permalink to this definition">¶</a></dt> | 148 | <em class="property">class </em><code class="descclassname">eventmq.router.</code><code class="descname">Router</code><span class="sig-paren">(</span><em>*args</em>, <em>**kwargs</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.router.Router" title="Permalink to this definition">¶</a></dt> |
| 149 | <dd><p>A simple router of messages</p> | 149 | <dd><p>A simple router of messages</p> |
| 150 | <p>This router uses tornado’s eventloop.</p> | 150 | <p>This router uses tornado’s eventloop.</p> |
| 151 | <dl class="attribute"> | 151 | <dl class="method"> |
| 152 | <dt id="eventmq.router.Router.__weakref__"> | 152 | <dt id="eventmq.router.Router.on_heartbeat"> |
| 153 | <code class="descname">__weakref__</code><a class="headerlink" href="#eventmq.router.Router.__weakref__" title="Permalink to this definition">¶</a></dt> | 153 | <code class="descname">on_heartbeat</code><span class="sig-paren">(</span><em>sender</em>, <em>msgid</em>, <em>msg</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.router.Router.on_heartbeat" title="Permalink to this definition">¶</a></dt> |
| 154 | <dd><p>list of weak references to the object (if defined)</p> | 154 | <dd></dd></dl> |
| 155 | </dd></dl> | ||
| 156 | 155 | ||
| 157 | <dl class="method"> | 156 | <dl class="method"> |
| 158 | <dt id="eventmq.router.Router.on_inform"> | 157 | <dt id="eventmq.router.Router.on_inform"> |
| @@ -187,6 +186,19 @@ warning is created.</p> | |||
| 187 | </dd></dl> | 186 | </dd></dl> |
| 188 | 187 | ||
| 189 | <dl class="method"> | 188 | <dl class="method"> |
| 189 | <dt id="eventmq.router.Router.send_heartbeat"> | ||
| 190 | <code class="descname">send_heartbeat</code><span class="sig-paren">(</span><em>socket</em>, <em>recipient</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.router.Router.send_heartbeat" title="Permalink to this definition">¶</a></dt> | ||
| 191 | <dd><p>Custom send heartbeat method to take into account the recipient that is | ||
| 192 | needed when building messages</p> | ||
| 193 | </dd></dl> | ||
| 194 | |||
| 195 | <dl class="method"> | ||
| 196 | <dt id="eventmq.router.Router.send_workers_heartbeats"> | ||
| 197 | <code class="descname">send_workers_heartbeats</code><span class="sig-paren">(</span><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.router.Router.send_workers_heartbeats" title="Permalink to this definition">¶</a></dt> | ||
| 198 | <dd><p>Send heartbeats to the registered workers.</p> | ||
| 199 | </dd></dl> | ||
| 200 | |||
| 201 | <dl class="method"> | ||
| 190 | <dt id="eventmq.router.Router.start"> | 202 | <dt id="eventmq.router.Router.start"> |
| 191 | <code class="descname">start</code><span class="sig-paren">(</span><em>frontend_addr='tcp://127.0.0.1:47290'</em>, <em>backend_addr='tcp://127.0.0.1:47291'</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.router.Router.start" title="Permalink to this definition">¶</a></dt> | 203 | <code class="descname">start</code><span class="sig-paren">(</span><em>frontend_addr='tcp://127.0.0.1:47290'</em>, <em>backend_addr='tcp://127.0.0.1:47291'</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.router.Router.start" title="Permalink to this definition">¶</a></dt> |
| 192 | <dd><p>Begin listening for connections on the provided connection strings</p> | 204 | <dd><p>Begin listening for connections on the provided connection strings</p> |