spawn.py

来自「Java Communicating Agents是一个用于开发网络反应式信息a」· Python 代码 · 共 37 行

import java
import jacomma
from jacomma.icm.type import Symbol
from jacomma.platform.core import Agent, AgentManager, \
	 MessagePattern, AgentObserver, AgentObserverAdapter


# The Message Handler class
class Spawner( Agent.MessageHandler ):
	def onMessage( self, agent, msg ):
		print agent, ": Incoming Agent:", msg
		name = msg.getContent().get( 1 )
		obs = msg.getContent().get( 2 )
		new_ag = AgentManager.instance.createAgent( name, obs )
		print agent, ":Agent", new_ag, "spawned"

## The pattern test object
class test( java.lang.Object ) :
	def equals( self, msg ) :
		l = msg.getContent()
		return java.util.List.isInstance( l ) \
			   and l.size() == 3 \
			   and l.get( 0 ).equals( Symbol( "spawn" ) ) \
			   and java.lang.String.isInstance( l.get( 1 ) ) \
			   and AgentObserver.isInstance( l.get( 2 ) )

# The local observer
class SpawnerObserver( AgentObserverAdapter ):
	def onRegisteredAgent( self, agent, at ):
		ptrn = MessagePattern.createPattern( java.util.List, test() )
		agent.registerHandler( ptrn, Spawner() )

## the code that creates the agent
def spawnAcceptor( name ) :
	AgentManager.instance.createAgent( name, SpawnerObserver() )