import webCrawlingSpider as wcs
import pubSub
import threading
import json

def callbackURLQueue(message):
	wcs.main(message)

if __name__ == '__main__':	

	pubSub.subscribe('urlQueue', callbackURLQueue)
	print("Subscribed to URL Queue")

2545c9ef650eb9731fe74994019bbd9f6ecd563a
<mask token>

<mask token>


def callbackURLQueue(message):
    wcs.main(message)


<mask token>

<mask token>


def callbackURLQueue(message):
    wcs.main(message)


if __name__ == '__main__':
    pubSub.subscribe('urlQueue', callbackURLQueue)
    print('Subscribed to URL Queue')

import webCrawlingSpider as wcs
import pubSub
import threading
import json


def callbackURLQueue(message):
    wcs.main(message)


if __name__ == '__main__':
    pubSub.subscribe('urlQueue', callbackURLQueue)
    print('Subscribed to URL Queue')

import webCrawlingSpider as wcs
import pubSub
import threading
import json

def callbackURLQueue(message):
	wcs.main(message)

if __name__ == '__main__':	

	pubSub.subscribe('urlQueue', callbackURLQueue)
	print("Subscribed to URL Queue")
