fix: builder errors due to missing configurations

Signed-off-by: Joel Hanson <joelhanson025@gmail.com>

Author: Joel-hanson

.github/workflows/checkstyle-and-tests.yml

@@ -7,27 +7,34 @@ on:
     types: [opened, synchronize, reopened]
 
 jobs:
-  test:
-    name: Checkstyle and Tests
+  build-and-test:
+    name: Build, Checkstyle, and Test
     runs-on: ubuntu-latest
     steps:
       - name: Checkout code
         uses: actions/checkout@v3
+
       - name: Set up JDK 8
         uses: actions/setup-java@v3
         with:
           java-version: 8
           distribution: 'semeru'
+
       - name: Get java-version
         run: |
           BUILD_VERSION=$( mvn help:evaluate -Dexpression=project.version -q -DforceStdout )
           echo "VERSION=$BUILD_VERSION" >> $GITHUB_ENV
-      - name: Compile
-        run: mvn -X compile
-      - name: Checkstyle
-        run: mvn -X validate
-      - name: Test
-        run: mvn -X test
+
+      - name: Build and Test
+        run: mvn -B clean compile verify checkstyle:check
+
+      - name: Upload test results
+        uses: actions/upload-artifact@v3
+        if: always()
+        with:
+          name: test-results
+          path: target/surefire-reports
+
   verify-commits:
     name: Verify Commits
     runs-on: ubuntu-latest

.github/workflows/github-build-release.yml

@@ -8,22 +8,25 @@ name: Build and create release
 jobs:
   build:
     name: Build and upload release binary
-    #if: github.event.base_ref == 'refs/heads/master' # only run if on master branch
     runs-on: ubuntu-latest
     steps:
       - name: Checkout code
         uses: actions/checkout@v3
+
       - name: Set up JDK 8
         uses: actions/setup-java@v3
         with:
           java-version: 8
           distribution: 'semeru'
+
       - name: Get java-version
         run: |
           BUILD_VERSION=$( mvn help:evaluate -Dexpression=project.version -q -DforceStdout )
           echo "VERSION=$BUILD_VERSION" >> $GITHUB_ENV
+
       - name: Build
-        run: mvn package
+        run: mvn -B clean package
+
       - name: Create Release
         id: create_release
         uses: actions/create-release@v1
@@ -34,6 +37,7 @@ jobs:
           release_name: Release ${{ github.ref }}
           draft: false
           prerelease: false
+
       - name: Upload Release Asset With Dependencies
         id: upload-release-asset-with-dependencies
         uses: actions/upload-release-asset@v1
@@ -44,6 +48,7 @@ jobs:
           asset_path: ./target/kafka-connect-mq-sink-${{env.VERSION}}-jar-with-dependencies.jar
           asset_name: kafka-connect-mq-sink-${{env.VERSION}}-jar-with-dependencies.jar
           asset_content_type: application/java-archive
+
       - name: Upload Release Asset With non-MQ Dependencies
         id: upload-release-asset-with-dependencies-exc-mq
         uses: actions/upload-release-asset@v1
@@ -54,6 +59,7 @@ jobs:
           asset_path: ./target/kafka-connect-mq-sink-${{env.VERSION}}-dependencies-exc-mq.jar
           asset_name: kafka-connect-mq-sink-${{env.VERSION}}-dependencies-exc-mq.jar
           asset_content_type: application/java-archive
+
       - name: Upload Release Asset
         id: upload-release-asset
         uses: actions/upload-release-asset@v1

pom.xml

@@ -138,6 +138,7 @@
         <configuration>
           <source>1.8</source>
           <target>1.8</target>
+          <compilerArgument>-Xlint:unchecked</compilerArgument>
         </configuration>
       </plugin>
 
@@ -150,6 +151,9 @@
           <systemPropertyVariables>
             <connectorVersion>${project.version}</connectorVersion>
           </systemPropertyVariables>
+          <additionalClasspathElements>
+            <additionalClasspathElement>src/test/resources</additionalClasspathElement>
+          </additionalClasspathElements>
         </configuration>
       </plugin>
 
@@ -162,6 +166,9 @@
           <systemPropertyVariables>
             <connectorVersion>${project.version}</connectorVersion>
           </systemPropertyVariables>
+          <additionalClasspathElements>
+            <additionalClasspathElement>src/test/resources</additionalClasspathElement>
+          </additionalClasspathElements>
         </configuration>
         <executions>
           <execution>
