MessageChannel Arayüzü

Giriş
Şu satırı dahil ederiz.

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.messaging.MessageChannel;

Tanımlama
Bir channel tanımlar ve JMS kuyruğunu ilişkilendiririz. Şöyle yaparız.

<!-- OUTBOUND settings -->
<int:channel id="senderChannel" />

<int-jms:outbound-channel-adapter id="jmsOut" destination="outQueue"
  channel="senderChannel"/>

JMS kuyruğu şöyledir

<bean id="outQueue" class="com.ibm.mq.jms.MQQueue" depends-on="connectionFactory">
  <constructor-arg index="0" value="*****" />
  <constructor-arg index="1" value="******" />
</bean>

Kuyruğa bağlanmak için ayarlar şöyledir.

<!-- Factory Defintions -->
<bean id="connectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
  <property name="transportType" value="1" />
  <property name="queueManager" value="****" />
  <property name="hostName" value="******" />
  <property name="port" value="****" />
  <property name="channel" value="******" />
</bean>

Bu sınıf ile alakası yok ancak örnek olsun diye not alıyorum. Mesajları okumak için şöyle yaparız.

<!-- INBOUND settings -->

<int:channel id="recieverChannel" />    

<int-jms:message-driven-channel-adapter id="jmsIn" destination="inQueue"
  channel="recieverChannel" extract-payload="false" />

<int:service-activator input-channel="recieverChannel" ref="messageListener"
  method="processMessage" />

Okuyan sınıf için şöyle yaparız.

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.TextMessage;

public class MessageListener {

  public void processMessage(Message message) {

    if (message instanceof TextMessage) {
      TextMessage txtmsg = (TextMessage) message;

      try {
         System.out.println(txtmsg.getText());
      } catch (JMSException e) {
        ...
      }
    }
  }
}

send metodu
Elimizde şu nesne olsun

@Autowired
MessageChannel senderChannel;

Şöyle yaparız.

String message = ...;

senderChannel.send(MessageBuilder.withPayload(message).build());