MSMQ input connector

This connector enables the StreamServer to integrate with Microsoft message queuing environments.

Comments

Segmented messages If the received messages are segmented, the application sending the messages must synchronize the messages as follows: • The first message in the sequence must have the appspecific property set to the number of messages that will arrive in this sequence of segmented messages (the first message is excluded). • The following messages must have this number decreased by one and the last message in the sequence must have the appspecific property set to 0. • All messages, except the first one, must have their correlation ID property set to the message ID of the first message. Private and public message queues Public message queues are published in the Active Directory. Private message queues are not published in the Active Directory. They are accessible only by Message Queuing applications that know the full path name or format name of the message queue.

The connector settings are described below.

Queue Manager

The server of the MS Message Queue.

Queue Name

The MS Message Queue from which to retrieve data. This MS Message Queue must belong to the Queue Manager specified above.

Private

Select to define the MS Message Queue as a private queue. Private message queues can be accessed even if the queue manager is off-line.

Transaction Type

•	MQ_NO_TRANSACTION – All messages will be read without transaction support.

•

MQ_INTERNAL_TRANSACTION – Messages that are not successfully processed will be rolled-back, and the StreamServer will try to process them again. Transactional messages are only read (removed) from a connector if and when the transaction is committed. Otherwise they are returned to the connector and can be read during a subsequent transaction.

Polling interval

Opens the Scheduler Configuration dialog where you specify when and how often to retrieve data. See Scheduling actions in the Design Center documentation for more information about scheduling.

Time-out

Specifies a time-out (seconds) for the connector. The StreamServer uses job-end sequences in the input data to determine when all data in an input job is received. If there are no job-end sequences in the input data, the StreamServer will not know when to stop waiting for more input. To prevent this from happening, you can define a time-out for the input connector.