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