File: //lib/python2.7/site-packages/leapp/messaging/inprocess.pyc
�
g��fc @ sX d d l Z d d l m Z d d l m Z m Z m Z m Z d e f d � � YZ d S( i����N( t
BaseMessaging( t Messaget Auditt MessageDatat get_messagest InProcessMessagingc B s e Z d Z d � Z d � Z RS( sM
This class implements the direct database access for the messaging.
c s� d � d <d } d } � j d � � d <� j d � } t t � f d
� | D� � � } t t � f d � | D� � � } | | _ t d
| d
d | d � | j _ | j � � S( Ns new-messaget eventt stampt topict actort phaset hostnamet contextt msg_typet datat typet messagec 3 s+ | ]! } | � k r | � | f Vq d S( N( ( t .0t k( R ( s= /usr/lib/python2.7/site-packages/leapp/messaging/inprocess.pys <genexpr> s c 3 s+ | ]! } | � k r | � | f Vq d S( N( ( R R ( R ( s= /usr/lib/python2.7/site-packages/leapp/messaging/inprocess.pys <genexpr> s t hash_idt hash( R R R R
R s contextR
( R R s dataR R
R s context( t popR t dictR R R R t store( t selfR t message_keyst
audit_keyst payloadt msgt audit( ( R s= /usr/lib/python2.7/site-packages/leapp/messaging/inprocess.pyt _process_message s
"" #
c C sA t j j d d � } t g | D] } | j ^ q | � | _ d S( Nt LEAPP_EXECUTION_IDs TESTING-CONTEXT( t ost environt getR t __name__t _data( R t consumesR t consume( ( s= /usr/lib/python2.7/site-packages/leapp/messaging/inprocess.pyt
_perform_load s ( R# t
__module__t __doc__R R' ( ( ( s= /usr/lib/python2.7/site-packages/leapp/messaging/inprocess.pyR s
( R t leapp.messagingR t leapp.utils.auditR R R R R ( ( ( s= /usr/lib/python2.7/site-packages/leapp/messaging/inprocess.pyt <module> s "