...
Если команда может иметь различные вариации, то необходимо выделить общую часть
| Команда в UTF-8 | Команда в Base64 |
|---|---|
| prev-ip-addr: next-ip-addr: 192.168.0.1 | cHJldi1pcC1hZGRyOiAgbmV4dC1pcC1hZGRyOiAxOTIuMTY4LjAuMQ== |
| prev-ip-addr: next-ip-addr: 192.168.0.2 | cHJldi1pcC1hZGRyOiAgbmV4dC1pcC1hZGRyOiAxOTIuMTY4LjAuMg== |
| prev-ip-addr: 192.168.0.1 next-ip-addr: | cHJldi1pcC1hZGRyOiAxOTIuMTY4LjAuMSBuZXh0LWlwLWFkZHI6IA== |
| prev-ip-addr: 192.168.0.2 next-ip-addr: | cHJldi1pcC1hZGRyOiAxOTIuMTY4LjAuMiBuZXh0LWlwLWFkZHI6IA== |
| prev-ip-addr: | cHJldi1pcC1hZGRyOg== |
В данном примере можно выделить общую часть команды в Base64 — cHJldi1pcC1hZGRyO, которую и нужно использовать при маршрутизации.
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
...
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}">
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry topic=">" >
<!-- The constantPendingMessageLimitStrategy is used to prevent
slow topic consumers to block producers and affect other consumers
by limiting the number of messages that are retained
For more information, see:
http://activemq.apache.org/slow-consumer-handling.html
-->
<pendingMessageLimitStrategy>
<constantPendingMessageLimitStrategy limit="1000"/>
</pendingMessageLimitStrategy>
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
... |
Задача
Скопилась большая очередь результатов команд, ActiveMQ медленно переносит сообщения в очередь Oracle.
Решение
При отправке сообщений в очередь Oracle, ActiveMQ завершает сессию после каждого переданного сообщения. Чтобы изменить такое поведение, настроим использование пула соединений к Oracle.
Изменим URI для очереди Oracle:
| Code Block | ||||
|---|---|---|---|---|
| ||||
...
<route>
<from uri="activemq:queue:hydra_command_results_1"/>
<to uri="oraclePool:topic:AIS_NET.HP_COM_RES_1?clientId=ActiveMQ&durableSubscriptionName=HP"/>
</route>
... |
И добавим описание PooledConnectionFactory после описания oracleTopic:
| Code Block | ||||
|---|---|---|---|---|
| ||||
...
<bean id="oracleTopic" class="org.apache.camel.component.jms.JmsComponent">
<property name="connectionFactory" ref="oracleTopicCredentials"/>
</bean>
<bean id="jmsPooledConnectionFactory" class="org.apache.activemq.jms.pool.PooledConnectionFactory"
init-method="start" destroy-method="stop" >
<property name="maxConnections" value="7" />
<property name="connectionFactory" ref="oracleTopicCredentials" />
</bean>
<bean id="oraclePool" class="org.apache.camel.component.jms.JmsComponent">
<property name="connectionFactory" ref="jmsPooledConnectionFactory"/>
</bean>
... |