Package org.openiam.common.beans.mq.converter

Class OpenIAMRabbitMQMessageConverter

java.lang.Object

org.openiam.common.beans.mq.converter.OpenIAMRabbitMQMessageConverter

All Implemented Interfaces:

org.springframework.amqp.support.converter.MessageConverter

public class OpenIAMRabbitMQMessageConverter
extends Object
implements org.springframework.amqp.support.converter.MessageConverter

Author:

zaporozhec OpenIAM message converter for rabbitmq messaging this converter is used to convert messages with content_type=application/x-openiam-encrypted-object alg is the following. java object is serialized to binary and after it's encrypted with provided alghoritm Cryptor by default AES Cryptor is used.

Method Summary

Modifier and Type	Method	Description
Object	fromMessage(org.springframework.amqp.core.Message message)
org.springframework.amqp.core.Message	toMessage(Object objectToConvert, org.springframework.amqp.core.MessageProperties messageProperties)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.amqp.support.converter.MessageConverter

toMessage

Method Detail

fromMessage

public Object fromMessage(org.springframework.amqp.core.Message message)
                   throws org.springframework.amqp.support.converter.MessageConversionException

Specified by:

fromMessage in interface org.springframework.amqp.support.converter.MessageConverter

Throws:

org.springframework.amqp.support.converter.MessageConversionException

toMessage

public org.springframework.amqp.core.Message toMessage(Object objectToConvert,
                                                       org.springframework.amqp.core.MessageProperties messageProperties)
                                                throws org.springframework.amqp.support.converter.MessageConversionException

Specified by:

toMessage in interface org.springframework.amqp.support.converter.MessageConverter

Throws:

org.springframework.amqp.support.converter.MessageConversionException