[hornetq-commits] JBoss hornetq SVN: r12258 - trunk/hornetq-ra/hornetq-ra-jar/src/main/java/org/hornetq/ra.

[do-not-reply at jboss.org]

Author: borges
Date: 2012-03-07 07:49:11 -0500 (Wed, 07 Mar 2012)
New Revision: 12258

Modified:
   trunk/hornetq-ra/hornetq-ra-jar/src/main/java/org/hornetq/ra/HornetQRASession.java
Log:
Fix type warnings

Modified: trunk/hornetq-ra/hornetq-ra-jar/src/main/java/org/hornetq/ra/HornetQRASession.java
===================================================================
--- trunk/hornetq-ra/hornetq-ra-jar/src/main/java/org/hornetq/ra/HornetQRASession.java	2012-03-07 12:48:58 UTC (rev 12257)
+++ trunk/hornetq-ra/hornetq-ra-jar/src/main/java/org/hornetq/ra/HornetQRASession.java	2012-03-07 12:49:11 UTC (rev 12258)
@@ -50,13 +50,14 @@
 import javax.resource.ResourceException;
 import javax.resource.spi.ConnectionEvent;
 import javax.resource.spi.ManagedConnection;
+import javax.transaction.RollbackException;
 import javax.transaction.xa.XAResource;
 
 import org.hornetq.core.logging.Logger;
 
 /**
  * A joint interface for JMS sessions
- * 
+ *
  * @author <a href="mailto:adrian at jboss.com">Adrian Brock</a>
  * @author <a href="mailto:jesper.pedersen at jboss.org">Jesper Pedersen</a>
  * @version $Revision: $
@@ -79,10 +80,10 @@
    private HornetQRASessionFactory sf;
 
    /** The message consumers */
-   private final Set consumers;
+   private final Set<MessageConsumer> consumers;
 
    /** The message producers */
-   private final Set producers;
+   private final Set<MessageProducer> producers;
 
    /**
     * Constructor
@@ -99,8 +100,8 @@
       this.mc = mc;
       this.cri = cri;
       sf = null;
-      consumers = new HashSet();
-      producers = new HashSet();
+      consumers = new HashSet<MessageConsumer>();
+      producers = new HashSet<MessageProducer>();
    }
 
    /**
@@ -543,7 +544,7 @@
     * Create a topic subscriber
     * @param topic The topic
     * @param messageSelector The message selector
-    * @param noLocal If true inhibits the delivery of messages published by its own connection 
+    * @param noLocal If true inhibits the delivery of messages published by its own connection
     * @return The subscriber
     * @exception JMSException Thrown if an error occurs
     */
@@ -630,7 +631,7 @@
     * @param topic The topic
     * @param name The name
     * @param messageSelector The message selector
-    * @param noLocal If true inhibits the delivery of messages published by its own connection 
+    * @param noLocal If true inhibits the delivery of messages published by its own connection
     * @return The subscriber
     * @exception JMSException Thrown if an error occurs
     */
@@ -1100,7 +1101,7 @@
     * Create a message consumer
     * @param destination The destination
     * @param messageSelector The message selector
-    * @param noLocal If true inhibits the delivery of messages published by its own connection 
+    * @param noLocal If true inhibits the delivery of messages published by its own connection
     * @return The message consumer
     * @exception JMSException Thrown if an error occurs
     */
@@ -1339,7 +1340,7 @@
    {
       return mc;
    }
-   
+
    /**
     * Destroy
     */
@@ -1425,7 +1426,7 @@
 
          synchronized (consumers)
          {
-            for (Iterator i = consumers.iterator(); i.hasNext();)
+            for (Iterator<MessageConsumer> i = consumers.iterator(); i.hasNext();)
             {
                HornetQRAMessageConsumer consumer = (HornetQRAMessageConsumer)i.next();
                try
@@ -1442,7 +1443,7 @@
 
          synchronized (producers)
          {
-            for (Iterator i = producers.iterator(); i.hasNext();)
+            for (Iterator<MessageProducer> i = producers.iterator(); i.hasNext();)
             {
                HornetQRAMessageProducer producer = (HornetQRAMessageProducer)i.next();
                try
@@ -1621,9 +1622,9 @@
    }
 
    /**
-    * @throws SystemException 
-    * @throws RollbackException 
-    * 
+    * @throws SystemException
+    * @throws RollbackException
+    *
     */
    public void checkState() throws JMSException
    {