@@ -346,5 +353,10 @@
         </configuration>
       </plugin>
     </plugins>
+    <testResources>
+      <testResource>
+          <directory>src/integration/resources</directory>
+      </testResource>
+    </testResources>
   </build>
 </project>

src/integration/java/com/ibm/eventstreams/connect/mqsink/AbstractJMSContextIT.java

@@ -43,6 +43,7 @@
 import org.junit.ClassRule;
 import org.testcontainers.containers.GenericContainer;
 import org.testcontainers.containers.wait.strategy.Wait;
+import org.testcontainers.utility.MountableFile;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.core.type.TypeReference;
@@ -53,7 +54,6 @@
 import com.github.dockerjava.api.model.PortBinding;
 import com.github.dockerjava.api.model.Ports;
 import com.ibm.eventstreams.connect.mqsink.util.MQRestAPIHelper;
-import com.ibm.eventstreams.connect.mqsink.utils.Configs;
 import com.ibm.mq.jms.MQConnectionFactory;
 import com.ibm.msg.client.jms.JmsConnectionFactory;
 import com.ibm.msg.client.jms.JmsFactoryFactory;
@@ -111,7 +111,10 @@ private static MQRestAPIHelper getMQRestApiHelper() {
     final public static GenericContainer<?> MQ_CONTAINER = new GenericContainer<>(MQ_IMAGE)
             .withEnv("LICENSE", "accept")
             .withEnv("MQ_QMGR_NAME", QMGR_NAME)
+            .withEnv("MQ_APP_PASSWORD", ADMIN_PASSWORD)
+            .withEnv("MQ_ADMIN_PASSWORD", ADMIN_PASSWORD)
             .withExposedPorts(TCP_MQ_EXPOSED_PORT, REST_API_EXPOSED_PORT)
+            .withCopyFileToContainer(MountableFile.forClasspathResource("no-auth-qmgr.mqsc"), "/etc/mqm/99-no-auth-qmgr.mqsc")
             .withCreateContainerCmdModifier(cmd -> cmd.withHostConfig(
                     new HostConfig().withPortBindings(
                             new PortBinding(Ports.Binding.bindPort(TCP_MQ_HOST_PORT),
@@ -155,7 +158,7 @@ public JMSContext getJmsContext() throws Exception {
             mqcf.setQueueManager(QMGR_NAME);
             mqcf.setConnectionNameList(getConnectionName());
 
-            jmsContext = mqcf.createContext();
+            jmsContext = mqcf.createContext(APP_USERNAME, ADMIN_PASSWORD);
         }
 
         return jmsContext;

src/integration/java/com/ibm/eventstreams/connect/mqsink/MQSinkTaskAuthIT.java

@@ -34,6 +34,7 @@
 import org.junit.Test;
 import org.testcontainers.containers.GenericContainer;
 import org.testcontainers.containers.wait.strategy.Wait;
+import org.testcontainers.utility.MountableFile;
 
 import com.github.dockerjava.api.model.ExposedPort;
 import com.github.dockerjava.api.model.HostConfig;
@@ -52,7 +53,9 @@ public class MQSinkTaskAuthIT {
             .withEnv("LICENSE", "accept")
             .withEnv("MQ_QMGR_NAME", AbstractJMSContextIT.QMGR_NAME)
             .withEnv("MQ_APP_PASSWORD", AbstractJMSContextIT.APP_PASSWORD)
+            .withEnv("MQ_ADMIN_PASSWORD", AbstractJMSContextIT.ADMIN_PASSWORD)
             .withExposedPorts(AbstractJMSContextIT.TCP_MQ_EXPOSED_PORT, AbstractJMSContextIT.REST_API_EXPOSED_PORT)
+            .withCopyFileToContainer(MountableFile.forClasspathResource("no-auth-qmgr.mqsc"), "/etc/mqm/99-no-auth-qmgr.mqsc")
             .withCreateContainerCmdModifier(cmd -> cmd.withHostConfig(
                     new HostConfig().withPortBindings(
                             new PortBinding(Ports.Binding.bindPort(AbstractJMSContextIT.TCP_MQ_HOST_PORT),

src/test/resources/no-auth-qmgr.mqsc

@@ -0,0 +1,3 @@
+ALTER QMGR CHLAUTH(DISABLED)
+ALTER QMGR CONNAUTH(' ')
+REFRESH SECURITY TYPE(CONNAUTH)