> > 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. > This is true, thanks. Now let's say I wanted to write to the client's console before reading anything from their console.
With no other changes, this Pipeline setting doesn't work: Pipeline( MyComponent(), ConsoleReader(), ).run() but I am expecting it to work. What am I missing? Thanks! Gloria > 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 -~----------~----~----~----~------~----~------~--~---