rabbitmq - java client lib一二事

import java.io.IOException;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.MessageProperties;
import com.rabbitmq.client.ConnectionParameters;

public class NewTask {

  private static final String TASK_QUEUE_NAME = "your_xxx_queue";

  public static void main(String[] argv)
                      throws java.io.IOException {
    String hostName ="your.domain.name";
    int portNumber = 5672;//AMQP.PROTOCOL.PORT
    int ticket =  0;
    ConnectionParameters params = new ConnectionParameters();
    params.setUsername("username_xxx");
    params.setPassword("password_xxx");
    params.setVirtualHost("virutalhost_xxxx");
    params.setRequestedHeartbeat(0);//TODO:
    ConnectionFactory factory = new ConnectionFactory(params);
    Connection connection = factory.newConnection(hostName, portNumber);

    Channel channel = connection.createChannel();

    channel.queueDeclare(ticket,TASK_QUEUE_NAME, false, true, false, false, null);
    /*
    queueDeclare(int ticket,
                                  java.lang.String queue,
                                  boolean passive,
                                  boolean durable,
                                  boolean exclusive,
                                  boolean autoDelete,
                                  java.util.Map<java.lang.String,java.lang.Object> arguments)
    */

    String message = "hello";

    //http://www.rabbitmq.com/releases/rabbitmq-java-client/v1.4.0/rabbitmq-java-client-javadoc-1.4.0/com/rabbitmq/client/Channel.html#basicPublish
    channel.basicPublish(ticket, "", TASK_QUEUE_NAME,
            MessageProperties.PERSISTENT_TEXT_PLAIN,
            message.getBytes());
    System.out.println(" [x] Sent ‘" + message + "‘");
    int closeCode = 200;
    String closeMessage="job done.";
    channel.close(closeCode, closeMessage);
    connection.close();
  }      
  //...
}