<s> import coro . amqp as amqp <EOL> def t3 ( ) : <EOL> global c <EOL> c = amqp . client ( ( '<STR_LIT>' , '<STR_LIT>' ) , '<STR_LIT:127.0.0.1>' ) <EOL> print '<STR_LIT>' <EOL> c . go ( ) <EOL> print '<STR_LIT>' <EOL> ch = c . channel ( ) <EOL> print '<STR_LIT>' <EOL> ch . confirm_select ( ) <EOL> print '<STR_LIT>' <EOL> for i in range ( <NUM_LIT:10> ) : <EOL> props = { '<STR_LIT>' : '<STR_LIT>' , '<STR_LIT>' : '<STR_LIT>' % ( i , ) } <EOL> ch . basic_publish ( '<STR_LIT>' , exchange = '<STR_LIT>' , routing_key = '<STR_LIT>' , properties = props ) <EOL> print '<STR_LIT>' <EOL> coro . sleep_relative ( <NUM_LIT:1> ) <EOL> coro . set_exit ( ) <EOL> import coro <EOL> coro . spawn ( t3 ) <EOL> coro . event_loop ( ) </s>
