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




example mkyong (4)

У меня есть компонент, который отправляет сообщения в очередь для обработки другой системой. Следует также периодически публиковать тему о статусе работы. Могу ли я просто использовать тот же 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);

Answers

Это может показаться немного странным, вам нужно сообщить JmsTemplate, что это тема, а не очередь, установив для его свойства pubSubDomain значение true .

Это означает, что вам понадобятся два компонента JmsTemplate , один для очереди и один для темы:

<bean id="jmsQueueTemplate" class="org.springframework.jms.core.JmsTemplate">
   <constructor-arg ref="connectionFactory" />
   <property name="pubSubDomain" value="false"/>
</bean>

<bean id="jmsTopicTemplate" class="org.springframework.jms.core.JmsTemplate">
   <constructor-arg ref="connectionFactory" />
   <property name="pubSubDomain" value="true"/>
</bean>

Если вы создадите место назначения как 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, так как она более стандартна.


Если вы можете использовать соглашение об именах для очереди / тем, то вы можете реализовать пользовательский 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


В дополнение к тому, что сказал , убедитесь, что:

  • Экземпляр ExpectedException является общедоступным ( связанный с ним вопрос )
  • ExpectedException не создается, например, методом @Before. В этой post четко объясняются все тонкости порядка исполнения Юнитом.

Вы не делать этого:

@Rule    
public ExpectedException expectedException;

@Before
public void setup()
{
    expectedException = ExpectedException.none();
}

Наконец, this сообщение в блоге ясно показывает, как утверждать, что выбрано определенное исключение.





java spring jms activemq