Skip to content
Permalink
Browse files

[JBQA-5855] Ejb cluster tests - remote call

  • Loading branch information...
ochaloup committed Feb 22, 2012
1 parent f18e852 commit a5a5405894080dc01925a7d47640ae60d76972ea
@@ -0,0 +1,182 @@
/*
* JBoss, Home of Professional Open Source.
* Copyright 2012, Red Hat Middleware LLC, and individual contributors
* as indicated by the @author tags. See the copyright.txt file in the
* distribution for a full listing of individual contributors.
*
* This is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This software is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this software; if not, write to the Free
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
*/

package org.jboss.as.test.multinode.remotecall;

import javax.naming.InitialContext;

import org.jboss.arquillian.container.test.api.Deployment;
import org.jboss.arquillian.container.test.api.OperateOnDeployment;
import org.jboss.arquillian.container.test.api.TargetsContainer;
import org.jboss.arquillian.junit.Arquillian;
import org.jboss.arquillian.test.api.ArquillianResource;
import org.jboss.logging.Logger;
import org.jboss.shrinkwrap.api.Archive;
import org.jboss.shrinkwrap.api.ShrinkWrap;
import org.jboss.shrinkwrap.api.spec.JavaArchive;
import org.junit.Assert;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.runner.RunWith;

/**
* @author William DeCoste, Ondrej Chaloupka
*/
@RunWith(Arquillian.class)
public class RemoteLocalCallTestCase {
private static final Logger log = Logger.getLogger(RemoteLocalCallTestCase.class);
public static final String ARCHIVE_NAME = "remotelocalcall-test";

@BeforeClass
public static void printSysProps() {
log.info("System properties:\n" + System.getProperties());
}

@Deployment(name = "server")
@TargetsContainer("multinode-server")
public static Archive<?> deployment0() {
JavaArchive jar = createJar();
return jar;
}

@Deployment(name = "client")
@TargetsContainer("multinode-client")
public static Archive<?> deployment1() {
JavaArchive jar = createJar();
jar.addAsManifestResource("META-INF/jboss-ejb-client.xml", "jboss-ejb-client.xml");
return jar;
}

private static JavaArchive createJar() {
JavaArchive jar = ShrinkWrap.create(JavaArchive.class, ARCHIVE_NAME + ".jar");
jar.addPackage(RemoteLocalCallTestCase.class.getPackage());
return jar;
}

//@Test
@OperateOnDeployment("client")
public void testStatelessLocalFromRemote(@ArquillianResource InitialContext ctx) throws Exception {
StatefulRemote bean = (StatefulRemote) ctx.lookup("java:module/" + StatefulBean.class.getSimpleName() + "!"
+ StatefulRemote.class.getName());
Assert.assertNotNull(bean);

try {
bean.localCall();
Assert.fail("should not be allowed to call local interface remotely");
} catch (javax.ejb.EJBException e) {
}
}

//@Test
@OperateOnDeployment("client")
public void testStatelessLocalHomeFromRemoteHome(@ArquillianResource InitialContext ctx) throws Exception {
StatefulRemoteHome home = (StatefulRemoteHome) ctx.lookup("java:module/" + StatefulBean.class.getSimpleName() + "!"
+ StatefulRemoteHome.class.getName());
StatefulRemote bean = home.create();
Assert.assertNotNull(bean);

try {
bean.localHomeCall();
Assert.fail("should not be allowed to call local interface remotely");
} catch (javax.ejb.EJBException e) {
}
}

//@Test
@OperateOnDeployment("client")
public void testStatelessRemoteFromRemote(@ArquillianResource InitialContext ctx) throws Exception {
StatefulRemote bean = (StatefulRemote) ctx.lookup("java:module/" + StatefulBean.class.getSimpleName() + "!"
+ StatefulRemote.class.getName());
Assert.assertNotNull(bean);

int methodCount = bean.remoteCall();
Assert.assertEquals(1, methodCount);
}

@Test
@OperateOnDeployment("client")
public void testStatelessRemoteHomeFromRemoteHome(@ArquillianResource InitialContext ctx) throws Exception {
StatefulRemoteHome home = (StatefulRemoteHome) ctx.lookup("java:module/" + StatefulBean.class.getSimpleName() + "!"
+ StatefulRemoteHome.class.getName());
StatefulRemote bean = home.create();
Assert.assertNotNull(bean);

int methodCount = bean.remoteHomeCall();
Assert.assertEquals(1, methodCount);
}

//@Test
@OperateOnDeployment("client")
public void testStatefulRemoteFromRemote(@ArquillianResource InitialContext ctx) throws Exception {
StatelessRemote bean = (StatelessRemote) ctx.lookup("java:module/" + StatelessBean.class.getSimpleName() + "!"
+ StatelessRemote.class.getName());
Assert.assertNotNull(bean);

int methodCount = bean.remoteCall();
Assert.assertEquals(1, methodCount);
}

//@Test
@OperateOnDeployment("client")
public void testStatefulRemoteHomeFromRemoteHome(@ArquillianResource InitialContext ctx) throws Exception {
StatelessRemoteHome home = (StatelessRemoteHome) ctx.lookup("java:module/" + StatelessBean.class.getSimpleName() + "!"
+ StatelessRemoteHome.class.getName());
StatelessRemote bean = home.create();
Assert.assertNotNull(bean);

int methodCount = bean.remoteHomeCall();
Assert.assertEquals(1, methodCount);
}

//@Test
@OperateOnDeployment("client")
public void testStatefulLocalFromRemote(@ArquillianResource InitialContext ctx) throws Exception {
InitialContext jndiContext = new InitialContext();
StatelessRemote bean = (StatelessRemote) jndiContext.lookup("java:module/" + StatelessBean.class.getSimpleName() + "!"
+ StatelessRemote.class.getName());
Assert.assertNotNull(bean);

try {
bean.localCall();
Assert.fail("should not be allowed to call local interface remotely");
} catch (javax.naming.NamingException e) {
if (e.getCause() == null || !(e.getCause() instanceof javax.ejb.EJBException))
Assert.fail("should not be allowed to call local interface remotely");
}
}

//@Test
@OperateOnDeployment("client")
public void testStatefulLocalHomeFromRemoteHome(@ArquillianResource InitialContext ctx) throws Exception {
InitialContext jndiContext = new InitialContext();
StatelessRemoteHome home = (StatelessRemoteHome) jndiContext.lookup("java:module/"
+ StatelessBean.class.getSimpleName() + "!" + StatelessRemoteHome.class.getName());
StatelessRemote bean = home.create();
Assert.assertNotNull(bean);

try {
bean.localHomeCall();
Assert.fail("should not be allowed to call local interface remotely");
} catch (javax.ejb.EJBException e) {
}
}
}
@@ -0,0 +1,118 @@
/*
* JBoss, Home of Professional Open Source.
* Copyright 2012, Red Hat Middleware LLC, and individual contributors
* as indicated by the @author tags. See the copyright.txt file in the
* distribution for a full listing of individual contributors.
*
* This is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This software is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this software; if not, write to the Free
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
*/

