Stream binder package/gid rename

Signed-off-by: Anders Swanson <anders.swanson@oracle.com>

Author: anders-swanson

database/spring-cloud-stream-binder-oracle-txeventq/README.md

@@ -29,7 +29,7 @@ mvn integration-test
 To use in an application project, add the following dependencies apart from regular spring-cloud-stream project dependencies:
 ```
 <dependency>
-	<groupId>com.oracle.database.spring.cloud.stream.binder</groupId>
+	<groupId>com.oracle.database.spring.cloudstreambinder</groupId>
 	<artifactId>spring-cloud-stream-binder-oracle-txeventq</artifactId>
 	<version>0.9.0</version>
 </dependency>

database/spring-cloud-stream-binder-oracle-txeventq/pom.xml

@@ -1,7 +1,7 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
-    <groupId>com.oracle.database.spring.cloud.stream.binder</groupId>
+    <groupId>com.oracle.database.spring.cloudstreambinder</groupId>
     <artifactId>spring-cloud-stream-binder-oracle-txeventq</artifactId>
     <version>0.9.0</version>
     <packaging>jar</packaging>

database/spring-cloud-stream-binder-oracle-txeventq/samples/MultipleConsumerTest.java

@@ -1,4 +1,4 @@
-package com.oracle.database.spring.cloud.stream.binder;
+package com.oracle.database.spring.cloudstreambinder;
 
 import java.util.function.Consumer;
 import java.util.function.Supplier;

database/spring-cloud-stream-binder-oracle-txeventq/scripts/deploy

@@ -48,5 +48,5 @@ echo "Successfully deployed project to ${REPOSITORY_URL}/${REPOSITORY_NAME}"
 PACKAGES="$(mvn -Dexec.executable='echo' -Dexec.args='${project.artifactId}' exec:exec -q)"
 printf "The following artifacts have been created for upload:\n\n"
 for PACKAGE in $PACKAGES; do
-  echo "com.oracle.database.spring.cloud.stream.binder:${PACKAGE}:${VERSION}"
+  echo "com.oracle.database.spring.cloudstreambinder:${PACKAGE}:${VERSION}"
 done

database/spring-cloud-stream-binder-oracle-txeventq/spring-cloud-stream-binder-txeventq-sample/pom.xml

@@ -3,7 +3,7 @@
     <!-- Copyright (c) 2024, Oracle and/or its affiliates. -->
     <!-- Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl. -->
     <modelVersion>4.0.0</modelVersion>
-    <groupId>com.oracle.database.spring.cloud.stream.binder</groupId>
+    <groupId>com.oracle.database.spring.cloudstreambinder</groupId>
     <artifactId>spring-cloud-stream-binder-txeventq-sample</artifactId>
     <version>1.0.0</version>
     <packaging>jar</packaging>
@@ -52,7 +52,7 @@
 
     <dependencies>
         <dependency>
-            <groupId>com.oracle.database.spring.cloud.stream.binder</groupId>
+            <groupId>com.oracle.database.spring.cloudstreambinder</groupId>
             <artifactId>spring-cloud-stream-binder-oracle-txeventq</artifactId>
             <version>${txeventq.streambinder.version}</version>
         </dependency>

database/spring-cloud-stream-binder-oracle-txeventq/spring-cloud-stream-binder-txeventq-sample/src/main/java/com/oracle/database/spring/cloud/stream/binder/sample/StreamConfiguration.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/spring-cloud-stream-binder-txeventq-sample/src/main/java/com/oracle/database/spring/cloudstreambinder/sample/StreamConfiguration.java

@@ -1,6 +1,6 @@
 // Copyright (c) 2024, Oracle and/or its affiliates.
 // Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl.
-package com.oracle.database.spring.cloud.stream.binder.sample;
+package com.oracle.database.spring.cloudstreambinder.sample;
 
 import java.util.function.Consumer;
 import java.util.function.Function;

database/spring-cloud-stream-binder-oracle-txeventq/spring-cloud-stream-binder-txeventq-sample/src/main/java/com/oracle/database/spring/cloud/stream/binder/sample/TxEventQSampleApp.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/spring-cloud-stream-binder-txeventq-sample/src/main/java/com/oracle/database/spring/cloudstreambinder/sample/TxEventQSampleApp.java

@@ -1,6 +1,6 @@
 // Copyright (c) 2024, Oracle and/or its affiliates.
 // Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl.
-package com.oracle.database.spring.cloud.stream.binder.sample;
+package com.oracle.database.spring.cloudstreambinder.sample;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;

database/spring-cloud-stream-binder-oracle-txeventq/spring-cloud-stream-binder-txeventq-sample/src/main/java/com/oracle/database/spring/cloud/stream/binder/sample/WordSupplier.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/spring-cloud-stream-binder-txeventq-sample/src/main/java/com/oracle/database/spring/cloudstreambinder/sample/WordSupplier.java

@@ -1,4 +1,4 @@
-package com.oracle.database.spring.cloud.stream.binder.sample;
+package com.oracle.database.spring.cloudstreambinder.sample;
 
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicInteger;

database/spring-cloud-stream-binder-oracle-txeventq/spring-cloud-stream-binder-txeventq-sample/src/test/java/com/oracle/database/spring/cloud/stream/binder/sample/TxEventQSampleAppTest.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/spring-cloud-stream-binder-txeventq-sample/src/test/java/com/oracle/database/spring/cloudstreambinder/sample/TxEventQSampleAppTest.java

@@ -1,6 +1,6 @@
 // Copyright (c) 2024, Oracle and/or its affiliates.
 // Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl.
-package com.oracle.database.spring.cloud.stream.binder.sample;
+package com.oracle.database.spring.cloudstreambinder.sample;
 
 import java.time.Duration;
 

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/JMSMessageChannelBinder.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/JMSMessageChannelBinder.java

@@ -23,18 +23,18 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder;
+package com.oracle.database.spring.cloudstreambinder;
 
-import com.oracle.database.spring.cloud.stream.binder.config.JmsConsumerProperties;
-import com.oracle.database.spring.cloud.stream.binder.config.JmsExtendedBindingProperties;
-import com.oracle.database.spring.cloud.stream.binder.config.JmsProducerProperties;
-import com.oracle.database.spring.cloud.stream.binder.provisioning.JmsConsumerDestination;
-import com.oracle.database.spring.cloud.stream.binder.provisioning.JmsProducerDestination;
+import com.oracle.database.spring.cloudstreambinder.config.JmsConsumerProperties;
+import com.oracle.database.spring.cloudstreambinder.config.JmsExtendedBindingProperties;
+import com.oracle.database.spring.cloudstreambinder.config.JmsProducerProperties;
+import com.oracle.database.spring.cloudstreambinder.provisioning.JmsConsumerDestination;
+import com.oracle.database.spring.cloudstreambinder.provisioning.JmsProducerDestination;
 
 
-import com.oracle.database.spring.cloud.stream.binder.utils.DestinationNameResolver;
-import com.oracle.database.spring.cloud.stream.binder.utils.JmsMessageDrivenChannelAdapterFactory;
-import com.oracle.database.spring.cloud.stream.binder.utils.JmsSendingMessageHandlerFactory;
+import com.oracle.database.spring.cloudstreambinder.utils.DestinationNameResolver;
+import com.oracle.database.spring.cloudstreambinder.utils.JmsMessageDrivenChannelAdapterFactory;
+import com.oracle.database.spring.cloudstreambinder.utils.JmsSendingMessageHandlerFactory;
 import jakarta.jms.Connection;
 import jakarta.jms.ConnectionFactory;
 import jakarta.jms.Session;

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/TxEventQQueueProvisioner.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/TxEventQQueueProvisioner.java

@@ -22,13 +22,13 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder;
+package com.oracle.database.spring.cloudstreambinder;
 
-import com.oracle.database.spring.cloud.stream.binder.config.JmsConsumerProperties;
-import com.oracle.database.spring.cloud.stream.binder.config.JmsProducerProperties;
-import com.oracle.database.spring.cloud.stream.binder.plsql.OracleDBUtils;
-import com.oracle.database.spring.cloud.stream.binder.provisioning.JmsConsumerDestination;
-import com.oracle.database.spring.cloud.stream.binder.provisioning.JmsProducerDestination;
+import com.oracle.database.spring.cloudstreambinder.config.JmsConsumerProperties;
+import com.oracle.database.spring.cloudstreambinder.config.JmsProducerProperties;
+import com.oracle.database.spring.cloudstreambinder.plsql.OracleDBUtils;
+import com.oracle.database.spring.cloudstreambinder.provisioning.JmsConsumerDestination;
+import com.oracle.database.spring.cloudstreambinder.provisioning.JmsProducerDestination;
 import jakarta.jms.Connection;
 import jakarta.jms.ConnectionFactory;
 import jakarta.jms.JMSException;

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/config/JmsBinderAutoConfiguration.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/config/JmsBinderAutoConfiguration.java

@@ -23,7 +23,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.config;
+package com.oracle.database.spring.cloudstreambinder.config;
 
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.cloud.stream.binder.Binder;

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/config/JmsBinderGlobalConfiguration.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/config/JmsBinderGlobalConfiguration.java

@@ -22,17 +22,17 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.config;
-
-import com.oracle.database.spring.cloud.stream.binder.JMSMessageChannelBinder;
-import com.oracle.database.spring.cloud.stream.binder.utils.Base64UrlNamingStrategy;
-import com.oracle.database.spring.cloud.stream.binder.utils.DestinationNameResolver;
-import com.oracle.database.spring.cloud.stream.binder.utils.JmsMessageDrivenChannelAdapterFactory;
-import com.oracle.database.spring.cloud.stream.binder.utils.JmsSendingMessageHandlerFactory;
-import com.oracle.database.spring.cloud.stream.binder.utils.ListenerContainerFactory;
-import com.oracle.database.spring.cloud.stream.binder.utils.MessageRecoverer;
-import com.oracle.database.spring.cloud.stream.binder.utils.RepublishMessageRecoverer;
-import com.oracle.database.spring.cloud.stream.binder.utils.SpecCompliantJmsHeaderMapper;
+package com.oracle.database.spring.cloudstreambinder.config;
+
+import com.oracle.database.spring.cloudstreambinder.JMSMessageChannelBinder;
+import com.oracle.database.spring.cloudstreambinder.utils.Base64UrlNamingStrategy;
+import com.oracle.database.spring.cloudstreambinder.utils.DestinationNameResolver;
+import com.oracle.database.spring.cloudstreambinder.utils.JmsMessageDrivenChannelAdapterFactory;
+import com.oracle.database.spring.cloudstreambinder.utils.JmsSendingMessageHandlerFactory;
+import com.oracle.database.spring.cloudstreambinder.utils.ListenerContainerFactory;
+import com.oracle.database.spring.cloudstreambinder.utils.MessageRecoverer;
+import com.oracle.database.spring.cloudstreambinder.utils.RepublishMessageRecoverer;
+import com.oracle.database.spring.cloudstreambinder.utils.SpecCompliantJmsHeaderMapper;
 import jakarta.jms.ConnectionFactory;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/config/JmsBindingProperties.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/config/JmsBindingProperties.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.config;
+package com.oracle.database.spring.cloudstreambinder.config;
 
 import org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider;
 

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/config/JmsConsumerProperties.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/config/JmsConsumerProperties.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.config;
+package com.oracle.database.spring.cloudstreambinder.config;
 
 public class JmsConsumerProperties {
     private static final String DEFAULT_DLQ_NAME = "Spring_Cloud_Stream_dlq";

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/config/JmsExtendedBindingProperties.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/config/JmsExtendedBindingProperties.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.config;
+package com.oracle.database.spring.cloudstreambinder.config;
 
 import java.util.Map;
 

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/config/JmsProducerProperties.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/config/JmsProducerProperties.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.config;
+package com.oracle.database.spring.cloudstreambinder.config;
 
 public class JmsProducerProperties {
     private String serializer = null;

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/config/TxEventQJmsConfiguration.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/config/TxEventQJmsConfiguration.java

@@ -22,10 +22,10 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.config;
+package com.oracle.database.spring.cloudstreambinder.config;
 
-import com.oracle.database.spring.cloud.stream.binder.TxEventQQueueProvisioner;
-import com.oracle.database.spring.cloud.stream.binder.plsql.OracleDBUtils;
+import com.oracle.database.spring.cloudstreambinder.TxEventQQueueProvisioner;
+import com.oracle.database.spring.cloudstreambinder.plsql.OracleDBUtils;
 
 import jakarta.jms.ConnectionFactory;
 import jakarta.jms.JMSException;

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/plsql/OracleDBUtils.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/plsql/OracleDBUtils.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.plsql;
+package com.oracle.database.spring.cloudstreambinder.plsql;
 
 import java.sql.CallableStatement;
 import java.sql.Connection;

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/provisioning/JmsConsumerDestination.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/provisioning/JmsConsumerDestination.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.provisioning;
+package com.oracle.database.spring.cloudstreambinder.provisioning;
 
 import org.springframework.cloud.stream.provisioning.ConsumerDestination;
 

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/provisioning/JmsProducerDestination.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/provisioning/JmsProducerDestination.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.provisioning;
+package com.oracle.database.spring.cloudstreambinder.provisioning;
 
 import jakarta.jms.JMSException;
 import jakarta.jms.Topic;

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/serialize/CustomSerializationMessageConverter.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/serialize/CustomSerializationMessageConverter.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.serialize;
+package com.oracle.database.spring.cloudstreambinder.serialize;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -66,8 +66,8 @@ public Object fromMessage(Message jmsMessage) throws JMSException {
         }
 
         if (!isInstanceOfDeserializer) {
-            logger.debug("The configured deserializer class is not an instance of 'com.oracle.database.spring.cloud.stream.binder.serialize.DeSerializer'");
-            throw new IllegalArgumentException("The configured serializer class is not an instance of 'com.oracle.database.spring.cloud.stream.binder.serialize.DeSerializer'");
+            logger.debug("The configured deserializer class is not an instance of 'com.oracle.database.spring.cloudstreambinder.serialize.DeSerializer'");
+            throw new IllegalArgumentException("The configured serializer class is not an instance of 'com.oracle.database.spring.cloudstreambinder.serialize.DeSerializer'");
         }
 
         Deserializer<?> s = null;

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/serialize/Deserializer.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/serialize/Deserializer.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.serialize;
+package com.oracle.database.spring.cloudstreambinder.serialize;
 
 public interface Deserializer<T> {
     T deserialize(byte[] bytes);

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/serialize/Serializer.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/serialize/Serializer.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.serialize;
+package com.oracle.database.spring.cloudstreambinder.serialize;
 
 public interface Serializer {
     byte[] serialize(Object data);

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/utils/AnonymousNamingStrategy.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/utils/AnonymousNamingStrategy.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.utils;
+package com.oracle.database.spring.cloudstreambinder.utils;
 
 public interface AnonymousNamingStrategy {
 

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/utils/Base64UrlNamingStrategy.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/utils/Base64UrlNamingStrategy.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.utils;
+package com.oracle.database.spring.cloudstreambinder.utils;
 
 import java.nio.ByteBuffer;
 import java.util.Base64;

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/utils/DestinationNameResolver.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/utils/DestinationNameResolver.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.utils;
+package com.oracle.database.spring.cloudstreambinder.utils;
 
 import org.springframework.util.StringUtils;
 

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/utils/JmsMessageDrivenChannelAdapter.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/utils/JmsMessageDrivenChannelAdapter.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.utils;
+package com.oracle.database.spring.cloudstreambinder.utils;
 
 import org.springframework.beans.BeansException;
 import org.springframework.context.ApplicationContext;

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/utils/JmsMessageDrivenChannelAdapterFactory.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/utils/JmsMessageDrivenChannelAdapterFactory.java

@@ -22,10 +22,10 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.utils;
+package com.oracle.database.spring.cloudstreambinder.utils;
 
-import com.oracle.database.spring.cloud.stream.binder.config.JmsConsumerProperties;
-import com.oracle.database.spring.cloud.stream.binder.serialize.CustomSerializationMessageConverter;
+import com.oracle.database.spring.cloudstreambinder.config.JmsConsumerProperties;
+import com.oracle.database.spring.cloudstreambinder.serialize.CustomSerializationMessageConverter;
 
 import jakarta.jms.BytesMessage;
 import jakarta.jms.Destination;

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/utils/JmsSendingMessageHandlerFactory.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/utils/JmsSendingMessageHandlerFactory.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.utils;
+package com.oracle.database.spring.cloudstreambinder.utils;
 
 import org.springframework.beans.BeansException;
 import org.springframework.beans.factory.BeanFactory;

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/utils/ListenerContainerFactory.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/utils/ListenerContainerFactory.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.utils;
+package com.oracle.database.spring.cloudstreambinder.utils;
 
 import jakarta.jms.ConnectionFactory;
 import jakarta.jms.Destination;

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/utils/MessageRecoverer.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/utils/MessageRecoverer.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.utils;
+package com.oracle.database.spring.cloudstreambinder.utils;
 
 import jakarta.jms.Message;
 

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/utils/PartitionAwareJmsSendingMessageHandler.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/utils/PartitionAwareJmsSendingMessageHandler.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.utils;
+package com.oracle.database.spring.cloudstreambinder.utils;
 
 import jakarta.jms.Destination;
 import jakarta.jms.JMSException;
@@ -39,7 +39,7 @@
 import org.springframework.messaging.MessageChannel;
 import org.springframework.messaging.support.ErrorMessage;
 
-import com.oracle.database.spring.cloud.stream.binder.serialize.Serializer;
+import com.oracle.database.spring.cloudstreambinder.serialize.Serializer;
 
 public class PartitionAwareJmsSendingMessageHandler
         extends AbstractMessageHandler
@@ -119,8 +119,8 @@ protected void jmsHandleMessageInternal(Message<?> message) {
             }
 
             if (!isInstanceOfSerializer) {
-                logger.debug("The configured serializer class is not an instance of 'com.oracle.database.spring.cloud.stream.binder.serialize.Serializer'");
-                throw new IllegalArgumentException("The configured serializer class is not an instance of 'com.oracle.database.spring.cloud.stream.binder.serialize.Serializer'");
+                logger.debug("The configured serializer class is not an instance of 'com.oracle.database.spring.cloudstreambinder.serialize.Serializer'");
+                throw new IllegalArgumentException("The configured serializer class is not an instance of 'com.oracle.database.spring.cloudstreambinder.serialize.Serializer'");
             }
             Serializer s = null;
 

database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloud/stream/binder/utils/RepublishMessageRecoverer.java renamed to database/spring-cloud-stream-binder-oracle-txeventq/src/main/java/com/oracle/database/spring/cloudstreambinder/utils/RepublishMessageRecoverer.java

@@ -22,7 +22,7 @@
  * limitations under the License.
  */
 
-package com.oracle.database.spring.cloud.stream.binder.utils;
+package com.oracle.database.spring.cloudstreambinder.utils;
 
 import jakarta.jms.JMSException;
 import jakarta.jms.Message;