Package org.eclipse.ecf.core.identity

Examples of org.eclipse.ecf.core.identity.ID

102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
    assertTrue(containerIDa.equals(containerID));

  }

  public void testAndRetrieveStoreContainerByIDAndCreateContainer() throws Exception {
    final ID containerID = testStoreContainer();

    // Now retrieve from container store with given ID
    final IContainerEntry containerEntry = containerStore.retrieve(containerID);
    assertNotNull(containerEntry);

    final IContainer containera = containerEntry.createContainer();

    final ID containerIDa = containera.getID();
    assertNotNull(containerIDa);
    assertTrue(containerIDa.equals(containerID));

  }
View Full Code Here
32
33
34
35
36
37
38
39
40
41
42
  public void testConnectOneClient() throws Exception {
    final int clientIndex = 0;
    final IContainer client = getClient(clientIndex);
    assertNull(client.getConnectedID());
    final ID serverConnectID = getServerConnectID(clientIndex);
    assertNotNull(serverConnectID);
    connectClient(client, serverConnectID, getConnectContext(clientIndex));
    assertEquals(serverConnectID, client.getConnectedID());
    sleep(SLEEPTIME);
    client.disconnect();
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
  public void testConnectTwoClients() throws Exception {
    for (int i = 0; i < 2; i++) {
      final IContainer client = getClient(i);
      assertNull(client.getConnectedID());
      final ID serverConnectID = getServerConnectID(i);
      assertNotNull(serverConnectID);
      connectClient(client, serverConnectID, getConnectContext(i));
      assertEquals(serverConnectID, client.getConnectedID());
    }
View Full Code Here
72
73
74
75
76
77
78
79
80
    super.tearDown();
  }

  public void testSendMessage() throws Exception {
    final IChannel ch0 = getChannelContainer(0).getChannel(channelID);
    ID target1 = getClient(1).getConnectedID();
    ch0.sendMessage(target1, new String("hello").getBytes());
    sleep(SLEEPTIME);
  }
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
92
  public void testBiSendMessage() throws Exception {
    final IChannel ch0 = getChannelContainer(0).getChannel(channelID);
    final IChannel ch1 = getChannelContainer(1).getChannel(channelID);
   
    ID target1 = getClient(1).getConnectedID();
    ID target0 = getClient(0).getConnectedID();
   
    ch0.sendMessage(target1, new String("hello").getBytes());
    ch1.sendMessage(target0, new String("hello").getBytes());
    sleep(SLEEPTIME);
  }
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
  }


  public void testSendMessages() throws Exception {
    final IChannel ch0 = getChannelContainer(0).getChannel(channelID);
    ID target1 = getClient(1).getConnectedID();
    for(int i=0; i < SEND_MESSAGE_COUNT; i++) {
      ch0.sendMessage(target1, new String("hello.  msg#="+i).getBytes());
    }
    sleep(SLEEPTIME);
  }
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
114
  public void testBiSendMessages() throws Exception {
    final IChannel ch0 = getChannelContainer(0).getChannel(channelID);
    final IChannel ch1 = getChannelContainer(1).getChannel(channelID);
   
    ID target1 = getClient(1).getConnectedID();
    ID target0 = getClient(0).getConnectedID();
       
    for(int i=0; i < SEND_MESSAGE_COUNT; i++) {
      ch0.sendMessage(target1, new String("hello.  msg#="+i).getBytes());
      ch1.sendMessage(target0, new String("hello.  msg#="+i).getBytes());
    }
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
76
    assertNotNull(client0Container);
    //
    final ISharedObjectContainer socontainer = (ISharedObjectContainer) client0Container.getAdapter(ISharedObjectContainer.class);
    final ISharedObjectManager manager = socontainer.getSharedObjectManager();
    assertNotNull(manager);
    final ID objectID = createSharedObjectID();
    final ID id = manager.addSharedObject(objectID, createSharedObject(objectID), null);
    assertNotNull(id);
    final ISharedObject sharedObject = manager.getSharedObject(id);
    assertNotNull(sharedObject);
    sleep(5000);
  }
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
92
    assertNotNull(client0Container);
    //
    final ISharedObjectContainer socontainer = (ISharedObjectContainer) client0Container.getAdapter(ISharedObjectContainer.class);
    final ISharedObjectManager manager = socontainer.getSharedObjectManager();
    assertNotNull(manager);
    final ID objectID = createSharedObjectID();
    final ID id = manager.addSharedObject(objectID, createSharedObject(objectID), null);
    assertNotNull(id);
    final ISharedObject sharedObject = manager.getSharedObject(id);
    assertNotNull(sharedObject);
    sleep(5000);
  }
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
    rsContainer = new RemoteServiceContainer(client,adapter);
   
    System.out.println("Client created with ID=" + client.getID());

    ID connectTargetID = IDFactory.getDefault().createStringID(
        NLS.bind(SERVER_ID, new Integer(port)));
   
    System.out.println("Attempting connect to id="+connectTargetID);
    client.connect(connectTargetID, null);
    System.out.println("Client connected to connectTargetID="
View Full Code Here
TOP

Related Classes of org.eclipse.ecf.core.identity.ID

  • org.eclipse.ecf.core.ContainerFactory
  • org.eclipse.ecf.core.sharedobject.TwoPhaseCommitEventProcessor
  • org.eclipse.ecf.example.collab.share.EclipseCollabSharedObject
  • org.eclipse.ecf.example.collab.share.GenericSharedObject
  • org.eclipse.ecf.example.sdo.editor.EditorPlugin
  • org.eclipse.ecf.internal.console.ECFCommandProvider
  • org.eclipse.ecf.internal.example.collab.CollabClient
  • org.eclipse.ecf.internal.example.collab.ServerStartup
  • org.eclipse.ecf.internal.example.collab.ui.ChatComposite
  • org.eclipse.ecf.internal.example.collab.ui.SharedObjectContainerUI
    • Copyright © 2018 www.massapicom. 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.