WildFly JavaEE - запускать / останавливать управляемый сообщениями компонент во время выполнения - PullRequest
Новая
       104

WildFly JavaEE - запускать / останавливать управляемый сообщениями компонент во время выполнения

0 голосов
/ 30 апреля 2020

У меня есть вопрос о бинах, управляемых сообщениями (MDB). Есть ли способ генерировать их только во время выполнения? Я хочу предоставить способ в моем бэкэнде, чтобы начать или прекратить получать сообщения. Он должен контролироваться через запись конфигурации в базе данных. При запуске WildFly, он также должен сначала проверить, можно ли запустить MDB.

Соответствует ли Java EE без MDB и создавать слушателей вручную?

Я сейчас использую следующий код 

@MessageDriven(name = "MyMDB", activationConfig = {
        @ActivationConfigProperty(propertyName = "maxSession", propertyValue = "2"),
        @ActivationConfigProperty(propertyName = "destination", propertyValue = "java:/jms/queue/Test"),
        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
        @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge")})
public class JmsConsumer implements MessageListener {

    @Override
    public void onMessage(final Message msg) {

        if (msg instanceof TextMessage) {
            try {
                final String text = ((TextMessage) msg).getText();

                System.out.println("message: " + text + " (" + msg.getJMSRedelivered() + ")");

            } catch (final JMSException e) {
                e.printStackTrace();
            }
        }
    }
}

Будет ли этот код также соответствовать Java EE? 

@Singleton
@LocalBean
public class QueueWorkerManager {
    private InitialContext initialContext = null;
    private QueueConnectionFactory queueConnectionFactory = null;
    private Queue queue = null;
    private QueueConnection queueConnection = null;
    private QueueSession queueSession = null;
    private MessageConsumer consumer = null;

    @PostConstruct
    public void init() {
        try {
            this.initialContext = new InitialContext();
            this.queueConnectionFactory = (QueueConnectionFactory) initialContext
                    .lookup("java:/ConnectionFactory");

            this.queue = (Queue) initialContext.lookup(MyQueueSender.WORKER_QUEUE);
            this.queueConnection = queueConnectionFactory.createQueueConnection();
            this.queueSession = queueConnection.createQueueSession(false, Session.CLIENT_ACKNOWLEDGE);

            this.consumer = queueSession.createConsumer(this.queue);
            this.consumer.setMessageListener(new ConsumerMessageListener());

            this.queueConnection.start();
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    @PreDestroy
    public void destroy() {
        this.stopConsumer(this.consumer;
        if(this.consumer != null) {
            try {
                this.consumer.close();
            } catch (JMSException e) {
            }
            this.consumer = null;
        }

        if(this.queueSession != null) {
            try {
                this.queueSession.close();
            } catch (JMSException e) {
            }
            this.queueSession = null;
        }

        if(this.queueConnection != null) {
            try {
                this.queueConnection.close();
            } catch (JMSException e) {
            }
            this.queueConnection = null;
        }
    }
}

public class ConsumerMessageListener implements MessageListener {

    @Override
    public void onMessage(Message message) {
        TextMessage textMessage = (TextMessage) message;
        try {
             System.out.println("message: " + textMessage.getText() + " (" + msg.getJMSRedelivered() + ")");
            message.acknowledge();
        } catch (JMSException | InterruptedException e) {          
            e.printStackTrace();
        }
    }

}

1 Ответ

1 голос
/ 04 мая 2020

Я бы предложил вам

  • добавить аннотацию @DeliveryActive( false / true) к вашему MDB, чтобы загрузить ее в желаемое начальное состояние
  • Использовать JMX или JBoss CLI для программного изменения значения атрибута active вашего MDB

Здесь все объясняется: https://docs.wildfly.org/16/Developer_Guide.html#Message_Driven_Beans_Controlled_Delivery

Удачи

...