package org.jboss.as.test.multinode.remotecall;

import java.util.Properties;

import javax.annotation.Resource;
import javax.ejb.Local;
import javax.ejb.LocalHome;
import javax.ejb.Remote;
import javax.ejb.RemoteHome;
import javax.ejb.SessionContext;
import javax.ejb.Stateful;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import org.jboss.logging.Logger;

/**
* @author <a href="mailto:bdecoste@jboss.com">William DeCoste</a>
*/
@Stateful
@Local(StatefulLocal.class)
@LocalHome(StatefulLocalHome.class)
@Remote(StatefulRemote.class)
@RemoteHome(StatefulRemoteHome.class)
public class StatefulBean {
private static final Logger log = Logger.getLogger(StatefulBean.class);

@Resource
SessionContext sessionContext;

private static int methodCount = 0;
private static int homeMethodCount = 0;

private InitialContext getInitialContext() throws NamingException {
final Properties props = new Properties();
// setup the ejb: namespace URL factory
props.put(Context.URL_PKG_PREFIXES, "org.jboss.ejb.client.naming");
return new InitialContext(props);
}

public void localCall() throws Exception {
InitialContext jndiContext = getInitialContext();
log.info("*** calling Local remotely ... " + jndiContext.getEnvironment());
StatelessLocal stateless = (StatelessLocal) jndiContext.lookup("ejb:/" + RemoteLocalCallTestCase.ARCHIVE_NAME + "//" +
StatelessBean.class.getSimpleName() + "!" + StatelessLocal.class.getName());
stateless.method();
}

public void localHomeCall() throws Exception {
InitialContext jndiContext = getInitialContext();
log.info("*** calling LocalHome remotely ... " + jndiContext.getEnvironment());
StatelessLocalHome statelessHome = (StatelessLocalHome) jndiContext.lookup("ejb:/" + RemoteLocalCallTestCase.ARCHIVE_NAME + "//" +
StatelessBean.class.getSimpleName() + "!" + StatelessLocalHome.class.getName());
StatelessLocal stateless = statelessHome.create();
stateless.homeMethod();
}

public int remoteCall() throws Exception {
++methodCount;
InitialContext jndiContext = getInitialContext();
log.info("*** calling Remote ... " + jndiContext.getEnvironment());
StatefulRemote stateful = (StatefulRemote) jndiContext.lookup("ejb:/" + RemoteLocalCallTestCase.ARCHIVE_NAME + "//"
+ StatefulBean.class.getSimpleName() + "!" + StatefulRemote.class.getName());
return stateful.method();
}

public int remoteHomeCall() throws Exception {
++homeMethodCount;
InitialContext jndiContext = getInitialContext();
log.info("*** calling RemoteHome ... " + jndiContext.getEnvironment());
StatefulRemoteHome statefulHome = (StatefulRemoteHome) jndiContext.lookup("ejb:/" + RemoteLocalCallTestCase.ARCHIVE_NAME + "//"
+ StatefulBean.class.getSimpleName() + "!"
+ StatefulRemoteHome.class.getName());
StatefulRemote stateful = statefulHome.create();
return stateful.homeMethod();
}

public int method() throws Exception {
++methodCount;
log.info("*** method called " + methodCount);
return methodCount;
}

public int homeMethod() throws Exception {
log.info("Before adding ++ is homeMethodCount: " + homeMethodCount);
++homeMethodCount;
log.info("*** homeMethod called " + homeMethodCount);
return homeMethodCount;
}

public void ejbCreate() throws java.rmi.RemoteException, javax.ejb.CreateException {
log.debug("Creating method for home interface...");
}
}
@@ -0,0 +1,40 @@
/*
* JBoss, Home of Professional Open Source.
* Copyright 2012, Red Hat Middleware LLC, and individual contributors
* as indicated by the @author tags. See the copyright.txt file in the
* distribution for a full listing of individual contributors.
*
* This is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This software is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this software; if not, write to the Free
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
*/

package org.jboss.as.test.multinode.remotecall;

/**
* @author <a href="mailto:bdecoste@jboss.com">William DeCoste</a>
*/
public interface StatefulLocal extends javax.ejb.EJBLocalObject {
void localCall() throws Exception;

void localHomeCall() throws Exception;

int remoteCall() throws Exception;

int remoteHomeCall() throws Exception;

int method() throws Exception;

int homeMethod() throws Exception;
}
@@ -0,0 +1,31 @@
/*
* JBoss, Home of Professional Open Source.
* Copyright 2006, Red Hat Middleware LLC, and individual contributors
* as indicated by the @author tags. See the copyright.txt file in the
* distribution for a full listing of individual contributors.
*
* This is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This software is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this software; if not, write to the Free
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
*/
package org.jboss.as.test.multinode.remotecall;

import javax.ejb.*;

/**
* @author <a href="mailto:bdecoste@jboss.com">William DeCoste</a>
*/
public interface StatefulLocalHome extends EJBHome {
public StatefulLocal create() throws java.rmi.RemoteException, javax.ejb.CreateException;
}

0 comments on commit a5a5405

Please sign in to comment.
You can’t perform that action at this time.