Сообщение возбуждается POJO с пружиной.Не могу получить сообщение - PullRequest
Новая
       67

Сообщение возбуждается POJO с пружиной.Не могу получить сообщение

0 голосов
/ 31 декабря 2018

мое приложение развернуто на Tomcat. Я пытаюсь отправить и получить сообщение из удаленной очереди.

Мне уже удалось отправить несколько сообщений в удаленную очередь.Сейчас я пытаюсь создать контейнер слушателя сообщений, однако мой onMessage (метод никогда не вызывается) не понимает, чего мне не хватает.

Это моя конфигурация 

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="connectionFactory" />
    <property name="destinationResolver" ref="destinationResolver" />
</bean>

<bean id="connectionFactory" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
    <property name="targetConnectionFactory" ref="targetConnectionFactory"/>
    <property name="username" value="user"/>
    <property name="password" value="pass"/>
</bean>

<bean id="targetConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiTemplate" ref="jndiTemplate" />
    <property name="jndiName" value="MY_TEST_QUEUE" />
    <property name="proxyInterface" value="javax.jms.ConnectionFactory"/>
</bean>

<bean id="destinationResolver" class="org.springframework.jms.support.destination.JndiDestinationResolver">
    <property name="jndiTemplate" ref="jndiTemplate" />
    <property name="cache" value="true" />
</bean>

<bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate">
    <property name="environment">
        <props>
            <prop key="java.naming.factory.initial">weblogic.jndi.WLInitialContextFactory</prop>
            <prop key="java.naming.provider.url">t3://host:port</prop>
        </props>
    </property>
</bean>

<bean id="messageListener" class="com.package.MyCustomMDB" />

<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="connectionFactory" ref="connectionFactory"/>
    <property name="destinationName" value="MY_TEST_QUEUE"/>
    <property name="destinationResolver" ref="destinationResolver" />
    <property name="messageListener" ref="messageListener" />
</bean>

И реализация mdb 

public class MyCustomMDB implements MessageListener {
@Override
public void onMessage(Message message) {
    System.out.println(message.toString());
}}

Не могли бы вы сообщить мне, где я делаю что-то не так?

1 Ответ

0 голосов
/ 31 декабря 2018

Вы используете MY_TEST_QUEUE для и , jndiName из targetConnectionFactory и destinationName из jmsContainer.jndiName из targetConnectionFactory должно ссылаться на имя фабрики соединений , а не на очередь.

...