Examples of XStreamSerializer

br.com.caelum.vraptor.serialization.xstream.XStreamSerializer
A SerializerBuilder based on XStream @author Lucas Cavalcanti @since 3.0.2
com.ovea.jetty.session.serializer.XStreamSerializer
@author Mathieu Carbou (mathieu.carbou@gmail.com)
org.axonframework.serializer.xml.XStreamSerializer
Serializer that uses XStream to serialize and deserialize arbitrary objects. The XStream instance is configured to deal with the Classes used in Axon Framework in the most compact fashion.
When running on a Sun JVM, XStream does not pose any restrictions on classes to serialize. On other JVM's, however, you need to either implement Serializable, or provide a default constructor (accessible under the JVM's security policy). That means that for portability, you should do either of these two. @author Allard Buijze @see com.thoughtworks.xstream.XStream @since 1.2
org.prevayler.foundation.serialization.XStreamSerializer
am.codehaus.org/">XStream Java and XML language binding framework which provides for Java object XML serialization.

Note that XStream has some dependencies of its own. It requires the standard XML API's (xml-apis.jar from the Apache Xerces2-j project or j2sdk1.4+) and an XML implementation (again, provided by Xerces2 or j2sdk1.4+).

To make XStream up to 10x faster, add XPP3 to the classpath. XStream has the concept of a HierarchicalStreamDriver and the default implementation for XStream is the highly performant XppDriver. However, XStream will fall back to the DomDriver if XPP3 is not found in the classpath making the XPP3 library entirely optional... well, not quite. See XSTR-71. The current decision in that issue forces XPP3 to be a required runtime dependency when using XStream unless one specifically configures another driver, such as the DomDriver.

Examples of org.axonframework.serializer.xml.XStreamSerializer


        // the serialized form of the Saga exceeds the default length of a blob.
        // So we must alter the table to prevent data truncation
        entityManager.createNativeQuery("ALTER TABLE SagaEntry ALTER COLUMN serializedSaga VARBINARY(1024)")
                     .executeUpdate();
        serializer = new XStreamSerializer();
    }

View Full Code Here

Examples of org.axonframework.serializer.xml.XStreamSerializer

    }


    @DirtiesContext
    @Test
    public void testLoadUncachedSaga_ByIdentifier() {
        repository.setSerializer(new XStreamSerializer());
        String identifier = UUID.randomUUID().toString();
        StubSaga saga = new StubSaga(identifier);
        entityManager.persist(new SagaEntry(saga, new XStreamSerializer()));
        entityManager.flush();
        entityManager.clear();
        Saga loaded = repository.load(identifier);
        assertNotSame(saga, loaded);
        assertEquals(identifier, loaded.getSagaIdentifier());

View Full Code Here

Examples of org.axonframework.serializer.xml.XStreamSerializer

    @DirtiesContext
    @Test
    public void testSaveSaga() {
        String identifier = UUID.randomUUID().toString();
        StubSaga saga = new StubSaga(identifier);
        entityManager.persist(new SagaEntry(saga, new XStreamSerializer()));
        entityManager.flush();
        StubSaga loaded = (StubSaga) repository.load(identifier);
        repository.commit(loaded);


        entityManager.clear();


        SagaEntry entry = entityManager.find(SagaEntry.class, identifier);
        StubSaga actualSaga = (StubSaga) entry.getSaga(new XStreamSerializer());
        assertNotSame(loaded, actualSaga);
    }

View Full Code Here

Examples of org.axonframework.serializer.xml.XStreamSerializer


        // the serialized form of the Saga exceeds the default length of a blob.
        // So we must alter the table to prevent data truncation
        entityManager.createNativeQuery("ALTER TABLE SagaEntry ALTER COLUMN serializedSaga VARBINARY(1024)")
                     .executeUpdate();
        serializer = new XStreamSerializer();
        repository.setSerializer(serializer);
    }

View Full Code Here

