changed version to alpha

Demo_Application/pulsar_test_receiver/config/connectivity/UserConnectivity/UserConnectivity.plugins.yaml

@@ -9,8 +9,8 @@ connectivityPlugins:
       - ${MY_WORK}/protobuf-shaded-2.1.0-incubating.jar
       - ${MY_WORK}/pulsar-client-2.2.0.jar
       - ${MY_WORK}/pulsar-client-schema-2.2.0.jar
-      - ${MY_WORK}/pulsar-connector-1.0-Beta.jar
+      - ${MY_WORK}/pulsar-connector-1.0-Alpha.jar
       - ${MY_WORK}/pulsar-functions-api-2.2.0.jar
       - ${MY_WORK}/slf4j-api-1.7.25.jar
       - ${MY_WORK}/validation-api-1.1.0.Final.jar
-    class: com.apama.pulsarChainManager
+    class: com.apama.PulsarChainManager

Demo_Application/pulsar_test_sender/config/connectivity/UserConnectivity/UserConnectivity.plugins.yaml

@@ -9,8 +9,8 @@ connectivityPlugins:
       - ${MY_WORK}/protobuf-shaded-2.1.0-incubating.jar
       - ${MY_WORK}/pulsar-client-2.2.0.jar
       - ${MY_WORK}/pulsar-client-schema-2.2.0.jar
-      - ${MY_WORK}/pulsar-connector-1.0-Beta.jar
+      - ${MY_WORK}/pulsar-connector-1.0-Alpha.jar
       - ${MY_WORK}/pulsar-functions-api-2.2.0.jar
       - ${MY_WORK}/slf4j-api-1.7.25.jar
       - ${MY_WORK}/validation-api-1.1.0.Final.jar
-    class: com.apama.pulsarChainManager
+    class: com.apama.PulsarChainManager

pom.xml

@@ -4,7 +4,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>com.apama</groupId>
 	<artifactId>pulsar-connector</artifactId>
-	<version>1.0-Beta</version>
+	<version>1.0-Alpha</version>
 
 	<properties>
 		<maven.compiler.source>1.8</maven.compiler.source>

src/main/java/com/apama/pulsarChainManager.java

@@ -22,8 +22,8 @@
 import org.apache.pulsar.client.api.PulsarClientException;
 import org.slf4j.Logger;
 
-import com.apama.transport.consumerTransport;
-import com.apama.transport.producerTransport;
+import com.apama.transport.ConsumerTransport;
+import com.apama.transport.ProducerTransport;
 import com.softwareag.connectivity.AbstractSimpleTransport;
 import com.softwareag.connectivity.AbstractTransport;
 import com.softwareag.connectivity.Direction;
@@ -40,7 +40,7 @@
  * @author Prabal Nandi
  *
  */
