[pyar] Problema con asignación

[Angel Java Lopez]

Hmmm... gracias, voy entendiendo.

Hay threads que quieren consumir algo, segun tu "approach", cada thread
quiere ir a una queue. Llamemosle threads subscriptores (la parte sub, del
pub sub).

Pero a ver... para mi pub sub es mas bien orientado a topico. Y tus
"threads subscriptores" deberian poder suscribirse a varios topicos. De ahi
que no me cierra eso de usar una cola por cada uno de los threads
subscriptores.

A no ser que pongas algo mas de logica en la publicacion de un mensaje,
tipo:

- Por cada mensaje publicado, revisaria su topico
- Tendria una lista de queues, con informacion de su thread asociado y los
topicos a los que se suscribio
- Entonces, esta logica adicional DEJARIA en el mensaje en CADA QUEUE de
CADA THREAD interesado en el topico

Entonces, en todo esto, no necesitarias el nombre de la queue, sino la
lista de topicos que el thread asociado a esa queue.

Esa es una forma de hacerlo. Hay otras.

Cual era tu idea sobre este tema de topicos? (un thread puede estar
interesado en mas de un topico, un mensaje puede ir a parar a mas de un
suscriptor, ejecutado en su thread)

Cual era tu idea? Soportar topicos? O solamente tomar el nombre de la queue
como topico?

Si solo necesitas el nombre de la queue, lo que guardaria en algun lado es
un diccionario con clave string, y contenido Queue. Cuando un mensaje se
publica, busco en ese diccionario a que queue tiene que ir por nombre.

Se entendio?

Nos leemos!

Angel "Java" Lopez
http://www.ajlopez.com
http://twitter.com/ajlopez

2012/4/18 Pablo M. Mana <pablo.m.mana en gmail.com>

> > No se entiende cuales son tus requerimientos.
> > Y el codigo es demasiado extraño para pensar en un req. razonable.
> > Podés aclarar ?
>
> Ahora aclaro, no lo hice antes por que no tenia ganas de escribir.
>
> Hace unos dias en otro hilo "implemente" un pubsub vía queue para
> poder interactuar con  un thread auxiliar. Por ahora tengo un solo
> thread pero pienso tener varios mas, ahora tengo la intención de
> agregarle una función a la la librería que uso para el pubsub .La
> funcion deberia permitir crear un queue y meterle los datos que luego
> del otro lado alimentaran el pubsub
>
> La funcion que trato de que ande es:  RemotePublish(self, queue_name,
> key, *args, **kwargs):
>
> Podria usar un solo queue pero en cada thread auxiliar tendria que
> descargarlo ver si es para ese thread y sino cargarlo de nuevo. Eso si
> tenes varios thread no me convence. Por eso me gustaria  darle  un
> nombre cuando llamo la función. Asi podria tener varios queue, uno
> para cada thread
>
> Saludos
> _______________________________________________
> pyar mailing list pyar en python.org.ar
> http://listas.python.org.ar/listinfo/pyar
>
> PyAr - Python Argentina - Sitio web: http://www.python.org.ar/
>
> La lista de PyAr esta Hosteada en USLA - Usuarios de Software Libre de
> Argentina - http://www.usla.org.ar
>
------------ próxima parte ------------
Se ha borrado un adjunto en formato HTML...
URL: <http://listas.python.org.ar/pipermail/pyar/attachments/20120418/ca6347c0/attachment.html>