未在消息驱动的bean(MDB)中注入无状态EJB

Question

我有一个消息驱动的bean（MDB），它实现了MessageListener，并有几个EJB属性，但没有注入它们，所以我必须手动注入它们。MDB还有一个资源和一个CDIBean，它们被很好地注入。

为什么EJB不是自动注入的？我在应用程序的其他部分使用NotificationServiceEJB，它们被注入。有关于如何解决这个问题的线索吗？

我没有从Weblogic 12.1.3中得到任何错误，所以我不知道这里发生了什么。我的代码是（出于调试目的，充满了跟踪）。我已经删除了与问题无关的javadocs和方法实现：

@MessageDriven(name = "MailMessageConsumer", description = "JMS consumer", mappedName = MailJndiConfiguration.JNDI_QUEUE,
    activationConfig = {
            @ActivationConfigProperty(propertyName = "acknowledgeMode",
                                      propertyValue = "Auto-acknowledge"),
            @ActivationConfigProperty(propertyName = "destinationType",
                                      propertyValue = "javax.jms.Queue")
    })
@TransactionAttribute(TransactionAttributeType.REQUIRED)
@MessageReceiver(responsibility = "Consumes JMS messages of type MailMessage")
public class MailMessageConsumer implements MessageListener {
    private static final Logger log = LoggerFactory.getLogger(MailMessageConsumer.class);
    @Resource
    private MessageDrivenContext messageDrivenContext;
    @EJB
    private NotificationService notificationService;
    @EJB
    private MailClient mailClient;
    @Inject
    private ApplicationInformation applicationInformation;
    @Override
    public void onMessage(Message message) {
        if (mailClient == null) {
            log.error("mailClient object is null");
            try {
                log.info("Instantiating MailClient manually...");
                mailClient = BeanManagerHelper.getReference(MailClient.class);
            } catch (Exception e) {
                log.error("Cannot instantiate MailClient manually", e);
            }
        }
        if (notificationService == null) {
            log.error("notificationService object is null");
            try {
                log.info("Instantiating NotificationService manually...");
                notificationService = BeanManagerHelper.getReference(NotificationService.class);
            } catch (Exception e) {
                log.error("Cannot instantiate NotificationService manually", e);
            }
        }
        // This never happens
        if (applicationInformation == null) {
            log.error("applicationInformation object is null");
        }
        // This never happens
        if (messageDrivenContext == null) {
            log.error("messageDrivenContext object is null");
        }
        deliverMessage(message);
    }
    private void deliverMessage(Message message) {
        // Not important
    }
    private MailMessage retrieveMessage(Message message) {
        // Not important
    }
    private void sendEmail(MailMessage mailMessage) {
        // Not important
    }
}

MailClient EJB:

@Stateless
@LocalBean
@TransactionAttribute(TransactionAttributeType.MANDATORY)
@Service
public class MailClient {
    private static final Logger logger = LoggerFactory.getLogger(MailClient.class);
    @Resource(mappedName = MailJndiConfiguration.JNDI_MAIL_SESSION)
    private Session mailSession;
    @EJB
    private NotificationService notificationService;
    @Inject
    private ApplicationInformation applicationInformation;
    enum ValidationError {
        NULL_OBJECT("Mail message is null"),
        CONTENT_TYPE_EMPTY("Content type not initialized"),
        BODY_EMPTY("Message body content is empty");
        private static final String ERROR_MESSAGE_PREFIX = "Invalid mail message: ";
        private String message = ERROR_MESSAGE_PREFIX;
        ValidationError(String message) {
            this.message += message;
        }
        public String getMessage() {
            return message;
        }
    }
    public void sendMail(MailMessage mailMessage) throws MailMessageSendingException {
        // Not important
    }
}

NotificationService EJB:

@Stateless
@LocalBean
@TransactionAttribute(TransactionAttributeType.MANDATORY)
@Service
public class NotificationService {
    private static final Logger logger = LoggerFactory.getLogger(NotificationService.class);
    @PersistenceContext(unitName = "myEntityManager")
    private EntityManager entityManager;
    @EJB
    private NotificationPendingMessageValidator notificationPendingMessageValidator;
    @EJB
    private NotificationFinder notificationFinder;
    @Inject
    private ApplicationInformation applicationInformation;
    public NotificationPendingMessageEntity saveNotificationMessageForDeferredMail(NotificationPendingMessageEntity notificationPendingMessageEntity) throws ValidationException {
        // Not important
    }
    public List<NotificationPendingMessageEntity> findNotificationPendingMessageEntities(TimeSlot timeSlot) {
        // Not important
    }
    @TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
    public NotificationMailEntity createNewMailEntity() {
        // Not important
    }
    @TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
    public void updateMailEntity(NotificationMailEntity mailEntity) {
        // Not important
    }
    public void createNotificationMessageProcessedEntity(NotificationProcessedMessageEntity notificationProcessedMessageEntity) {
        // Not important
    }
    public void removeNotificationMessagePendingEntity(NotificationPendingMessageEntity notificationPendingMessageEntity) {
        // Not important
    }
    public void reportMailFailure(NotificationMailEntity mailEntity, String failureNotice) {
        // Not important
    }
}

Answer 1

使用@Inject而不是@EJB注释来注入EJB效果良好。因此，一些Weblogic的补丁程序应该有问题，因为在另一个Weblogic（相同版本，不同的补丁程序）中测试它也能很好地进行