[jboss-user] [Clustering/JBoss] - Partition name for clustered EJB3 SLSB
Hello
I'm using JBoss-4.0.4.GA and trying to set up clustered EJB3 SLSB for work in
dedicated partition. Annotated bean with explicit partition name works fine, failover and
load balancing take place. But I don't want to hardcode partition name into the bean
class...
Unfortunately @Clustered annotation doesn't allow partition name in
${jboss.partition.name:DefaultPartition} notation, so I switched to XML deployment
descriptor. But in this case bean's behaviour is not clustered regardless of using
explicit partition name or jboss.partition.name environment variable: requests execute on
one server and if this server goes down, client gets an exception.
Below is my test code:
| package test.cluster.intf;
| public interface Foo {
| int doSomething(int value);
| }
|
| package test.cluster.ejb;
| import org.apache.log4j.LogManager;
| import test.cluster.intf.Foo;
| public class FooBean implements Foo {
| public int doSomething(int value) {
| LogManager.getLogger(FooBean.class).info("iteration " + value);
| return 100;
| }
| }
|
| package test.cluster.client;
| import java.util.Properties;
| import javax.naming.Context;
| import javax.naming.InitialContext;
| import javax.naming.NamingException;
| import test.cluster.intf.Foo;
| public class Client {
| private Foo foo;
|
| private void connect() {
| Properties props = new Properties();
| props.put("java.naming.factory.initial",
"org.jboss.naming.NamingContextFactory");
| props.put("java.naming.factory.url.pkgs",
"org.jboss.naming:org.jnp.interfaces");
| props.put("java.naming.provider.url",
"localhost:1100,shamrock-a4:1100");
| props.put("jnp.partitionName", "ShamrockPartition");
| Context ctx = null;
| try {
| ctx = new InitialContext(props);
| foo = (Foo) ctx.lookup("Foo");
| } catch (NamingException e) {
| throw new RuntimeException("Unable to lookup bean", e);
| }
| }
| private void process() {
| assert foo != null;
| for (int i = 0; i < 10000; i++) {
| foo.doSomething(i);
| System.out.println("iteration " + i + " success");
| try {
| Thread.sleep((long) (Math.random() * 500));
| } catch (InterruptedException e) {
| throw new RuntimeException(e);
| }
| }
| }
| public static void main(String[] args) {
| Client client = new Client();
| client.connect();
| client.process();
| }
| }
|
| <?xml version="1.0" encoding="UTF-8"?>
| <ejb-jar
| xmlns="http://java.sun.com/xml/ns/javaee"
| xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
| xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
| http://java.sun.com/xml/ns/javaee/ejb-jar_3_0.xsd"
| version="3.0">
| <enterprise-beans>
| <session>
| <ejb-name>FooBean</ejb-name>
| <remote>test.cluster.intf.Foo</remote>
| <ejb-class>test.cluster.ejb.FooBean</ejb-class>
| <session-type>Stateless</session-type>
| </session>
| </enterprise-beans>
| </ejb-jar>
|
| <?xml version="1.0" encoding="UTF-8"?>
| <jboss xmlns="http://java.sun.com/xml/ns/javaee"
| xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
| xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
| http://www.jboss.org/j2ee/schema/jboss_5_0.xsd"
| version="3.0">
| <enterprise-beans>
| <session>
| <ejb-name>FooBean</ejb-name>
| <jndi-name>Foo</jndi-name>
| <clustered>true</clustered>
| <cluster-config>
|
<partition-name>${jboss.partition.name:DefaultPartition}</partition-name>
|
<load-balance-policy>org.jboss.ha.framework.interfaces.RandomRobin</load-balance-policy>
| </cluster-config>
| </session>
| </enterprise-beans>
| </jboss>
|
I start server with -Djboss.partition.name=ShamrockPartition
-Djboss.partition.udpGroup=228.1.2.4 environment variables.
What's wrong with my configuration?
Is there any other way to define cluster partition for annotated beans at deployment
time?
Thanks in advance.
Konstantin.
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=3974859#...
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&a...