my $res = $rabbit_mq->publish(1, "my_exchange.lookup", $bin, {exchange=>'my_exchange'}, {reply_to => $rabbit_mq->{replyQ},}); #####in here if timeout has been reached reconnect #####or if the cnx is dead reconnect $res = $rabbit_mq->recv();