Как создать jms Topic и TopicConnectionFactory программно? - PullRequest
Новая
       45

Как создать jms Topic и TopicConnectionFactory программно?

10 голосов
/ 07 декабря 2011

Кто-нибудь знает, можно ли создать тему и фабрику ее соединений программно? В настоящее время я использую утилиту администратора glassfish для создания своей темы и фабрики соединений. Если я не могу создать его в коде, есть ли у glassfish / openmq тема по умолчанию и заводская настройка, которую я могу использовать?

1 Ответ

17 голосов
/ 08 декабря 2011

Если вы хотите обойти создание ресурсов вручную только в администраторе, вы можете просто развернуть их с помощью файла "glassfish-resources.xml" (GF 3.1, см. http://docs.oracle.com/cd/E18930_01/html/821-2417/giyhh.html).

Вам нужен админ-объект-ресурс, подобный этому (для темы): 

<admin-object-resource enabled="true" jndi-name="jms/myTopic"
   object-type="user" res-adapter="jmsra" res-type="javax.jms.Topic">
  <property name="Name" value="physicalTopic"/>
</admin-object-resource>

Помните, что вы должны использовать разные значения «Имя» для Темы (здесь: «PhysicalTopic»), если вы реализуете несколько Тем, чьи сообщения не должны смешиваться.

Далее вам нужен ресурс-коннектор, ссылающийся на пул коннекторных соединений типа javax.jms.TopicConnectionFactory.

Если вы не стремитесь к динамическому созданию ресурсов с использованием дескриптора развертывания, лучше всего использовать glassfish-resources.xml.

Обратите внимание, что ресурсы, развернутые таким образом, относятся к области приложения: http://docs.oracle.com/cd/E18930_01/html/821-2417/giydj.html

"glassfish-resources.xml" - это файл для GF 3.x, для GF 2.x это был "sun-resources.xml". Файл находится в папке «Ресурсы сервера» в представлении проекта, если вы используете NetBeans. Внимание: glassfish-resources.xml в разделе «Ресурсы сервера» используется NetBeans, только если вы используете NetBeans для развертывания! NetBeans знает, как создавать эти ресурсы, и выполняет эту задачу. Если вы развернете EAR непосредственно на Glassfish без NetBeans - что весьма вероятно для производственной среды - вы должны предоставить glassfish-resources.xml в:

  • META-INF вашего EJB-модуля или WEB-INF вашей WAR для ресурсов области действия модуля
  • META-INF вашего корпоративного приложения для ресурсов приложений В NetBeans это достигается путем помещения файла в папку «Файлы конфигурации» в представлении проекта (в файловой системе - src / conf /).

Вы можете легко создать это определение ресурса с помощью мастера [New Bean-Driven Bean] NetBeans (просто добавьте MBean, выбрав [New ...]). В мастере выберите «Назначения проекта»> [Добавить]. Полный пример 3.1 выглядит следующим образом: 

<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE resources PUBLIC "-//GlassFish.org//DTD GlassFish Application Server 3.1 Resource Definitions//EN" "http://glassfish.org/dtds/glassfish-resources_1_5.dtd">
<resources>
    <admin-object-resource enabled="true" jndi-name="jms/myDestination"  res-type="javax.jms.Topic"  res-adapter="jmsra">
        <property name="Name" value="PhysicalTopic"/>
    </admin-object-resource>
    <connector-connection-pool name="jms/myDestinationFactoryPool"  connection-definition-name="javax.jms.TopicConnectionFactory"  resource-adapter-name="jmsra"/>
    <connector-resource enabled="true" jndi-name="jms/myDestinationFactory" pool-name="jms/myDestinationFactoryPool"  />
</resources>

Это аннотация MBean: 

@MessageDriven(mappedName = "java:app/jms/myDestination", activationConfig =
{
    @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Topic"),
    @ActivationConfigProperty(propertyName = "subscriptionDurability", propertyValue = "Durable"),
    @ActivationConfigProperty(propertyName = "clientId", propertyValue = "NewMessageBean"),
    @ActivationConfigProperty(propertyName = "subscriptionName", propertyValue = "NewMessageBean")
})
public class NewMessageBean implements MessageListener
{ 
[...]

Внимание : «java: app /» в mappedName является правильным, только если вы используете ресурсы области приложения. Вы можете сэкономить "java: app /" в определении в glassfish-resources.xml. Руководство по развертыванию GF гласит: «Имена JNDI ресурсов в области приложения начинаются с java: app или Java: модуль. Если один из этих префиксов не указан в имени JNDI, он добавляется. "

Вы также можете ввести другой уровень косвенности, используя «имя» вместо «mappedName». Затем вам необходимо предоставить файл с именем «application-client.xml», в котором (логическое) имя будет сопоставлено с «физическим» местоположением JNDI.

...