com.liferay.portal.kernel.messaging
Class DefaultMessageBus
java.lang.Object
com.liferay.portal.kernel.messaging.DefaultMessageBus
- All Implemented Interfaces:
- MessageBus
public class DefaultMessageBus
- extends Object
- implements MessageBus
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DefaultMessageBus
public DefaultMessageBus()
addDestination
public void addDestination(Destination destination)
- Specified by:
addDestination in interface MessageBus
addDestinationEventListener
public void addDestinationEventListener(DestinationEventListener destinationEventListener)
- Specified by:
addDestinationEventListener in interface MessageBus
addDestinationEventListener
public void addDestinationEventListener(String destinationName,
DestinationEventListener destinationEventListener)
- Specified by:
addDestinationEventListener in interface MessageBus
destroy
public void destroy()
getDestination
public Destination getDestination(String destinationName)
- Specified by:
getDestination in interface MessageBus
getDestinationCount
public int getDestinationCount()
- Specified by:
getDestinationCount in interface MessageBus
getDestinationNames
public Collection<String> getDestinationNames()
- Specified by:
getDestinationNames in interface MessageBus
getDestinations
public Collection<Destination> getDestinations()
- Specified by:
getDestinations in interface MessageBus
hasDestination
public boolean hasDestination(String destinationName)
- Specified by:
hasDestination in interface MessageBus
hasMessageListener
public boolean hasMessageListener(String destinationName)
- Specified by:
hasMessageListener in interface MessageBus
registerMessageListener
public boolean registerMessageListener(String destinationName,
MessageListener messageListener)
- Specified by:
registerMessageListener in interface MessageBus
removeDestination
public Destination removeDestination(String destinationName)
- Specified by:
removeDestination in interface MessageBus
removeDestinationEventListener
public void removeDestinationEventListener(DestinationEventListener destinationEventListener)
- Specified by:
removeDestinationEventListener in interface MessageBus
removeDestinationEventListener
public void removeDestinationEventListener(String destinationName,
DestinationEventListener destinationEventListener)
- Specified by:
removeDestinationEventListener in interface MessageBus
replace
public void replace(Destination destination)
- Specified by:
replace in interface MessageBus
sendMessage
public void sendMessage(String destinationName,
Message message)
- Specified by:
sendMessage in interface MessageBus
shutdown
public void shutdown()
- Specified by:
shutdown in interface MessageBus
shutdown
public void shutdown(boolean force)
- Specified by:
shutdown in interface MessageBus
unregisterMessageListener
public boolean unregisterMessageListener(String destinationName,
MessageListener messageListener)
- Specified by:
unregisterMessageListener in interface MessageBus
fireDestinationAddedEvent
protected void fireDestinationAddedEvent(Destination destination)
fireDestinationRemovedEvent
protected void fireDestinationRemovedEvent(Destination destination)
fireMessageListenerRegisteredEvent
protected void fireMessageListenerRegisteredEvent(Destination destination,
MessageListener messageListener)
fireMessageListenerUnregisteredEvent
protected void fireMessageListenerUnregisteredEvent(Destination destination,
MessageListener messageListener)