Package org.jboss.remoting.transport

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

158
159
160
161
162
163
164
165
166
167
168
      Connector c = new Connector(locator, config);
      if (xmlConfig != null)
      {
         c.setConfiguration(xmlConfig);
      }
      c.create();

      return c;
   }

   /**
 
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
        }

        String locatorString1 = "socket://127.0.0.1:" + CommTestConstants.CONNECTOR_BIND_PORT + "/?force_remote=true";

        Connector c1 = new Connector(locatorString1);
        c1.create();
        c1.addInvocationHandler("test", this);
        c1.start();

        try {
            Client client1 = new Client(new InvokerLocator(locatorString1), "test");
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
            String results = (String) client1.invoke("");
            assert "foo".equals(results) : "Results were " + results;

            c1.stop();
            c1.destroy();
            c1.create();

            c1.addInvocationHandler("test", this);
            c1.start();

            results = (String) client1.invoke("");
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
    @Test(groups = "comm.client")
    public void testShutdownRestartWithJBossRemotingRemoteCommunicator() throws Throwable {
        String locatorString1 = "socket://127.0.0.1:11112/?force_remote=true";

        Connector c1 = new Connector(locatorString1);
        c1.create();
        c1.addInvocationHandler("test", this);
        c1.start();

        try {
            JBossRemotingRemoteCommunicator client1 = new JBossRemotingRemoteCommunicator(locatorString1);
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
            c1.stop();
            c1.destroy();

            Thread.sleep(5000); // I have no idea if this will matter, but maybe this avoids the address-already-in-use error we periodically get

            c1.create();

            c1.addInvocationHandler("test", this);
            c1.start();

            results = client1.send(new IdentifyCommand());
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
      InvokerLocator locator = new InvokerLocator(getLocatorUri());
      System.out.println("Calling remoting server with locator uri of: " + getLocatorUri());

      InvokerLocator callbackLocator = new InvokerLocator(callbackLocatorURI);
      Connector callbackConnector = new Connector(callbackLocator);
      callbackConnector.create();
      callbackConnector.start();

      TestCallbackHandler callbackHandler = new TestCallbackHandler();

      Map metadata = new HashMap();
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
   {
      InvokerLocator locator = new InvokerLocator(locatorURI);
      println("Starting remoting server with locator uri of: " + locatorURI);
      Connector connector = new Connector();
      connector.setInvokerLocator(locator.getLocatorURI());
      connector.create();

      SampleInvocationHandler invocationHandler = new SampleInvocationHandler();

      // first parameter is sub-system name.  can be any String value.
      connector.addInvocationHandler("sample", invocationHandler);
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
        
         log.info("configuration: " + conf);
        
         // Create Connector.
         Connector connector1 = new Connector(ConfigurationTestServer.connectorURI3, conf);
         connector1.create();
         connector1.start();
         log.info("started Connector on: " + connector1.getInvokerLocator());
        
         // Tell test server to connect.
         os.write(13);
View Full Code Here
259
260
261
262
263
264
265
266
267
268
269
        
         log.info("configuration: " + conf);
        
         // Create Connector.
         Connector connector2 = new Connector(ConfigurationTestServer.connectorURI4, conf);
         connector2.create();
         connector2.start();
         log.info("started Connector on: " + connector2.getInvokerLocator());
        
         // Tell test server to connect.
         os.write(19);
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
               OutputStream os = syncSocket.getOutputStream();
               log.info("got sync socket");
              
               // Create Connector.
               Connector connector = new Connector(connectorURI);
               connector.create();
               connector.start();
               os.write(7);
               log.info("started Connector on: " + connector.getInvokerLocator());
              
               // Wait for end of test signal.
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.