-public class pulsarChainManager extends AbstractChainManager implements ChannelLifecycleListener {
+public class PulsarChainManager extends AbstractChainManager implements ChannelLifecycleListener {
 
 	/** Identifies the version of the API this plug-in was built against. */
 	public static final String CONNECTIVITY_API_VERSION = com.softwareag.connectivity.ConnectivityPlugin.CONNECTIVITY_API_VERSION;
@@ -75,7 +75,7 @@ public class pulsarChainManager extends AbstractChainManager implements ChannelL
 	private final StatusItem producedStatus;
 	private final StatusItem statusItem;
 
-	public pulsarChainManager(Logger logger, ChainManagerConstructorParameters params)
+	public PulsarChainManager(Logger logger, ChainManagerConstructorParameters params)
 			throws IllegalArgumentException, Exception {
 		super(logger, params);
 
@@ -149,8 +149,8 @@ public AbstractTransport createTransport(Logger logger, ManagedTransportConstruc
 			throws IllegalArgumentException, Exception {
 
 		logger.info("createTransport " + params.getSubscribeChannels().isEmpty());
-		return params.getSubscribeChannels().isEmpty() ? new consumerTransport(logger, params, this)
-				: new producerTransport(logger, params, this);
+		return params.getSubscribeChannels().isEmpty() ? new ConsumerTransport(logger, params, this)
+				: new ProducerTransport(logger, params, this);
 	}
 
 	@Override

src/main/java/com/apama/transport/consumerTransport.java

@@ -29,7 +29,7 @@
 import org.apache.pulsar.client.api.PulsarClientException;
 import org.slf4j.Logger;
 
-import com.apama.pulsarChainManager;
+import com.apama.PulsarChainManager;
 import com.apama.util.ExceptionUtil;
 import com.softwareag.connectivity.AbstractSimpleTransport;
 import com.softwareag.connectivity.Direction;
@@ -42,9 +42,9 @@
  * @author NANP
  *
  */
-public class consumerTransport extends AbstractSimpleTransport {
+public class ConsumerTransport extends AbstractSimpleTransport {
 
-	private final pulsarChainManager chainManager;
+	private final PulsarChainManager chainManager;
 	private Consumer<byte[]> consumer;
 	private ConsumerBuilder<byte[]> consumerBuilder;
 	private CompletableFuture<Consumer<byte[]>> future;
@@ -57,7 +57,7 @@ public class consumerTransport extends AbstractSimpleTransport {
 	private final int maxReceiverQueueSize;
 	private final Map<String, org.apache.pulsar.client.api.Message<byte[]>> messageIdMap;
 
-	public consumerTransport(Logger logger, TransportConstructorParameters params, pulsarChainManager chainManager)
+	public ConsumerTransport(Logger logger, TransportConstructorParameters params, PulsarChainManager chainManager)
 			throws IllegalArgumentException, Exception {
 		super(logger, params);
 		// Save the callee chainManager instance
@@ -68,7 +68,7 @@ public consumerTransport(Logger logger, TransportConstructorParameters params, p
 				(int) (this.chainManager.getAckRequestFrequency() * this.maxReceiverQueueSize));
 
 		// Setup status monitoring and KPIs
-		final String statusPrefix = String.format("%s.%s.%s", pulsarChainManager.CHANNEL_PREFIX_FROM,
+		final String statusPrefix = String.format("%s.%s.%s", PulsarChainManager.CHANNEL_PREFIX_FROM,
 				chainManager.managerName, this.chainManager.getConsumerPropertyMap().getOrDefault("topic", ""));
 		statusItem = getStatusReporter().createStatusItem(statusPrefix + ".status", STATUS_STARTING);
 
@@ -180,7 +180,7 @@ public void deliverNullPayloadTowardsTransport(Message message) throws Exception
 	 * @return {@link MessageListener}
 	 */
 	@SuppressWarnings("unchecked")
-	private MessageListener<byte[]> createMessageListenerStrategy(pulsarChainManager chainManager) {
+	private MessageListener<byte[]> createMessageListenerStrategy(PulsarChainManager chainManager) {
 
 		if (chainManager.isAutoAckEnabled()) {
 

src/main/java/com/apama/transport/producerTransport.java

@@ -18,7 +18,7 @@
 import org.apache.pulsar.client.api.Producer;
 import org.slf4j.Logger;
 
-import com.apama.pulsarChainManager;
+import com.apama.PulsarChainManager;
 import com.apama.util.ExceptionUtil;
 import com.softwareag.connectivity.AbstractSimpleTransport;
 import com.softwareag.connectivity.Message;
@@ -30,9 +30,9 @@
  * @author NANP
  *
  */
-public class producerTransport extends AbstractSimpleTransport {
+public class ProducerTransport extends AbstractSimpleTransport {
 
-	private pulsarChainManager chainManager;
+	private PulsarChainManager chainManager;
 	private Producer<byte[]> producer;
 
 	private final StatusItem managerProducedStatus;
@@ -41,15 +41,15 @@ public class producerTransport extends AbstractSimpleTransport {
 	private volatile AtomicBoolean shuttingDown = new AtomicBoolean(false);
 	private volatile Lock lock = new ReentrantLock();
 
-	public producerTransport(Logger logger, TransportConstructorParameters params, pulsarChainManager chainManager)
+	public ProducerTransport(Logger logger, TransportConstructorParameters params, PulsarChainManager chainManager)
 			throws IllegalArgumentException, Exception {
 		super(logger, params);
 
 		// Save the callee chainManager instance
 		this.chainManager = chainManager;
 
 		// Setup status monitoring and KPIs
-		final String statusPrefix = String.format("%s.%s.%s", pulsarChainManager.CHANNEL_PREFIX_TO,
+		final String statusPrefix = String.format("%s.%s.%s", PulsarChainManager.CHANNEL_PREFIX_TO,
 				chainManager.managerName, this.chainManager.getProducerPropertyMap().getOrDefault("topic", ""));
 
 		statusItem = getStatusReporter().createStatusItem(statusPrefix + ".status", STATUS_STARTING);

src/main/resources/chainManager.properties

@@ -10,11 +10,11 @@ connectivityPlugins:
       - ${MY_WORK}/protobuf-shaded-2.1.0-incubating.jar
       - ${MY_WORK}/pulsar-client-2.2.0.jar
       - ${MY_WORK}/pulsar-client-schema-2.2.0.jar
-      - ${MY_WORK}/pulsar-connector-1.0-Beta.jar
+      - ${MY_WORK}/pulsar-connector-1.0-Alpha.jar
       - ${MY_WORK}/pulsar-functions-api-2.2.0.jar
       - ${MY_WORK}/slf4j-api-1.7.25.jar
       - ${MY_WORK}/validation-api-1.1.0.Final.jar
-    class: com.apama.pulsarChainManager
+    class: com.apama.PulsarChainManager
 
 
 ##Sample Chain configurations