|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface MessageConsumer
The parent interface for all messages consumers.
Engine, Network.
Method Summary | |
---|---|
void |
delete()
Deletes the component, removes all persistent data. |
float |
getAverageLoad1()
Returns the load averages for the last minute. |
float |
getAverageLoad15()
Returns the load averages for the past 15 minutes. |
float |
getAverageLoad5()
Returns the load averages for the past 5 minutes. |
java.lang.String |
getDomainName()
Returns the corresponding domain's name. |
java.lang.String |
getName()
Returns this MessageConsumer 's name. |
MessageQueue |
getQueue()
Get this consumer's MessageQueue . |
void |
insert(Message msg)
Insert a message in the MessageQueue . |
boolean |
isRunning()
Tests if the component is alive. |
void |
post(Message msg)
Adds a message in "ready to deliver" list. |
void |
restore()
Restores logical clock information from persistent storage. |
void |
save()
Saves logical clock information to persistent storage. |
void |
start()
Causes this component to begin execution. |
void |
stop()
Forces the component to stop executing. |
void |
validate()
Validates all messages pushed in queue during transaction session. |
Method Detail |
---|
java.lang.String getName()
MessageConsumer
's name.
MessageConsumer
's name.java.lang.String getDomainName()
void insert(Message msg)
MessageQueue
.
This method is used during initialization to restore the component
state from persistent storage.
msg
- the messagevoid save() throws java.io.IOException
java.io.IOException
void restore() throws java.lang.Exception
java.lang.Exception
void post(Message msg) throws java.lang.Exception
java.lang.Exception
void validate()
void start() throws java.lang.Exception
java.lang.Exception
stop
void stop()
start
void delete() throws java.lang.IllegalStateException
java.lang.IllegalStateException
Transaction
MessageQueue getQueue()
MessageQueue
. Use in administration and
debug tasks, should be replaced by a common attribute.
MessageConsumer
's queue.boolean isRunning()
MessageConsumer
is alive
if it has been started and has not yet stopped.
MessageConsumer
is alive; false
otherwise.float getAverageLoad1()
float getAverageLoad5()
float getAverageLoad15()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |