public abstract class AbstractSensor extends AbstractParticipant implements ISensor
IParticipant.State
Constructor and Description |
---|
AbstractSensor() |
Modifier and Type | Method and Description |
---|---|
protected void |
agentAdded(IAgentObject agent)
callback when a new agent is added to te simulation (will only receive is
shouldInterface(IAgentObject) is true). |
protected void |
agentRemoved(IAgentObject agent)
callback when an interfaced agent is removed from the simulation This is
called on the IO thread, you should not make any blocking calls here
|
protected void |
agentUpdated(IAgentObject agent)
callback for when an actively interfaced agent is updated This is called
on the IO thread, you should not make any blocking calls here
|
void |
connect()
connect
|
protected IAfferentObjectManager |
createAfferentObjectManager() |
protected IAgentObjectManager |
createAgentObjectManager() |
protected IEfferentObjectManager |
createEfferentObjectManager() |
protected IRealObjectManager |
createRealObjectManager() |
protected ISensorObject |
createSensor(IIdentifier identifier) |
void |
disconnect(boolean force)
force the system to disconnect, regardless of its current state
|
IAddressingInformation |
getAddressingInformation()
by default, we dont open any listeners, so we return null
|
IRequestableAfferentObjectManager |
getAfferentObjectManager() |
ICredentials |
getCredentials() |
IRequestableEfferentObjectManager |
getEfferentObjectManager() |
java.util.Collection<IIdentifier> |
getInterfacedAgents() |
IRequestableRealObjectManager |
getRealObjectManager() |
protected boolean |
isInterfacedAgent(IIdentifier identifier)
are we currently interfaced with this agent
|
void |
setCredentials(ICredentials credentials) |
void |
setIdentifier(IIdentifier identifier)
called after the connection has been established..
|
protected boolean |
shouldInterface(IAgentObject agent)
should we provide afferent/efferent objects to this agent default returns
true
|
void |
shutdown()
shutdown the participant if it is stopped and disconnect
|
addClientService, addServerService, checkState, clearObjectManagers, configure, createEfferentCommandManager, createIOExecutorService, createIOHandler, createNotificationManager, createSensorObjectManager, disconnect, getAgentObjectManager, getCentralThreadFactory, getClock, getCommonRealityIdentifier, getEfferentCommandManager, getIdentifier, getIOExecutor, getIOHandler, getIOThreadFactory, getName, getNotificationManager, getPeriodicExecutor, getSensorObjectManager, getServerAddressInformation, getState, initialize, reset, resume, send, setClock, setCommonRealityIdentifier, shutdown, start, stateMatches, stop, suspend, waitForState, waitForState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
configure, disconnect, getAgentObjectManager, getClock, getEfferentCommandManager, getNotificationManager, getSensorObjectManager, getState, initialize, reset, resume, send, shutdown, start, stateMatches, stop, suspend, waitForState, waitForState
getIdentifier
public void setCredentials(ICredentials credentials)
setCredentials
in interface ISensor
protected boolean isInterfacedAgent(IIdentifier identifier)
identifier
- public java.util.Collection<IIdentifier> getInterfacedAgents()
protected boolean shouldInterface(IAgentObject agent)
agent
- protected void agentAdded(IAgentObject agent)
shouldInterface(IAgentObject)
is true). This is called on the
IO thread, you should not make any blocking calls hereagent
- protected void agentRemoved(IAgentObject agent)
agent
- protected void agentUpdated(IAgentObject agent)
agent
- protected IAgentObjectManager createAgentObjectManager()
createAgentObjectManager
in class AbstractParticipant
protected IAfferentObjectManager createAfferentObjectManager()
createAfferentObjectManager
in class AbstractParticipant
protected IEfferentObjectManager createEfferentObjectManager()
createEfferentObjectManager
in class AbstractParticipant
protected IRealObjectManager createRealObjectManager()
createRealObjectManager
in class AbstractParticipant
protected ISensorObject createSensor(IIdentifier identifier)
public void setIdentifier(IIdentifier identifier)
AbstractParticipant
setIdentifier
in class AbstractParticipant
public IRequestableEfferentObjectManager getEfferentObjectManager()
getEfferentObjectManager
in interface IParticipant
getEfferentObjectManager
in interface ISensor
getEfferentObjectManager
in class AbstractParticipant
public IRequestableAfferentObjectManager getAfferentObjectManager()
getAfferentObjectManager
in interface IParticipant
getAfferentObjectManager
in interface ISensor
getAfferentObjectManager
in class AbstractParticipant
public IRequestableRealObjectManager getRealObjectManager()
getRealObjectManager
in interface IParticipant
getRealObjectManager
in class AbstractParticipant
public ICredentials getCredentials()
getCredentials
in class AbstractParticipant
public IAddressingInformation getAddressingInformation()
getAddressingInformation
in class AbstractParticipant
AbstractParticipant.getAddressingInformation()
public void shutdown() throws java.lang.Exception
IParticipant
shutdown
in interface IParticipant
shutdown
in class AbstractParticipant
java.lang.Exception
public void connect() throws java.lang.Exception
IParticipant
connect
in interface IParticipant
connect
in class AbstractParticipant
java.lang.Exception
IParticipant.connect()
public void disconnect(boolean force) throws java.lang.Exception
IParticipant
disconnect
in interface IParticipant
disconnect
in class AbstractParticipant
java.lang.Exception