Examples of com.sun.sgs.impl.service.session.ClientSessionServiceImpl$ContextFactory

Package com.sun.sgs.impl.service.session

Examples of com.sun.sgs.impl.service.session.ClientSessionServiceImpl$ContextFactory

com.sun.sgs.impl.service.session.ClientSessionServiceImpl
Manages client sessions.
The {@link #ClientSessionServiceImpl constructor} requires the com.sun.sgs.app.name configuration property and supports these public configuration properties. It also supports the following additional properties:

Property: {@value #SERVER_PORT_PROPERTY}
Default: {@value #DEFAULT_SERVER_PORT}
Specifies the port for the ClientSessionService's internal server.

Property: {@value #WRITE_BUFFER_SIZE_PROPERTY}
Default: {@value #DEFAULT_WRITE_BUFFER_SIZE}
Specifies the approximate write buffer capacity per client session.

Property: {@value #EVENTS_PER_TXN_PROPERTY}
Default: {@value #DEFAULT_EVENTS_PER_TXN}
Specifies the number of client session events to process per transaction.

Property: {@value #ALLOW_NEW_LOGIN_PROPERTY}
Default: {@code false}
If {@code false}, any connecting client with the same username as an already connected client will not be permitted to login. If {@code true}, the user's existing session will be disconnected and the new login is allowed to proceed.

Property: {@value #PROTOCOL_ACCEPTOR_PROPERTY}
Default: {@value #DEFAULT_PROTOCOL_ACCEPTOR}
Specifies the name of the class which will be used as the protocol acceptor. The default value uses an acceptor based on the {@link SimpleSgsProtocol}. Other values should specify the fully qualified name of a non-abstract class that implements {@link ProtocolAcceptor}.

    {
        final ContextFactoryMapper contextFactoryMapper = ContextFactoryMapper.getFactory() ;
        try
        {
            final String coordinationType = createCoordinationContext.getCoordinationType() ;
            final ContextFactory contextFactory = contextFactoryMapper.getContextFactory(coordinationType) ;
            
            if (contextFactory != null)
            {
                final CoordinationContext coordinationContext ;
                try
                {
                    final Expires expiresElement = createCoordinationContext.getExpires() ;
                    final Long expires = (expiresElement == null ? null : new Long(expiresElement.getValue())) ;
                    
                    coordinationContext = contextFactory.create(coordinationType, expires, createCoordinationContext.getCurrentContext(), isSecure) ;
                    final CreateCoordinationContextResponseType response = new CreateCoordinationContextResponseType() ;
                    response.setCoordinationContext(coordinationContext) ;
                    return response;
                }
                catch (final InvalidCreateParametersException invalidCreateParametersException)

View Full Code Here


  public void removeContextFactory (String coordinationTypeURI)
  {
    try
    {
      ContextFactory contextFactory = (ContextFactory) _protocols.removeProtocol(convert(coordinationTypeURI));


      contextFactory.uninstall(coordinationTypeURI);
    }
    catch (Exception ex)
    {
      ex.printStackTrace();
    }

View Full Code Here


                if (type instanceof String)
                {
                    Class c = Class.forName((String) type);


                    ContextFactory factory = (ContextFactory) c.newInstance();


                    _protocols.replaceProtocol(doc, factory);


                    return factory;
                }

View Full Code Here

    {
        final ContextFactoryMapper contextFactoryMapper = ContextFactoryMapper.getFactory() ;
        try
        {
            final String coordinationType = createCoordinationContext.getCoordinationType() ;
            final ContextFactory contextFactory = contextFactoryMapper.getContextFactory(coordinationType) ;
            
            if (contextFactory != null)
            {
                final CoordinationContext coordinationContext ;
                try
                {
                    final Expires expiresElement = createCoordinationContext.getExpires() ;
                    final Long expires = (expiresElement == null ? null : new Long(expiresElement.getValue())) ;
                    
                    coordinationContext = contextFactory.create(coordinationType, expires, createCoordinationContext.getCurrentContext(), isSecure) ;
                    final CreateCoordinationContextResponseType response = new CreateCoordinationContextResponseType() ;
                    response.setCoordinationContext(coordinationContext) ;
                    return response;
                }
                catch (final InvalidCreateParametersException invalidCreateParametersException)

View Full Code Here

    // -- Test constructor --


    @Test
    public void testConstructorNullProperties() throws Exception {
  try {
      new ClientSessionServiceImpl(
    null, serverNode.getSystemRegistry(),
    serverNode.getProxy());
      fail("Expected NullPointerException");
  } catch (NullPointerException e) {
      System.err.println(e);

View Full Code Here

    }


    @Test
    public void testConstructorNullComponentRegistry() throws Exception {
  try {
      new ClientSessionServiceImpl(serviceProps, null,
           serverNode.getProxy());
      fail("Expected NullPointerException");
  } catch (NullPointerException e) {
      System.err.println(e);
  }

View Full Code Here

    }


    @Test
    public void testConstructorNullTransactionProxy() throws Exception {
  try {
      new ClientSessionServiceImpl(serviceProps,
           serverNode.getSystemRegistry(), null);
      fail("Expected NullPointerException");
  } catch (NullPointerException e) {
      System.err.println(e);
  }

View Full Code Here

    }


    @Test
    public void testConstructorNoAppName() throws Exception {
  try {
      new ClientSessionServiceImpl(
    new Properties(), serverNode.getSystemRegistry(),
    serverNode.getProxy());
      fail("Expected IllegalArgumentException");
  } catch (IllegalArgumentException e) {
      System.err.println(e);

View Full Code Here


    @Test
    public void testConstructorNoPort() throws Exception {
        Properties props =
            createProperties(StandardProperties.APP_NAME, APP_NAME);
        new ClientSessionServiceImpl(
            props, serverNode.getSystemRegistry(),
            serverNode.getProxy());
    }

View Full Code Here

  try {
      Properties props =
    createProperties(
        StandardProperties.APP_NAME, APP_NAME,
                    SimpleSgsProtocolAcceptor.DISCONNECT_DELAY_PROPERTY, "199");
      new ClientSessionServiceImpl(
    props, serverNode.getSystemRegistry(),
    serverNode.getProxy());
      fail("Expected IllegalArgumentException");
  } catch (IllegalArgumentException e) {
      System.err.println(e);

View Full Code Here

0 1 2 3

TOP

Related Classes of com.sun.sgs.impl.service.session.ClientSessionServiceImpl$ContextFactory

com.arjuna.mwlabs.wsc11.ContextFactoryMapperImple

com.arjuna.wsc11.messaging.ActivationCoordinatorProcessorImpl

com.sun.istack.FinalArrayList

com.sun.sgs.app.Delivery

com.sun.sgs.app.util.ManagedSerializable

com.sun.sgs.auth.Identity

com.sun.sgs.impl.kernel.ConfigManager

com.sun.sgs.impl.service.session.ClientSessionHandler.SetupCompletionFuture

com.sun.sgs.impl.service.session.ClientSessionImpl.HandleNextDisconnectedSessionTask

com.sun.sgs.impl.sharedutil.PropertiesWrapper

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.