/*
* Copyright (c) 2009-2012, 2019, 2022 Eike Stepper (Loehne, Germany) and others.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* Simon McDuff - initial API and implementation
* Eike Stepper - maintenance
*/
package org.eclipse.emf.cdo.tests;
import org.eclipse.emf.cdo.session.CDOSession;
import org.eclipse.emf.cdo.session.remote.CDORemoteSession;
import org.eclipse.emf.cdo.session.remote.CDORemoteSessionEvent;
import org.eclipse.emf.cdo.session.remote.CDORemoteSessionMessage;
import org.eclipse.emf.cdo.session.remote.CDORemoteTopic;
import org.eclipse.emf.cdo.session.remote.CDORemoteTopicEvent;
import org.eclipse.net4j.util.container.ContainerEventAdapter;
import org.eclipse.net4j.util.container.IContainer;
import org.eclipse.net4j.util.event.IEvent;
import org.eclipse.net4j.util.event.IListener;
import java.util.Arrays;
/**
* @author Eike Stepper
*/
public class RemoteSessionManagerTest extends AbstractCDOTest
{
public void testRemoteSessionOpened() throws Exception
{
final AsyncResult<Integer> result1 = new AsyncResult<>();
CDOSession session1 = openSession();
session1.getRemoteSessionManager().addListener(new ContainerEventAdapter<CDORemoteSession>()
{
@Override
protected void onAdded(IContainer<CDORemoteSession> container, CDORemoteSession session)
{
result1.setValue(session.getSessionID());
}
});
CDOSession session2 = openSession();
assertEquals(session2.getSessionID(), (int)result1.getValue());
session2.close();
session1.close();
}
public void testRemoteSessionClosed() throws Exception
{
final AsyncResult<Integer> result1 = new AsyncResult<>();
CDOSession session1 = openSession();
session1.getRemoteSessionManager().addListener(new ContainerEventAdapter<CDORemoteSession>()
{
@Override
protected void onRemoved(IContainer<CDORemoteSession> container, CDORemoteSession session)
{
result1.setValue(session.getSessionID());
}
});
CDOSession session2 = openSession();
session2.close();
assertEquals(session2.getSessionID(), (int)result1.getValue());
session2.close();
session1.close();
}
public void testSubscribeByForce() throws Exception
{
final AsyncResult<Integer> result1 = new AsyncResult<>();
CDOSession session1 = openSession();
session1.getRemoteSessionManager().addListener(new IListener()
{
@Override
public void notifyEvent(IEvent event)
{
if (event instanceof CDORemoteSessionEvent.SubscriptionChanged)
{
CDORemoteSessionEvent.SubscriptionChanged e = (CDORemoteSessionEvent.SubscriptionChanged)event;
if (e.isSubscribed())
{
result1.setValue(e.getRemoteSession().getSessionID());
}
else
{
result1.setValue(-1);
}
}
}
});
CDOSession session2 = openSession();
session2.getRemoteSessionManager().setForceSubscription(true);
assertEquals(session2.getSessionID(), (int)result1.getValue());
session2.close();
session1.close();
}
public void testSubscribeByListen() throws Exception
{
final AsyncResult<Integer> result1 = new AsyncResult<>();
CDOSession session1 = openSession();
session1.getRemoteSessionManager().addListener(new IListener()
{
@Override
public void notifyEvent(IEvent event)
{
if (event instanceof CDORemoteSessionEvent.SubscriptionChanged)
{
CDORemoteSessionEvent.SubscriptionChanged e = (CDORemoteSessionEvent.SubscriptionChanged)event;
if (e.isSubscribed())
{
result1.setValue(e.getRemoteSession().getSessionID());
}
else
{
result1.setValue(-1);
}
}
}
});
CDOSession session2 = openSession();
session2.getRemoteSessionManager().addListener(new IListener()
{
@Override
public void notifyEvent(IEvent event)
{
}
});
assertEquals(session2.getSessionID(), (int)result1.getValue());
session2.close();
session1.close();
}
public void testUnsubscribeByForce() throws Exception
{
final AsyncResult<Integer> result1 = new AsyncResult<>();
CDOSession session1 = openSession();
session1.getRemoteSessionManager().addListener(new IListener()
{
@Override
public void notifyEvent(IEvent event)
{
if (event instanceof CDORemoteSessionEvent.SubscriptionChanged)
{
CDORemoteSessionEvent.SubscriptionChanged e = (CDORemoteSessionEvent.SubscriptionChanged)event;
if (!e.isSubscribed())
{
result1.setValue(e.getRemoteSession().getSessionID());
}
}
}
});
CDOSession session2 = openSession();
session2.getRemoteSessionManager().setForceSubscription(true);
session2.getRemoteSessionManager().setForceSubscription(false);
assertEquals(session2.getSessionID(), (int)result1.getValue());
session2.close();
session1.close();
}
public void testUnsubscribeByListen100() throws Exception
{
for (int i = 0; i < 100; i++)
{
testUnsubscribeByListen();
}
}
public void testUnsubscribeByListen() throws Exception
{
final AsyncResult<Integer> subscribed = new AsyncResult<>();
final AsyncResult<Integer> unsubscribed = new AsyncResult<>();
CDOSession session1 = openSession();
session1.getRemoteSessionManager().addListener(new IListener()
{
@Override
public void notifyEvent(IEvent event)
{
if (event instanceof CDORemoteSessionEvent.SubscriptionChanged)
{
CDORemoteSessionEvent.SubscriptionChanged e = (CDORemoteSessionEvent.SubscriptionChanged)event;
if (e.isSubscribed())
{
subscribed.setValue(e.getRemoteSession().getSessionID());
}
else
{
unsubscribed.setValue(e.getRemoteSession().getSessionID());
}
}
}
});
CDOSession session2 = openSession();
IListener listener = new IListener()
{
@Override
public void notifyEvent(IEvent event)
{
// Do nothing
}
};
session2.getRemoteSessionManager().addListener(listener);
assertEquals(session2.getSessionID(), (int)subscribed.getValue());
session2.getRemoteSessionManager().removeListener(listener);
assertEquals(session2.getSessionID(), (int)unsubscribed.getValue());
session2.close();
session1.close();
}
public void testCustomData() throws Exception
{
final AsyncResult<byte[]> result1 = new AsyncResult<>();
CDOSession session1 = openSession();
session1.getRemoteSessionManager().addListener(new IListener()
{
@Override
public void notifyEvent(IEvent event)
{
if (event instanceof CDORemoteSessionEvent.MessageReceived)
{
CDORemoteSessionEvent.MessageReceived e = (CDORemoteSessionEvent.MessageReceived)event;
result1.setValue(e.getMessage().getData());
}
}
});
CDOSession session2 = openSession();
session2.getRemoteSessionManager().setForceSubscription(true);
byte[] data = "This is a custom data test".getBytes();
CDORemoteSession remoteSession = session2.getRemoteSessionManager().getRemoteSessions()[0];
remoteSession.sendMessage(new CDORemoteSessionMessage("type", data));
assertEquals(true, Arrays.equals(data, result1.getValue()));
session2.close();
session1.close();
}
public void testCustomDataLocallyUnsubscribed() throws Exception
{
final AsyncResult<byte[]> result1 = new AsyncResult<>();
CDOSession session1 = openSession();
session1.getRemoteSessionManager().addListener(new IListener()
{
@Override
public void notifyEvent(IEvent event)
{
if (event instanceof CDORemoteSessionEvent.MessageReceived)
{
CDORemoteSessionEvent.MessageReceived e = (CDORemoteSessionEvent.MessageReceived)event;
result1.setValue(e.getMessage().getData());
}
}
});
CDOSession session2 = openSession();
byte[] data = "This is a custom data test".getBytes();
CDORemoteSession remoteSession = session2.getRemoteSessionManager().getRemoteSessions()[0];
boolean sent = remoteSession.sendMessage(new CDORemoteSessionMessage("type", data));
assertEquals(true, sent);
session2.close();
session1.close();
}
public void testCustomDataRemotelyUnsubscribed() throws Exception
{
CDOSession session1 = openSession();
CDOSession session2 = openSession();
session2.getRemoteSessionManager().setForceSubscription(true);
byte[] data = "This is a custom data test".getBytes();
CDORemoteSession remoteSession = session2.getRemoteSessionManager().getRemoteSessions()[0];
boolean sent = remoteSession.sendMessage(new CDORemoteSessionMessage("type", data));
assertEquals(false, sent);
session2.close();
session1.close();
}
public void testRemoteTopicSubscription() throws Exception
{
AsyncResult<Boolean> session2Subscribed = new AsyncResult<Boolean>();
AsyncResult<Boolean> session2Unsubscribed = new AsyncResult<Boolean>();
CDOSession session1 = openSession();
assertEquals(false, session1.getRemoteSessionManager().isSubscribed());
CDORemoteTopic topic1 = session1.getRemoteSessionManager().subscribeTopic("my.special.topic");
assertEquals(0, topic1.getRemoteSessions().length);
assertEquals(true, session1.getRemoteSessionManager().isSubscribed());
topic1.addListener(new ContainerEventAdapter<CDORemoteSession>()
{
@Override
protected void onAdded(IContainer<CDORemoteSession> container, CDORemoteSession element)
{
session2Subscribed.setValue(true);
}
@Override
protected void onRemoved(IContainer<CDORemoteSession> container, CDORemoteSession element)
{
session2Unsubscribed.setValue(true);
}
});
CDOSession session2 = openSession();
assertEquals(false, session2.getRemoteSessionManager().isSubscribed());
CDORemoteTopic topic2 = session2.getRemoteSessionManager().subscribeTopic("my.special.topic");
assertEquals(1, topic2.getRemoteSessions().length);
assertEquals(true, session2.getRemoteSessionManager().isSubscribed());
assertEquals(true, (boolean)session2Subscribed.getValue());
assertEquals(1, topic1.getRemoteSessions().length);
topic2.unsubscribe();
assertEquals(true, (boolean)session2Unsubscribed.getValue());
assertEquals(false, session2.getRemoteSessionManager().isSubscribed());
session2.close();
session1.close();
}
public void testRemoteTopicMessage() throws Exception
{
AsyncResult<Boolean> messageReceived = new AsyncResult<Boolean>();
AsyncResult<Boolean> unsubscribeReceived = new AsyncResult<Boolean>();
CDOSession session1 = openSession();
CDORemoteTopic topic1 = session1.getRemoteSessionManager().subscribeTopic("my.special.topic");
topic1.addListener(new IListener()
{
@Override
public void notifyEvent(IEvent event)
{
if (event instanceof CDORemoteTopicEvent.MessageReceived)
{
CDORemoteTopicEvent.MessageReceived e = (CDORemoteTopicEvent.MessageReceived)event;
if (e.getSource().getID().equals("my.special.topic"))
{
messageReceived.setValue(true);
}
}
}
});
topic1.addListener(new ContainerEventAdapter<CDORemoteSession>()
{
@Override
protected void onRemoved(IContainer<CDORemoteSession> container, CDORemoteSession element)
{
unsubscribeReceived.setValue(true);
}
});
CDOSession session2 = openSession();
CDORemoteTopic topic2 = session2.getRemoteSessionManager().subscribeTopic("my.special.topic");
topic2.sendMessage(new CDORemoteSessionMessage("my.type"));
assertEquals(true, (boolean)messageReceived.getValue());
session2.close();
assertEquals(true, (boolean)unsubscribeReceived.getValue(10000000));
session1.close();
}
}
