public interface MessageConsumer extends MessageComparator
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.
|
isPrior
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
- an error occurs.void restore() throws Exception
Exception
- an error occurs.void post(Message msg) throws Exception
msg
- the message to deliver.Exception
- an error occurs.void postAndValidate(Message msg) throws Exception
msg
- the message to deliver.Exception
- an error occurs.void validate()
void start() throws Exception
Exception
- an error occurs.stop
void stop()
start
void delete() throws IllegalStateException
IllegalStateException
- an error occurs.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 © 2023 ScalAgent D.T.. All rights reserved.