Examples of org.serviceconnector.api.srv.SCPublishServer.register()

Class org.serviceconnector.api.srv.SCPublishServer

Examples of org.serviceconnector.api.srv.SCPublishServer.register()

org.serviceconnector.api.srv.SCPublishServer.register()
Register server on SC with default operation timeout. @param maxSessions the max sessions to serve @param maxConnections the max connections pool uses to connect to SC @param scCallback the SC callback @throws SCServiceException listener not started yet
server already registered for service
register server on SC failed
error message received from SC
@throws SCMPValidatorException callback is not set


        int maxSessions = 10;
        int maxConnections = 5;
        SCPublishServerCallback cbk = new SrvCallback(publishSrv);


        publishSrv.register(maxSessions, maxConnections, cbk);
      } catch (Exception e) {
        publishSrv.deregister();
        throw e;
      }
    } catch (Exception e) {

View Full Code Here

      SCPublishServer server = sc.newPublishServer(serviceName);
      int maxSess = 100;
      int maxConn = 10;
      SCPublishServerCallback cbk = newPublishSrvCallback(server);
      try {
        server.register(maxSess, maxConn, cbk); // regular
        // server.registerServer(10, maxSess, maxConn, cbk); //
        // alternative with operation timeout
      } catch (Exception e) {
        LOGGER.error("runSessionServer", e);
        server.deregister();

View Full Code Here

      String[] serviceNames = this.serviceNames.split(",");
      for (String serviceName : serviceNames) {
        SCPublishServer server = sc.newPublishServer(serviceName);
        SCPublishServerCallback cbk = new SrvCallback(server);
        try {
          server.register(10, this.maxSessions, this.maxConnections, cbk);
        } catch (Exception e) {
          LOGGER.error("runPublishServer", e);
          server.deregister();
        }
      }

View Full Code Here

  public void t198_register() throws Exception {
    server = new SCServer(TestConstants.HOST, TestConstants.PORT_SC0_TCP, TestConstants.PORT_PUB_SRV_TCP, ConnectionType.NETTY_TCP); 
    server.startListener();
    SCPublishServer publishServer1 = server.newPublishServer(TestConstants.pubServiceName1);
    SCPublishServerCallback cbk1 = new PubSrvCallback(publishServer1);
    publishServer1.register(1, 1, cbk1);
    Assert.assertEquals("SessionServer is not registered", true, publishServer1.isRegistered());
    
    SCPublishServer publishServer2 = server.newPublishServer(TestConstants.sesServiceName2);
    SCPublishServerCallback cbk2 = new PubSrvCallback(publishServer2);
    publishServer2.register(1, 1, cbk2);

View Full Code Here

    publishServer1.register(1, 1, cbk1);
    Assert.assertEquals("SessionServer is not registered", true, publishServer1.isRegistered());
    
    SCPublishServer publishServer2 = server.newPublishServer(TestConstants.sesServiceName2);
    SCPublishServerCallback cbk2 = new PubSrvCallback(publishServer2);
    publishServer2.register(1, 1, cbk2);
    Assert.assertEquals("SessionServer is not registered", true, publishServer2.isRegistered());
    
    publishServer1.deregister();
    publishServer2.deregister();
  }

View Full Code Here

  public void t199_register() throws Exception {
    server = new SCServer(TestConstants.HOST, TestConstants.PORT_SC0_TCP, TestConstants.PORT_PUB_SRV_TCP, ConnectionType.NETTY_TCP); 
    server.startListener();
    SCPublishServer publishServer1 = server.newPublishServer(TestConstants.pubServiceName1);
    SCPublishServerCallback cbk = new PubSrvCallback(publishServer1);
    publishServer1.register(1, 1, cbk);
    Assert.assertEquals("SessionServer is not registered", true, publishServer1.isRegistered());
    
    SCPublishServer publishServer2 = server.newPublishServer(TestConstants.sesServiceName2);
    publishServer2.register(1, 1, cbk);
    Assert.assertEquals("SessionServer is not registered", true, publishServer2.isRegistered());

View Full Code Here

    SCPublishServerCallback cbk = new PubSrvCallback(publishServer1);
    publishServer1.register(1, 1, cbk);
    Assert.assertEquals("SessionServer is not registered", true, publishServer1.isRegistered());
    
    SCPublishServer publishServer2 = server.newPublishServer(TestConstants.sesServiceName2);
    publishServer2.register(1, 1, cbk);
    Assert.assertEquals("SessionServer is not registered", true, publishServer2.isRegistered());
    
    publishServer1.deregister();
    publishServer2.deregister();
  }

View Full Code Here

  public void t298_register() throws Exception {
    server = new SCServer(TestConstants.HOST, TestConstants.PORT_SC0_HTTP, TestConstants.PORT_PUB_SRV_HTTP, ConnectionType.NETTY_HTTP); 
    server.startListener();
    SCPublishServer publishServer1 = server.newPublishServer(TestConstants.pubServiceName1);
    SCPublishServerCallback cbk1 = new PubSrvCallback(publishServer1);
    publishServer1.register(1, 1, cbk1);
    Assert.assertEquals("SessionServer is not registered", true, publishServer1.isRegistered());
    
    SCPublishServer publishServer2 = server.newPublishServer(TestConstants.pubServiceName2);
    SCPublishServerCallback cbk2 = new PubSrvCallback(publishServer2);
    publishServer2.register(1, 1, cbk2);

View Full Code Here

    publishServer1.register(1, 1, cbk1);
    Assert.assertEquals("SessionServer is not registered", true, publishServer1.isRegistered());
    
    SCPublishServer publishServer2 = server.newPublishServer(TestConstants.pubServiceName2);
    SCPublishServerCallback cbk2 = new PubSrvCallback(publishServer2);
    publishServer2.register(1, 1, cbk2);
    Assert.assertEquals("SessionServer is not registered", true, publishServer2.isRegistered());
    
    publishServer1.deregister();
    publishServer2.deregister();
  }

View Full Code Here

  public void t299_register() throws Exception {
    server = new SCServer(TestConstants.HOST, TestConstants.PORT_SC0_HTTP, TestConstants.PORT_PUB_SRV_HTTP, ConnectionType.NETTY_HTTP); 
    server.startListener();
    SCPublishServer publishServer1 = server.newPublishServer(TestConstants.pubServiceName1);
    SCPublishServerCallback cbk = new PubSrvCallback(publishServer1);
    publishServer1.register(1, 1, cbk);
    Assert.assertEquals("SessionServer is not registered", true, publishServer1.isRegistered());
    
    SCPublishServer publishServer2 = server.newPublishServer(TestConstants.pubServiceName2);
    publishServer2.register(1, 1, cbk);
    Assert.assertEquals("SessionServer is not registered", true, publishServer2.isRegistered());

View Full Code Here

0 1

TOP

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.