package com.redch;

import java.io.IOException;

import com.redch.exception.AMQPServiceException;

/**
 * The producer endpoint that writes to the queue.
 *
 */
public class Producer extends EndPoint {

	public Producer(String host, String exchangeName) throws IOException, AMQPServiceException{
		super(host, exchangeName);
	}

	public void sendMessage(String message) throws IOException {
    if (connection == null) {
      connect();
    }
		channel.basicPublish(exchangeName, "", null, message.getBytes());
		System.out.println(" [x] Sent '" + message + "'");
	}
}

@@ -384,16 +384,17 @@
 ption %7B%0A
+%09
     if (
@@ -415,16 +415,17 @@
 null) %7B%0A
+%09
       co
@@ -433,16 +433,17 @@
 nect();%0A
+%09
     %7D%0A%09%09

Fix text alignment