[jboss-cvs] JBoss Messaging SVN: r6620 - trunk/examples/jms/security/src/org/jboss/jms/example.

[jboss-cvs-commits at lists.jboss.org]

Author: gaohoward
Date: 2009-04-29 03:18:01 -0400 (Wed, 29 Apr 2009)
New Revision: 6620

Modified:
   trunk/examples/jms/security/src/org/jboss/jms/example/SecurityExample.java
Log:
temp commit


Modified: trunk/examples/jms/security/src/org/jboss/jms/example/SecurityExample.java
===================================================================
--- trunk/examples/jms/security/src/org/jboss/jms/example/SecurityExample.java	2009-04-29 07:09:35 UTC (rev 6619)
+++ trunk/examples/jms/security/src/org/jboss/jms/example/SecurityExample.java	2009-04-29 07:18:01 UTC (rev 6620)
@@ -168,15 +168,22 @@
       MessageProducer producer = session.createProducer(topic);
       MessageConsumer consumer = session.createConsumer(topic);
       TextMessage msg = session.createTextMessage("hello-world-1");
-      producer.send(msg);
-      TextMessage receivedMsg = (TextMessage)consumer.receive(2000);
-      if (receivedMsg == null)
+      
+      try
       {
-         System.out.println("User " + user + " cannot send message [" + msg.getText() + "] to topic " + topic);
+         producer.send(msg);
+         System.out.println("Security setting is broken! User " + user + " can send message [" + msg.getText() + "] to topic " + topic);
+         result = false;
       }
-      else
+      catch (JMSException e)
       {
-         System.out.println("Security setting is broken! User " + user + " can send message [" + receivedMsg.getText() + "] to topic " + topic);
+         System.out.println("User " + user + " cannot send message [" + msg.getText() + "] to topic: " + topic);
+      }
+
+      TextMessage receivedMsg = (TextMessage)consumer.receive(2000);
+      if (receivedMsg != null)
+      {
+         System.out.println("Security setting is broken for User " + user + ". message [" + receivedMsg.getText() + "] to topic " + topic + " shouldn't be received!");
          result = false;
       }
 
@@ -196,6 +203,8 @@
          System.out.println("Security setting is broken! User " + user + " cannot receive message from topic " + topic);
          result = false;         
       }
+      
+      session1.close();
       session.close();
    }