Author: alessio.soldano(a)jboss.com Date: 2013-06-05 13:54:10 -0400 (Wed, 05 Jun 2013) New Revision: 17653 Modified: stack/cxf/branches/JBWS-3648/modules/server/src/main/java/org/jboss/wsf/stack/cxf/configuration/BusHolder.java Log: Install new bean listener into deployment bus Modified: stack/cxf/branches/JBWS-3648/modules/server/src/main/java/org/jboss/wsf/stack/cxf/configuration/BusHolder.java =================================================================== --- stack/cxf/branches/JBWS-3648/modules/server/src/main/java/org/jboss/wsf/stack/cxf/configuration/BusHolder.java 2013-06-05 17:52:55 UTC (rev 17652) +++ stack/cxf/branches/JBWS-3648/modules/server/src/main/java/org/jboss/wsf/stack/cxf/configuration/BusHolder.java 2013-06-05 17:54:10 UTC (rev 17653) @@ -38,6 +38,8 @@ import org.apache.cxf.management.interceptor.ResponseTimeMessageOutInterceptor; import org.apache.cxf.resource.ResourceManager; import org.apache.cxf.resource.ResourceResolver; +import org.apache.cxf.service.factory.FactoryBeanListener; +import org.apache.cxf.service.factory.FactoryBeanListenerManager; import org.apache.cxf.workqueue.AutomaticWorkQueue; import org.apache.cxf.workqueue.AutomaticWorkQueueImpl; import org.apache.cxf.workqueue.WorkQueueManager; @@ -55,6 +57,7 @@ import org.jboss.wsf.stack.cxf.interceptor.EndpointAssociationInterceptor; import org.jboss.wsf.stack.cxf.interceptor.NsCtxSelectorStoreInterceptor; import org.jboss.wsf.stack.cxf.management.InstrumentationManagerExtImpl; +import org.jboss.wsf.stack.cxf.policy.PolicySetsAnnotationListener; /** * A wrapper of the Bus for performing most of the configurations required on it by JBossWS @@ -70,6 +73,7 @@ protected Bus bus; protected BusHolderLifeCycleListener busHolderListener; + protected FactoryBeanListener policySetsListener; public BusHolder() { @@ -111,6 +115,9 @@ setCXFManagement(bus, props); //*first* enabled cxf management if required, *then* add anything else which could be manageable (e.g. work queues) setAdditionalWorkQueues(bus, props); setWSDiscovery(bus, props); + + policySetsListener = new PolicySetsAnnotationListener(); + bus.getExtension(FactoryBeanListenerManager.class).addListener(policySetsListener); } @@ -126,6 +133,8 @@ bus.shutdown(true); } busHolderListener = null; + bus.getExtension(FactoryBeanListenerManager.class).removeListener(policySetsListener); + policySetsListener = null; } /**