Параллельно передача сообщений в базу данных, а также на сторону производителя (jms) при весенней интеграции - PullRequest
Новая
       18

Параллельно передача сообщений в базу данных, а также на сторону производителя (jms) при весенней интеграции

0 голосов
/ 01 июня 2018

Я делаю пример проекта по интеграции с пружиной (jms) activemq.Требование состоит в том, чтобы хранить данные в базе данных и передавать эти данные в очередь в activemq, оба должны работать параллельно.Я получаю сообщение об ошибке при отправке сообщения стороне производителя, например ", вложенное исключение - java.lang.IllegalStateException: целевой объект типа [class userDetails.web.QkaapzzMessageProducer] не имеет подходящих методов для обработки сообщений." 

    <int:publish-subscribe-channel id="postChannel" />      
    <jms:inbound-channel-adapter id="jmsIn"
        destination="helloWorldJMSQueue"
        channel="postChannel"
        extract-payload="false" 
        auto-startup="true">
        <int:poller fixed-delay="3000" />
     </jms:inbound-channel-adapter>                                     
 <jms:message-driven-channel-adapter id="helloWorldJMSAdapater" destination="helloWorldJMSQueue" connection-factory="jmsConnectionFactory"
    channel="postChannel" />


<integration:service-activator id="helloWorldServiceActivator" input-channel="postChannel" 
ref="qkaapzzMessageProducer" method="sendMessage" output-channel="nullChannel" />                                                                                                       


<int:channel id="requestChannel" />
<int:channel id="outputChannel" />

<int-http:inbound-gateway request-channel="requestChannel"
reply-channel="outputChannel" supported-methods="GET" path="/register"
view-name="register">
<int-http:request-mapping />
</int-http:inbound-gateway>
<int-http:inbound-gateway request-channel="postChannel"
reply-channel="outputChannel" supported-methods="POST" path="/registerNew"
error-channel="errorChannel" view-name="login">
</int-http:inbound-gateway>



<int-jdbc:outbound-channel-adapter 
    query="insert into user_registration (USER_FSTNAME,USER_ADDRESS,USER_STATE,USER_CITY,USER_OCCUPATION,USER_EMAIL,USER_CONTACT,USER_PASSWORD) 
values (:fstName,:addrss,:state,:city,:occupation,:email,:contact,:password)"
    channel="postChannel" data-source="dataSource" id="sample" sql-parameter-source-factory="spelSource"  />


<int:service-activator  ref="userService" input-channel="requestChannel"
                             output-channel="outputChannel"  method="message"/>

<bean id="spelSource"
    class="org.springframework.integration.jdbc.ExpressionEvaluatingSqlParameterSourceFactory">
    <property name="parameterExpressions">
        <map>                                                                                                                           
            <entry key="fstName" value="payload[firstName]" />
            <entry key="lstName" value="payload[lastName]" />
            <entry key="addrss" value="payload[address]" />
            <entry key="state" value="payload[state]" />                
            <entry key="city" value="payload[city]" />
            <entry key="occupation" value="payload[occupation]" />
            <entry key="email" value="payload[email]"/>
            <entry key="contact" value="payload[contact]"/>
            <entry key="password" value="payload[password]"/>
        </map>
    </property>
</bean>

Мой класс производителя 

public class QkaapzzMessageProducer {
private Connection connection;
private Session session;
private javax.jms.MessageProducer messageProducer;
public static final String HELLO_WORLD_QUEUE = "testQueue";
public Message<?> sendMessage(Message<?> msg,String queue2) throws 
JMSException {

    if((queue2.equals("")) ||(queue2.equals(null)) )
    {   
        queue2=HELLO_WORLD_QUEUE;
        session =
            connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Queue queue = session.createQueue(queue2);
        messageProducer = session.createProducer(queue);
       // TextMessage txt = session.createTextMessage(text);
        messageProducer.send((javax.jms.Message) msg);
        // TODO Auto-generated method stub
     }
    else      
    {
    session =connection.createSession(false, 
    Session.AUTO_ACKNOWLEDGE);
    Queue queue = session.createQueue(queue2);
    messageProducer = session.createProducer(queue);
    messageProducer.send((javax.jms.Message) msg);
        }
    return msg;
}
}

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

1 Ответ

0 голосов
/ 01 июня 2018

Ваш вопрос неясен, поскольку проблема, которую вы показываете, не связана с предметом вопроса.

В вашем исключении говорится, что сигнатура метода sendMessage() не соответствует модели обмена сообщениями.

Это там как: 

public Message<?> sendMessage(Message<?> msg, String queue2) throws

Spring Integration основывается на Message<?> обмене объектами.Таким образом, когда Service Activator пытается вызвать этот метод, он имеет в руках только запрос Message<?> и полностью не знает, что это за аргумент queue2 и что с этим делать.

Вы можете немного помочь, разместив аннотацию @Header для этого аргумента queue2.Конечно, это сработает, если у вас действительно есть эта информация в заголовках сообщений.

См. Дополнительную информацию в Справочном руководстве .

...