v1.0.3 pom

pom.xml

@@ -5,7 +5,7 @@
 	
 	<groupId>com.inteligr8.alfresco</groupId>
 	<artifactId>annotations-platform-module</artifactId>
-	<version>1.0.0</version>
+	<version>1.0.3</version>
 	<packaging>jar</packaging>
 	
 	<name>Annotations ACS Platform Module</name>
@@ -72,8 +72,16 @@
 		<dependency>
 			<groupId>com.inteligr8.alfresco</groupId>
 			<artifactId>aspectj-platform-module</artifactId>
-			<version>1.0.0</version>
+			<version>1.0.1</version>
-			<scope>provided</scope>
+			<type>amp</type>
+		</dependency>
+		
+		<!-- AMP resources are included in the WAR, not the extension directory; this makes aspectjweaver available to javaagent -->
+		<dependency>
+			<groupId>org.aspectj</groupId>
+			<artifactId>aspectjweaver</artifactId>
+			<version>${aspectj.version}</version>
+			<scope>test</scope>
 		</dependency>
 	</dependencies>
 

src/main/java/com/inteligr8/alfresco/annotations/TransactionalWrapper.java

@@ -0,0 +1,113 @@
+package com.inteligr8.alfresco.annotations;
+
+import java.lang.reflect.Method;
+
+import org.springframework.transaction.annotation.Isolation;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+public class TransactionalWrapper {
+	
+	private Transactional stxl = null;
+	private javax.transaction.Transactional jtxl = null;
+	
+	public TransactionalWrapper(Transactional txl) {
+		this.stxl = txl;
+	}
+	
+	public TransactionalWrapper(javax.transaction.Transactional txl) {
+		this.jtxl = txl;
+	}
+	
+	public static TransactionalWrapper wrap(Method method) {
+		Transactional stxl = method.getAnnotation(Transactional.class);
+		javax.transaction.Transactional jtxl = method.getAnnotation(javax.transaction.Transactional.class);
+		if (stxl == null && jtxl == null) {
+			return null;
+		} else if (stxl != null) {
+			return new TransactionalWrapper(stxl);
+		} else if (jtxl != null) {
+			return new TransactionalWrapper(jtxl);
+		} else {
+			throw new IllegalStateException("This should never happen");
+		}
+	}
+	
+	public boolean isReadOnly() {
+		if (this.stxl != null) {
+			return this.stxl.readOnly();
+		} else if (this.jtxl != null) {
+			return false;
+		} else {
+			throw new IllegalStateException("This should never happen");
+		}
+	}
+	
+	public Propagation getPropagation() {
+		if (this.stxl != null) {
+			return this.stxl.propagation();
+		} else if (this.jtxl != null) {
+			switch (this.jtxl.value()) {
+				case MANDATORY:
+					return Propagation.MANDATORY;
+				case REQUIRED:
+					return Propagation.REQUIRED;
+				case REQUIRES_NEW:
+					return Propagation.REQUIRES_NEW;
+				case SUPPORTS:
+					return Propagation.SUPPORTS;
+				case NOT_SUPPORTED:
+					return Propagation.NOT_SUPPORTED;
+				case NEVER:
+					return Propagation.NEVER;
+				default:
+					throw new IllegalStateException("This should never happen");
+			}
+		} else {
+			throw new IllegalStateException("This should never happen");
+		}
+	}
+	
+	public Isolation getIsolation() {
+		if (this.stxl != null) {
+			return this.stxl.isolation();
+		} else if (this.jtxl != null) {
+			return Isolation.DEFAULT;
+		} else {
+			throw new IllegalStateException("This should never happen");
+		}
+	}
+	
+	public int getTimeoutInSeconds() {
+		if (this.stxl != null) {
+			return this.stxl.timeout();
+		} else if (this.jtxl != null) {
+			return 0;
+		} else {
+			throw new IllegalStateException("This should never happen");
+		}
+	}
+	
+	@SuppressWarnings("unchecked")
+	public Class<? extends Throwable>[] getRollbackFor() {
+		if (this.stxl != null) {
+			return this.stxl.rollbackFor();
+		} else if (this.jtxl != null) {
+			return this.jtxl.rollbackOn();
+		} else {
+			throw new IllegalStateException("This should never happen");
+		}
+	}
+	
+	@SuppressWarnings("unchecked")
+	public Class<? extends Throwable>[] getNoRollbackFor() {
+		if (this.stxl != null) {
+			return this.stxl.noRollbackFor();
+		} else if (this.jtxl != null) {
+			return this.jtxl.dontRollbackOn();
+		} else {
+			throw new IllegalStateException("This should never happen");
+		}
+	}
+
+}

