~ubuntu-branches/ubuntu/trusty/ehcache/trusty

« back to all changes in this revision

Viewing changes to src/test/java/net/sf/ehcache/distribution/EventMessageTest.java

  • Committer: Package Import Robot
  • Author(s): Emmanuel Bourg
  • Date: 2013-05-06 14:53:07 UTC
  • mfrom: (1.1.7) (2.1.8 sid)
  • Revision ID: package-import@ubuntu.com-20130506145307-v5bhw5yu70re00l3
Tags: 2.6.7-1
* Team upload.
* New upstream release

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
1
/**
2
 
 *  Copyright 2003-2010 Terracotta, Inc.
 
2
 *  Copyright Terracotta, Inc.
3
3
 *
4
4
 *  Licensed under the Apache License, Version 2.0 (the "License");
5
5
 *  you may not use this file except in compliance with the License.
33
33
import java.lang.ref.SoftReference;
34
34
import java.util.HashMap;
35
35
import java.util.Map;
 
36
import net.sf.ehcache.distribution.RmiEventMessage.RmiEventType;
36
37
 
37
38
import org.slf4j.Logger;
38
39
import org.slf4j.LoggerFactory;
41
42
 * Tests Serialization and SoftReferences in EventMessage
42
43
 *
43
44
 * @author Greg Luck
44
 
 * @version $Id: EventMessageTest.java 3409 2011-01-04 03:36:52Z gluck $
 
45
 * @version $Id: EventMessageTest.java 5631 2012-05-10 08:31:33Z teck $
45
46
 */
46
47
public class EventMessageTest {
47
48
 
79
80
    @Test
80
81
    public void testSerialization() throws IOException, ClassNotFoundException {
81
82
 
82
 
        EventMessage eventMessage = new EventMessage(EventMessage.PUT, "key", new Element("key", "element"));
 
83
        RmiEventMessage eventMessage = new RmiEventMessage(null, RmiEventType.PUT, "key", new Element("key", "element"));
83
84
 
84
85
        ByteArrayOutputStream bout = new ByteArrayOutputStream();
85
86
        ObjectOutputStream oos = new ObjectOutputStream(bout);
86
87
        oos.writeObject(eventMessage);
87
88
        byte[] serializedValue = bout.toByteArray();
88
89
        oos.close();
89
 
        EventMessage eventMessage2 = null;
 
90
        RmiEventMessage eventMessage2 = null;
90
91
        ByteArrayInputStream bin = new ByteArrayInputStream(serializedValue);
91
92
        ObjectInputStream ois = new ObjectInputStream(bin);
92
 
        eventMessage2 = (EventMessage) ois.readObject();
 
93
        eventMessage2 = (RmiEventMessage) ois.readObject();
93
94
        ois.close();
94
95
 
95
96
        //Check after Serialization
96
97
        assertEquals("key", eventMessage2.getSerializableKey());
97
98
        assertEquals("element", eventMessage2.getElement().getObjectValue());
98
 
        assertEquals(EventMessage.PUT, eventMessage2.getEvent());
99
 
        assertTrue(eventMessage2.isValid());
100
 
 
 
99
        assertEquals(RmiEventType.PUT, eventMessage2.getType());
101
100
    }
102
101
 
103
102