rabbitmq

src/main/python/kr/co/swh/lecture/opensource/rabbitmq/receive.py

@@ -0,0 +1,22 @@
+import pika
+
+class Consumer: 
+    def __init__(self): 
+        self.__url = 'dev-swh.ga' 
+        self.__port = 5672 
+        self.__vhost = '/' 
+        self.__cred = pika.PlainCredentials('guest', 'guest') 
+        self.__queue = 'py'; 
+    
+    def on_message(channel, method_frame, header_frame, body): 
+        print('Received %s' % body) 
+    
+    def main(self): 
+        conn = pika.BlockingConnection(pika.ConnectionParameters(self.__url, self.__port, self.__vhost, self.__cred)) 
+        chan = conn.channel() 
+        chan.basic_consume( queue = self.__queue, on_message_callback = Consumer.on_message, auto_ack = True ) 
+        print('Consumer is starting...') 
+        chan.start_consuming() 
+
+consumer = Consumer() 
+consumer.main()

src/main/python/kr/co/swh/lecture/opensource/rabbitmq/send.py

@@ -0,0 +1,19 @@
+import pika
+
+class Publisher: 
+    def __init__(self): 
+        self.__url = 'dev-swh.ga' 
+        self.__port = 5672 
+        self.__vhost = '/' 
+        self.__cred = pika.PlainCredentials('guest', 'guest') 
+        self.__queue = 'py'; 
+        
+    def main(self): 
+        conn = pika.BlockingConnection(pika.ConnectionParameters(self.__url, self.__port, self.__vhost, self.__cred)) 
+        chan = conn.channel() 
+        chan.basic_publish( exchange = '', routing_key = self.__queue, body = 'Hello RabbitMQ' ) 
+        conn.close() 
+
+publisher = Publisher() 
+publisher.main()
+