src/main/java/com/inteligr8/alfresco/annotations/aspect/RetryingTransactionAspect.java

@@ -17,9 +17,9 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.IllegalTransactionStateException;
-import org.springframework.transaction.annotation.Transactional;
 
 import com.inteligr8.alfresco.annotations.TransactionalRetryable;
+import com.inteligr8.alfresco.annotations.TransactionalWrapper;
 
 /**
  * This aspect implements the @Transactional and @TransactionalRetryable
@@ -50,20 +50,24 @@ public class RetryingTransactionAspect {
 	public void isTransactionalAnnotated() {
 	}
 	
+	@Pointcut("@annotation(javax.transaction.Transactional) && execution(* *(..))")
+	public void isJtaTransactionalAnnotated() {
+	}
+	
 	@Pointcut("@annotation(com.inteligr8.alfresco.annotations.TransactionalRetryable) && execution(* *(..))")
 	public void isTransactionalRetryableAnnotated() {
 	}
 	
-	@Around("isTransactionalAnnotated() || isTransactionalRetryableAnnotated()")
+	@Around("isTransactionalAnnotated() || isJtaTransactionalAnnotated() || isTransactionalRetryableAnnotated()")
 	public Object retryingTransactional(ProceedingJoinPoint joinPoint) throws Throwable {
 		this.logger.trace("retryingTransactional({})", joinPoint);
 		
 		Method method = this.getMethod(joinPoint);
-		Transactional txl = method.getAnnotation(Transactional.class);
+		TransactionalWrapper txl = TransactionalWrapper.wrap(method);
 		TransactionalRetryable txtry = method.getAnnotation(TransactionalRetryable.class);
 		
 		if (this.doCreateNewTxContext(txl) || this.isReadStateChange(txl)) {
-			this.logger.debug("Changing TX context: {} => [ro: {}, new: {}]", AlfrescoTransactionSupport.getTransactionReadState(), txl.readOnly(), txl.propagation());
+			this.logger.debug("Changing TX context: {} => [ro: {}, new: {}]", AlfrescoTransactionSupport.getTransactionReadState(), txl.isReadOnly(), txl.getPropagation());
 			return this.execute(joinPoint, txl, txtry);
 		} else if (this.doCreateNewTxRetryContext(txtry)) {
 			this.logger.debug("Changing TX context: retries: {}", txtry.maxRetries());
@@ -81,11 +85,11 @@ public class RetryingTransactionAspect {
 		return methodSig.getMethod();
 	}
 	
-	private boolean isReadStateChange(Transactional txl) {
+	private boolean isReadStateChange(TransactionalWrapper txl) {
 		if (txl == null)
 			return false;
 		
-		switch (txl.propagation()) {
+		switch (txl.getPropagation()) {
 			case NEVER:
 			case NOT_SUPPORTED:
 			case SUPPORTS:
@@ -98,9 +102,9 @@ public class RetryingTransactionAspect {
 			case TXN_NONE:
 				return true;
 			case TXN_READ_ONLY:
-				return !txl.readOnly();
+				return !txl.isReadOnly();
 			case TXN_READ_WRITE:
-				return txl.readOnly();
+				return txl.isReadOnly();
 			default:
 				throw new IllegalStateException();
 		}
@@ -110,10 +114,10 @@ public class RetryingTransactionAspect {
 		return txtry != null;
 	}
 	
-	private boolean doCreateNewTxContext(Transactional txl) {
+	private boolean doCreateNewTxContext(TransactionalWrapper txl) {
 		if (txl == null) {
 			return false;
-		} else switch (txl.propagation()) {
+		} else switch (txl.getPropagation()) {
 			case NEVER:
 				switch (AlfrescoTransactionSupport.getTransactionReadState()) {
 					case TXN_NONE:
@@ -126,14 +130,20 @@ public class RetryingTransactionAspect {
 					case TXN_NONE:
 						throw new IllegalTransactionStateException("A transaction does not exist where one is mandatory");
 					case TXN_READ_ONLY:
-						if (!txl.readOnly())
+						if (!txl.isReadOnly())
 							throw new IllegalTransactionStateException("A read-only transaction exists where a read/write one is mandatory");
 					case TXN_READ_WRITE:
-						if (txl.readOnly())
+						if (txl.isReadOnly())
 							throw new IllegalTransactionStateException("A read/write transaction exists where a read-only one is mandatory");
 				}
+			case NOT_SUPPORTED:
+				switch (AlfrescoTransactionSupport.getTransactionReadState()) {
+					case TXN_NONE:
+						return false;
+					default:
+						throw new IllegalTransactionStateException("A transaction exists and pausing it is not supported");
+				}
 			case SUPPORTS:
-			//case NOT_SUPPORTED:  not supported; we would have to create another thread to simulate
 				return false;
 			case REQUIRED:
 				switch (AlfrescoTransactionSupport.getTransactionReadState()) {
@@ -145,11 +155,11 @@ public class RetryingTransactionAspect {
 			case REQUIRES_NEW:
 				return true;
 			default:
-				throw new IllegalTransactionStateException("The transactional propagation is not supported: " + txl.propagation());
+				throw new IllegalTransactionStateException("The transactional propagation is not supported: " + txl.getPropagation());
 		}
 	}
 	
-	private Object execute(final ProceedingJoinPoint joinPoint, Transactional txl, TransactionalRetryable txtry) throws Throwable {
+	private Object execute(final ProceedingJoinPoint joinPoint, TransactionalWrapper txl, TransactionalRetryable txtry) throws Throwable {
 		RetryingTransactionCallback<Object> rtcallback = new RetryingTransactionCallback<Object>() {
 			@Override
 			public Object execute() throws Throwable {
@@ -179,12 +189,12 @@ public class RetryingTransactionAspect {
 			if (txtry.incRetryWaitInMillis() > 0)
 				rthelper.setRetryWaitIncrementMs(txtry.incRetryWaitInMillis());
 		}
-		if (txl != null && txl.timeout() > 0)
+		if (txl != null && txl.getTimeoutInSeconds() > 0)
-			rthelper.setMaxExecutionMs(txl.timeout() * 1000L);
+			rthelper.setMaxExecutionMs(txl.getTimeoutInSeconds() * 1000L);
 		
 		try {
 			this.logger.trace("source tx: {}", AlfrescoTransactionSupport.getTransactionId());
-			boolean readonly = txl != null && txl.readOnly() || txl == null && AlfrescoTransactionSupport.getTransactionReadState() == TxnReadState.TXN_READ_ONLY;
+			boolean readonly = txl != null && txl.isReadOnly() || txl == null && AlfrescoTransactionSupport.getTransactionReadState() == TxnReadState.TXN_READ_ONLY;
 			return rthelper.doInTransaction(rtcallback, readonly, txl != null);
 		} catch (RuntimeException re) {
 			// attempt to unwrap the exception

src/main/java/com/inteligr8/alfresco/annotations/service/impl/MqAsyncService.java

@@ -9,6 +9,15 @@ import java.lang.reflect.Method;
 import java.lang.reflect.Parameter;
 import java.net.InetAddress;
 import java.net.UnknownHostException;
+import java.time.Instant;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.time.OffsetDateTime;
+import java.time.OffsetTime;
+import java.time.ZonedDateTime;
+import java.time.format.DateTimeFormatter;
+import java.time.temporal.Temporal;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collection;
@@ -478,8 +487,29 @@ public class MqAsyncService extends AbstractLifecycleBean implements AsyncServic
 	private Object unmarshal(Parameter param, Object arg) throws NoSuchMethodException, IllegalAccessException, InvocationTargetException, InstantiationException {
     	Class<?> paramType = param.getType();
 		this.logger.trace("Unmarshaling parameter of type: {}", paramType);
-    	
+
-		if (Version.class.isAssignableFrom(paramType)) {
+    	if (arg instanceof String || arg instanceof Number || arg instanceof Boolean) {
+			this.logger.trace("Unmarshaling primitive: {}", arg);
+			return arg;
+    	} else if (Temporal.class.isAssignableFrom(paramType)) {
+    		if (OffsetDateTime.class.isAssignableFrom(paramType)) {
+    			return OffsetDateTime.from(DateTimeFormatter.ISO_OFFSET_DATE_TIME.parse(arg.toString()));
+    		} else if (ZonedDateTime.class.isAssignableFrom(paramType)) {
+    			return ZonedDateTime.from(DateTimeFormatter.ISO_ZONED_DATE_TIME.parse(arg.toString()));
+    		} else if (LocalDate.class.isAssignableFrom(paramType)) {
+    			return LocalDate.from(DateTimeFormatter.ISO_LOCAL_DATE.parse(arg.toString()));
+    		} else if (LocalDateTime.class.isAssignableFrom(paramType)) {
+    			return LocalDateTime.from(DateTimeFormatter.ISO_LOCAL_DATE_TIME.parse(arg.toString()));
+    		} else if (Instant.class.isAssignableFrom(paramType)) {
+    			return Instant.from(DateTimeFormatter.ISO_INSTANT.parse(arg.toString()));
+    		} else if (LocalTime.class.isAssignableFrom(paramType)) {
+    			return LocalTime.from(DateTimeFormatter.ISO_LOCAL_TIME.parse(arg.toString()));
+    		} else if (OffsetTime.class.isAssignableFrom(paramType)) {
+    			return OffsetTime.from(DateTimeFormatter.ISO_OFFSET_TIME.parse(arg.toString()));
+    		} else {
+    			throw new UnsupportedOperationException();
+    		}
+    	} else if (Version.class.isAssignableFrom(paramType)) {
 			this.logger.trace("Unmarshaling as JSON object: {}", arg);
 			Map<String, Object> argMap = (Map<String, Object>) this.om.convertValue(arg, Map.class);
 			
@@ -515,13 +545,22 @@ public class MqAsyncService extends AbstractLifecycleBean implements AsyncServic
 			return cons.invoke(null, arg.toString());
 		} else {
 			this.logger.trace("Unmarshaling as POJO: {}", arg);
-			Constructor<?> cons = paramType.getConstructor(String.class);
+			try {
-			return cons.newInstance(arg.toString());
+				Constructor<?> cons = paramType.getConstructor(String.class);
+				return cons.newInstance(arg.toString());
+			} catch (NoSuchMethodException nsme) {
+				Method method = paramType.getDeclaredMethod("valueOf", String.class);
+				return method.invoke(null, arg.toString());
+			}
 		}
     }
     
     private Object marshal(Object arg) {
-		if (arg instanceof Version) {
+    	if (arg instanceof String || arg instanceof Number || arg instanceof Boolean) {
+    		return arg;
+    	} else if (arg instanceof Temporal) {
+    		return arg.toString();
+    	} else if (arg instanceof Version) {
 			Version version = (Version) arg;
 			Map<String, Object> map = new HashMap<>();
 			map.put("nodeRef", version.getFrozenStateNodeRef());
@@ -555,7 +594,8 @@ public class MqAsyncService extends AbstractLifecycleBean implements AsyncServic
 			this.logger.trace("Marshaling Java Map as JSON object: {}", map);
 			return this.om.convertValue(map, String.class);
 		} else {
-			return arg;
+			this.logger.trace("Marshaling Java object as JSON object: {}", arg);
+			return this.om.convertValue(arg, String.class);
 		}
     }
     

src/main/java/com/inteligr8/alfresco/annotations/util/MapUtils.java

@@ -0,0 +1,32 @@
+package com.inteligr8.alfresco.annotations.util;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.alfresco.util.Pair;
+
+public class MapUtils {
+	
+	public static <K, V> Map<K, V> build(Pair<K, V>... pairs) {
+		Map<K, V> map = new HashMap<>();
+		for (Pair<K, V> pair : pairs) {
+			map.put(pair.getFirst(), pair.getSecond());
+		}
+		
+		return map;
+	}
+	
+	public static Map<String, String> build(String... keyValuePairs) {
+		if (keyValuePairs.length % 2 == 1)
+			throw new IllegalArgumentException();
+		
+		Map<String, String> map = new HashMap<>();
+		for (int pair = 0; pair < keyValuePairs.length / 2; pair++) {
+			int base = pair * 2;
+			map.put(keyValuePairs[base], keyValuePairs[base + 1]);
+		}
+		
+		return map;
+	}
+
+}

src/main/resources/alfresco/module/com_inteligr8_alfresco_annotations-platform-module/module.properties

@@ -6,4 +6,4 @@ module.version=${project.version}
 module.repo.version.min=6.0
 #module.repo.version.max=
 
-module.depends.aspectj-platform-module=1.0-*
+module.depends.com.inteligr8.alfresco.aspectj-platform-module=1.0-*