Как внедрить Сессионный Бин в Бин, управляемый сообщениями? - PullRequest
Новая
       51

Как внедрить Сессионный Бин в Бин, управляемый сообщениями?

5 голосов
/ 17 марта 2010

Я довольно новичок в Java EE, так что это может быть глупо ... потерпи меня, пожалуйста: D

Я бы хотел внедрить сессионный компонент без сохранения состояния в управляемый сообщениями компонент. По сути, MDB получает сообщение JMS, а затем использует сессионный компонент для выполнения работы. Сессионный компонент содержит бизнес-логику.

Вот мой сессионный компонент: 

@Stateless
public class TestBean implements TestBeanRemote {

  public void doSomething() {
    // business logic goes here
  }
}

Соответствующий интерфейс: 

@Remote
public interface TestBeanRemote {

  public void doSomething();
}

Вот мой MDB: 

@MessageDriven(mappedName = "jms/mvs.TestController", activationConfig =  {
@ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
    })
public class TestController implements MessageListener {

 @EJB
 private TestBean testBean;

    public TestController() {
    }

    public void onMessage(Message message) {
      testBean.doSomething();
    }
}

Пока не ракетостроение, верно?

К сожалению, при развертывании этого на glassfish v3 и отправке сообщения в соответствующую JMS-очередь я получаю сообщения об ошибках, которые Glassfish не может найти в EJB TestBean: 

java.lang.IllegalStateException: Exception attempting to inject Remote ejb-ref name=mvs.test.TestController/testBean,Remote 3.x interface =mvs.test.TestBean,ejb-link=null,lookup=null,mappedName=,jndi-name=mvs.test.TestBean,refType=Session into class mvs.test.TestController
Caused by: com.sun.enterprise.container.common.spi.util.InjectionException: Exception attempting to inject Remote ejb-ref name=mvs.test.TestController/testBean,Remote 3.x interface =mvs.test.TestBean,ejb-link=null,lookup=null,mappedName=,jndi-name=mvs.test.TestBean,refType=Session into class mvs.test.TestController
Caused by: javax.naming.NamingException: Lookup failed for 'java:comp/env/mvs.test.TestController/testBean' in SerialContext  [Root exception is javax.naming.NamingException: Exception resolving Ejb for 'Remote ejb-ref name=mvs.test.TestController/testBean,Remote 3.x interface =mvs.test.TestBean,ejb-link=null,lookup=null,mappedName=,jndi-name=mvs.test.TestBean,refType=Session' .  Actual (possibly internal) Remote JNDI name used for lookup is 'mvs.test.TestBean#mvs.test.TestBean' [Root exception is javax.naming.NamingException: Lookup failed for 'mvs.test.TestBean#mvs.test.TestBean' in SerialContext  [Root exception is javax.naming.NameNotFoundException: mvs.test.TestBean#mvs.test.TestBean not found]]]

Итак, мои вопросы:

  • это правильный способ внедрения сессионного компонента в другой компонент (в частности, управляемый сообщениями компонент)?
  • почему поиск имен не удался?

Ответы [ 4 ]

6 голосов
/ 28 января 2012

Я думаю, что проблема самого первого примера в том, что вы пытаетесь внедрить реализацию EJB, а не его интерфейс. Локальное представление без интерфейса EJB 3.1 просто возможно, если вы не определяете ни один интерфейс, даже удаленный. Таким образом, изменение точки впрыска до следующего должно сработать: 

 @EJB
 private TestBeanRemote testBean;

Если вы используете свое приложение в некластерной среде, то есть в единой JVM, вам следует подумать об изменении интерфейса на @Local. Как только вы получаете доступ к EJB-компонентам через их удаленный интерфейс, вы получаете много накладных расходов. Доступ к параметрам и возвращаемым значениям может осуществляться не по ссылке, а по значению, так как они всегда копируются (так сказано в спецификации). Это может привести к проблемам с производительностью при работе с более сложными объектами.

Надеялся, что помог.

6 голосов
/ 18 марта 2010

Не могли бы вы попытаться определить такие вещи: 

@Remote
public interface TestBeanRemote {

  public void doSomething();
}

@Stateless(name="TestBeanRemote")
public class TestBean implements TestBeanRemote {

  public void doSomething() {
    // business logic goes here
  }
}

А затем в MDB: 

@MessageDriven(mappedName = "jms/mvs.TestController", activationConfig =  {
@ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
    })
public class TestController implements MessageListener {

    @EJB(beanName="TestBeanRemote")
    private TestBeanRemote testBean;

    public TestController() {
    }

    public void onMessage(Message message) {
      testBean.doSomething();
    }
}

Если это сработает, я постараюсь дать объяснение :)

4 голосов
/ 18 марта 2010

Кажется, что моя проблема была связана с инверсией управления и вызвана моим недостатком знаний и предложениями Netbeans для имен классов / интерфейсов.

Я обнаружил, что - чтобы найти правильный бин и правильный интерфейс - я должен назвать их правильно. Вот что работает: 

@Remote
public interface Test {

  public void doSomething();
}

@Stateless
public class TestBean implements Test {

  public void doSomething() {
    // business logic goes here
  }
}

И в MDB я получаю доступ к «Test» , а не «TestBean»: 

@MessageDriven(mappedName = "jms/mvs.TestController", activationConfig =  {
@ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
    })
public class TestController implements MessageListener {

    @EJB
    private Test testBean;

    public TestController() {
    }

    public void onMessage(Message message) {
      testBean.doSomething();
    }
}
3 голосов
/ 17 марта 2010

Хорошо, я обнаружил, что если я добавляю аннотацию @LocalBean к сессионному компоненту, она работает.Что за ...?

...