ClientHandler.java

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;

import java.io.BufferedInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.net.Socket;

/**
 * Created by sameerraghuram on 4/25/17.
 */
public class ClientHandler implements Runnable {
 Socket clientSocket;
 Callbacks callbacks;

 public ClientHandler(Socket clientSocket){
 this.clientSocket = clientSocket;
 this.callbacks = Callbacks.getInstance();
 }


 @Override
 public void run() {

 // Buffer
 byte[] buf = new byte[1024];

 try {
 BufferedInputStream bis = new BufferedInputStream(clientSocket.getInputStream());
 ByteArrayOutputStream byos = new ByteArrayOutputStream();

 // Read bytes from the socket input stream in 1024 increments
 // Untill we reach EOF
 while(bis.read(buf, 0, buf.length) != -1){
 // Write bytes to a op stream
 byos.write(buf, 0, buf.length);
 }

 // Capture the byte array as a string
 String message = byos.toString("utf-8").trim();

 // Convert String to JSON
 Gson gson = new GsonBuilder().setPrettyPrinting().setLenient().create();

 System.out.println(message);
 Message messageJSON = gson.fromJson(message, Message.class);

 if(messageJSON.HEADER.REQUEST.equals(Consts.REQ_ADD_MESSGAE)){
 PublishMessage publishMessage = gson.fromJson(message, PublishMessage.class);

 String queueName = publishMessage.QUEUE_NAME;
 String exchangeName = publishMessage.EXCHANGE_NAME;
 String key = exchangeName.equals("default") ? queueName : exchangeName + "." + queueName;

 callbacks.exec(key, publishMessage.PUBLISH_MESSAGE);

 }

 } catch (IOException e) {
 e.printStackTrace();
 } catch (Exception e) {
 e.printStackTrace();
 }
 finally {
 try {
 clientSocket.close();
 } catch (IOException e) {
 e.printStackTrace();
 }
 }
 }
}