Package org.axonframework.serializer

Examples of org.axonframework.serializer.ConverterFactory

63
64
65
66
67
68
69
70
71
72
73
    public void testUpcastObject_NoTypeConversionRequired() {
        Upcaster mockUpcaster12 = new StubUpcaster<byte[]>(intermediate1.getType(), intermediate2, byte[].class);
        Upcaster mockUpcasterFake = mock(Upcaster.class, "Fake upcaster");
        Upcaster mockUpcaster23 = new StubUpcaster<byte[]>(intermediate2.getType(), intermediate3, byte[].class);

        final ConverterFactory converterFactory = mock(ConverterFactory.class);
        UpcasterChain chain = createUpcasterChain(converterFactory, mockUpcaster12, mockUpcasterFake, mockUpcaster23);

        List<SerializedObject> actual1 = chain.upcast(object1, upcastingContext);
        assertEquals(object3.getType(), actual1.get(0).getType());
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
        SerializedObject intermediate2_stream = new MockIntermediateRepresentation(object2,
                                                                                   InputStream.class);
        Upcaster mockUpcaster12 = new StubUpcaster<InputStream>(intermediate1.getType(), intermediate2_stream,
                                                                InputStream.class);

        ConverterFactory mockConverterFactory = mock(ConverterFactory.class);
        ContentTypeConverter mockByteToStreamConverter = mock(ContentTypeConverter.class);
        ContentTypeConverter mockStreamToByteConverter = mock(ContentTypeConverter.class);
        when(mockConverterFactory.getConverter(byte[].class, InputStream.class)).thenReturn(mockByteToStreamConverter);
        when(mockConverterFactory.getConverter(InputStream.class, byte[].class)).thenReturn(mockStreamToByteConverter);

        when(mockByteToStreamConverter.expectedSourceType()).thenReturn(byte[].class);
        when(mockStreamToByteConverter.targetType()).thenReturn(InputStream.class);
        when(mockByteToStreamConverter.convert(isA(SerializedObject.class)))
                .thenReturn(intermediate1_stream);
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
128
129
    }

    @Test
    public void testUpcastObject_UnavailableTypeConversion() {
        Upcaster mockUpcaster12 = new StubUpcaster(intermediate1.getType(), intermediate2, Document.class);
        ConverterFactory mockConverterFactory = mock(ConverterFactory.class);
        CannotConvertBetweenTypesException mockException = new CannotConvertBetweenTypesException("Mock");
        when(mockConverterFactory.getConverter(isA(Class.class), isA(Class.class))).thenThrow(
                mockException);

        UpcasterChain chain = createUpcasterChain(mockConverterFactory, mockUpcaster12);
        try {
            chain.upcast(object1, upcastingContext);
View Full Code Here
135
136
137
138
139
140
141
142
143
144
145
    @Test
    public void testUpcastObjectToMultipleObjects() {
        Upcaster mockUpcaster = new StubUpcaster(intermediate1.getType(), byte[].class, intermediate2, intermediate3);

        final ConverterFactory converterFactory = mock(ConverterFactory.class);
        UpcasterChain chain = createUpcasterChain(converterFactory, mockUpcaster);
        List<SerializedObject> upcastedObjects = chain.upcast(object1, upcastingContext);

        assertEquals(2, upcastedObjects.size());
        assertEquals(intermediate2.getData(), upcastedObjects.get(0).getData());
View Full Code Here
TOP

Related Classes of org.axonframework.serializer.ConverterFactory

  • org.axonframework.upcasting.UpcasterChainTest
    • 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.