Изучаем Java EE 7 - [209]
Требования к разработке класса MDB:
• класс должен иметь аннотацию @javax.ejb.MessageDriven или ее эквивалент в дескрипторе развертывания XML;
• класс должен реализовывать, прямо или косвенно, интерфейс MessageListener;
• класс должен быть определен как общедоступный и не должен быть окончательным или абстрактным;
• класс должен иметь общедоступный конструктор без аргументов, который контейнер будет использовать для создания экземпляров MDB;
• класс не должен реализовывать метод finalize().
Классу MDB разрешено выполнять иные методы, вызывать другие ресурсы и т. д. MDB развертывается в контейнере и может дополнительно поставляться с файлом ejb-jar.xml. Следуя модели «простота использования» Java EE 7, MDB может быть всего лишь аннотированным POJO, устраняя необходимость выполнять большую часть конфигурации. Однако если вам все еще нужно настроить конфигурацию JMS, можете использовать элементы с аннотациями @MessageDriven и @ActivationConfigProperty (XML или эквивалент).
@MessageDriven
MDB являются одним из самых простых видов EJB с точки зрения разработки, так как они поддерживают наименьшее количество аннотаций. Аннотация @MessageDriven (или эквивалентный XML) обязательна, потому что является частью метаданных, которые требуются, чтобы контейнер распознал, что класс Java на самом деле MDB.
API аннотации @MessageDriven, показанный в листинге 13.10, очень прост, и все элементы являются необязательными.
>@Target(TYPE) @Retention(RUNTIME)
>public @interface MessageDriven {
>··String name() default "";
>··Class messageListenerInterface default Object.class;
>··ActivationConfigProperty[] activationConfig() default {};
>··String mappedName();
>··String description();
>}
Элемент name указывает имя MDB (по умолчанию это название класса). messageListenerInterface определяет, какой слушатель сообщений реализует MDB (если MDB реализует несколько интерфейсов, то он сообщает контейнеру EJB, какой из них является интерфейсом MessageListener). Элемент mappedName — это имя JNDI места назначения, которое должны слушать MDB. Description — строка, которая используется, чтобы дать описание MDB после развертывания. Элемент activationConfig задействуется для задания свойств конфигурации и принимает массив аннотаций @ActivationConfigProperty.
@ActivationConfigProperty
JMS позволяет настроить определенные свойства, такие как селекторы сообщений, режим подтверждения, стойкие подписчики и т. д. В MDB эти свойства можно установить с помощью аннотации @ActivationConfigProperty. Эта необязательная аннотация может быть предоставлена как один из параметров аннотации @MessageDriven, и, по сравнению с эквивалентом JMS, аннотация @ActivationConfigProperty очень проста — она состоит из пары «имя/значение» (листинг 13.11).
>@Target({}) @Retention(RUNTIME)
>public @interface ActivationConfigProperty {
>··String propertyName();
>··String propertyValue();
>}
Свойство activationConfig позволяет вам предоставить стандартную и нестандартную (зависящую от поставщика) конфигурацию. Код в листинге 13.12 устанавливает флаг режима подтверждения и селектор сообщения.
>@MessageDriven(mappedName = "jms/javaee7/Topic", activationConfig = {
>··@ActivationConfigProperty(propertyName = "acknowledgeMode",
>····························propertyValue = "Auto-acknowledge"),
>··@ActivationConfigProperty(propertyName = "messageSelector",
>····························propertyValue = "orderAmount < 3000")
>})
>public class BillingMDB implements MessageListener {
>··public void onMessage(Message message) {
>····System.out.println("Сообщение получено: " +
>·······················message.getBody(String.class));
>··}
>}
Каждое свойство активизации — это пара «имя/значение», которую понимает лежащий в основе поставщик сообщений и использует для настройки MDB. В табл. 13.8 перечислены некоторые стандартные свойства.
| Свойство | Описание |
|---|---|
| acknowledgeMode | Режим подтверждения (по умолчанию AUTO_ACKNOWLEDGE) |
| messageSelector | Селектор сообщений, используемый MDB |
| destinationType | Тип места назначения, TOPIC или QUEUE |
| destinationLookup | Имя административно определенной очереди или темы |
| connectionFactoryLookup | Имя административно определенной очереди или темы фабрики соединений |
| destination | Имя места назначения |
| subscriptionDurability | Стойкость подписки (по умолчанию NON_DURABLE) |
| subscriptionName | Имя подписки потребителя |
| shareSubscriptions | Используется, если управляемый сообщениями компонент развернут и может быть разделенным |
| clientId | Идентификатор клиента, который будет использован при соединении с поставщиком JMS |
Внедрение зависимостей
Как и все EJB, описанные ранее (см. главу 7), MDB могут использовать внедрение зависимостей, чтобы получить ссылки на ресурсы, такие как источники данных JDBC, EJB или другие объекты. Внедрение — это средство, с помощью которого контейнер вставляет зависимости автоматически после создания объекта. Эти ресурсы должны быть доступны в контейнере или среде контекста, поэтому следующий код можно написать в MDB:
