>
> 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 [email protected]
To unsubscribe from this group, send email to
[email protected]
For more options, visit this group at
http://groups.google.com/group/kamaelia?hl=en
-~----------~----~----~----~------~----~------~--~---
