svn commit: r701862 - /cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConfigFeature.java

[cschneider-2]

Author: cschneider
Date: Sun Oct  5 12:24:44 2008
New Revision: 701862

URL: http://svn.apache.org/viewvc?rev=701862&view=rev
Log:
CXF-1832 JMSConfigFeature Server part

Modified:
    cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConfigFeature.java

Modified: cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConfigFeature.java
URL: http://svn.apache.org/viewvc/cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConfigFeature.java?rev=701862&r1=701861&r2=701862&view=diff
==============================================================================
--- cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConfigFeature.java (original)
+++ cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConfigFeature.java Sun Oct  5 12:24:44 2008
@@ -20,12 +20,14 @@
 
 import org.apache.cxf.Bus;
 import org.apache.cxf.endpoint.Client;
+import org.apache.cxf.endpoint.Server;
 import org.apache.cxf.feature.AbstractFeature;
 import org.apache.cxf.transport.Conduit;
+import org.apache.cxf.transport.Destination;
 import org.springframework.beans.factory.annotation.Required;
 
 /**
- * Allows to configure the JMSConfiguration directly at the Client or Endpoint. Simply add this class to the
+ * Allows to configure the JMSConfiguration directly at the Client or Server. Simply add this class to the
  * Features and reference a JMSConfiguration. The configuration inside this class takes precedence over a
  * configuration that is generated from the old configuration style.
  */
@@ -42,6 +44,16 @@
         super.initialize(client, bus);
     }
 
+    @Override
+    public void initialize(Server server, Bus bus) {
+        Destination destination = server.getDestination();
+        if (destination instanceof JMSDestination && jmsConfig != null) {
+            JMSDestination jmsConduit = (JMSDestination)destination;
+            jmsConduit.setJmsConfig(jmsConfig);
+        }
+        super.initialize(server, bus);
+    }
+    
     public JMSConfiguration getJmsConfig() {
         return jmsConfig;
     }