Examples of net.jini.jeri.ServerEndpoint

net.jini.jeri.ServerEndpoint
Represents one or more communication endpoints on the current (local) host to listen for and receive requests on and a template for producing an Endpoint instance to send requests to those communication endpoints.
A ServerEndpoint instance contains the information necessary to listen for requests on the communication endpoints and to produce Endpoint instances. For example, a TCP-based ServerEndpoint implementation typically contains the TCP port to listen on and the host address to put in the Endpoint instances it produces. An implementation that supports authentication typically contains the {@link Subject}(if any) to use for server authentication.
The {@link #enumerateListenEndpoints enumerateListenEndpoints}method can be invoked to
- discover each of the discrete communication endpoints represented by this ServerEndpoint, which are individually represented as {@link ListenEndpoint ListenEndpoint}instances,
- ensure an active listen operation (see {@link ListenEndpoint#listen ListenEndpoint.listen}) on each discrete communication endpoint by choosing, for each endpoint, either to start a new listen operation or to use an existing one, and
- obtain an Endpoint instance that corresponds to the chosen listen operations
The obtained Endpoint instance can then be used to send requests to the communication endpoints being listened on as a result of that {@link #enumerateListenEndpoints enumerateListenEndpoints} invocation.
Typically, a ServerEndpoint is just used to specify the transport layer implementation to use when exporting a remote object; for example, some constructors of {@link BasicJeriExporter BasicJeriExporter} have a ServerEndpoint parameter tospecify the transport layer implementation. The exporter implementation is then responsible for using the supplied ServerEndpoint to manage listen operations as necessary and to obtain an Endpoint instance for putting in the client-side proxy.
All aspects of the underlying communication mechanism that are not specified here are defined by the particular implementation of this interface. @author Sun Microsystems, Inc. @since 2.0

               = new LookupDiscoveryManager(DiscoveryGroupManagement.NO_GROUPS,
                                            new LookupLocator[0], null,config);
        }


        /* Handle items and duties related to exporting this service. */
        ServerEndpoint endpoint = TcpServerEndpoint.getInstance(0);
        InvocationLayerFactory ilFactory = new BasicILFactory();
        Exporter defaultExporter = new BasicJeriExporter(endpoint,
                                                         ilFactory,
                                                         false,
                                                         true);

View Full Code Here

    }


    private static Ping export(String host, int port, Ping impl)
  throws ExportException, UnsupportedConstraintException
    {
  ServerEndpoint se = getServerEndpoint(host, port, new SF(), null);
  InvocationLayerFactory ilf =
      new BasicILFactory(null, null, PingImpl.class.getClassLoader());
  Exporter exporter = new BasicJeriExporter(se, ilf, false, false);
  return (Ping) exporter.export(impl);
    }

View Full Code Here

      }
  }
    }


    public static void main(String[] args) throws Exception {
  ServerEndpoint sep = TcpServerEndpoint.getInstance(0);
  Endpoint ep = sep.enumerateListenEndpoints(new ListenContext() {
      public ListenCookie addListenEndpoint(ListenEndpoint lep)
    throws IOException
      {
    return lep.listen(new Dispatcher()).getCookie();
      }

View Full Code Here

  throws UnsupportedConstraintException
    {
  if (constraints == null) {
      constraints = InvocationConstraints.EMPTY;
  }
  ServerEndpoint ep = getServerEndpoint(null);
  checkIntegrity(ep.checkConstraints(constraints));
    }

View Full Code Here

      throw new NullPointerException();
  }
  if (constraints == null) {
      constraints = InvocationConstraints.EMPTY;
  }
  ServerEndpoint ep = 
      getServerEndpoint(new PrearrangedServerSocketFactory(socket));
  ServerConnManagerImpl mgr = new ServerConnManagerImpl();
  endpointInternals.setServerConnManager(ep, mgr);


  ListenContextImpl lc = new ListenContextImpl();
  ep.enumerateListenEndpoints(lc);
  ServerConnection conn = mgr.getServerConnection();
  try {
      InputStream in = new BufferedInputStream(conn.getInputStream());
      OutputStream out = new BufferedOutputStream(conn.getOutputStream());
      InboundRequestHandle handle = conn.processRequestData(in, out);

View Full Code Here

  
  ActivationGroupID[] gids = (ActivationGroupID[])
      groupTable.keySet().toArray(
            new ActivationGroupID[groupTable.size()]);
  activator = new ActivatorImpl();
  ServerEndpoint se = TcpServerEndpoint.getInstance(PHOENIX_PORT);
  activatorExporter =
      getExporter(config, "activatorExporter",
      new BasicJeriExporter(se, new BasicILFactory(),
                false, true,
               PhoenixConstants.ACTIVATOR_UUID));

View Full Code Here

  if (System.getSecurityManager() == null) {
      System.setSecurityManager(new SecurityManager());
  }


  SSF ssf = new SSF();
  ServerEndpoint se = getServerEndpoint(ssf);
  ListenContext lc = new ListenContext() {
      public ListenCookie addListenEndpoint(ListenEndpoint le)
    throws IOException
      {
    return le.listen(new RequestDispatcher() {
        public void dispatch(InboundRequest r) { }
    }).getCookie();
      }
  };
  se.enumerateListenEndpoints(lc);


  synchronized (ssf) {
      long now, deadline = 0;
      while (!ssf.serverSocketClosed) {
    now = System.currentTimeMillis();

View Full Code Here

      public ServerSocket createServerSocket() throws IOException {
    return useNIO ? ServerSocketChannel.open().socket()
            : new ServerSocket();
      }
  };
  ServerEndpoint se =
      TcpServerEndpoint.getInstance(null, 0, sf, ssf);
  InvocationLayerFactory ilf =
      new BasicILFactory(null, null, PingImpl.class.getClassLoader());
  Exporter exporter = new BasicJeriExporter(se, ilf, false, false);
  Ping proxy = (Ping) exporter.export(impl);

View Full Code Here

    private static boolean testedInboundRequest = false;
    private static RuntimeException inboundRequestFailure = null;


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


  ServerEndpoint serverEndpoint = TcpServerEndpoint.getInstance(0);
  System.err.println("obtained server endpoint: " + serverEndpoint);


  String method = "ServerCapabilities.checkConstraints";
  System.err.println("\nTesting " + method + ":");
  for (Iterator i = testCases.entrySet().iterator(); i.hasNext();) {
      Map.Entry entry = (Map.Entry) i.next();
      InvocationConstraints c = (InvocationConstraints) entry.getKey();
      System.err.println("  trying: " + c);
      InvocationConstraints u = serverEndpoint.checkConstraints(c);
      System.err.println("returned: " + u);
      if (!entry.getValue().equals(u)) {
    throw new RuntimeException(
        "TEST FAILED: incorrect constraints returned by " +
        method);
      }
  }


  Endpoint endpoint =
      serverEndpoint.enumerateListenEndpoints(new ListenContext() {
    public ListenCookie addListenEndpoint(ListenEndpoint le)
        throws IOException
    {
        return le.listen(new RD()).getCookie();
    }

View Full Code Here

  ServerSocketFactory ssf = new AbstractServerSocketFactory() {
      public ServerSocket createServerSocket() throws IOException {
    return new ServerSocket();
      }
  };
  ServerEndpoint se =
      TcpServerEndpoint.getInstance("localhost", 0, sf, ssf);
  InvocationLayerFactory ilf =
      new BasicILFactory(null, null, PingImpl.class.getClassLoader());
  Exporter exporter = new BasicJeriExporter(se, ilf, false, false);
  Ping proxy = (Ping) exporter.export(impl);

View Full Code Here

0 1 2 3

TOP

Related Classes of net.jini.jeri.ServerEndpoint

com.sun.jini.discovery.internal.EndpointBasedServer

com.sun.jini.fiddler.FiddlerImpl

com.sun.jini.phoenix.Activation

com.sun.jini.test.impl.end2end.e2etest.ProviderManager

com.sun.jini.test.impl.joinmanager.LeaseRenewDurRFE$RemoteTestServiceImpl

com.sun.jini.test.spec.jeri.basicjeriexporter.ConstructorTest

com.sun.jini.test.spec.jeri.basicjeriexporter.ExportExceptionTest_SameIDSameSE

com.sun.jini.test.spec.jeri.mux.MuxServerTest

com.sun.jini.test.spec.jeri.mux.ServerAbortTest

com.sun.jini.test.spec.jeri.mux.ServerFlowControlTest

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.