Package org.jboss.remoting.transport

Examples of org.jboss.remoting.transport.Connector.create()

150
151
152
153
154
155
156
157
158
159
160
         getTransport() + "://localhost:" + port + "/?serializationType=jboss";

      InvokerLocator locator = new InvokerLocator(locatorString);

      connector.setInvokerLocator(locator.getLocatorURI());
      connector.create();
      connector.addInvocationHandler(getSubsystem(), getServerInvocationHandler());
      connector.start();

      return locator;
   }
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
      String locatorURI = getTransport() + "://" + host + ":" + port;
      InvokerLocator locator = new InvokerLocator(locatorURI);
      HashMap serverConfig = new HashMap();
      serverConfig.put(InvokerLocator.FORCE_REMOTE, "true");
      Connector connector = new Connector(locator, serverConfig);
      connector.create();
      TestHandler handler = new TestHandler();
      connector.addInvocationHandler("test", handler);
      connector.start();
     
      HashMap clientConfig = new HashMap();
View Full Code Here
131
132
133
134
135
136
137
138
139
140
141
      String locatorURI = getTransport() + "://" + host + ":" + port;
      InvokerLocator locator = new InvokerLocator(locatorURI);
      HashMap serverConfig = new HashMap();
      serverConfig.put(InvokerLocator.FORCE_REMOTE, "true");
      Connector connector = new Connector(locator, serverConfig);
      connector.create();
      TestHandler handler = new TestHandler();
      connector.addInvocationHandler("test", handler);
      connector.start();
     
      HashMap clientConfig = new HashMap();
View Full Code Here
68
69
70
71
72
73
74
75
76
77
78
         Client client = new Client(new InvokerLocator(RestartServerTestServer.locatorURI), cconfig);
        
         HashMap sconfig = new HashMap();
         sconfig.put(Multiplex.SERVER_MULTIPLEX_ID, "id");
         Connector connector = new Connector("multiplex://localhost", sconfig);
         connector.create();
         connector.start();
         client.connect();
        
         // Test method invocation on first server.
         assertEquals(new Integer(3), client.invoke("abc"));
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
         InvokerLocator connectorLocator = new InvokerLocator(connectorURI);
         System.out.println("Starting remoting server with locator uri of: " + connectorURI);
         log.info("Starting remoting server with locator uri of: " + connectorURI);
         Connector connector = new Connector();
         connector.setInvokerLocator(connectorLocator.getLocatorURI());
         connector.create();
         connector.start();
        
         // Create Client.
         int clientPort = PortUtil.findFreePort("localhost");
         String clientURI = connectorURI + "&multiplexBindHost=localhost&multiplexBindPort=" + clientPort;
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
         Socket s = ss.accept();
         InputStream is = s.getInputStream();
         OutputStream os = s.getOutputStream();
        
         Connector connector = new Connector(locatorURI);
         connector.create();
         connector.addInvocationHandler("test", new SampleInvocationHandler(3));
         connector.start();
         os.write(2);
        
         is.read();
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
        
         is.read();
         connector.stop();
         System.out.println("********** stopped first Connector *************");
         connector = new Connector(locatorURI);
         connector.create();
         connector.addInvocationHandler("test", new SampleInvocationHandler(7));
         connector.start();
         System.out.println("********** started second Connector *************");
         os.write(4);
        
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
      connector.setInvokerLocator(locator.getLocatorURI());

//      ServerSocketFactory svrSocketFactory = createServerSocketFactory();
//      connector.setServerSocketFactory(svrSocketFactory);

      connector.create();

      connector.addInvocationHandler(getSubsystem(), getServerInvocationHandler());
      connector.start();
   }
  
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
      String host = InetAddress.getLocalHost().getHostAddress();
      int port = PortUtil.findFreePort(host);
      String locatorURI = "socket://" + host + ":" + port;
      locator = new InvokerLocator(locatorURI);
      Connector connector = new Connector(locator);
      connector.create();
      connector.setLeasePeriod(1000);
      connector.addConnectionListener(new TestListener());
      TestHandler handler = new TestHandler();
      connector.addInvocationHandler("test", handler);
      connector.start();
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
      String host = InetAddress.getLocalHost().getHostAddress();
      int port = PortUtil.findFreePort(host);
      String locatorURI = "socket://" + host + ":" + port;
      locator = new InvokerLocator(locatorURI);
      Connector connector = new Connector(locator);
      connector.create();
      connector.setLeasePeriod(1000);
      connector.addConnectionListener(new TestListener());
      TestHandler handler = new TestHandler();
      connector.addInvocationHandler("test", handler);
      connector.start();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.