6 Replies Latest reply on Apr 5, 2018 7:41 AM by mayerw01

EJB Remote Call

marcusdidiusfalco Apr 5, 2018 2:25 AM

Hello,

I am trying to call an EJB from a remote client.

JBoss EAP 7.1

@Remote
public interface CustomerDAO extends AbstractDAO<Long, Customer> {
    
    public int deleteAll();
    public List<Customer> findAll();

}

@Stateless
public class CustomerDAOBean extends AbstractDAOBean<Long, Customer> implements CustomerDAO {

    @Override
    public int deleteAll() {
        List<Customer> customers = null;
        TypedQuery<Customer> query = em.createNamedQuery(Customer.FIND_ALL, Customer.class);
        customers = query.getResultList();
        int num = customers.size();
        customers.forEach(em::remove);
        return num;
    }

    @Override
    public List<Customer> findAll() {
        TypedQuery<Customer> query = em.createNamedQuery(Customer.FIND_ALL, Customer.class);
        return query.getResultList();
    }

}

java:global/kundenverwaltung-ear/kundenverwaltung-ejb/MemberRegistration!de.rupp.service.MemberRegistration

java:app/kundenverwaltung-ejb/MemberRegistration!de.rupp.service.MemberRegistration

java:module/MemberRegistration!de.rupp.service.MemberRegistration

java:global/kundenverwaltung-ear/kundenverwaltung-ejb/MemberRegistration

java:app/kundenverwaltung-ejb/MemberRegistration

java:module/MemberRegistration

Client:

public class CustomerTest {
    
    private CustomerDAO customerDAO;
    
    @Before
    public void init() throws Exception {
        try {
            final Hashtable<String, Comparable> jndiProperties =
                    new Hashtable<>();
            jndiProperties.put(Context.INITIAL_CONTEXT_FACTORY,
                    "org.wildfly.naming.client.WildFlyInitialContextFactory");
            jndiProperties.put("jboss.naming.client.ejb.context", true);
            
            jndiProperties.put(Context.PROVIDER_URL, "http-remoting://localhost:8080");
            jndiProperties.put(Context.SECURITY_PRINCIPAL, "adminr");
            jndiProperties.put(Context.SECURITY_CREDENTIALS, "jboss_123");
            
            final Context context = new InitialContext(jndiProperties);
            
            final String lookupName = "ejb:/kundenverwaltung-ear/kundenverwaltung-ejb/CustomerDAOBean!de.rupp.persistence.CustomerDAO";
            
            this.customerDAO = (CustomerDAO) context.lookup(lookupName);
            
        } catch (Exception ex) {
            ex.printStackTrace();
            throw ex;
        }
    }
    
    
    @Test
    public void test() {
        assertNotNull(customerDAO);
    }
    
    @Test
    public void testInsert() {
        Customer customer = new Customer();
        customer.setFirstName("Hein");
        customer.setLastName("Blöd");
        this.customerDAO.save(customer);
        List<Customer> customers = this.customerDAO.findAll();
        assertTrue(customers.size() > 0);
    }

}

I have added the user with the option to allow remote access.

test() succeeds

testInsert() fails with

org.jboss.ejb.client.RequestSendFailedException: EJBCLIENT000409: No more destinations are available

at org.jboss.ejb.client.EJBClientInvocationContext.getResult(EJBClientInvocationContext.java:567)

at org.jboss.ejb.client.EJBClientInvocationContext.getResult(EJBClientInvocationContext.java:503)

at org.jboss.ejb.protocol.remote.RemotingEJBClientInterceptor.handleInvocationResult(RemotingEJBClientInterceptor.java:56)

at org.jboss.ejb.client.EJBClientInvocationContext.getResult(EJBClientInvocationContext.java:569)

at org.jboss.ejb.client.EJBClientInvocationContext.getResult(EJBClientInvocationContext.java:503)

at org.jboss.ejb.client.TransactionPostDiscoveryInterceptor.handleInvocationResult(TransactionPostDiscoveryInterceptor.java:133)

at org.jboss.ejb.client.EJBClientInvocationContext.getResult(EJBClientInvocationContext.java:569)

at org.jboss.ejb.client.EJBClientInvocationContext.getResult(EJBClientInvocationContext.java:503)

at org.jboss.ejb.client.DiscoveryEJBClientInterceptor.handleInvocationResult(DiscoveryEJBClientInterceptor.java:108)

at org.jboss.ejb.client.EJBClientInvocationContext.getResult(EJBClientInvocationContext.java:569)

at org.jboss.ejb.client.EJBClientInvocationContext.getResult(EJBClientInvocationContext.java:503)

at org.jboss.ejb.client.NamingEJBClientInterceptor.handleInvocationResult(NamingEJBClientInterceptor.java:78)

at org.jboss.ejb.client.EJBClientInvocationContext.getResult(EJBClientInvocationContext.java:569)

at org.jboss.ejb.client.EJBClientInvocationContext.getResult(EJBClientInvocationContext.java:503)

at org.jboss.ejb.client.TransactionInterceptor.handleInvocationResult(TransactionInterceptor.java:172)

at org.jboss.ejb.client.EJBClientInvocationContext.getResult(EJBClientInvocationContext.java:569)

at org.jboss.ejb.client.EJBClientInvocationContext.getResult(EJBClientInvocationContext.java:503)

at org.jboss.ejb.client.EJBClientInvocationContext.awaitResponse(EJBClientInvocationContext.java:913)

at org.jboss.ejb.client.EJBInvocationHandler.invoke(EJBInvocationHandler.java:177)

at org.jboss.ejb.client.EJBInvocationHandler.invoke(EJBInvocationHandler.java:112)

at com.sun.proxy.$Proxy6.save(Unknown Source)

at test.CustomerTest.testInsert(CustomerTest.java:60)

at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

at java.lang.reflect.Method.invoke(Method.java:498)

at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)

at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)

at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)

at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)

at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)

at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)

at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)

at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)

at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)

at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)

at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)

at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)

at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)

at org.junit.runners.ParentRunner.run(ParentRunner.java:363)

at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)

at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)

at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:538)

at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:760)

at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:460)

at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:206)

Suppressed: org.jboss.ejb.client.RequestSendFailedException: org.jboss.remoting3.ServiceOpenException: Unknown service name@http-remoting://localhost:8080

at org.jboss.ejb.protocol.remote.RemoteEJBReceiver$1.lambda$handleDone$0(RemoteEJBReceiver.java:83)

at org.xnio.AbstractIoFuture$NotifierRunnable.run(AbstractIoFuture.java:720)

at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)

at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)

at java.lang.Thread.run(Thread.java:745)