Examples of org.axonframework.serializer.xml.XStreamSerializer

    }


    @DirtiesContext
    @Test
    public void testLoadUncachedSaga_ByIdentifier() {
        repository.setSerializer(new XStreamSerializer());
        String identifier = UUID.randomUUID().toString();
        StubSaga saga = new StubSaga(identifier);
        entityManager.persist(new SagaEntry(saga, new XStreamSerializer()));
        entityManager.flush();
        entityManager.clear();
        Saga loaded = repository.load(identifier);
        assertNotSame(saga, loaded);
        assertEquals(identifier, loaded.getSagaIdentifier());

View Full Code Here

Examples of org.axonframework.serializer.xml.XStreamSerializer

    @DirtiesContext
    @Test
    public void testSaveSaga() {
        String identifier = UUID.randomUUID().toString();
        StubSaga saga = new StubSaga(identifier);
        entityManager.persist(new SagaEntry(saga, new XStreamSerializer()));
        StubSaga loaded = (StubSaga) repository.load(identifier);
        repository.commit(loaded);


        entityManager.clear();


        SagaEntry entry = entityManager.find(SagaEntry.class, identifier);
        StubSaga actualSaga = (StubSaga) entry.getSaga(new XStreamSerializer());
        assertNotSame(loaded, actualSaga);
    }

View Full Code Here

Examples of org.axonframework.serializer.xml.XStreamSerializer

public class CassandraEventStoreTest {


    @Test
    public void testStoreAndReadEvents() {
        EmbeddedCassandra.start();
        CassandraEventStore cassandraEventStore = new CassandraEventStore(new XStreamSerializer(),
                                                                          EmbeddedCassandra.CLUSTER_NAME,
                                                                          EmbeddedCassandra.KEYSPACE_NAME,
                                                                          EmbeddedCassandra.CF_NAME,
                                                                          EmbeddedCassandra.HOSTS);
        final int batch_count = 100;

View Full Code Here

Examples of org.axonframework.serializer.xml.XStreamSerializer

        // we want to delete the directory that will store our events
        final File eventsDir = new File(System.getProperty("java.io.tmpdir"), "Events");
        FileUtils.deleteDirectory(eventsDir);


        // we create a serializer, so we can ensure the event store and the upcasters use the same configuration
        Serializer serializer = new XStreamSerializer();
        // initialize a FileSystem Event Store
        FileSystemEventStore eventStore = new FileSystemEventStore(serializer, new SimpleEventFileResolver(eventsDir));
        // initialize the upcaster chain with our upcaster
        eventStore.setUpcasterChain(new LazyUpcasterChain(serializer,
                                                          Collections.<Upcaster>singletonList(new ToDoItemUpcaster())));

View Full Code Here

Examples of org.axonframework.serializer.xml.XStreamSerializer

        testSubject = new AggregateRoot();
    }


    @Test
    public void testSerializability_GenericXStreamSerializer() throws IOException {
        XStreamSerializer serializer = new XStreamSerializer();
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        baos.write(serializer.serialize(testSubject, byte[].class).getData());


        assertEquals(0, deserialized(baos).getUncommittedEventCount());
        assertFalse(deserialized(baos).getUncommittedEvents().hasNext());
        assertNotNull(deserialized(baos).getIdentifier());

View Full Code Here

Examples of org.axonframework.serializer.xml.XStreamSerializer

        assertNotNull(deserialized2.getUncommittedEvents().next());
        assertEquals(1, deserialized2.getUncommittedEventCount());
    }


    private AggregateRoot deserialized(ByteArrayOutputStream baos) {
        XStreamSerializer serializer = new XStreamSerializer();
        return (AggregateRoot) serializer.deserialize(new SimpleSerializedObject<byte[]>(baos.toByteArray(),
                                                                                         byte[].class,
                                                                                         "ignored",
                                                                                         "0"));
    }

View Full Code Here

0 1 2 3 4 5

TOP

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.