[jBoss-Dev] CVS update: jboss/src/main/org/jboss/ejb/plugins/jmsJMSContainerInvoker.java

[jBoss CVS Development]

  User: pra     
  Date: 00/12/29 03:30:33

  Modified:    src/main/org/jboss/ejb/plugins/jms JMSContainerInvoker.java
  Log:
  Fixed DurableConsumer API for compile agains latest jms.jar - how to get a durable 
name is not fixed yet
  
  Revision  Changes    Path
  1.2       +3 -2      
jboss/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvoker.java
  
  Index: JMSContainerInvoker.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/jboss/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvoker.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- JMSContainerInvoker.java  2000/12/06 13:00:58     1.1
  +++ JMSContainerInvoker.java  2000/12/29 11:30:33     1.2
  @@ -59,7 +59,7 @@
    *      @author Rickard �berg ([EMAIL PROTECTED])
    *           @author <a href="mailto:[EMAIL PROTECTED]">Sebastien 
Alborini</a>
    *      @author <a href="mailto:[EMAIL PROTECTED]">Marc Fleury</a>
  - *      @version $Revision: 1.1 $
  + *      @version $Revision: 1.2 $
    */
   public class JMSContainerInvoker implements
   ContainerInvoker, XmlLoadable
  @@ -288,7 +288,8 @@
            connectionConsumer = topicConnection.createConnectionConsumer(topic, 
messageSelector, pool, maxMessagesNr); 
           } else {
               // Create durable - FIXME durable name!!
  -            connectionConsumer = 
topicConnection.createDurableConnectionConsumer(topic, messageSelector, pool, 
maxMessagesNr);
  +            String durableName = "";
  +            connectionConsumer = 
topicConnection.createDurableConnectionConsumer(topic, durableName,messageSelector, 
pool, maxMessagesNr);
           }
           // set global connection, so we have something to start() and close()
           connection = topicConnection;