|
|||||||||
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
org.objectweb.joram.mom.dest.Queue
public class Queue
A Queue
agent is an agent hosting a MOM queue, and which
behavior is provided by a QueueImpl
instance.
QueueImpl
,
Serialized FormField Summary | |
---|---|
private static long |
serialVersionUID
define serialVersionUID for interoperability |
Fields inherited from class org.objectweb.joram.mom.dest.Destination |
---|
destImpl, logger, task |
Fields inherited from class fr.dyade.aaa.agent.Agent |
---|
emptyString, fixed, logmon |
Constructor Summary | |
---|---|
Queue()
Empty constructor for newInstance(). |
Method Summary | |
---|---|
DestinationImpl |
createsImpl(AgentId adminId,
java.util.Properties prop)
Creates the QueueImpl. |
byte |
getType()
Returns the type of this destination: Queue or Topic. |
void |
react(AgentId from,
Notification not)
Distributes the received notifications to the appropriate reactions. |
void |
readBag(java.io.ObjectInputStream in)
The readBag method is responsible for reading from the stream and restoring the agent's transient state. |
void |
writeBag(java.io.ObjectOutputStream out)
The writeBag method is responsible for writing the extra data of this particular agent so that the corresponding readBag method can restore it. |
Methods inherited from class org.objectweb.joram.mom.dest.Destination |
---|
agentFinalize, agentInitialize, getMBeanName, init, setFreeReading, setFreeWriting, setNoSave, setSave |
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 |
---|
private static final long serialVersionUID
Constructor Detail |
---|
public Queue()
Method Detail |
---|
public final byte getType()
Destination
getType
in class Destination
DestinationConstants.TOPIC_TYPE
,
DestinationConstants.QUEUE_TYPE
public DestinationImpl createsImpl(AgentId adminId, java.util.Properties prop) throws RequestException
createsImpl
in class Destination
adminId
- Identifier of the queue administrator.prop
- The initial set of properties.
RequestException
public void react(AgentId from, Notification not) throws java.lang.Exception
react
in class Destination
from
- agent sending notificationnot
- notification to react to
java.lang.Exception
public void readBag(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException
BagSerializer
readBag
in interface BagSerializer
java.io.IOException
java.lang.ClassNotFoundException
public void writeBag(java.io.ObjectOutputStream out) throws java.io.IOException
BagSerializer
writeBag
in interface BagSerializer
java.io.IOException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |