Always use 'localhost', avoid setting username and password.

Author: majek

java/Recv.java

@@ -8,7 +8,9 @@ public static void main(String[] argv) {
     try {
       Connection conn = null;
       try {
-        conn = new ConnectionFactory().newConnection();
+        ConnectionFactory factory = new ConnectionFactory();
+        factory.setHost("localhost");
+        conn = factory.newConnection();
         Channel chan = conn.createChannel();
         chan.queueDeclare("hello", false, false, false, null);
         QueueingConsumer consumer = new QueueingConsumer(chan);

java/Send.java

@@ -8,7 +8,9 @@ public static void main(String[] argv) {
     try {
       Connection conn = null;
       try {
-        conn = new ConnectionFactory().newConnection();
+        ConnectionFactory factory = new ConnectionFactory();
+        factory.setHost("localhost");
+        conn = factory.newConnection();
         Channel chan = conn.createChannel();
         chan.queueDeclare("hello", false, false, false, null);
         chan.basicPublish("", "hello", null, "Hello World!".getBytes());

python/emit_log.py

@@ -3,8 +3,7 @@
 import sys
 
 connection = pika.AsyncoreConnection(pika.ConnectionParameters(
-        host='127.0.0.1',
-        credentials=pika.PlainCredentials('guest', 'guest')))
+        host='localhost'))
 channel = connection.channel()
 
 channel.exchange_declare(exchange='logs',

python/emit_log_direct.py

@@ -3,8 +3,7 @@
 import sys
 
 connection = pika.AsyncoreConnection(pika.ConnectionParameters(
-        host='127.0.0.1',
-        credentials=pika.PlainCredentials('guest', 'guest')))
+        host='localhost'))
 channel = connection.channel()
 
 channel.exchange_declare(exchange='direct_logs',

python/new_task.py

@@ -3,8 +3,7 @@
 import sys
 
 connection = pika.AsyncoreConnection(pika.ConnectionParameters(
-        host='127.0.0.1',
-        credentials=pika.PlainCredentials('guest', 'guest')))
+        host='localhost'))
 channel = connection.channel()
 
 channel.queue_declare(queue='task_queue', durable=True)

python/receive.py

@@ -2,8 +2,7 @@
 import pika
 
 connection = pika.AsyncoreConnection(pika.ConnectionParameters(
-        host='127.0.0.1',
-        credentials=pika.PlainCredentials('guest', 'guest')))
+        host='localhost'))
 channel = connection.channel()
 
 

python/receive_logs.py

@@ -2,8 +2,7 @@
 import pika
 
 connection = pika.AsyncoreConnection(pika.ConnectionParameters(
-        host='127.0.0.1',
-        credentials=pika.PlainCredentials('guest', 'guest')))
+        host='localhost'))
 channel = connection.channel()
 
 channel.exchange_declare(exchange='logs',

python/receive_logs_direct.py

@@ -3,8 +3,7 @@
 import sys
 
 connection = pika.AsyncoreConnection(pika.ConnectionParameters(
-        host='127.0.0.1',
-        credentials=pika.PlainCredentials('guest', 'guest')))
+        host='localhost'))
 channel = connection.channel()
 
 channel.exchange_declare(exchange='direct_logs',

python/rpc_client.py

@@ -5,8 +5,7 @@
 class FibonacciClient(object):
     def __init__(self):
         self.connection = pika.AsyncoreConnection(pika.ConnectionParameters(
-                host='127.0.0.1',
-                credentials=pika.PlainCredentials('guest', 'guest')))
+                host='localhost'))
         self.channel = self.connection.channel()
 
         result = self.channel.queue_declare(auto_delete=True)

python/rpc_server.py

@@ -3,8 +3,7 @@
 
 
 connection = pika.AsyncoreConnection(pika.ConnectionParameters(
-        host='127.0.0.1',
-        credentials=pika.PlainCredentials('guest', 'guest')))
+        host='localhost'))
 channel = connection.channel()