Package org.jboss.remoting.transport

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

95
96
97
98
99
100
101
102
103
104
105
      String locatorURI = getTransport() + "://" + host + ":" + port;
      locatorURI += "/?marshaller=org.jboss.remoting.marshal.serializable.SerializableMarshaller";
      locatorURI += "&unmarshaller=org.jboss.remoting.marshal.serializable.SerializableUnMarshaller";
      InvokerLocator locator = new InvokerLocator(locatorURI);
      Connector connector = new Connector(locator);
      connector.create();
      connector.addInvocationHandler("test", new TestHandler());
      connector.start();
     
      HashMap config = new HashMap();
      config.put(InvokerLocator.FORCE_REMOTE, "true");
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
      config.put(SSLSocketBuilder.REMOTING_KEY_STORE_PASSWORD, "unit-tests-server");
 
      Connector connector = new Connector(config);
      InvokerLocator locator = new InvokerLocator(buildLocatorURI(metatdata));
      connector.setInvokerLocator(locator.getLocatorURI());
      connector.create();
      connector.addInvocationHandler(getSubsystem(), getServerInvocationHandler());
      connector.start();
   }
  
   public static void main(String[] args)
View Full Code Here
186
187
188
189
190
191
192
193
194
195
196
      String locatorURI = getTransport() + "://" + host + ":" + port;
      locatorURI += "/?marshaller=org.jboss.test.remoting.marshall.preferredstream.TestMarshaller";
      locatorURI += "&unmarshaller=org.jboss.test.remoting.marshall.preferredstream.TestUnMarshaller";
      InvokerLocator locator = new InvokerLocator(locatorURI);
      Connector connector = new Connector(locator);
      connector.create();
      connector.addInvocationHandler("test", new TestHandler());
      connector.start();
     
      HashMap config = new HashMap();
      config.put(InvokerLocator.FORCE_REMOTE, "true");
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
         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();
         SimpleServerInvocationHandler invocationHandler = new SimpleServerInvocationHandler();
         connector.addInvocationHandler("test", invocationHandler);
         connector.start();
        
         // Create Client.
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
         config.put(SSLSocketBuilder.REMOTING_TRUST_STORE_FILE_PATH, trustStoreFilePath);
         config.put(SSLSocketBuilder.REMOTING_SOCKET_USE_CLIENT_MODE, "false");
         config.put(SSLSocketBuilder.REMOTING_SERVER_SOCKET_USE_CLIENT_MODE, "true"); 

         Connector callbackConnector = new Connector(locator.getLocatorURI(), config);
         callbackConnector.create();
         callbackConnector.addInvocationHandler("sample", new SampleInvocationHandler());
         callbackConnector.start();

         CallbackHandler callbackHandler = new CallbackHandler();
         String callbackHandleObject = "myCallbackHandleObject";
View Full Code Here
106
107
108
109
110
111
112
113
114
115
116
      //Start a server
     
      Connector serverConnector = new Connector();
      InvokerLocator serverLocator = new InvokerLocator("multiplex://localhost:9099");
      serverConnector.setInvokerLocator(serverLocator.getLocatorURI());
      serverConnector.create();
      SimpleServerInvocationHandler invocationHandler = new SimpleServerInvocationHandler();
      serverConnector.addInvocationHandler("JMS", invocationHandler);
      serverConnector.start();
     
      log.info("Server started");
View Full Code Here
169
170
171
172
173
174
175
176
177
178
179
         Connector callbackServerConnector = new Connector();     
        
         InvokerLocator callbackServerLocator = new InvokerLocator("multiplex://localhost:" + localPort + "/?serverMultiplexId=mytestid" + i);
              
         callbackServerConnector.setInvokerLocator(callbackServerLocator.getLocatorURI());     
         callbackServerConnector.create();     
         callbackServerConnector.start();
        
         log.info("Created callback server");
        
    
View Full Code Here
225
226
227
228
229
230
231
232
233
234
235
      //Start a server
     
      Connector serverConnector = new Connector();
      InvokerLocator serverLocator = new InvokerLocator("socket://localhost:9098");
      serverConnector.setInvokerLocator(serverLocator.getLocatorURI());
      serverConnector.create();
      SimpleServerInvocationHandler invocationHandler = new SimpleServerInvocationHandler();
      serverConnector.addInvocationHandler("JMS", invocationHandler);
      serverConnector.start();
     
      log.info("Server started");
View Full Code Here
261
262
263
264
265
266
267
268
269
270
271
         Connector callbackServerConnector = new Connector();     
        
         InvokerLocator callbackServerLocator = new InvokerLocator("socket://localhost:" + localPort);
              
         callbackServerConnector.setInvokerLocator(callbackServerLocator.getLocatorURI());     
         callbackServerConnector.create();     
         callbackServerConnector.start();
        
         log.info("Created callback server");
             
         client.disconnect();
View Full Code Here
287
288
289
290
291
292
293
294
295
296
297
      //Start a server
     
      Connector serverConnector = new Connector();
      InvokerLocator serverLocator = new InvokerLocator("multiplex://localhost:9099");
      serverConnector.setInvokerLocator(serverLocator.getLocatorURI());
      serverConnector.create();
      SimpleServerInvocationHandler invocationHandler = new SimpleServerInvocationHandler();
      serverConnector.addInvocationHandler("JMS", invocationHandler);
      serverConnector.start();
     
      log.info("Server started");
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.