KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > mule > test > integration > service > TestReceiver


1 /*
2  * $Id: TestReceiver.java 3798 2006-11-04 04:07:14Z aperepel $
3  * --------------------------------------------------------------------------------------
4  * Copyright (c) MuleSource, Inc. All rights reserved. http://www.mulesource.com
5  *
6  * The software in this package is published under the terms of the MuleSource MPL
7  * license, a copy of which has been included with this distribution in the
8  * LICENSE.txt file.
9  */
10
11 package org.mule.test.integration.service;
12
13 import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger;
14
15 import javax.jms.TextMessage JavaDoc;
16
17 import org.apache.commons.logging.Log;
18 import org.apache.commons.logging.LogFactory;
19 import org.mule.impl.RequestContext;
20 import org.mule.util.StringMessageUtils;
21
22 public class TestReceiver
23 {
24     private static final Log logger = LogFactory.getLog(TestComponent.class);
25
26     private AtomicInteger count = new AtomicInteger(0);
27
28     public String JavaDoc receive(String JavaDoc message) throws Exception JavaDoc
29     {
30         if (logger.isDebugEnabled())
31         {
32             logger.debug(StringMessageUtils.getBoilerPlate("Received: " + message + " Number: " + inc()
33                                                            + " in thread: "
34                                                            + Thread.currentThread().getName()));
35             logger.debug("Message ID is: " + RequestContext.getEventContext().getMessage().getCorrelationId());
36         }
37
38         return "Received: " + message;
39     }
40
41     public String JavaDoc receive(TextMessage JavaDoc message) throws Exception JavaDoc
42     {
43         if (logger.isDebugEnabled())
44         {
45             logger.debug("Received: " + message.getText() + " Number: " + inc() + " in thread: "
46                          + Thread.currentThread().getName());
47             logger.debug("Message ID is: " + message.getJMSMessageID());
48         }
49
50         return "Received: " + message.getText();
51     }
52
53     protected int inc()
54     {
55         return count.incrementAndGet();
56     }
57
58 }
59
Popular Tags