JBoss HornetQ: установить размер окна потребителя для медленного потребителя - PullRequest
Новая
       86

JBoss HornetQ: установить размер окна потребителя для медленного потребителя

7 голосов
/ 11 августа 2011

Я хочу установить <consumer-window-size/> на 0. Похоже, что это ответ на другой вопрос ( очередь JMS с несколькими потребителями ), и он описан в этой статье в главе 17.1.1. Я получаю фабрику соединений, используя JNDI. Мой hornetq-jms.xml выглядит так: 

<configuration xmlns="urn:hornetq"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd">

  <connection-factory name="ConnectionFactory">
    <connectors>
      <connector-ref connector-name="netty-connector"/>
    </connectors>
    <entries>
      <entry name="ConnectionFactory"/>       
    </entries>
    <consumer-window-size>0</consumer-window-size>
  </connection-factory>

  <queue name="my.qeue">  
    <entry name="/queue/test"/>  
  </queue>   
</configuration>

Раздел <connection-factory/> является копией и вставкой по ссылке выше, но я получил ошибку: 

DEPLOYMENTS IN ERROR:
Deployment "org.hornetq:module=JMS,name="ConnectionFactory",
  type=ConnectionFactory" is in error due to the following reason(s):
  HornetQException[errorCode=104 message=There is no connector with
  name 'netty-connector' deployed.]

Это может быть связано с JBoss-6, потому что в других средах это работает: принудительный порядок сообщений с HornetQ

1 Ответ

10 голосов
/ 11 августа 2011

Прежде чем разместить netty-connector, вам нужно посмотреть на разъемы, которые вы зарегистрировали в hornetq-configuration.xml

Из вашей конфигурации hornetq вы увидите что-то вроде этого: 

<connectors>
        <connector name="netty">
                <factory-class>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</factory-class>
                <param key="host" value="${jboss.bind.address:localhost}" />
                <param key="port" value="${hornetq.remoting.netty.port:5445}" />
        </connector>

        <connector name="in-vm">
                <factory-class>org.hornetq.core.remoting.impl.invm.InVMConnectorFactory</factory-class>
                <param key="server-id" value="${hornetq.server-id:0}" />
        </connector>

</connectors>

Здесь вы должны будете сопоставить разъем при определении фабрики соединений.

Для получения дополнительной информации прочитайте документацию HornetQ о приемниках и разъемах.

...