inteligr8/alfresco-transform-core
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-transform-core.git synced 2025-10-01 14:41:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Save point: [skip ci]

Browse Source 
* tidy up
This commit is contained in:
alandavis
2022-07-27 17:45:44 +01:00
parent e9c149a440
commit 67f4fadcc4
15 changed files with 48 additions and 68 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
engines/base/src/main/java/org/alfresco/transform/base/QueueTransformService.java
View File

@@ -139,8 +139,7 @@ public class QueueTransformService
{
try
{
TransformRequest request = (TransformRequest) transformMessageConverter
.fromMessage(msg);
TransformRequest request = (TransformRequest) transformMessageConverter.fromMessage(msg);
return Optional.ofNullable(request);
}
catch (MessageConversionException e)

17
engines/base/src/main/java/org/alfresco/transform/base/messaging/TransformMessageConverter.java
View File

@@ -27,14 +27,11 @@
package org.alfresco.transform.base.messaging;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import com.fasterxml.jackson.databind.JavaType;
import com.fasterxml.jackson.databind.type.TypeFactory;
import com.google.common.collect.ImmutableMap;
import org.alfresco.transform.client.model.TransformReply;
import org.alfresco.transform.client.model.TransformRequest;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jms.support.converter.MappingJackson2MessageConverter;
import org.springframework.jms.support.converter.MessageConversionException;
import org.springframework.jms.support.converter.MessageConverter;
@@ -42,9 +39,9 @@ import org.springframework.jms.support.converter.MessageType;
import org.springframework.lang.NonNull;
import org.springframework.stereotype.Service;
import com.fasterxml.jackson.databind.JavaType;
import com.fasterxml.jackson.databind.type.TypeFactory;
import com.google.common.collect.ImmutableMap;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
/**
* TODO: Duplicated from the Router
@@ -55,8 +52,6 @@ import com.google.common.collect.ImmutableMap;
@Service
public class TransformMessageConverter implements MessageConverter
{
private static final Logger logger = LoggerFactory.getLogger(TransformMessageConverter.class);
private static final MappingJackson2MessageConverter converter;
private static final JavaType TRANSFORM_REQUEST_TYPE =
TypeFactory.defaultInstance().constructType(TransformRequest.class);

7
engines/base/src/main/java/org/alfresco/transform/base/messaging/TransformReplySender.java
View File

@@ -60,14 +60,17 @@ public class TransformReplySender
{
if (destination != null)
{
try {
try
{
//jmsTemplate.setSessionTransacted(true); // do we need this?
jmsTemplate.convertAndSend(destination, reply, m -> {
m.setJMSCorrelationID(correlationId);
return m;
});
logger.trace("Sent: {} - with correlation ID {}", reply, correlationId);
} catch (Exception e) {
}
catch (Exception e)
{
logger.error("Failed to send T-Reply " + reply + " - for correlation ID " + correlationId, e);
}
}

7
engines/base/src/test/java/org/alfresco/transform/base/SourceTarget.java
View File

@@ -29,6 +29,8 @@ package org.alfresco.transform.base;
import java.util.Objects;
/**
* Source & Target media type pair
*
* @author Cezar Leahu
*/
public class SourceTarget
@@ -65,11 +67,6 @@ public class SourceTarget
}
public static SourceTarget of(final String source, final String target)
{
return sourceTarget(source, target);
}
public static SourceTarget sourceTarget(final String source, final String target)
{
return new SourceTarget(source, target);
}