tag ssv rslogix que programación programacion mensajes instruccion gsv estudiante español entre descripcion compactlogix flex4 air blazeds

flex4 - ssv - ¿Múltiples consumidores por conexión StreamingAmf?



que es un tag en plc (0)

Tengo una aplicación Adobe Air 2.0 que también utiliza la integración Spring BlazeDS. Dentro de esta aplicación tengo un par de cuadrículas de datos. El diseño era para el modelo de cada grilla registrar a un Consumidor para escuchar los cambios realizados desde BlazeDS. La primera cuadrícula instanciada funciona correctamente, sin embargo, cada red subsiguiente causa la siguiente advertencia en BlazeDS

[WARN] [Endpoint.StreamingAMF] Endpoint with id ''streaming-amf'' received a duplicate streaming connection request from, FlexClient with id ''''

Tenía la impresión de que podría tener múltiples consumidores dentro de una aplicación Flex / Air. ¿Estoy equivocado o me he perdido algo en mi configuración?

Definición del canal del lado del servidor

<channel-definition id="streaming-amf" class="mx.messaging.channels.StreamingAMFChannel"> <endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/streamingamf" class="flex.messaging.endpoints.StreamingAMFEndpoint"/> <properties> <add-no-cache-headers>false</add-no-cache-headers> <max-streaming-clients>15</max-streaming-clients> <user-agent-settings> <user-agent match-on="AdobeAIR" kickstart-bytes="2048" max-streaming-connections-per-session="2" /> <user-agent match-on="MSIE" kickstart-bytes="2048" max-streaming-connections-per-session="3" /> <user-agent match-on="Firefox" kickstart-bytes="2048" max-streaming-connections-per-session="3" /> </user-agent-settings> </properties> </channel-definition>

Código para el conjunto de canales

<s:ChannelSet id="pricingCS"> <s:channels> <s:StreamingAMFChannel id="streaming-amf" url="http://localhost:8080/blazeds/messagebroker/streamingamf" connectTimeout="5"/> </s:channels> </s:ChannelSet>

Código para el consumidor

consumer = new Consumer(); consumer.id = "pricingConsumer"; consumer.destination = "pricingUpdates"; consumer.subtopic = pId; consumer.channelSet = channelSet; consumer.addEventListener(MessageEvent.MESSAGE, priceUpdate); consumer.addEventListener(MessageFaultEvent.FAULT, priceUpdateFail); consumer.subscribe();