Add null check in convert methode
Signed-off-by: SirWayne <dennis.melzer@bosch-si.com>
This commit is contained in:
@@ -47,6 +47,9 @@ public class BaseAmqpService {
|
|||||||
*/
|
*/
|
||||||
@SuppressWarnings("unchecked")
|
@SuppressWarnings("unchecked")
|
||||||
protected <T> T convertMessage(final Message message, final Class<T> clazz) {
|
protected <T> T convertMessage(final Message message, final Class<T> clazz) {
|
||||||
|
if (message == null) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
message.getMessageProperties().getHeaders().put(AbstractJavaTypeMapper.DEFAULT_CLASSID_FIELD_NAME,
|
message.getMessageProperties().getHeaders().put(AbstractJavaTypeMapper.DEFAULT_CLASSID_FIELD_NAME,
|
||||||
clazz.getTypeName());
|
clazz.getTypeName());
|
||||||
return (T) messageConverter.fromMessage(message);
|
return (T) messageConverter.fromMessage(message);
|
||||||
|
|||||||
Reference in New Issue
Block a user