001
014
015 package com.liferay.portal.kernel.messaging.jmx;
016
017 import com.liferay.portal.kernel.messaging.MessageBus;
018
019 import javax.management.MalformedObjectNameException;
020 import javax.management.ObjectName;
021
022
026 public class MessageBusManager implements MessageBusManagerMBean {
027
028 public static ObjectName createObjectName() {
029 try {
030 return new ObjectName(_OBJECT_NAME);
031 }
032 catch (MalformedObjectNameException mone) {
033 throw new IllegalStateException(mone);
034 }
035 }
036
037 public MessageBusManager(MessageBus messageBus) {
038 _messageBus = messageBus;
039 }
040
041 @Override
042 public int getDestinationCount() {
043 return _messageBus.getDestinationCount();
044 }
045
046 private static final String _OBJECT_NAME =
047 "Liferay:product=Portal,type=MessageBusManager,host=localhost";
048
049 private MessageBus _messageBus;
050
051 }