|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
The parent interface for all messages consumers.
Engine, Network.
Method Summary | |
void |
delete()
Deletes the component, removes all persistent datas. |
java.lang.String |
getDomainName()
Returns the corresponding domain's name. |
java.lang.String |
getName()
Returns this MessageConsumer 's name. |
fr.dyade.aaa.agent.MessageQueue |
getQueue()
Get this consumer's MessageQueue . |
void |
insert(fr.dyade.aaa.agent.Message msg)
Insert a message in the MessageQueue . |
boolean |
isRunning()
Tests if the component is alive. |
void |
post(fr.dyade.aaa.agent.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 |
public java.lang.String getName()
MessageConsumer
's name.
MessageConsumer
's name.public java.lang.String getDomainName()
public void insert(fr.dyade.aaa.agent.Message msg)
MessageQueue
.
This method is used during initialisation to restore the component
state from persistent storage.
msg
- the messagepublic void save() throws java.io.IOException
java.io.IOException
public void restore() throws java.lang.Exception
java.lang.Exception
public void post(fr.dyade.aaa.agent.Message msg) throws java.lang.Exception
java.lang.Exception
public void validate()
public void start() throws java.lang.Exception
java.lang.Exception
stop
public void stop()
start
public void delete() throws java.lang.IllegalStateException
java.lang.IllegalStateException
Transaction
public fr.dyade.aaa.agent.MessageQueue getQueue()
MessageQueue
. Use in administration and
debug tasks, should be replaced by a common attribute.
MessageConsumer
's queue.public boolean isRunning()
MessageConsumer
is alive
if it has been started and has not yet stopped.
MessageConsumer
is alive; false
otherwise.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |