23 Commits
Author SHA1 Message Date
brian.long 23f426ab43 v1.0.11 pom 2025-09-24 12:19:37 -04:00
brian.long 212801f489 Merge branch 'develop' into stable 2025-09-24 12:13:20 -04:00
brian.long bf6ba664f5 v1.0.10 2025-03-18 14:35:29 -04:00
brian.long d5fe8e3176 Merge branch 'develop' into stable 2025-03-18 14:35:10 -04:00
brian.long 893596898b v1.0.9 pom 2025-03-11 12:22:44 -04:00
brian.long 61c552fdd2 Merge branch 'develop' into stable 2025-03-11 12:22:26 -04:00
brian.long e3d49c2811 v1.0.8 pom 2025-02-24 15:33:11 -05:00
brian.long 5234aad45d Merge branch 'develop' into stable 2025-02-24 15:32:48 -05:00
brian.long 8b90e42614 v1.0.7 pom 2025-02-21 09:36:27 -05:00
brian.long 1d98e90e97 Merge branch 'develop' into stable 2025-02-21 09:36:12 -05:00
brian.long 7a5065419a v1.0.6 pom 2025-02-20 13:10:24 -05:00
brian.long d3c79cac9c Merge branch 'develop' into stable 2025-02-20 13:10:05 -05:00
brian.long dfb24cbd1f v1.0.5 pom 2025-02-19 11:59:39 -05:00
brian.long 7a67634cfb Merge branch 'develop' into stable 2025-02-19 11:59:12 -05:00
brian.long 969d7661cf v1.0.4 pom 2025-02-14 15:52:23 -05:00
brian.long fbca940d7a Merge branch 'develop' into stable 2025-02-14 15:52:06 -05:00
brian.long fd142e709e v1.0.3 pom 2025-02-14 11:25:59 -05:00
brian.long 98ee188595 Merge branch 'develop' into stable 2025-02-14 11:25:41 -05:00
brian.long bdbda54743 v1.0.2 pom 2025-02-13 15:58:45 -05:00
brian.long 8d91166a01 Merge branch 'develop' into stable 2025-02-13 15:58:12 -05:00
brian.long 370b385aea v1.0.1 pom 2025-02-13 15:08:24 -05:00
brian.long 82b4c500d5 Merge branch 'develop' into stable 2025-02-12 15:16:48 -05:00
brian.long 90ac5540df v1.0.0 poms 2025-02-11 17:37:28 -05:00
21 changed files with 246 additions and 134 deletions
+2 -6
View File
@@ -5,7 +5,7 @@
<groupId>com.inteligr8.activiti</groupId> <groupId>com.inteligr8.activiti</groupId>
<artifactId>mq-activiti-ext-parent</artifactId> <artifactId>mq-activiti-ext-parent</artifactId>
<version>1.1-SNAPSHOT</version> <version>1.0.0</version>
<packaging>pom</packaging> <packaging>pom</packaging>
<name>MQ Activiti Extension Parent</name> <name>MQ Activiti Extension Parent</name>
@@ -79,12 +79,8 @@
<distributionManagement> <distributionManagement>
<repository> <repository>
<id>inteligr8-private</id> <id>inteligr8-releases</id>
<url>https://repos.inteligr8.com/nexus/repository/inteligr8-private/</url> <url>https://repos.inteligr8.com/nexus/repository/inteligr8-private/</url>
</repository> </repository>
<snapshotRepository>
<id>inteligr8-snapshots</id>
<url>https://repos.inteligr8.com/nexus/repository/inteligr8-private-snapshots/</url>
</snapshotRepository>
</distributionManagement> </distributionManagement>
</project> </project>
+199 -83
View File
@@ -6,11 +6,12 @@
<parent> <parent>
<groupId>com.inteligr8.activiti</groupId> <groupId>com.inteligr8.activiti</groupId>
<artifactId>mq-activiti-ext-parent</artifactId> <artifactId>mq-activiti-ext-parent</artifactId>
<version>1.1-SNAPSHOT</version> <version>1.0.0</version>
<relativePath>parent/pom.xml</relativePath> <relativePath>parent/pom.xml</relativePath>
</parent> </parent>
<artifactId>mq-activiti-ext</artifactId> <artifactId>mq-activiti-ext</artifactId>
<version>1.0.11</version>
<packaging>jar</packaging> <packaging>jar</packaging>
<name>MQ Activiti Extension</name> <name>MQ Activiti Extension</name>
@@ -21,49 +22,28 @@
<maven.compiler.target>11</maven.compiler.target> <maven.compiler.target>11</maven.compiler.target>
<maven.compiler.release>11</maven.compiler.release> <maven.compiler.release>11</maven.compiler.release>
<aps.version>26.2.0</aps.version>
<!-- see versions: https://mvnrepository.com/artifact/com.rabbitmq/amqp-client -->
<rabbitmq.version>5.34.0</rabbitmq.version>
<!-- see versions: https://mvnrepository.com/artifact/org.apache.activemq/activemq-client -->
<activemq.version>6.3.0</activemq.version>
<!-- see versions: https://mvnrepository.com/artifact/org.apache.activemq/artemis-jms-client -->
<activemq.jms.version>2.55.0</activemq.jms.version>
<!-- for testing only -->
<spring.version>6.2.5</spring.version>
<tomcat-rad.version>10-2.2</tomcat-rad.version>
<aps.docker-tag>docker.inteligr8.com/inteligr8/alfresco-process-services</aps.docker-tag> <aps.docker-tag>docker.inteligr8.com/inteligr8/alfresco-process-services</aps.docker-tag>
<aps.version>25.1.1</aps.version>
<spring.version>6.2.5</spring.version>
<activiti.version>8.1.3</activiti.version>
<tomcat-rad.version>10-2.2</tomcat-rad.version>
<aps.tomcat.opts>-Dinteligr8.mq.connectors.docker-mq.url=failover:\(tcp://${project.artifactId}-mq:61616\)?timeout=3000 -Dinteligr8.mq.connectors.docker-mq.username=admin -Dinteligr8.mq.connectors.docker-mq.password=admin -Dvalidator.editor.dmn.espression=false -Dvalidator.editor.bpmn.disable.scripttask=false -Djavascript.secure-scripting.enabled=false -Djavascript.secure-scripting.enable-class-whitelisting=false -Dbeans.whitelisting.enabled=false -Del.whitelisting.enabled=false -Dshell.whitelisting.enabled=false</aps.tomcat.opts> <aps.tomcat.opts>-Dinteligr8.mq.connectors.docker-mq.url=failover:\(tcp://${project.artifactId}-mq:61616\)?timeout=3000 -Dinteligr8.mq.connectors.docker-mq.username=admin -Dinteligr8.mq.connectors.docker-mq.password=admin -Dvalidator.editor.dmn.espression=false -Dvalidator.editor.bpmn.disable.scripttask=false -Djavascript.secure-scripting.enabled=false -Djavascript.secure-scripting.enable-class-whitelisting=false -Dbeans.whitelisting.enabled=false -Del.whitelisting.enabled=false -Dshell.whitelisting.enabled=false</aps.tomcat.opts>
<activemq.httpPort>8161</activemq.httpPort>
<!-- reloads in APS are slower than a restart --> <!-- reloads in APS are slower than a restart -->
<aps.hotswap.enabled>false</aps.hotswap.enabled> <aps.hotswap.enabled>false</aps.hotswap.enabled>
<rabbitmq.version>5.18.0</rabbitmq.version>
<activemq.version>5.18.7</activemq.version>
<activemq.jms.version>2.42.0</activemq.jms.version>
<activemq.httpPort>8161</activemq.httpPort>
</properties> </properties>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>com.activiti</groupId>
<artifactId>activiti-app-root</artifactId>
<version>${aps.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>com.activiti</groupId>
<artifactId>activiti-app</artifactId>
<version>${aps.version}</version>
<classifier>classes</classifier>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies> <dependencies>
<!-- APS and Activiti --> <!-- APS and Activiti -->
<dependency> <dependency>
<groupId>com.activiti</groupId> <groupId>com.activiti</groupId>
<artifactId>activiti-app-rest</artifactId> <artifactId>activiti-app-rest</artifactId>
<version>${aps.version}</version>
<scope>provided</scope> <scope>provided</scope>
<!-- none of these are needed for builds --> <!-- none of these are needed for builds -->
@@ -78,6 +58,26 @@
<groupId>com.activiti</groupId> <groupId>com.activiti</groupId>
<artifactId>aspose-transformation</artifactId> <artifactId>aspose-transformation</artifactId>
</exclusion> </exclusion>
<exclusion>
<!-- avoiding log4j-api vulnerabilities -->
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
</exclusion>
<exclusion>
<!-- avoiding old spring-context-support -->
<groupId>com.ryantenney.metrics</groupId>
<artifactId>metrics-spring</artifactId>
</exclusion>
<exclusion>
<!-- avoiding old spring-* versions -->
<groupId>org.activiti</groupId>
<artifactId>activiti-spring</artifactId>
</exclusion>
<exclusion>
<!-- avoiding old tomcat-* versions -->
<groupId>org.apache.tomcat.embed</groupId>
<artifactId>*</artifactId>
</exclusion>
</exclusions> </exclusions>
</dependency> </dependency>
<!-- This can help with debugging in IDE; never do RAD or compile with it --> <!-- This can help with debugging in IDE; never do RAD or compile with it -->
@@ -85,8 +85,15 @@
<dependency> <dependency>
<groupId>com.activiti</groupId> <groupId>com.activiti</groupId>
<artifactId>activiti-app</artifactId> <artifactId>activiti-app</artifactId>
<version>${aps.version}</version>
<classifier>classes</classifier> <classifier>classes</classifier>
<scope>provided</scope> <scope>provided</scope>
<exclusions>
<exclusion>
<groupId>*</groupId>
<artifactId>*</artifactId>
</exclusion>
</exclusions>
</dependency> </dependency>
--> -->
@@ -101,11 +108,31 @@
<groupId>org.apache.activemq</groupId> <groupId>org.apache.activemq</groupId>
<artifactId>activemq-client</artifactId> <artifactId>activemq-client</artifactId>
<version>${activemq.version}</version> <version>${activemq.version}</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>*</artifactId>
</exclusion>
</exclusions>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.apache.artemis</groupId> <groupId>org.apache.activemq</groupId>
<artifactId>artemis-jms-client</artifactId> <artifactId>artemis-jms-client</artifactId>
<version>${activemq.jms.version}</version> <version>${activemq.jms.version}</version>
<exclusions>
<exclusion>
<groupId>commons-collections</groupId>
<artifactId>commons-collections</artifactId>
</exclusion>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>*</artifactId>
</exclusion>
<exclusion>
<groupId>commons-beanutils</groupId>
<artifactId>*</artifactId>
</exclusion>
</exclusions>
</dependency> </dependency>
<!-- Testing only --> <!-- Testing only -->
@@ -141,7 +168,7 @@
<!-- avoids log4j dependency --> <!-- avoids log4j dependency -->
<plugin> <plugin>
<artifactId>maven-compiler-plugin</artifactId> <artifactId>maven-compiler-plugin</artifactId>
<version>3.14.1</version> <version>3.13.0</version>
</plugin> </plugin>
<!-- avoids struts and vulnerable jetty dependency --> <!-- avoids struts and vulnerable jetty dependency -->
<plugin> <plugin>
@@ -150,29 +177,18 @@
</plugin> </plugin>
<plugin> <plugin>
<artifactId>maven-surefire-plugin</artifactId> <artifactId>maven-surefire-plugin</artifactId>
<version>3.5.4</version> <version>3.5.2</version>
</plugin> </plugin>
<plugin> <plugin>
<artifactId>maven-failsafe-plugin</artifactId> <artifactId>maven-failsafe-plugin</artifactId>
<version>3.5.4</version> <version>3.5.2</version>
</plugin>
<plugin>
<artifactId>maven-assembly-plugin</artifactId>
<version>3.7.1</version>
</plugin>
<plugin>
<artifactId>maven-shade-plugin</artifactId>
<version>3.6.1</version>
</plugin>
<plugin>
<artifactId>maven-deploy-plugin</artifactId>
<version>3.1.4</version>
</plugin> </plugin>
</plugins> </plugins>
</pluginManagement> </pluginManagement>
<plugins> <plugins>
<plugin> <plugin>
<artifactId>maven-assembly-plugin</artifactId> <artifactId>maven-assembly-plugin</artifactId>
<version>3.7.1</version>
<executions> <executions>
<execution> <execution>
<id>package-stencil</id> <id>package-stencil</id>
@@ -200,29 +216,51 @@
</plugin> </plugin>
<plugin> <plugin>
<artifactId>maven-shade-plugin</artifactId> <artifactId>maven-shade-plugin</artifactId>
</plugin> <version>3.6.0</version>
<plugin>
<artifactId>maven-failsafe-plugin</artifactId>
<executions> <executions>
<execution> <execution>
<goals> <id>shade-deps</id>
<goal>integration-test</goal> <phase>package</phase>
<goal>verify</goal> <goals><goal>shade</goal></goals>
</goals> <configuration>
<shadedArtifactAttached>true</shadedArtifactAttached>
<relocations>
<relocation>
<shadedPattern>shaded.mq.</shadedPattern>
<excludes>
<!-- anything in the root directory of a JAR -->
<exclude>*</exclude>
<!-- anything in the META-INF directory of a JAR -->
<exclude>META-INF/**</exclude>
<!-- anything developed in this extension -->
<exclude>com.activiti.extension.**</exclude>
<exclude>com.inteligr8.activiti.mq.**</exclude>
</excludes>
</relocation>
</relocations>
</configuration>
</execution> </execution>
</executions> </executions>
</plugin> </plugin>
<plugin>
<artifactId>maven-failsafe-plugin</artifactId>
<configuration>
<includes>
<include>**/*IT.java</include>
</includes>
</configuration>
</plugin>
<plugin> <plugin>
<groupId>io.repaint.maven</groupId> <groupId>io.repaint.maven</groupId>
<artifactId>tiles-maven-plugin</artifactId> <artifactId>tiles-maven-plugin</artifactId>
<version>2.45</version> <version>2.40</version>
<extensions>true</extensions> <extensions>true</extensions>
<configuration> <configuration>
<tiles> <tiles>
<!-- Documentation: https://bitbucket.org/inteligr8/ootbee-beedk/src/stable/beedk-aps-ext-rad-tile --> <!-- Documentation: https://bitbucket.org/inteligr8/ootbee-beedk/src/stable/beedk-aps-ext-rad-tile -->
<tile>com.inteligr8.ootbee:beedk-aps-ext-rad-tile:1.1-SNAPSHOT</tile> <tile>com.inteligr8.ootbee:beedk-aps-ext-rad-tile:[1.1,1.1.999)</tile>
<!-- Documentation: https://bitbucket.org/inteligr8/ootbee-beedk/src/stable/beedk-aps-ext-it-tile --> <!-- Documentation: https://bitbucket.org/inteligr8/ootbee-beedk/src/stable/beedk-aps-ext-it-tile -->
<tile>com.inteligr8.ootbee:beedk-aps-ext-it-tile:1.1-SNAPSHOT</tile> <tile>com.inteligr8.ootbee:beedk-aps-ext-it-tile:[1.1,1.1.999)</tile>
</tiles> </tiles>
</configuration> </configuration>
</plugin> </plugin>
@@ -290,38 +328,109 @@
<aps.timeout>90000</aps.timeout> <!-- tests do some delays --> <aps.timeout>90000</aps.timeout> <!-- tests do some delays -->
</properties> </properties>
</profile> </profile>
<profile>
<id>apidoc</id>
<build>
<plugins>
<plugin>
<artifactId>maven-clean-plugin</artifactId>
<configuration>
<filesets>
<fileset>
<directory>${basedir}/apidocs</directory>
</fileset>
</filesets>
</configuration>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-javadoc-plugin</artifactId>
<version>3.8.0</version>
<executions>
<execution>
<id>generate-doclet</id>
<phase>generate-resources</phase>
<goals><goal>javadoc</goal></goals>
<configuration>
<doclet>com.inteligr8.activiti.doclet.ActivitiDoclet</doclet>
<docletArtifact>
<groupId>com.inteligr8.activiti</groupId>
<artifactId>activiti-api-doclet</artifactId>
<version>1.1.0</version>
</docletArtifact>
<useStandardDocletOptions>false</useStandardDocletOptions>
<destDir>apidocs</destDir>
<reportOutputDirectory>${basedir}</reportOutputDirectory>
<additionalOptions>
<additionalOption>--title 'API Documentation'</additionalOption>
<additionalOption>--apiName '${project.name}</additionalOption>
</additionalOptions>
<!-- This is required in maven-javadoc-plugin v3.5+ -->
<sourceFileIncludes>**/*.java</sourceFileIncludes>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
</profile>
<profile> <profile>
<id>bundle</id> <id>ossrh-release</id>
<properties>
<maven.deploy.skip>true</maven.deploy.skip>
</properties>
<build> <build>
<plugins> <plugins>
<plugin> <plugin>
<artifactId>maven-shade-plugin</artifactId> <artifactId>maven-source-plugin</artifactId>
<executions>
<execution>
<id>source</id>
<phase>package</phase>
<goals><goal>jar-no-fork</goal></goals>
</execution>
</executions>
</plugin>
<plugin>
<artifactId>maven-javadoc-plugin</artifactId>
<executions>
<execution>
<id>javadoc</id>
<phase>package</phase>
<goals><goal>jar</goal></goals>
<configuration>
<show>public</show>
</configuration>
</execution>
</executions>
</plugin>
<plugin>
<artifactId>maven-gpg-plugin</artifactId>
<executions>
<execution>
<id>sign</id>
<phase>verify</phase>
<goals><goal>sign</goal></goals>
</execution>
</executions>
</plugin>
<plugin>
<groupId>org.sonatype.plugins</groupId>
<artifactId>nexus-staging-maven-plugin</artifactId>
<version>1.7.0</version>
<configuration> <configuration>
<!-- this seems to do nothing; using `filters` --> <serverId>ossrh</serverId>
<artifactSet> <nexusUrl>https://s01.oss.sonatype.org/</nexusUrl>
<excludes> <autoReleaseAfterClose>true</autoReleaseAfterClose>
<exclude>commons-beanutils:commons-beanutils</exclude>
<exclude>commons-collections:commons-collections</exclude>
<exclude>commons-logging:commons-logging</exclude>
<exclude>org.slf4j:*</exclude>
</excludes>
</artifactSet>
<relocations>
<relocation>
<shadedPattern>shaded.mq.</shadedPattern>
<excludes>
<!-- anything in the root directory of a JAR -->
<exclude>*</exclude>
<!-- anything in the META-INF directory of a JAR -->
<exclude>META-INF/**</exclude>
<!-- anything developed in this extension -->
<exclude>com.activiti.extension.**</exclude>
<exclude>com.inteligr8.activiti.mq.**</exclude>
</excludes>
</relocation>
</relocations>
</configuration> </configuration>
<executions>
<execution>
<id>ossrh-deploy</id>
<phase>deploy</phase>
<goals><goal>deploy</goal></goals>
</execution>
</executions>
</plugin> </plugin>
</plugins> </plugins>
</build> </build>
@@ -338,4 +447,11 @@
<url>https://artifacts.alfresco.com/nexus/content/repositories/activiti-enterprise-releases</url> <url>https://artifacts.alfresco.com/nexus/content/repositories/activiti-enterprise-releases</url>
</repository> </repository>
</repositories> </repositories>
<distributionManagement>
<repository>
<id>inteligr8-releases</id>
<url>https://repos.inteligr8.com/nexus/repository/inteligr8-private/</url>
</repository>
</distributionManagement>
</project> </project>
@@ -6,7 +6,7 @@ import java.util.HashMap;
import java.util.Map; import java.util.Map;
import java.util.concurrent.TimeoutException; import java.util.concurrent.TimeoutException;
import jakarta.jms.JMSException; import javax.jms.JMSException;
import org.activiti.engine.delegate.JavaDelegate; import org.activiti.engine.delegate.JavaDelegate;
import org.slf4j.Logger; import org.slf4j.Logger;
@@ -2,8 +2,8 @@ package com.inteligr8.activiti.mq;
import java.util.List; import java.util.List;
import jakarta.annotation.PostConstruct; import javax.annotation.PostConstruct;
import jakarta.annotation.PreDestroy; import javax.annotation.PreDestroy;
import org.activiti.engine.ProcessEngine; import org.activiti.engine.ProcessEngine;
import org.activiti.engine.delegate.event.ActivitiEntityEvent; import org.activiti.engine.delegate.event.ActivitiEntityEvent;
@@ -1,9 +1,9 @@
package com.inteligr8.activiti.mq; package com.inteligr8.activiti.mq;
import jakarta.jms.JMSException; import javax.jms.JMSException;
import jakarta.jms.Queue; import javax.jms.Queue;
import jakarta.jms.Session; import javax.jms.Session;
import jakarta.jms.Topic; import javax.jms.Topic;
public class GenericDestination { public class GenericDestination {
@@ -4,7 +4,7 @@ import java.net.URI;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import jakarta.jms.JMSException; import javax.jms.JMSException;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -3,7 +3,7 @@ package com.inteligr8.activiti.mq;
import java.io.IOException; import java.io.IOException;
import java.util.concurrent.TimeoutException; import java.util.concurrent.TimeoutException;
import jakarta.jms.JMSException; import javax.jms.JMSException;
import com.inteligr8.activiti.mq.model.DeliveredMessage; import com.inteligr8.activiti.mq.model.DeliveredMessage;
import com.inteligr8.activiti.mq.model.PreparedMessage; import com.inteligr8.activiti.mq.model.PreparedMessage;
@@ -3,7 +3,7 @@ package com.inteligr8.activiti.mq;
import java.io.IOException; import java.io.IOException;
import java.util.concurrent.TimeoutException; import java.util.concurrent.TimeoutException;
import jakarta.jms.JMSException; import javax.jms.JMSException;
import org.activiti.engine.ProcessEngine; import org.activiti.engine.ProcessEngine;
import org.activiti.engine.delegate.BpmnError; import org.activiti.engine.delegate.BpmnError;
@@ -3,7 +3,7 @@ package com.inteligr8.activiti.mq;
import java.io.IOException; import java.io.IOException;
import java.util.concurrent.TimeoutException; import java.util.concurrent.TimeoutException;
import jakarta.jms.JMSException; import javax.jms.JMSException;
import org.activiti.engine.ProcessEngine; import org.activiti.engine.ProcessEngine;
import org.activiti.engine.delegate.BpmnError; import org.activiti.engine.delegate.BpmnError;
@@ -3,7 +3,7 @@ package com.inteligr8.activiti.mq;
import java.io.IOException; import java.io.IOException;
import java.util.concurrent.TimeoutException; import java.util.concurrent.TimeoutException;
import jakarta.jms.JMSException; import javax.jms.JMSException;
import org.activiti.engine.ProcessEngine; import org.activiti.engine.ProcessEngine;
import org.activiti.engine.delegate.BpmnError; import org.activiti.engine.delegate.BpmnError;
@@ -6,7 +6,7 @@ import java.util.Map;
import java.util.regex.Matcher; import java.util.regex.Matcher;
import java.util.regex.Pattern; import java.util.regex.Pattern;
import jakarta.annotation.PostConstruct; import javax.annotation.PostConstruct;
import org.activiti.bpmn.model.BpmnModel; import org.activiti.bpmn.model.BpmnModel;
import org.activiti.bpmn.model.FlowElement; import org.activiti.bpmn.model.FlowElement;
@@ -8,7 +8,7 @@ import java.util.Collections;
import java.util.UUID; import java.util.UUID;
import java.util.concurrent.TimeoutException; import java.util.concurrent.TimeoutException;
import jakarta.jms.JMSException; import javax.jms.JMSException;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -6,7 +6,7 @@ import java.nio.channels.Channels;
import java.nio.channels.ReadableByteChannel; import java.nio.channels.ReadableByteChannel;
import java.util.Date; import java.util.Date;
import jakarta.jms.DeliveryMode; import javax.jms.DeliveryMode;
import org.apache.commons.io.IOUtils; import org.apache.commons.io.IOUtils;
import org.jgroups.util.UUID; import org.jgroups.util.UUID;
@@ -3,8 +3,8 @@ package com.inteligr8.activiti.mq.jms;
import java.io.IOException; import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import jakarta.jms.BytesMessage; import javax.jms.BytesMessage;
import jakarta.jms.JMSException; import javax.jms.JMSException;
public class BytesMessageInputStream extends InputStream { public class BytesMessageInputStream extends InputStream {
@@ -3,8 +3,8 @@ package com.inteligr8.activiti.mq.jms;
import java.io.IOException; import java.io.IOException;
import java.io.OutputStream; import java.io.OutputStream;
import jakarta.jms.BytesMessage; import javax.jms.BytesMessage;
import jakarta.jms.JMSException; import javax.jms.JMSException;
public class BytesMessageOutputStream extends OutputStream { public class BytesMessageOutputStream extends OutputStream {
@@ -3,12 +3,12 @@ package com.inteligr8.activiti.mq.jms;
import java.io.IOException; import java.io.IOException;
import java.util.concurrent.TimeoutException; import java.util.concurrent.TimeoutException;
import jakarta.jms.Connection; import javax.jms.Connection;
import jakarta.jms.JMSException; import javax.jms.JMSException;
import jakarta.jms.Message; import javax.jms.Message;
import jakarta.jms.MessageConsumer; import javax.jms.MessageConsumer;
import jakarta.jms.MessageProducer; import javax.jms.MessageProducer;
import jakarta.jms.Session; import javax.jms.Session;
import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.ActiveMQConnectionFactory;
import org.slf4j.Logger; import org.slf4j.Logger;
@@ -7,14 +7,14 @@ import java.time.OffsetDateTime;
import java.time.ZoneOffset; import java.time.ZoneOffset;
import java.util.Enumeration; import java.util.Enumeration;
import jakarta.jms.BytesMessage; import javax.jms.BytesMessage;
import jakarta.jms.Destination; import javax.jms.Destination;
import jakarta.jms.JMSException; import javax.jms.JMSException;
import jakarta.jms.Message; import javax.jms.Message;
import jakarta.jms.Queue; import javax.jms.Queue;
import jakarta.jms.StreamMessage; import javax.jms.StreamMessage;
import jakarta.jms.TextMessage; import javax.jms.TextMessage;
import jakarta.jms.Topic; import javax.jms.Topic;
import org.apache.commons.io.IOUtils; import org.apache.commons.io.IOUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
@@ -4,12 +4,12 @@ import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import java.util.Map.Entry; import java.util.Map.Entry;
import jakarta.jms.BytesMessage; import javax.jms.BytesMessage;
import jakarta.jms.DeliveryMode; import javax.jms.DeliveryMode;
import jakarta.jms.JMSException; import javax.jms.JMSException;
import jakarta.jms.Message; import javax.jms.Message;
import jakarta.jms.Session; import javax.jms.Session;
import jakarta.jms.StreamMessage; import javax.jms.StreamMessage;
import org.apache.commons.io.IOUtils; import org.apache.commons.io.IOUtils;
import org.jgroups.util.UUID; import org.jgroups.util.UUID;
@@ -3,8 +3,8 @@ package com.inteligr8.activiti.mq.jms;
import java.io.IOException; import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import jakarta.jms.JMSException; import javax.jms.JMSException;
import jakarta.jms.StreamMessage; import javax.jms.StreamMessage;
public class StreamMessageInputStream extends InputStream { public class StreamMessageInputStream extends InputStream {
@@ -3,8 +3,8 @@ package com.inteligr8.activiti.mq.jms;
import java.io.IOException; import java.io.IOException;
import java.io.OutputStream; import java.io.OutputStream;
import jakarta.jms.JMSException; import javax.jms.JMSException;
import jakarta.jms.StreamMessage; import javax.jms.StreamMessage;
public class StreamMessageOutputStream extends OutputStream { public class StreamMessageOutputStream extends OutputStream {
@@ -5,8 +5,8 @@ import java.net.URI;
import java.time.OffsetDateTime; import java.time.OffsetDateTime;
import java.util.concurrent.TimeoutException; import java.util.concurrent.TimeoutException;
import jakarta.annotation.PostConstruct; import javax.annotation.PostConstruct;
import jakarta.jms.JMSException; import javax.jms.JMSException;
import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;