Package org.apache.cayenne.remote

Examples of org.apache.cayenne.remote.SyncMessage

38
39
40
41
42
43
44
45
46
47
48
49
        // do most common messages first...
        if (message instanceof QueryMessage) {
            return channel.onQuery(null, ((QueryMessage) message).getQuery());
        }
        else if (message instanceof SyncMessage) {
            SyncMessage sync = (SyncMessage) message;
            return channel.onSync(null, sync.getSenderChanges(), sync.getType());
        }
        else if (message instanceof BootstrapMessage) {
            return channel.getEntityResolver().getClientEntityResolver();
        }
        else {
View Full Code Here
37
38
39
40
41
42
43
44
45
46
47
48
        // do most common messages first...
        if (message instanceof QueryMessage) {
            return channel.onQuery(null, ((QueryMessage) message).getQuery());
        }
        else if (message instanceof SyncMessage) {
            SyncMessage sync = (SyncMessage) message;
            return channel.onSync(null, sync.getSenderChanges(), sync.getType());
        }
        else if (message instanceof BootstrapMessage) {
            return channel.getEntityResolver().getClientEntityResolver();
        }
        else {
View Full Code Here
34
35
36
37
38
39
40
41
42
43
44
public class SyncMessageTest extends TestCase {

    public void testConstructor() {
        ObjectContext source = new MockObjectContext();
        GraphDiff diff = new CompoundDiff();
        SyncMessage message = new SyncMessage(source, DataChannel.FLUSH_NOCASCADE_SYNC, diff);

        assertSame(source, message.getSource());
        assertEquals(DataChannel.FLUSH_NOCASCADE_SYNC, message.getType());
        assertSame(diff, message.getSenderChanges());
    }
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
    public void testHessianSerialization() throws Exception {
        // id must be a serializable object; source doesn't have to be
        ObjectContext source = new MockObjectContext();
        GraphDiff diff = new NodeCreateOperation("id-string");
        SyncMessage message = new SyncMessage(source, DataChannel.FLUSH_NOCASCADE_SYNC, diff);

        Object d = HessianUtil.cloneViaClientServerSerialization(message, new EntityResolver());
        assertNotNull(d);
        assertTrue(d instanceof SyncMessage);

        SyncMessage ds = (SyncMessage) d;
        assertNull(ds.getSource());
        assertEquals(message.getType(), ds.getType());
        assertNotNull(ds.getSenderChanges());
    }
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
        assertNotNull(ds.getSenderChanges());
    }

    public void testConstructorInvalid() {
        ObjectContext source = new MockObjectContext();
        new SyncMessage(source, DataChannel.FLUSH_NOCASCADE_SYNC, new CompoundDiff());
        new SyncMessage(source, DataChannel.FLUSH_CASCADE_SYNC, new CompoundDiff());
        new SyncMessage(null, DataChannel.ROLLBACK_CASCADE_SYNC, new CompoundDiff());

        int bogusType = 45678;
        try {
            new SyncMessage(source, bogusType, new CompoundDiff());
            fail("invalid type was allowed to go unnoticed...");
        }
        catch (IllegalArgumentException e) {

        }
View Full Code Here
TOP

Related Classes of org.apache.cayenne.remote.SyncMessage

  • org.apache.cayenne.remote.service.DispatchHelper
  • org.apache.cayenne.remote.SyncMessageTest
    • 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.