1
22
23 package com.liferay.portal.messaging;
24
25 import com.liferay.portal.kernel.messaging.Destination;
26 import com.liferay.portal.kernel.messaging.DestinationEventListener;
27 import com.liferay.portal.kernel.messaging.Message;
28 import com.liferay.portal.kernel.messaging.MessageBus;
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 addDestinationEventListener(DestinationEventListener listener) {
47 _messageBus.addDestinationEventListener(listener);
48 }
49
50 public void destroy() throws Exception {
51 shutdown(true);
52 }
53
54 public boolean hasDestination(String destination) {
55 return _messageBus.hasDestination(destination);
56 }
57
58 public boolean hasMessageListener(String destination) {
59 return _messageBus.hasMessageListener(destination);
60 }
61
62 public void registerMessageListener(
63 String destination, MessageListener listener) {
64
65 _messageBus.registerMessageListener(destination, listener);
66 }
67
68 public void removeDestination(String destination) {
69 _messageBus.removeDestination(destination);
70 }
71
72 public void removeDestinationEventListener(
73 DestinationEventListener listener) {
74 _messageBus.removeDestinationEventListener(listener);
75 }
76
77 public void sendMessage(String destination, Message message) {
78 _messageBus.sendMessage(destination, message);
79 }
80
81 public void setMessageBus(MessageBus messageBus) {
82 _messageBus = messageBus;
83 }
84
85 public boolean unregisterMessageListener(
86 String destination, MessageListener listener) {
87
88 return _messageBus.unregisterMessageListener(destination, listener);
89 }
90
91 public void shutdown() {
92 _messageBus.shutdown();
93 }
94
95 public void shutdown(boolean force) {
96 _messageBus.shutdown(force);
97 }
98
99 private MessageBus _messageBus;
100
101 }