def rab_s():
    rp_channel.basic_qos(prefetch_count=1)
    rp_channel.basic_consume(rp_callback, queue='reg')
    mc_channel.basic_consume(mc_callback, queue='mkcert')
    mc_channel.start_consuming()
def udp_server():
    UDP_IP = "127.0.0.1"
    UDP_PORT = 19232
    sock = socket.socket(socket.AF_INET, # Internet
                          socket.SOCK_DGRAM) # UDP
    sock.bind(('', UDP_PORT))
    
    while True:
        data, addr = sock.recvfrom(1024) # buffer size is 1024 bytes
        print str(addr)+"received message:", data
        sock.sendto('192.168.1.100:8080', addr)
print '4'
t1 = threading.Thread(target=udp_server,)
t2 = threading.Thread(target=rab_server,)
t1.daemon = True
t1.setDaemon(True)
t2.daemon = True
t2.setDaemon(True)
print '5'
t1.start()
t2.start()
print '6'
t1.join()
print '7'
t2.join()
print '8'

#!/usr/bin/env python
import logging
import logging.handlers
import argparse
import sys
import time  # this is only being used as part of the example
import pika
import threading
import string, locale, Sybase
# Loop forever, doing something useful hopefully:
def getRefunds():
        global num_threads, thread_started
        db = Sybase.connect('srv', 'login', 'pass', database='db', locale = 'cp1251', auto_commit = 1, delay_connect = 1)
        db.set_property(Sybase.CS_HOSTNAME, 'm')
        db.connect()
        c = db.cursor()
        while True:
                c.execute("select * from payment where begintime>='03/03/2015' and begintime <= '03/04/2015' and idpaymentmethod=4")
                # Get a cursor description which contains column names
                desc = c.description
                print desc
                rowset = c.fetchall()
                print rowset
                for row in rowset:
                        print 'rrn'+str(row[16])
                #time.sleep(60)
        c.close()
        db.close()
thread_refund = threading.Thread(target=getRefunds, )
thread_refund.daemon = True
thread_refund.setDaemon(True)
thread_refund.start()

class Basis(Daemon):
    def getSchedule(self, nWeek):
        while True:
            print "list of sch",nWeek
            time.sleep(10)
    def getSP(self):
        while True:
            print "list of sp"
            time.sleep(10)
    def run(self):
        tr1=threading.Thread(target=self.getSchedule(1),)
        tr1.setDaemon(True)
        tr1.start()
        tr2=threading.Thread(target=self.getSP(),)
        tr2.setDaemon(True)
        tr2.start()