java - пример - Как вы публикуете тему JMS с Spring JMS?




spring jms пример (2)

Если вы можете использовать соглашение об именах для очереди / тем, то вы можете реализовать пользовательский org.springframework.jms.support.destination.DestinationResolver

public class NamingDestinationResolver implements DestinationResolver {
   public Destination resolveDestinationName(Session session, String destinationName, boolean pubSubDomain) throws JMSException {
      if (destinationName.endsWith("Queue")) {
         return session.createQueue(destinationName);
      } else if (destinationName.endsWith("Topic")) {
         return session.createTopic(destinationName);
      }
      throw new RuntimeException("Naming convention not respected for destination " + destinationName);
   }
}

и ссылаться на него с помощью JmsTemplate.setDestinationResolver

У меня есть компонент, который отправляет сообщения в очередь для обработки другой системой. Следует также периодически публиковать тему о статусе работы. Могу ли я просто использовать тот же JmsTemplate, который используется для отправки в очередь и публикации в теме?

Я создал новую тему в ActiveMQ, за исключением того, что, когда я отправляю из JmsTemplate сообщение, с отправленным сообщением создается новая очередь с именем темы (вместо отправки данных в актуальную тему), что я делаю здесь неправильно?

вот мой конфиг:

<bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
    <constructor-arg ref="amqConnectionFactory" />
    <property name="exceptionListener" ref="jmsExceptionListener" />
    <property name="sessionCacheSize" value="100" />
</bean>

<!--  JmsTemplate Definition -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <constructor-arg ref="connectionFactory" />
</bean>


<bean id="messageFacade" class="org.foo.MessageFacadeJms">
    <property name="jmsTemplate" ref="jmsTemplate" />
</bean>

MessageFacadeJms - это класс, который я использую для отправки сообщения очереди (и он работает), могу ли я также использовать его для публикации темы?

Могу ли я просто использовать это для отправки очереди и публикации темы ?:

jmsTemplate.convertAndSend("TOPIC_NAME" /* or queue name */, message);

Если вы создадите место назначения как Spring Bean, а не используете имя места назначения в своем коде, Spring не нужно будет знать, является ли это темой или очередью. В противном случае решение, предложенное выше, также должно работать.

Назначения AMQ JMS могут быть созданы путем непосредственного их создания:

  <bean id="destination" class="org.apache.activemq.command.ActiveMQTopic">
    <constructor-arg value="TOPIC_NAME" />
  </bean>

или выборка из JNDI:

<bean id="topic" class="org.springframework.jndi.JndiObjectFactoryBean">
        <property name="jndiName" value="TOPIC_NAME"/>
        <property name="jndiTemplate" ref="jmsJndiTemplate"/> 
</bean>

Я предпочитаю технику JNDI, так как она более стандартна.





activemq