...
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
{
"ConnectionName": "wmq.pool",
"ComponentName": "wmq",
"Parameters": {
"transportType": 1,
"port": 1414,
"channel": "S_eglwwvm24c",
"queueManager": "QM_eglwwvm24c",
"HostName": "10.130.36.42"
}
}
|
...
Inbound Queue MC2JMS Stream - Preserving The Sequence (available starting July 2019 MC2 Release)
To preserve the sequence we should , make sure we to consume messages on for one consumer only. The configuration for this type of consumption will be is the same as the configuration for Queue Concurrent Processing with the following differences:The
- Set the Sequential Reading parameter
...
- to Y. This
...
- indicates that MC2 runs only for one consumer in the MC2 cluster.
...
- Set the Concurrent Consumers to 1 or
...
- leave blank.
...
- This configuration
...
- ensures that the messages are processed strictly sequentially.
- To improve the performance and have some of the messages processed in parallel, define a Splitting Rule
...
- for the JMS stream. If the Split Type parameter in the Message Center Console Stream is defined as Rule Based and a rule is selected, MC2
...
- uses the Split Rule to calculate the key for each record in the message and
...
- persists it in its local topic (currently kafka) for further processing. The records/messages with the same key
...
- are processed sequentially.
...
- Records with different keys can be processed concurrently.
Durable Topic Subscription (available starting July 2019 MC2 Release)
The configuration for the Durable Topic Subscription is almost the same as the configuration for Inbound Queue - Preserving The Sequence, with the following differences:The
- Set the Destination Type
...
- to TOPIC or ALIAS.
- Eagle MC2 provides the following Component Names configured specifically for Durable Topic Subscriptions: wmq-tds & eagle-amq-tds.
...
- Set the Durable Subscription Name
...
- to a name used for the durable topic subscription.
- If Durable Subscription Name is set, MC2
...
- limits the number of consumers to one for the whole cluster. To improve the performance
...
- you are strongly
...
- advised to use Rule Based splitting with a Splitting Rule.
| Info |
|---|
...
The Client ID set on the connection |
...
is the |
...
SID-stream_name |
...
, where SID is the oracle database SID MC2 is connected to, and stream_name is the stream name for which the subscription is created. |
Publishing To Queue or Topic
...