org.objectweb.proactive.ic2d.spy
Class Spy

java.lang.Object
  org.objectweb.proactive.ic2d.spy.Spy

All Implemented Interfaces:

org.objectweb.proactive.Active, org.objectweb.proactive.ProActiveInternalObject, org.objectweb.proactive.RunActive

public class Spy
extends java.lang.Object
implements org.objectweb.proactive.RunActive, org.objectweb.proactive.ProActiveInternalObject

The master Spy class

Field Summary

protected boolean	isActive
protected SpyEventManager	spyEventManager event manager
protected SpyListener	spyListener the listener of our events
protected long	updateFrequence Timeout between updates

Constructor Summary

Spy()

Spy(SpyListener spyListener)

Method Summary

void	addMessageEventListener(org.objectweb.proactive.core.UniqueID bodyId)
org.objectweb.proactive.core.body.migration.MigratableBody	getBody(org.objectweb.proactive.core.UniqueID bodyId)
java.lang.String	getSystemProperty(java.lang.String key)
long	getUpdateFrequence()
void	migrateTo(org.objectweb.proactive.core.UniqueID bodyId, java.lang.String nodeDestination)
protected void	notifyListener(SpyEvent[] events)
void	removeMessageEventListener(org.objectweb.proactive.core.UniqueID bodyId)
void	runActivity(org.objectweb.proactive.Body body)
void	sendEventsForAllActiveObjects()
void	setUpdateFrequence(long updateFrequence)
void	terminate()

Methods inherited from class java.lang.Object

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

Field Detail

updateFrequence

protected long updateFrequence

Timeout between updates

spyEventManager

protected transient SpyEventManager spyEventManager

event manager

spyListener

protected SpyListener spyListener

the listener of our events

isActive

protected boolean isActive

Constructor Detail

Spy

public Spy()

Spy

public Spy(SpyListener spyListener)

Method Detail

getUpdateFrequence

public long getUpdateFrequence()

sendEventsForAllActiveObjects

public void sendEventsForAllActiveObjects()

setUpdateFrequence

public void setUpdateFrequence(long updateFrequence)

migrateTo

public void migrateTo(org.objectweb.proactive.core.UniqueID bodyId,
                      java.lang.String nodeDestination)
               throws org.objectweb.proactive.core.body.migration.MigrationException

Throws:

org.objectweb.proactive.core.body.migration.MigrationException

getSystemProperty

public java.lang.String getSystemProperty(java.lang.String key)

terminate

public void terminate()

addMessageEventListener

public void addMessageEventListener(org.objectweb.proactive.core.UniqueID bodyId)

removeMessageEventListener

public void removeMessageEventListener(org.objectweb.proactive.core.UniqueID bodyId)

runActivity

public void runActivity(org.objectweb.proactive.Body body)

Specified by:

runActivity in interface org.objectweb.proactive.RunActive

getBody

public org.objectweb.proactive.core.body.migration.MigratableBody getBody(org.objectweb.proactive.core.UniqueID bodyId)

notifyListener

protected void notifyListener(SpyEvent[] events)