<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=us-ascii">
</head>
<body dir="auto">
<div>Thank you very much for your feedback, Simon and woodslee. I now have an idea what the problem might be. For both localhost and dev-environment we use the same rabbitmq-cloud service. This might explain, why I got only every second message in the first
place. As I extracted the relevant code to a main-method I obviously created yet another consumer, which is why now only every third message was displayed.</div>
<div>I'm going to try this out. Thanks a lot!<br>
<br>
Von meinem iPhone gesendet</div>
<div><br>
Am 05.12.2013 um 02:48 schrieb "woodslee" <<a href="mailto:woodslee@126.com">woodslee@126.com</a>>:<br>
<br>
</div>
<blockquote type="cite">
<div>
<title>Mail</title>
<meta name="GENERATOR" content="KsDHTMLEDLib.ocx, FreeWare HTML Editor 1.164.2, ?Kurt Senfer">
<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>
</div>
</blockquote>
<blockquote type="cite">
<div><span>_______________________________________________</span><br>
<span>rabbitmq-discuss mailing list</span><br>
<span><a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a></span><br>
<span><a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a></span><br>
</div>
</blockquote>
</body>
</html>