package org.superbiz.telephone;

import javax.ejb.Remote;
import javax.ejb.Stateful;
import java.util.ArrayList;
import java.util.List;

@Remote
@Stateful
public class TelephoneBean implements Telephone {

    private static final String[] answers = {
            "How nice.",
            "Oh, of course.",
            "Interesting.",
            "Really?",
            "No.",
            "Definitely.",
            "I wondered about that.",
            "Good idea.",
            "You don't say!",
    };

    private List<String> conversation = new ArrayList<String>();

    public void speak(String words) {
        conversation.add(words);
    }

    public String listen() {
        if (conversation.size() == 0) {
            return "Nothing has been said";
        }

        String lastThingSaid = conversation.get(conversation.size() - 1);
        return answers[Math.abs(lastThingSaid.hashCode()) % answers.length];
    }
}

package org.superbiz.telephone;

public interface Telephone {

    void speak(String words);

    String listen();
}

protected void setUp() throws Exception {
    Properties properties = new Properties();
    properties.setProperty(Context.INITIAL_CONTEXT_FACTORY, "org.apache.openejb.client.LocalInitialContextFactory");
    properties.setProperty("openejb.embedded.remotable", "true");
    // Uncomment these properties to change the defaults
    //properties.setProperty("ejbd.port", "4202");
    //properties.setProperty("ejbd.bind", "localhost");
    //properties.setProperty("ejbd.threads", "200");
    //properties.setProperty("ejbd.disabled", "false");
    //properties.setProperty("ejbd.only_from", "127.0.0.1,192.168.1.1");

    new InitialContext(properties);
}

public void testTalkOverLocalNetwork() throws Exception {

    Properties properties = new Properties();
    properties.setProperty(Context.INITIAL_CONTEXT_FACTORY, "org.apache.openejb.client.LocalInitialContextFactory");
    InitialContext localContext = new InitialContext(properties);

    Telephone telephone = (Telephone) localContext.lookup("TelephoneBeanRemote");

    telephone.speak("Did you know I am talking directly through the embedded container?");

    assertEquals("Interesting.", telephone.listen());


    telephone.speak("Yep, I'm using the bean's remote interface but since the ejb container is embedded " +
            "in the same vm I'm just using the LocalInitialContextFactory.");

    assertEquals("Really?", telephone.listen());


    telephone.speak("Right, you really only have to use the RemoteInitialContextFactory if you're in a different vm.");

    assertEquals("Oh, of course.", telephone.listen());
}

public void testTalkOverRemoteNetwork() throws Exception {
    Properties properties = new Properties();
    properties.setProperty(Context.INITIAL_CONTEXT_FACTORY, "org.apache.openejb.client.RemoteInitialContextFactory");
    properties.setProperty(Context.PROVIDER_URL, "ejbd://localhost:4201");
    InitialContext remoteContext = new InitialContext(properties);

    Telephone telephone = (Telephone) remoteContext.lookup("TelephoneBeanRemote");

    telephone.speak("Is this a local call?");

    assertEquals("No.", telephone.listen());


    telephone.speak("This would be a lot cooler if I was connecting from another VM then, huh?");

    assertEquals("I wondered about that.", telephone.listen());


    telephone.speak("I suppose I should hangup and call back over the LocalInitialContextFactory.");

    assertEquals("Good idea.", telephone.listen());


    telephone.speak("I'll remember this though in case I ever have to call you accross a network.");

    assertEquals("Definitely.", telephone.listen());
}

<dependency>
  <groupId>org.apache.openejb</groupId>
  <artifactId>openejb-ejbd</artifactId>
  <version>3.1.2-SNAPSHOT</version>
  <scope>test</scope>
</dependency>