JBoss HornetQ: establecer el tamaño de la ventana del consumidor para consumidores lentos

Question

Quiero configurar el <consumer-window-size/> en 0. Esta parece ser la respuesta a otra pregunta (JMS queue with multiple consumers), y se describe en este article en el capítulo 17.1.1. Recupero la fábrica de conexiones usando JNDI. Mi hornetq-jms.xml se parece a esto:

<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> 

La sección <connection-factory/> es copiar & pegar desde el enlace de arriba, pero me dio el error:

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.] 

Esto puede ser JBoss-6 relacionado, porque en otros entornos esto parece funcionar: force order of messages with HornetQ

Answer 1

Antes de colocar netty-connector, necesita ver los conectores que ha registrado en su hornetq-configuration.xml

Desde su hornetq configuración, verá algo como esto:

<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> 

Tendrá que coincida con el conector de aquí a su definición de la conexión de fábrica.

Para obtener más información, lea la documentación de HornetQ sobre aceptadores y conectores.