001
014
015 package com.liferay.portal.kernel.messaging.config;
016
017 import com.liferay.portal.kernel.messaging.MessageBus;
018 import com.liferay.portal.kernel.messaging.MessageBusUtil;
019 import com.liferay.portal.kernel.portlet.PortletClassLoaderUtil;
020 import com.liferay.portal.kernel.util.ClassLoaderPool;
021
022
025 public class PluginMessagingConfigurator extends AbstractMessagingConfigurator {
026
027 @Override
028 public void afterPropertiesSet() {
029 _servletContextName = PortletClassLoaderUtil.getServletContextName();
030
031 super.afterPropertiesSet();
032 }
033
034 @Override
035 protected MessageBus getMessageBus() {
036 return MessageBusUtil.getMessageBus();
037 }
038
039 @Override
040 protected ClassLoader getOperatingClassloader() {
041 ClassLoader classLoader = ClassLoaderPool.getClassLoader(
042 _servletContextName);
043
044 if (classLoader == null) {
045 Thread currentThread = Thread.currentThread();
046
047 classLoader = currentThread.getContextClassLoader();
048 }
049
050 return classLoader;
051 }
052
053 private String _servletContextName;
054
055 }