Package org.objectweb.joram.mom.util

Class SynchronousAgent

java.lang.Object

fr.dyade.aaa.agent.Agent

org.objectweb.joram.mom.util.SynchronousAgent

All Implemented Interfaces:

AgentMBean, Encodable, Serializable

@Deprecated
public class SynchronousAgent
extends Agent

Deprecated.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
private static boolean	DEBUG	Deprecated.
private static SynchronousAgent	INSTANCE	Deprecated.
private static Logger	logger	Deprecated.
private int	nextReqMsgId	Deprecated.
private Map<String,Message>	requests	Deprecated.
private static long	serialVersionUID	Deprecated.

Fields inherited from class fr.dyade.aaa.agent.Agent

agentProfiling, emptyString, fixed, logmon

Fields inherited from interface fr.dyade.aaa.common.encoding.Encodable

BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE

Constructor Summary

Constructors

Constructor	Description
SynchronousAgent()	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	agentFinalize(boolean lastTime)	Deprecated. Called to inform this agent that it is garbaged and that it should free any active resources that it has allocated.
protected void	agentInitialize(boolean firstTime)	Deprecated. Gives this agent an opportunity to initialize after having been deployed, and each time it is loaded into memory.
boolean	clearQueue(String queueName)	Deprecated. Clears all pending message of a queue
boolean	clearSubscription(String userName, String subName)	Deprecated. Clears all pending message of a subscription
boolean	createDestination(short serverId, String name, String className, Properties props, byte expectedType)	Deprecated.
boolean	createUser(short serverId, String userName, String password, String identityClass, Properties props)	Deprecated.
boolean	deleteDest(String agentId)	Deprecated.
boolean	deleteQueueMessage(String queueName, String msgId)	Deprecated. Delete a message in a queue
boolean	deleteSubMessage(String userName, String subName, String msgId)	Deprecated. Deletes a message in a subscription
boolean	deleteUser(String userName, String agentId)	Deprecated.
static SynchronousAgent	getSynchronousAgent()	Deprecated.
private String	nextReqMsgId()	Deprecated.
void	react(AgentId from, Notification not)	Deprecated. Defines the reaction of the agent when receiving a notification.
boolean	setFreeReading(boolean freeReading, String destId)	Deprecated.
boolean	setFreeWriting(boolean freeWriting, String destId)	Deprecated.

Methods inherited from class fr.dyade.aaa.agent.Agent

agentSave, decode, delete, delete, delete, deploy, deploy, doAdminSyncNotification, encode, getAgentId, getCommitTime, getEncodableClassId, getEncodedSize, getId, getLogTopic, getName, getReactNb, getReactTime, hasName, incWorkInProgress, isAgentProfiling, isDeployed, isFixed, isUpdated, load, needToBeCommited, resetCommitTime, resetReactTime, resetTimer, save, sendTo, sendTo, sendTo, setAgentProfiling, setName, setNoSave, setSave, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

logger

private static final Logger logger

Deprecated.

DEBUG

private static final boolean DEBUG

Deprecated.

INSTANCE

private static SynchronousAgent INSTANCE

Deprecated.

serialVersionUID

private static final long serialVersionUID

Deprecated.

See Also:

Constant Field Values

nextReqMsgId

private int nextReqMsgId

Deprecated.

requests

private Map<String,Message> requests

Deprecated.

Constructor Detail

SynchronousAgent

public SynchronousAgent()

Deprecated.

Method Detail

getSynchronousAgent

public static SynchronousAgent getSynchronousAgent()
                                            throws IOException,
                                                   InterruptedException

Deprecated.

Throws:

IOException

InterruptedException

agentInitialize

protected void agentInitialize(boolean firstTime)
                        throws Exception

Deprecated.

Description copied from class: Agent

Gives this agent an opportunity to initialize after having been deployed, and each time it is loaded into memory.

This function is first called by the factory agent, just after it deploys the agent.

This function is used by agents with a fixed field set to true to initialize their transient variables, as it is called each time the agent server is restarted.

This function is not declared final so that derived classes may change their reload policy. The implementation of this method provided by the Agent class just registers the JMS MBean.

Overrides:

agentInitialize in class Agent

Parameters:

firstTime - true when first called by the factory

Throws:

Exception - unspecialized exception

agentFinalize

public void agentFinalize(boolean lastTime)

Deprecated.

Description copied from class: Agent

Called to inform this agent that it is garbaged and that it should free any active resources that it has allocated. A subclass of Agent should override this method if it has any operation that it wants to perform before it is garbaged. For example, an agent with threads (a ProxyAgent for example) would use the initialize method to create the threads and the agentFinalize method to stop them.

Be careful, the notification sending is not allowed in this method.

The implementation of this method provided by the Agent class just unregister the JMX MBean if needed.

Overrides:

agentFinalize in class Agent

Parameters:

lastTime - true when last called by the factory on agent deletion.

createDestination

public boolean createDestination(short serverId,
                                 String name,
                                 String className,
                                 Properties props,
                                 byte expectedType)
                          throws InterruptedException

Deprecated.

Throws:

InterruptedException

createUser

public boolean createUser(short serverId,
                          String userName,
                          String password,
                          String identityClass,
                          Properties props)
                   throws Exception

Deprecated.

Parameters:

serverId -

userName -

password -

identityClass -

props -

Returns:

True if the request succeeds, false otherwise

Throws:

Exception

ClassNotFoundException

InterruptedException

deleteUser

public boolean deleteUser(String userName,
                          String agentId)
                   throws Exception

Deprecated.

Throws:

Exception

deleteDest

public boolean deleteDest(String agentId)
                   throws Exception

Deprecated.

Throws:

Exception

deleteQueueMessage

public boolean deleteQueueMessage(String queueName,
                                  String msgId)
                           throws InterruptedException

Deprecated.

Delete a message in a queue

Parameters:

queueName - Name of the queue

msgId - ID of the message to be deleted

Returns:

Throws:

InterruptedException

deleteSubMessage

public boolean deleteSubMessage(String userName,
                                String subName,
                                String msgId)
                         throws InterruptedException

Deprecated.

Deletes a message in a subscription

Parameters:

userName - Subscriber's name

subName - Subscription name

msgId - ID of the message to be deleted

Returns:

Throws:

InterruptedException

clearQueue

public boolean clearQueue(String queueName)
                   throws InterruptedException

Deprecated.

Clears all pending message of a queue

Parameters:

queueName - Name of the queue

Returns:

Throws:

InterruptedException

clearSubscription

public boolean clearSubscription(String userName,
                                 String subName)
                          throws InterruptedException

Deprecated.

Clears all pending message of a subscription

Parameters:

userName - Subscriber's name

subName - Subscription name

Returns:

Throws:

InterruptedException

setFreeWriting

public boolean setFreeWriting(boolean freeWriting,
                              String destId)
                       throws InterruptedException

Deprecated.

Throws:

InterruptedException

setFreeReading

public boolean setFreeReading(boolean freeReading,
                              String destId)
                       throws InterruptedException

Deprecated.

Throws:

InterruptedException

nextReqMsgId

private String nextReqMsgId()

Deprecated.

react

public void react(AgentId from,
                  Notification not)
           throws Exception

Deprecated.

Description copied from class: Agent

Defines the reaction of the agent when receiving a notification. This member function implements the common reactive behavior of an agent, it is called by the execution engine (see Engine class).

If there is no corresponding reaction, the agent send an UnknownNotification notification to the sender.

Overrides:

react in class Agent

Parameters:

from - agent sending notification

not - notification to react to

Throws:

Exception - unspecialized exception