1
22
23 package com.liferay.portal.deploy.hot;
24
25 import com.liferay.portal.kernel.deploy.hot.HotDeployEvent;
26 import com.liferay.portal.kernel.deploy.hot.HotDeployException;
27 import com.liferay.portal.kernel.messaging.DestinationNames;
28 import com.liferay.portal.kernel.messaging.Message;
29 import com.liferay.portal.kernel.messaging.MessageBusUtil;
30
31 import javax.servlet.ServletContext;
32
33
38 public class MessagingHotDeployListener extends BaseHotDeployListener {
39
40 public void invokeDeploy(HotDeployEvent event) throws HotDeployException {
41 try {
42 doInvokeDeploy(event);
43 }
44 catch (Throwable t) {
45 throwHotDeployException(
46 event, "Error sending deploy message for ", t);
47 }
48 }
49
50 public void invokeUndeploy(HotDeployEvent event) throws HotDeployException {
51 try {
52 doInvokeUndeploy(event);
53 }
54 catch (Throwable t) {
55 throwHotDeployException(
56 event, "Error sending undeploy message for ", t);
57 }
58 }
59
60 protected void doInvokeDeploy(HotDeployEvent event) throws Exception {
61 ServletContext servletContext = event.getServletContext();
62
63 String servletContextName = servletContext.getServletContextName();
64
65 Message message = new Message();
66
67 message.put("command", "deploy");
68 message.put("servletContextName", servletContextName);
69
70 MessageBusUtil.sendMessage(DestinationNames.HOT_DEPLOY, message);
71 }
72
73 protected void doInvokeUndeploy(HotDeployEvent event) throws Exception {
74 ServletContext servletContext = event.getServletContext();
75
76 String servletContextName = servletContext.getServletContextName();
77
78 Message message = new Message();
79
80 message.put("command", "undeploy");
81 message.put("servletContextName", servletContextName);
82
83 MessageBusUtil.sendMessage(DestinationNames.HOT_DEPLOY, message);
84 }
85
86 }