Source Code for Module gofer.rmi.consumer

 1  # 
 2  # Copyright (c) 2011 Red Hat, Inc. 
 3  # 
 4  # This software is licensed to you under the GNU Lesser General Public 
 5  # License as published by the Free Software Foundation; either version 
 6  # 2 of the License (LGPLv2) or (at your option) any later version. 
 7  # There is NO WARRANTY for this software, express or implied, 
 8  # including the implied warranties of MERCHANTABILITY, 
 9  # NON-INFRINGEMENT, or FITNESS FOR A PARTICULAR PURPOSE. You should 
10  # have received a copy of LGPLv2 along with this software; if not, see 
11  # http://www.gnu.org/licenses/old-licenses/lgpl-2.0.txt. 
12  # 
13  # Jeff Ortel <jortel@redhat.com> 
14  # 
15   
16  from gofer.rmi.store import PendingQueue 
17  from gofer.messaging.consumer import Consumer 
18  from logging import getLogger 
19   
20  log = getLogger(__name__) 
21   
22   
23 -class RequestConsumer(Consumer): 
24      """ 
25      Reply consumer. 
26      Reads messages from AMQP and writes to 
27      local pending queue to be consumed by the scheduler. 
28      """ 
29   
30 -    def dispatch(self, envelope): 
31          """ 
32          Dispatch received request. 
33          @param envelope: The received envelope. 
34          @type envelope: L{Envelope} 
35          """ 
36          url = str(self.url) 
37          pending = PendingQueue() 
38          pending.add(url, envelope) 
39