|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectfr.dyade.aaa.agent.Agent
org.objectweb.joram.mom.dest.Destination
public abstract class Destination
A Destination
agent is an agent hosting a MOM destination,
for example a Queue or a Topic.
Its behavior is provided by a DestinationImpl
instance.
AdminDestinationItf
,
Serialized FormField Summary | |
---|---|
protected DestinationImpl |
destImpl
The reference of the DestinationItf instance providing this
this agent with its Destination behaviour. |
static org.objectweb.util.monolog.api.Logger |
logger
logger |
protected WakeUpTask |
task
|
Fields inherited from class fr.dyade.aaa.agent.Agent |
---|
emptyString, fixed, logmon |
Constructor Summary | |
---|---|
|
Destination()
Empty constructor for newInstance(). |
protected |
Destination(java.lang.String name,
boolean fixed,
int stamp)
Constructor with parameters for fixing the destination and specifying its identifier. |
Method Summary | |
---|---|
void |
agentFinalize(boolean lastTime)
Finalizes the agent before it is garbaged. |
protected void |
agentInitialize(boolean firstTime)
Gives this agent an opportunity to initialize after having been deployed, and each time it is loaded into memory. |
abstract DestinationImpl |
createsImpl(AgentId adminId,
java.util.Properties prop)
Creates the specific implementation. |
java.lang.String |
getMBeanName()
|
abstract byte |
getType()
Returns the type of this destination: Queue or Topic. |
void |
init(AgentId adminId,
java.util.Properties props)
Initializes the destination by creating the DestinationItf object. |
void |
react(AgentId from,
Notification not)
Distributes the received notifications to the appropriate reactions. |
void |
setFreeReading(boolean freeReading)
|
void |
setFreeWriting(boolean freeWriting)
|
protected void |
setNoSave()
Sets the updated field to false so that the
agent state is not saved after the current reaction; the field is set
back to true for the next reaction. |
private void |
setPeriod(long period)
|
protected void |
setSave()
Sets the updated field to true so that the
agent state is saved after the current reaction. |
Methods inherited from class fr.dyade.aaa.agent.Agent |
---|
delete, delete, delete, deploy, deploy, getAgentId, getCommitTime, getId, getLogTopic, getName, getReactNb, getReactTime, isDeployed, isFixed, needToBeCommited, save, sendTo, sendTo, sendTo, setName, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static org.objectweb.util.monolog.api.Logger logger
protected DestinationImpl destImpl
DestinationItf
instance providing this
this agent with its Destination behaviour.
protected transient WakeUpTask task
Constructor Detail |
---|
public Destination()
protected Destination(java.lang.String name, boolean fixed, int stamp)
Method Detail |
---|
public void setFreeReading(boolean freeReading)
public void setFreeWriting(boolean freeWriting)
public final void init(AgentId adminId, java.util.Properties props) throws RequestException
init
in interface AdminDestinationItf
adminId
- Identifier of the destination administrator.props
- The initial set of properties.
RequestException
public abstract DestinationImpl createsImpl(AgentId adminId, java.util.Properties prop) throws RequestException
adminId
- Identifier of the topic administrator.prop
- The initial set of properties.
RequestException
public abstract byte getType()
DestinationConstants.TOPIC_TYPE
,
DestinationConstants.QUEUE_TYPE
protected void agentInitialize(boolean firstTime) throws java.lang.Exception
agentInitialize
in class Agent
firstTime
- true when first called by the factory
java.lang.Exception
- unspecialized exceptionpublic void agentFinalize(boolean lastTime)
agentFinalize
in class Agent
lastTime
- true when last called by the factory on agent deletion.public java.lang.String getMBeanName()
public void react(AgentId from, Notification not) throws java.lang.Exception
react
in class Agent
from
- agent sending notificationnot
- notification to react to
java.lang.Exception
private void setPeriod(long period)
protected void setNoSave()
Agent
updated
field to false
so that the
agent state is not saved after the current reaction; the field is set
back to true
for the next reaction.
setNoSave
in class Agent
protected void setSave()
Agent
updated
field to true
so that the
agent state is saved after the current reaction.
setSave
in class Agent
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |