Use in-memory and TSQ storage to contrast the services.

Author: SoftlySplinter

projects/com.ibm.cicsdev.osgi.ds.tsq_1.0.0/OSGI-INF/com.ibm.cicsdev.osgi.ds.tsq.InMemoryStorageService.xml

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<scr:component xmlns:scr="http://www.osgi.org/xmlns/scr/v1.1.0" immediate="true" name="com.ibm.cicsdev.osgi.ds.tsq.InMemoryStorageService">
+   <implementation class="com.ibm.cicsdev.osgi.ds.tsq.InMemoryStorageService"/>
+   <service>
+      <provide interface="com.ibm.cicsdev.osgi.ds.TemporaryStorageService"/>
+   </service>
+</scr:component>

projects/com.ibm.cicsdev.osgi.ds.tsq_1.0.0/build.properties

@@ -1,2 +1,2 @@
 custom = true
-bin.includes = OSGI-INF/com.ibm.cicsdev.osgi.ds.tsq.TemporaryStorageQueueService.xml
+bin.includes = OSGI-INF/com.ibm.cicsdev.osgi.ds.tsq.InMemoryStorageService.xml

projects/com.ibm.cicsdev.osgi.ds.tsq_1.0.0/src/com/ibm/cicsdev/osgi/ds/tsq/InMemoryStorageService.java

@@ -0,0 +1,32 @@
+package com.ibm.cicsdev.osgi.ds.tsq;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import com.ibm.cicsdev.osgi.ds.TemporaryStorageException;
+import com.ibm.cicsdev.osgi.ds.TemporaryStorageService;
+
+public class InMemoryStorageService implements TemporaryStorageService {
+	private List<String> store = new ArrayList<>();
+	
+	public void activate() {
+		System.out.println("Starting in-memory temporary storage.");
+	}
+	
+	public void deactivate() {
+		System.out.println("Stopping in-memory temporary storage");
+		store.clear();
+	}
+	
+	@Override
+	public String get(int id) throws TemporaryStorageException {
+		// We're off by one, so the actual index is one less.
+		return store.get(id - 1);
+	}
+	
+	@Override
+	public int put(String record) throws TemporaryStorageException {
+		store.add(record);
+		return store.size();
+	}
+}

projects/com.ibm.cicsdev.osgi.ds.tsq_1.0.1/OSGI-INF/com.ibm.cicsdev.osgi.ds.tsq.CachedTemporaryStorageQueueService.xml

@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<scr:component xmlns:scr="http://www.osgi.org/xmlns/scr/v1.1.0" immediate="true" name="com.ibm.cicsdev.osgi.ds.tsq.TemporaryStorageQueueService">
+<scr:component xmlns:scr="http://www.osgi.org/xmlns/scr/v1.1.0" activate="activate" deactivate="deactivate" immediate="true" name="com.ibm.cicsdev.osgi.ds.tsq.TemporaryStorageQueueService">
    <implementation class="com.ibm.cicsdev.osgi.ds.tsq.TemporaryStorageQueueService"/>
    <service>
       <provide interface="com.ibm.cicsdev.osgi.ds.TemporaryStorageService"/>

….ds.tsq.TemporaryStorageQueueService.xml ….ds.tsq.TemporaryStorageQueueService.xmlprojects/com.ibm.cicsdev.osgi.ds.tsq_1.0.0/OSGI-INF/com.ibm.cicsdev.osgi.ds.tsq.TemporaryStorageQueueService.xml renamed to projects/com.ibm.cicsdev.osgi.ds.tsq_1.0.1/OSGI-INF/com.ibm.cicsdev.osgi.ds.tsq.TemporaryStorageQueueService.xml projects/com.ibm.cicsdev.osgi.ds.tsq_1.0.0/OSGI-INF/com.ibm.cicsdev.osgi.ds.tsq.TemporaryStorageQueueService.xml renamed to projects/com.ibm.cicsdev.osgi.ds.tsq_1.0.1/OSGI-INF/com.ibm.cicsdev.osgi.ds.tsq.TemporaryStorageQueueService.xml

@@ -8,32 +8,41 @@
 
 public class TemporaryStorageQueueService implements TemporaryStorageService {
 	private static final String TSQ_NAME = "TSQS";
-	
+
+	public void activate() {
+		System.out.println("Starting TSQ service");
+	}
+
+	public void deactivate() {
+		System.out.println("Stopping TSQ service");
+	}
+
 	private static TSQ getTSQ() {
 		TSQ tsq = new TSQ();
 		tsq.setName(TSQ_NAME);
-		
+
 		return tsq;
 	}
-	
+
 	@Override
 	public String get(int id) throws TemporaryStorageException {
 		final ItemHolder holder = new ItemHolder();
-		
+
 		try {
 			getTSQ().readItem(id, holder);
-		} catch(CicsConditionException e) {
+		} catch (CicsConditionException e) {
 			throw new TemporaryStorageException(e, e.getRESP(), e.getRESP2());
 		}
-		
+
 		return holder.getStringValue();
 	}
-	
+
 	@Override
 	public int put(String record) throws TemporaryStorageException {
 		try {
-			return getTSQ().writeString(record);
-		} catch(CicsConditionException e) {
+			final int id = getTSQ().writeString(record);
+			return id;
+		} catch (CicsConditionException e) {
 			throw new TemporaryStorageException(e, e.getRESP(), e.getRESP2());
 		}
 	}