Home

Stream queues

 

+

Search Tips   |   Advanced Search

 

Stream queues are used to process publications for all topics within a stream. Applications send publications (and requests to delete publications) to a stream queue. The stream queue must be a local queue at the broker, not an alias or remote queue. Applications can send messages to a stream queue through an alias or remote queue.

Publishing applications can register with the broker before they start sending publications. If the application specifies that it will be using a stream queue that does not yet exist, the broker might create a permanent dynamic queue with the same name as the stream specified, based on the queue...

SYSTEM.BROKER.MODEL.STREAM

If this queue does not exist, messages sent by applications that refer to a stream for which there is no stream queue, are rejected.

The broker keeps information about which streams are known to it so that, when it is restarted, it can recognize the stream queues.

Applications can also specify the stream name in a publication message. If a publication message specifies the name of a stream that is different from the name of the queue to which it was sent, the message is rejected. If the application does not specify a stream name, it defaults to the name of the stream queue to which it is sent.

If you are using a network of brokers, and you want to restrict a certain stream to a particular sub-tree of the hierarchy, brokers immediately outside the sub-tree must not have a SYSTEM.MODEL.STREAM.QUEUE defined. All stream queues for streams that these brokers support must, therefore, be defined by the administrator.

 

 

SYSTEM.BROKER.MODEL.STREAM

The SYSTEM.BROKER.MODEL.STREAM is a model queue definition that can be used by the broker to create dynamic queues to receive publications for streams other than the default stream. This is used only if the stream queue does not already exist. This definition must specify that the dynamic queue to be created is a permanent-dynamic queue. If this queue does not exist, all stream queues must be defined by the administrator. (The administrator can also define stream queues manually, even if this queue does exist.)

This queue is supplied as sampleamqsfmda.tst (see page Sample programs). To create the queue from the sample, use the following command:

runmqsc QMgrName < amqsfmda.tst

...whereQMgrName is the name of the queue manager.

 

Home