Hey Gloria, On 1 Mar, 06:51, Gloria W <strang...@comcast.net> wrote: > Hi all, > I am testing things, trying to get a small modification to this example > working correctly:http://www.kamaelia.org/Home > I've simple added this line: > > self.send("Testing..1.2.3...",'outbox') > > between these two lines: > > *while* not self.doShutdown(): > *if* self.dataReady(*"inbox"*): > > and it does nothing. yielding it also does nothing. I should be able to write > to the console without receiving data from it, I hope. > What am I missing?
Could you clarify which example you're looking at? The only one I can see with those lines is the "MyComponent" example, in which case you get the expected result. This is the code I'm running; http://davbo.pastebin.com/m5ea9e662 You might just be getting confused with the boxes, you need another component to take what you're sending from the outbox before anything will write to the console. As you can see in my example I've added the ConsoleEchoer to a Pipeline with MyComponent. Hope this helps! > Also, this is interesting: > > [glori...@g-monster glorias_stuff]$ Chat server running on port 1501 > Traceback (most recent call last): > File "./MyChatServer.py", line 50, in <module> > ChatServer(port=1501).run() > File "/usr/lib/python2.5/site-packages/Axon/Microprocess.py", line > 576, in run > self.__class__.schedulerClass.run.runThreads() > File "/usr/lib/python2.5/site-packages/Axon/Scheduler.py", line 545, > in runThreads > for i in self.main(slowmo,canblock=True): pass > File "/usr/lib/python2.5/site-packages/Axon/Scheduler.py", line 440, > in main > result = mprocess.next() > File "/usr/lib/python2.5/site-packages/Axon/Microprocess.py", line > 400, in next > return self.__thread.next() > File "/usr/lib/python2.5/site-packages/Axon/Microprocess.py", line > 509, in _microprocessGenerator > v = pc.next() > File > "/usr/lib/python2.5/site-packages/Kamaelia/Chassis/ConnectedServer.py", > line 169, in main > self.initialiseServerSocket() > File > "/usr/lib/python2.5/site-packages/Kamaelia/Chassis/ConnectedServer.py", > line 159, in initialiseServerSocket > self.server = (self.TCPS)(listenport=self.port) > File > "/usr/lib/python2.5/site-packages/Kamaelia/Internet/TCPServer.py", line > 121, in __init__ > self.listener,junk = self.makeTCPServerPort(listenport, maxlisten=5) > File > "/usr/lib/python2.5/site-packages/Kamaelia/Internet/TCPServer.py", line > 144, in makeTCPServerPort > s.bind((HOST,PORT)) > File "<string>", line 1, in bind > socket.error: (98, 'Address already in use') > > It locks the port for about a minute after every run, then finally frees > it, this error goes away, and I can finally reconnect. Seems odd. Will take a look at this. > Thanks in advance for your help! > Gloria --~--~---------~--~----~------------~-------~--~----~ You received this message because you are subscribed to the Google Groups "kamaelia" group. To post to this group, send email to kamaelia@googlegroups.com To unsubscribe from this group, send email to kamaelia+unsubscr...@googlegroups.com For more options, visit this group at http://groups.google.com/group/kamaelia?hl=en -~----------~----~----~----~------~----~------~--~---
