public class MessageQueue
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static void |
configureDefaultActions()
Configures defaut messaging actions needed by RHN
This method should be called directly after
startMessaging . |
static void |
deRegisterAction(MessageAction act,
java.lang.Class eventType)
De-register an action
|
static int |
getMessageCount()
Get the number of messages in the queue
|
static java.lang.String[] |
getRegisteredEventNames()
Get list of String Classnames of the registered Actions.
|
static boolean |
isMessaging()
Check to see if the MessageQueue is running and available to
publish MessageEvents to
|
static void |
publish(EventMessage msg)
Publish a new message
Each message is wrapped in a ActionExecutor instance
|
static void |
registerAction(MessageAction act,
java.lang.Class eventType)
Register an action
|
static void |
startMessaging()
Start the messaging system
|
static void |
stopMessaging()
Stop the messaging system
|
public static void publish(EventMessage msg)
msg
- EventMessage to publish to queue.public static void startMessaging()
public static void stopMessaging()
public static int getMessageCount()
public static void registerAction(MessageAction act, java.lang.Class eventType)
act
- MessageActioneventType
- type of event.public static void deRegisterAction(MessageAction act, java.lang.Class eventType)
act
- MessageAction.eventType
- Type of event.public static java.lang.String[] getRegisteredEventNames()
public static boolean isMessaging()
public static void configureDefaultActions()
startMessaging
.