svn commit: r692821 - /synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/jms/LogAspect.java

[veithen]

Author: veithen
Date: Sun Sep  7 04:37:47 2008
New Revision: 692821

URL: http://svn.apache.org/viewvc?rev=692821&view=rev
Log:
JMS transport tests: fixed some issues with message logging.

Modified:
    
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/jms/LogAspect.java

Modified: 
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/jms/LogAspect.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/jms/LogAspect.java?rev=692821&r1=692820&r2=692821&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/jms/LogAspect.java
 (original)
+++ 
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/jms/LogAspect.java
 Sun Sep  7 04:37:47 2008
@@ -39,12 +39,14 @@
 public class LogAspect {
     private static final Log log = LogFactory.getLog(LogAspect.class);
     
-    @Before("call(void javax.jms.MessageProducer.send(javax.jms.Message)) && 
args(message)")
+    @Before("(call(void javax.jms.MessageProducer.send(javax.jms.Message)) ||" 
+
+               " call(void 
javax.jms.TopicPublisher.publish(javax.jms.Message))) && args(message)")
     public void beforeSend(Message message) {
         try {
             OutputStream out = LogManager.INSTANCE.createLog("jms");
             try {
                 PrintWriter pw = new PrintWriter(new OutputStreamWriter(out), 
false);
+                pw.println("Type: " + message.getClass().getName());
                 pw.println("JMS message ID: " + message.getJMSMessageID());
                 pw.println("JMS correlation ID: " + 
message.getJMSCorrelationID());
                 pw.println("JMS reply to: " + message.getJMSReplyTo());
@@ -62,6 +64,7 @@
                     IOUtils.copy(new BytesMessageInputStream(bytesMessage), 
out);
                 } else if (message instanceof TextMessage) {
                     pw.print(((TextMessage)message).getText());
+                    pw.flush();
                 }
             } finally {
                 out.close();