<HTML><HEAD><TITLE>Mail</TITLE>
<META name=GENERATOR 
content="KsDHTMLEDLib.ocx, FreeWare HTML Editor 1.164.2, ?Kurt Senfer">
<META content="text/html; charset=GB2312" http-equiv=Content-Type></HEAD>
<BODY style="FONT-SIZE: 9pt; FONT-FAMILY: " leftMargin=5 topMargin=5 #ffffff>
<DIV>Hi Tom</DIV>
<DIV> </DIV>
<DIV>I run the test in my computer, and I got all the messages form 0 to 
9.</DIV>
<DIV>but i comment the statement </DIV>
<DIV> </DIV>
<DIV>if (!StringUtils.isEmpty(message)) </DIV>
<DIV> </DIV>
<DIV>Is the static method "isEmpty"  wrong?</DIV>
<DIV> </DIV>
<DIV> </DIV>
<DIV>----- Original Message ----- </DIV>
<BLOCKQUOTE 
style="PADDING-LEFT: 5px; MARGIN-LEFT: 5px; BORDER-LEFT: #000000 2px solid; PADDING-RIGHT: 0px; MARGIN-RIGHT: 0px">
  <DIV 
  style="FONT-SIZE: 9pt; FONT-VARIANT: normal; BACKGROUND: #e4e4e4; FONT-WEIGHT: normal; FONT-STYLE: normal; LINE-HEIGHT: normal; font-color: black"><B>From: 
  </B><A href="mailto:tom.reineke@googlemail.com">Tom Reineke</A> </DIV>
  <DIV 
  style="FONT-SIZE: 9pt; FONT-VARIANT: normal; FONT-WEIGHT: normal; FONT-STYLE: normal; LINE-HEIGHT: normal"><B>To: 
  </B><A href="mailto:rabbitmq-discuss@googlegroups.com">rabbitmq-discuss</A> 
  </DIV>
  <DIV 
  style="FONT-SIZE: 9pt; FONT-VARIANT: normal; FONT-WEIGHT: normal; FONT-STYLE: normal; LINE-HEIGHT: normal"><B>Sent: 
  </B>2013-12-04, 23:26:47</DIV>
  <DIV 
  style="FONT-SIZE: 9pt; FONT-VARIANT: normal; FONT-WEIGHT: normal; FONT-STYLE: normal; LINE-HEIGHT: normal"><B>Subject: 
  </B>[rabbitmq-discuss] Basic question on message delivery problem</DIV>
  <DIV><BR></DIV>
  <DIV></DIV>
  <DIV></DIV>
  <DIV>
  <DIV dir=ltr>Hi, 
  <DIV><BR></DIV>
  <DIV>I seem to have a very basic problem when setting up RabbitMQ and would be 
  grateful for any help. Ich have the following class:</DIV>
  <DIV><BR></DIV>
  <DIV>
  <DIV>public class RabbitTest {</DIV>
  <DIV><BR></DIV>
  <DIV><SPAN class=Apple-tab-span style="WHITE-SPACE: pre"></SPAN>private final 
  static ConnectionFactory factory = new ConnectionFactory();</DIV>
  <DIV>        private final static String MAIL_QUEUE_NAME = 
  "mailQueue";</DIV>
  <DIV>        private static Connection connection;</DIV>
  <DIV>        private static Channel channel;</DIV>
  <DIV>        private static QueueingConsumer 
  consumer;</DIV>
  <DIV><BR></DIV>
  <DIV><SPAN class=Apple-tab-span style="WHITE-SPACE: pre"></SPAN>public static 
  void main(final String[] args) throws IOException, KeyManagementException, 
  NoSuchAlgorithmException,  URISyntaxException, InterruptedException 
  {</DIV>
  <DIV>        factory = new ConnectionFactory();</DIV>
  <DIV><SPAN class=Apple-tab-span 
  style="WHITE-SPACE: pre"></SPAN>factory.setHost("localhost");</DIV>
  <DIV>        connection = factory.newConnection();</DIV>
  <DIV>        channel = connection.createChannel();</DIV>
  <DIV>        channel.queueDeclare(MAIL_QUEUE_NAME, true, 
  false, false, null);</DIV>
  <DIV>        consumer = new 
  QueueingConsumer(channel);</DIV>
  <DIV>        channel.basicConsume(MAIL_QUEUE_NAME, false, 
  consumer);</DIV>
  <DIV>        new Thread() {</DIV>
  <DIV>            @Override</DIV>
  <DIV>            public void run() {</DIV>
  <DIV>                while (true) 
  {</DIV>
  <DIV>                    try 
  {</DIV>
  <DIV>                    
      // The processor stops here until something</DIV>
  <DIV>                    
      // is in the queue. It does not continue with the next</DIV>
  <DIV>                    
      final QueueingConsumer.Delivery delivery = consumer</DIV>
  <DIV>                    
              .nextDelivery();</DIV>
  <DIV>                    
      final String message = new String(delivery.getBody());</DIV>
  <DIV>                    
      if (!StringUtils.isEmpty(message)) {</DIV>
  <DIV>                    
          System.out.println("########## message 
  #############");</DIV>
  <DIV>                    
          System.out.println(message);</DIV>
  <DIV>                    
      }</DIV>
  <DIV>                    } 
  catch (final Exception e) {</DIV>
  <DIV><BR></DIV>
  <DIV>                    
  }</DIV>
  <DIV>                }</DIV>
  <DIV>            }</DIV>
  <DIV>        }.start();</DIV>
  <DIV><BR></DIV>
  <DIV>        for (int i = 0; i < 10; i++) {</DIV>
  <DIV>            createMailTask("message " + 
  i);</DIV>
  <DIV>        }</DIV>
  <DIV><BR></DIV>
  <DIV>        Thread.sleep(10000);</DIV>
  <DIV>        channel.close();</DIV>
  <DIV>        connection.close();</DIV>
  <DIV>    }</DIV>
  <DIV><BR></DIV>
  <DIV>    public static void createMailTask(final String 
  amqpMessage)</DIV>
  <DIV>            throws IOException {</DIV>
  <DIV>        final Channel ch = 
  connection.createChannel();</DIV>
  <DIV>        ch.queueDeclare(MAIL_QUEUE_NAME, true, false, 
  false, null);</DIV>
  <DIV>        ch.basicPublish("", MAIL_QUEUE_NAME,</DIV>
  <DIV>                
  MessageProperties.PERSISTENT_TEXT_PLAIN, amqpMessage.getBytes());</DIV>
  <DIV>        ch.close();</DIV>
  <DIV>    }</DIV>
  <DIV>}</DIV>
  <DIV><BR></DIV>
  <DIV>I would have assumed that I get a log output for each of the 10 messages; 
  instead I only get:</DIV>
  <DIV><BR></DIV>
  <DIV>[Thread-0] INFO de.apt.utils.APTMailUtil - ########## message 
  #############</DIV>
  <DIV>[Thread-0] INFO de.apt.utils.APTMailUtil - message 2</DIV>
  <DIV>[Thread-0] INFO de.apt.utils.APTMailUtil - ########## message 
  #############</DIV>
  <DIV>[Thread-0] INFO de.apt.utils.APTMailUtil - message 5</DIV>
  <DIV>[Thread-0] INFO de.apt.utils.APTMailUtil - ########## message 
  #############</DIV>
  <DIV>[Thread-0] INFO de.apt.utils.APTMailUtil - message 8</DIV></DIV>
  <DIV><BR></DIV>
  <DIV>Can you tell me where the problem is in my 
code?</DIV></DIV></DIV></BLOCKQUOTE></BODY></HTML>