Register the channel access type support

Author: shroffk

gpclient/gpclient-ca/src/main/java/org/epics/gpclient/datasource/ca/CAChannelHandler.java

@@ -10,7 +10,9 @@
 import java.util.logging.Level;
 import java.util.regex.Pattern;
 
+import org.epics.gpclient.ReadCollector;
 import org.epics.gpclient.datasource.MultiplexedChannelHandler;
+import org.epics.gpclient.datasource.ca.types.CATypeAdapter;
 
 import gov.aps.jca.CAException;
 import gov.aps.jca.Channel;
@@ -67,11 +69,9 @@ protected void connect() {
             // Give the listener right away so that no event gets lost
             // If it's a large array, connect using lower priority
             if (largeArray) {
-                channel = caDataSource.getContext().createChannel(getChannelName(), connectionListener,
-                        Channel.PRIORITY_MIN);
+                channel = caDataSource.getContext().createChannel(getChannelName(), connectionListener, Channel.PRIORITY_MIN);
             } else {
-                channel = caDataSource.getContext().createChannel(getChannelName(), connectionListener,
-                        (short) (Channel.PRIORITY_MIN + 1));
+                channel = caDataSource.getContext().createChannel(getChannelName(), connectionListener, (short) (Channel.PRIORITY_MIN + 1));
             }
         } catch (CAException ex) {
             throw new RuntimeException("JCA Connection failed", ex);
@@ -106,6 +106,11 @@ protected boolean isWriteConnected(CAConnectionPayload connPayload) {
         return connPayload != null && connPayload.isWriteConnected();
     }
 
+    @Override
+    protected CATypeAdapter findTypeAdapter(ReadCollector<?, ?> cache, CAConnectionPayload connection) {
+        return caDataSource.getCaTypeSupport().find(cache, connection);
+    }
+
     private final ConnectionListener connectionListener = new ConnectionListener() {
 
         @Override

gpclient/gpclient-ca/src/main/java/org/epics/gpclient/datasource/ca/CADataSource.java

@@ -33,6 +33,8 @@ public class CADataSource extends DataSource {
     private boolean rtypValueOnly = false;
     private boolean honorZeroPrecision = true;
 
+    private final CATypeSupport caTypeSupport = new CATypeSupport(new CAVTypeAdapterSet());
+    
     public CADataSource() {
         super();
         // Some properties are not pre-initialized to the default,
@@ -75,6 +77,10 @@ public Context getContext() {
         return context;
     }
 
+    public CATypeSupport getCaTypeSupport() {
+        return caTypeSupport;
+    }
+
     public int getMonitorMask() {
         return monitorMask;
     }