diff options
Diffstat (limited to 'router.html')
| -rw-r--r-- | router.html | 35 |
1 files changed, 29 insertions, 6 deletions
diff --git a/router.html b/router.html index f9bec5f..d8c7fe1 100644 --- a/router.html +++ b/router.html | |||
| @@ -31,6 +31,7 @@ | |||
| 31 | 31 | ||
| 32 | 32 | ||
| 33 | <link rel="top" title="EventMQ 0 documentation" href="index.html"/> | 33 | <link rel="top" title="EventMQ 0 documentation" href="index.html"/> |
| 34 | <link rel="up" title="API Documentation" href="api.html"/> | ||
| 34 | <link rel="next" title="sender – Sender" href="sender.html"/> | 35 | <link rel="next" title="sender – Sender" href="sender.html"/> |
| 35 | <link rel="prev" title="receiver – Receiver" href="receiver.html"/> | 36 | <link rel="prev" title="receiver – Receiver" href="receiver.html"/> |
| 36 | 37 | ||
| @@ -82,10 +83,14 @@ | |||
| 82 | 83 | ||
| 83 | 84 | ||
| 84 | <ul class="current"> | 85 | <ul class="current"> |
| 85 | <li class="toctree-l1"><a class="reference internal" href="jobmanager.html"><code class="docutils literal"><span class="pre">jobmanager</span></code> – Job Manager</a></li> | 86 | <li class="toctree-l1 current"><a class="reference internal" href="api.html">API Documentation</a><ul class="current"> |
| 86 | <li class="toctree-l1"><a class="reference internal" href="receiver.html"><code class="docutils literal"><span class="pre">receiver</span></code> – Receiver</a></li> | 87 | <li class="toctree-l2"><a class="reference internal" href="receiver.html"><code class="docutils literal"><span class="pre">receiver</span></code> – Receiver</a></li> |
| 87 | <li class="toctree-l1 current"><a class="current reference internal" href=""><code class="docutils literal"><span class="pre">router</span></code> – Router</a></li> | 88 | <li class="toctree-l2 current"><a class="current reference internal" href=""><code class="docutils literal"><span class="pre">router</span></code> – Router</a></li> |
| 88 | <li class="toctree-l1"><a class="reference internal" href="sender.html"><code class="docutils literal"><span class="pre">sender</span></code> – Sender</a></li> | 89 | <li class="toctree-l2"><a class="reference internal" href="sender.html"><code class="docutils literal"><span class="pre">sender</span></code> – Sender</a></li> |
| 90 | <li class="toctree-l2"><a class="reference internal" href="utils.html"><code class="docutils literal"><span class="pre">utils</span></code> – Utilities</a></li> | ||
| 91 | </ul> | ||
| 92 | </li> | ||
| 93 | <li class="toctree-l1"><a class="reference internal" href="contributing.html">Contributing to EventMQ</a></li> | ||
| 89 | </ul> | 94 | </ul> |
| 90 | 95 | ||
| 91 | 96 | ||
| @@ -116,6 +121,8 @@ | |||
| 116 | <ul class="wy-breadcrumbs"> | 121 | <ul class="wy-breadcrumbs"> |
| 117 | <li><a href="index.html">Docs</a> »</li> | 122 | <li><a href="index.html">Docs</a> »</li> |
| 118 | 123 | ||
| 124 | <li><a href="api.html">API Documentation</a> »</li> | ||
| 125 | |||
| 119 | <li><code class="docutils literal"><span class="pre">router</span></code> – Router</li> | 126 | <li><code class="docutils literal"><span class="pre">router</span></code> – Router</li> |
| 120 | <li class="wy-breadcrumbs-aside"> | 127 | <li class="wy-breadcrumbs-aside"> |
| 121 | 128 | ||
| @@ -145,6 +152,22 @@ | |||
| 145 | </dd></dl> | 152 | </dd></dl> |
| 146 | 153 | ||
| 147 | <dl class="method"> | 154 | <dl class="method"> |
| 155 | <dt id="eventmq.router.Router.on_receive_reply"> | ||
| 156 | <code class="descname">on_receive_reply</code><span class="sig-paren">(</span><em>msg</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.router.Router.on_receive_reply" title="Permalink to this definition">¶</a></dt> | ||
| 157 | <dd><p>This method is called when a message comes in from the worker socket. | ||
| 158 | It then calls <cite>on_command</cite>. If <cite>on_command</cite> isn’t found, then a warning | ||
| 159 | is created.</p> | ||
| 160 | </dd></dl> | ||
| 161 | |||
| 162 | <dl class="method"> | ||
| 163 | <dt id="eventmq.router.Router.on_receive_request"> | ||
| 164 | <code class="descname">on_receive_request</code><span class="sig-paren">(</span><em>msg</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.router.Router.on_receive_request" title="Permalink to this definition">¶</a></dt> | ||
| 165 | <dd><p>This function is called when a message comes in from the client socket. | ||
| 166 | It then calls <cite>on_command</cite>. If <cite>on_command</cite> isn’t found, then a | ||
| 167 | warning is created.</p> | ||
| 168 | </dd></dl> | ||
| 169 | |||
| 170 | <dl class="method"> | ||
| 148 | <dt id="eventmq.router.Router.start"> | 171 | <dt id="eventmq.router.Router.start"> |
| 149 | <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> | 172 | <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> |
| 150 | <dd><p>Begin listening for connections on the provided connection strings</p> | 173 | <dd><p>Begin listening for connections on the provided connection strings</p> |
| @@ -153,8 +176,8 @@ | |||
| 153 | <col class="field-body" /> | 176 | <col class="field-body" /> |
| 154 | <tbody valign="top"> | 177 | <tbody valign="top"> |
| 155 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple"> | 178 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple"> |
| 156 | <li><strong>frontend_addr</strong> – connection string to listen for requests</li> | 179 | <li><strong>frontend_addr</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – connection string to listen for requests</li> |
| 157 | <li><strong>backend_addr</strong> – connection string to listen for workers</li> | 180 | <li><strong>backend_addr</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – connection string to listen for workers</li> |
| 158 | </ul> | 181 | </ul> |
| 159 | </td> | 182 | </td> |
| 160 | </tr> | 183 | </tr> |