List of readEventMessage() Examples

Examples of readEventMessage()

org.axonframework.eventhandling.io.EventMessageReader.readEventMessage()

Reads an EventMessage from the underlying input. If the written event was a DomainEventMessage, an instance of DomainEventMessage is returned. @param < T> The type of payload expected to be in the returned EventMessage. This is not checked at runtime! @return an EventMessage representing the message originally written, or null if the stream hasreached the end @throws IOException when an error occurs reading from the underlying input @throws java.io.EOFException when the end of the stream was reached before the message was entirely read @throws org.axonframework.serializer.UnknownSerializedTypeException if the type of the serialized object cannot be resolved to a class

    @Override
    public EventMessage readAMQPMessage(byte[] messageBody, Map<String, Object> headers) {
        try {
            EventMessageReader in = new EventMessageReader(new DataInputStream(new ByteArrayInputStream(messageBody)),
                                                           serializer);
            return in.readEventMessage();
        } catch (IOException e) {
            // ByteArrayInputStream doesn't throw IOException... anyway...
            throw new EventPublicationFailedException("Failed to deserialize an EventMessage", e);
        }
    }

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.

Examples of readEventMessage()

Examples of org.axonframework.eventhandling.io.EventMessageReader.readEventMessage()