Corrientes de datos e intermediarios contiguos

En una red de MQSeries Publicación/suscripción, un intermediario puede no dar soporte al mismo conjunto de corrientes de datos que los intermediarios contiguos. Si un intermediario no da soporte a una corriente de datos a la que sí da soporte uno de los intermediarios contiguos, las publicaciones asociadas a la corriente de datos no estarán disponibles para los clientes de dicho intermediario.

Cuando un intermediario de WebSphere Business Integration Message Broker se añade a la red, dicho intermediario da soporte a todas las corrientes de datos a las que dan soporte los intermediarios de MQSeries Publicación/suscripción contiguos. Esto significa que los clientes del intermediario de WebSphere Business Integration Message Broker pueden trabajar con publicaciones para cualquier corriente de datos a la que dé soporte cualquiera de los intermediarios contiguos de MQSeries Publicación/suscripción.

No obstante, para hacer que estas publicaciones estén disponibles, debe definir las colas de corriente de datos así como definir y difundir los flujos de mensajes que dan soporte a dichas colas en el intermediario de WebSphere Business Integration Message Broker.

Los efectos de agregar un intermediario de WebSphere Business Integration Message Broker a un entorno de MQSeries Publicación/suscripción de varias corrientes de datos se muestran en el ejemplo siguiente:

Red heterogénea. Esta figura muestra un intermediario de <ph conref='edvent.dita#edvent/mqsi'></ph>, NEWBROKER, colocado entre dos intermediarios de <ph conref='edvent.dita#edvent/sdk'></ph>, BROKERA y BROKERB.  También lista las corrientes de datos asociadas con cada uno de los intermediarios de <ph  conref='edvent.dita#edvent/sdk'></ph>.
Se ha utilizado el intermediario de WebSphere Business Integration Message Broker, NEWBROKER, para unir intermediarios de MQSeries Publicación/suscripción, BROKERA y BROKERB.

La cola de corriente de datos por omisión SYSTEM.BROKER.DEFAULT.STREAM siempre recibe soporte por parte de cada intermediario de una red de MQSeries Publicación/suscripción, y debe definirse para cada intermediario de WebSphere Business Integration Message Broker en una red heterogénea. El usuario debe definir y difundir un flujo de mensajes en cada intermediario para dar servicio a esta cola.

Si un intermediario de WebSphere Business Integration Message Broker se integra en una red de MQSeries Publicación/suscripción y enlaza dos o más intermediarios de MQSeries Publicación/suscripción que comparten corrientes de datos comunes, el usuario debe definir las colas de corriente de datos comunes, y definir y difundir los flujos de mensajes que dan servicio a dichas colas en el intermediario de WebSphere Business Integration Message Broker.

Por ejemplo, el intermediario de WebSphere Business Integration Message Broker, NEWBROKER, mostrado en la figura anterior, deberá tener una cola de corriente de datos definida para BULLETIN.STREAM. También deberá tener un flujo de mensajes definido y difundido para proporcionar un servicio de publicación a dicha cola.

El usuario debe definir colas de corriente de datos y flujos de mensajes asociados en el intermediario de WebSphere Business Integration Message Broker para las otras corrientes de datos mostradas en la figura sólo en el caso de que uno de los intermediarios contiguos de MQSeries Publicación/suscripción correspondientes pueda enviar un mensaje a uno de estas colas. Se enviará un mensaje si se produce uno de los sucesos siguientes:
  1. Un cliente del intermediario de WebSphere Business Integration Message Broker registra una suscripción a una publicación en una de estas corrientes de datos.
  2. Un cliente emite un mandato DeletePublication para la corriente de datos en cualquier lugar de la red de intermediarios.
Si no está seguro de que puedan producirse los casos anteriores, cree colas de corriente de datos y flujos de mensajes en el intermediario de WebSphere Business Integration Message Broker para cada corriente de datos a la que dé soporte el intermediario contiguo de MQSeries Publicación/suscripción. Si no lo hace, es posible que obtenga los resultados siguientes:
  • Los mensajes enviados desde los intermediarios de MQSeries Publicación/suscripción se ponen en la cola de mensajes no entregados (DLQ) del intermediario de WebSphere Business Integration Message Broker si la cola de corriente de datos no existe en ese intermediario.
  • Los mensajes se acumulan en las colas de corriente de datos del intermediario de WebSphere Business Integration Message Broker si la cola de corriente de datos existe pero no se ha difundido ningún flujo de mensajes que le dé servicio.