@@ -8,6 +8,9 @@
|
|||||||
*/
|
*/
|
||||||
package org.eclipse.hawkbit.amqp;
|
package org.eclipse.hawkbit.amqp;
|
||||||
|
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.Collections;
|
||||||
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
@@ -55,6 +58,27 @@ public class BaseAmqpService {
|
|||||||
return (T) messageConverter.fromMessage(message);
|
return (T) messageConverter.fromMessage(message);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Is needed to convert a incoming message to is originally object type.
|
||||||
|
*
|
||||||
|
* @param message
|
||||||
|
* the message to convert.
|
||||||
|
* @param clazz
|
||||||
|
* the class of the originally object.
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
|
protected <T> List<T> convertMessageList(final Message message, final Class<T> clazz) {
|
||||||
|
if (message == null) {
|
||||||
|
return Collections.emptyList();
|
||||||
|
}
|
||||||
|
message.getMessageProperties().getHeaders().put(AbstractJavaTypeMapper.DEFAULT_CLASSID_FIELD_NAME,
|
||||||
|
ArrayList.class);
|
||||||
|
message.getMessageProperties().getHeaders().put(AbstractJavaTypeMapper.DEFAULT_CONTENT_CLASSID_FIELD_NAME,
|
||||||
|
clazz.getTypeName());
|
||||||
|
return (List<T>) messageConverter.fromMessage(message);
|
||||||
|
}
|
||||||
|
|
||||||
protected String getStringHeaderKey(final Message message, final String key, final String errorMessageIfNull) {
|
protected String getStringHeaderKey(final Message message, final String key, final String errorMessageIfNull) {
|
||||||
final Map<String, Object> header = message.getMessageProperties().getHeaders();
|
final Map<String, Object> header = message.getMessageProperties().getHeaders();
|
||||||
final Object value = header.get(key);
|
final Object value = header.get(key);
|
||||||
|
|||||||
Reference in New Issue
Block a user