Just RabbitMQ Changes.

kumar-github · kumar-github · commit 39074f44e1fc · 2016-10-22T22:37:34.000+05:30
diff --git a/RabbitMQ/src/Receive.java b/RabbitMQ/src/Receive.java
@@ -1,4 +1,6 @@
+import java.io.ByteArrayInputStream;
 import java.io.IOException;
+import java.io.ObjectInputStream;
 
 import com.rabbitmq.client.AMQP;
 import com.rabbitmq.client.Channel;
@@ -13,7 +15,8 @@ public class Receive {
   private final static String QUEUE_NAME = "hello";
 
   public static void main(String[] argv) throws Exception {
-    ConnectionFactory factory = new ConnectionFactory();
+    //User s = new User();
+	  ConnectionFactory factory = new ConnectionFactory();
     factory.setHost("localhost");
     Connection connection = factory.newConnection();
     Channel channel = connection.createChannel();
@@ -25,10 +28,30 @@ public static void main(String[] argv) throws Exception {
       @Override
       public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)
           throws IOException {
-        String message = new String(body, "UTF-8");
-        System.out.println(" [x] Received '" + message + "'");
+        //String message = new String(body, "UTF-8");
+        //System.out.println(" [x] Received '" + message + "'");
+    	  ByteArrayInputStream b = new ByteArrayInputStream(body);
+    	  ObjectInputStream i = new ObjectInputStream(b);
+    	  try {
+			User s = (User)i.readObject();
+			System.out.println(s.getFirstName());
+			System.out.println(s.getLastName());
+		} catch (ClassNotFoundException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
       }
     };
     channel.basicConsume(QUEUE_NAME, true, consumer);
+    
+    /*Consumer consumer = new DefaultConsumer(channel);
+    channel.basicConsume(QUEUE_NAME, true, consumer);
+    
+    while(true)
+    {
+    	//consumer.handleDelivery(arg0, arg1, arg2, arg3);
+    }*/
+    
+    
   }
 }
diff --git a/RabbitMQ/src/Send.java b/RabbitMQ/src/Send.java
@@ -1,4 +1,6 @@
+import java.io.ByteArrayOutputStream;
 import java.io.IOException;
+import java.io.ObjectOutputStream;
 import java.util.concurrent.TimeoutException;
 
 import com.rabbitmq.client.Channel;
@@ -9,8 +11,27 @@ public class Send
 {
 	private static final String QUEUE_NAME = "hello";
 	
-	public static void main(String[] args)
+	public static void main(String[] args) throws  Exception
 	{
+		User user = new User();
+		user.setFirstName("First Name");
+		user.setLastName("Last Name");
+		
+		//ObjectOutputStream o = new ObjectOutputStream(new FileOutputStream("a.dat"));
+		//o.writeObject(user);
+		
+		ByteArrayOutputStream bb = new ByteArrayOutputStream();
+		
+		ObjectOutputStream o = new ObjectOutputStream(bb);
+		o.writeObject(user);
+		
+		
+//		ObjectInputStream i = new ObjectInputStream(new FileInputStream("a.dat"));
+//		User newUser = (User)i.readObject();
+//		System.out.println(newUser.getFirstName());
+//		System.out.println(newUser.getLastName());
+		
+		
 		ConnectionFactory factory = new ConnectionFactory();
 		factory.setHost("localhost");
 		try {
@@ -19,7 +40,11 @@ public static void main(String[] args)
 			
 			channel.queueDeclare(QUEUE_NAME, false, false, false, null);
 			String message = "This is to test.";
-			channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
+			//channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
+			for(int i=0;i<1000;i++)
+			{
+				channel.basicPublish("", QUEUE_NAME, null, bb.toByteArray());
+			}
 			System.out.println("X sent : " + message + "");
 			
 			channel.close();
diff --git a/RabbitMQ/src/User.java b/RabbitMQ/src/User.java
@@ -0,0 +1,21 @@
+import java.io.Serializable;
+
+public class User implements Serializable
+{
+	private String firstName;
+	private String lastName;
+	
+	public String getFirstName() {
+		return firstName;
+	}
+	public void setFirstName(String firstName) {
+		this.firstName = firstName;
+	}
+	public String getLastName() {
+		return lastName;
+	}
+	public void setLastName(String lastName) {
+		this.lastName = lastName;
+	}
+	
+}
