java - サービスまたはリスナーを使用して ActiveMQ でメッセージを消費する

Question

既存の ActiveMQ FORWARD キューにメッセージを送信する小さなテストを作成しました。残念ながら、メッセージはキューに送信されますが、受信されません。以下に、このメッセージを受信するための 2 つの試みを示します。MyMessageListener を使用する方法と MessageService を使用する方法です。どちらの方法も失敗します。これが私のテストです：

 Map<Parameter, String> params = new HashMap<Parameter, String>();

    params.put(key1, "601");
    params.put(key2, "3000");

    Map<String,String> headers = Collections.singletonMap("method-name","prepareHotDrink");
    Message<?>  msg = MessageBuilder.withPayload(params)
    .copyHeaders(headers)
    .build();

    boolean i = inputChannel.send(msg);

これは私の構成ファイルです：

<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
 <property name="brokerURL" value="${jms.primary.server}"/>
 </bean>


<!-- spring integration beans -->

<int-jms:channel id="inputChannel" queue-name="FORWARD"
    connection-factory="connectionFactory" auto-startup="true">
</int-jms:channel>

<!-- Consumers -->    
<int-jms:message-driven-channel-adapter
    id="jmsIn"
    container="messageListenerContainer"
    channel="inputChannel"
    extract-payload="true" />


<int:service-activator input-channel="inputChannel"
                   ref="messageService"
                   method="processMessage"/>


<bean id="messageListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">     
    <property name="connectionFactory" ref="connectionFactory"/>     
    <property name="destination" ref="requestQueue"/>
    <property name="exposeListenerSession" value="false"/>
    <property name="messageListener" ref="messageListener" />
</bean> 

<bean id="messageListener" class="com.ucware.ucpo.forward.mess.MyMessageListener"/>
<bean id="messageService" class="com.ucware.ucpo.forward.jms.MessageService"/>

<bean id="requestQueue" class="org.apache.activemq.command.ActiveMQQueue">

<constructor-arg name="name" value="FORWARD"/>
</bean>