1
22
23 package com.liferay.portal.messaging;
24
25 import com.liferay.portal.kernel.messaging.Destination;
26 import com.liferay.portal.kernel.messaging.Message;
27 import com.liferay.portal.kernel.messaging.MessageBus;
28 import com.liferay.portal.kernel.messaging.MessageBusException;
29 import com.liferay.portal.kernel.messaging.MessageListener;
30
31 import org.springframework.beans.factory.DisposableBean;
32
33
40 public class PortalMessageBus implements DisposableBean, MessageBus {
41
42 public void addDestination(Destination destination) {
43 _messageBus.addDestination(destination);
44 }
45
46 public void destroy() throws Exception {
47 shutdown(true);
48 }
49
50 public void registerMessageListener(
51 String destination, MessageListener listener) {
52
53 _messageBus.registerMessageListener(destination, listener);
54 }
55
56 public void removeDestination(String destination) {
57 _messageBus.removeDestination(destination);
58 }
59
60 public void sendMessage(String destination, Object message) {
61 _messageBus.sendMessage(destination, message);
62 }
63
64 public void sendMessage(String destination, String message) {
65 _messageBus.sendMessage(destination, message);
66 }
67
68 public Object sendSynchronizedMessage(
69 String destination, Message message, long timeout)
70 throws MessageBusException {
71
72 return _messageBus.sendSynchronizedMessage(
73 destination, message, timeout);
74 }
75
76 public String sendSynchronizedMessage(
77 String destination, String message, long timeout)
78 throws MessageBusException {
79
80 return _messageBus.sendSynchronizedMessage(
81 destination, message, timeout);
82 }
83
84 public void setMessageBus(MessageBus messageBus) {
85 _messageBus = messageBus;
86 }
87
88 public boolean unregisterMessageListener(
89 String destination, MessageListener listener) {
90
91 return _messageBus.unregisterMessageListener(destination, listener);
92 }
93
94 public void shutdown() {
95 _messageBus.shutdown();
96 }
97
98 public void shutdown(boolean force) {
99 _messageBus.shutdown(force);
100 }
101
102 private MessageBus _messageBus;
103
104 }