[Jboss-cvs] JBoss Messaging SVN: r1233 - branches/Branch_1_0/src/main/org/jboss/jms/client

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

Author: ovidiu.feodorov at jboss.com
Date: 2006-08-24 22:56:35 -0400 (Thu, 24 Aug 2006)
New Revision: 1233

Modified:
   branches/Branch_1_0/src/main/org/jboss/jms/client/JBossSession.java
Log:
http://jira.jboss.org/jira/browse/JBMESSAGING-533

Modified: branches/Branch_1_0/src/main/org/jboss/jms/client/JBossSession.java
===================================================================
--- branches/Branch_1_0/src/main/org/jboss/jms/client/JBossSession.java	2006-08-25 02:55:31 UTC (rev 1232)
+++ branches/Branch_1_0/src/main/org/jboss/jms/client/JBossSession.java	2006-08-25 02:56:35 UTC (rev 1233)
@@ -297,9 +297,22 @@
       {
          throw new InvalidDestinationException("Not a JBossTopic:" + topic);
       }
-      ConsumerDelegate consumerDelegate =
+
+      ThreadContextClassLoaderChanger tccc = new ThreadContextClassLoaderChanger();
+
+      try
+      {
+         tccc.set(getClass().getClassLoader());
+
+         ConsumerDelegate consumerDelegate =
             delegate.createConsumerDelegate((JBossTopic)topic, null, false, name, false);
-      return new JBossMessageConsumer(consumerDelegate);
+
+         return new JBossMessageConsumer(consumerDelegate);
+      }
+      finally
+      {
+         tccc.restore();
+      }
    }
 
    public TopicSubscriber createDurableSubscriber(Topic topic,