public interface MessageConsumer
Engine, Network.
Modifier and Type | Method and Description |
---|---|
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.
|
String |
getDomainName()
Returns the corresponding domain's name.
|
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 |
postAndValidate(Message msg)
Posts a message and validates it at the same time.
|
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.
|
String getName()
MessageConsumer
's name.MessageConsumer
's name.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 IOException
IOException
void restore() throws Exception
Exception
void post(Message msg) throws Exception
Exception
void postAndValidate(Message msg) throws Exception
Exception
void validate()
void start() throws Exception
Exception
stop
void stop()
start
void delete() throws IllegalStateException
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()
Copyright © 2015 ScalAgent D.T.. All Rights Reserved.