2 Replies Latest reply on Apr 9, 2013 1:21 PM by Sam D.

    (EJB Client Context) Multi-user  EJB invocation

    Sam D. Newbie

      Hi,

      I am trying to connect 2 users from my multi-threaded EJB client application using the JBoss 7 recommended solution for invoking ejb methods (https://docs.jboss.org/author/display/AS71/EJB+invocations+from+a+remote+client+using+JNDI).

      Each user will create a ContextSelector, then he calls  EJBClientContext.setSelector with the newly created context as argument. Finally he lookups a remote service to call a business method.

      The problem occurs in a multithreaded context : the last user calling EJBClientContext.setSelector will appear as the principal caller for all other calls.

      Any help on this issue would be very appreciated.


      Following I provide you my client code and EJB code.

      • Here is my client:

          private static ContextSelector<EJBClientContext> createContextSelector(String userName, String password){

              Properties clientProps = new Properties();

              clientProps.put("remote.connectionprovider.create.options.org.xnio.Options.SSL_ENABLED", "false");

              clientProps.put("remote.connections", "default");

              clientProps.put("remote.connection.default.host", "localhost");

              clientProps.put("remote.connection.default.port", "4447");

              clientProps.put("remote.connection.default.connect.options.org.xnio.Options.SASL_POLICY_NOANONYMOUS", "false");

              clientProps.put("remote.connection.default.username", userName);

              clientProps.put("remote.connection.default.password", password);

              clientProps.put("remote.connection.default.connect.options.org.xnio.Options.SASL_DISALLOWED_MECHANISMS", "JBOSS-LOCAL-USER");

              EJBClientConfiguration ecc = new PropertiesBasedEJBClientConfiguration(clientProps);

              ContextSelector<EJBClientContext> selector = new ConfigBasedEJBClientContextSelector(ecc);

              return selector;

          }

          public static void main(String[] args) throws InterruptedException {

       

              final String beanName = "ejb:/com.howto.jboss.examples//SecureBean!com.howto.jboss.examples.SecureBeanRemote";

                      //User1 thread

              new Thread(new Runnable() {

       

                  public void run() {

                      try {

                          final ContextSelector<EJBClientContext> userContext = createContextSelector("user1", "password");

                          EJBClientContext.setSelector(userContext);

                          Properties props = new Properties();

                          props.put(Context.URL_PKG_PREFIXES, "org.jboss.ejb.client.naming");

                          Context context = new InitialContext(props);

                          SecureBeanRemote remoteService = (SecureBeanRemote) context.lookup(beanName);

                          String caller = remoteService.getCaller();

                          System.out.println("user1 context: " + caller);

                      } catch (Exception e) {

                          e.printStackTrace();

                      }

                  }

              }).start();

                      //User2 thread

              new Thread(new Runnable() {

       

                  public void run() {

                      try {

                          final ContextSelector<EJBClientContext> userContext = createContextSelector("user2", "password");

                          EJBClientContext.setSelector(userContext);

                          Properties props = new Properties();

                          props.put(Context.URL_PKG_PREFIXES, "org.jboss.ejb.client.naming");

                          Context context = new InitialContext(props);

                          SecureBeanRemote remoteService = (SecureBeanRemote) context.lookup(beanName);

                          String caller = remoteService.getCaller();

                          System.out.println("user2 context: " + caller);

                      } catch (Exception e) {

                          e.printStackTrace();

                      }

                  }

              }).start();

       

          }

           

      • My EJB is only returing caller principal name:

      @Stateless(mappedName = "SecureBean")

      @SecurityDomain("other")

      public class SecureBean implements SecureBeanRemote {

          @Resource

          private SessionContext sessionContext;

       

          public SecureBean() {

          }

          

          @PermitAll

          @Override

          public String getCaller() {

              return sessionContext.getCallerPrincipal().getName();

          }

      }