Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
hook up new way to wire transform column extensions
  • Loading branch information
chenson42 committed Dec 23, 2011
1 parent 31bd033 commit c12558f
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 13 deletions.
1 change: 0 additions & 1 deletion symmetric/symmetric-assemble/TODO.txt
Expand Up @@ -13,7 +13,6 @@
* Add settings to channel
* Lookup/choose datawriter based on channel settings
* clean up error handling in loader service
* add transform extensions back in

* Add table copy utility
* Clean up service tests
Expand Down
Expand Up @@ -36,6 +36,7 @@
import org.jumpmind.symmetric.io.IOfflineClientListener;
import org.jumpmind.symmetric.io.data.transform.IColumnTransform;
import org.jumpmind.symmetric.io.data.writer.IDatabaseWriterFilter;
import org.jumpmind.symmetric.io.data.writer.TransformWriter;
import org.jumpmind.symmetric.load.IReloadListener;
import org.jumpmind.symmetric.route.IBatchAlgorithm;
import org.jumpmind.symmetric.route.IDataRouter;
Expand All @@ -49,7 +50,6 @@
import org.jumpmind.symmetric.service.IParameterService;
import org.jumpmind.symmetric.service.IRegistrationService;
import org.jumpmind.symmetric.service.IRouterService;
import org.jumpmind.symmetric.service.ITransformService;
import org.jumpmind.symmetric.service.ITriggerRouterService;
import org.jumpmind.symmetric.transport.IAcknowledgeEventListener;
import org.jumpmind.symmetric.transport.ISyncUrlExtension;
Expand Down Expand Up @@ -94,9 +94,7 @@ public class ExtensionPointManager implements IExtensionPointManager, BeanFactor
private ITransportManager transportManager;

private IRouterService routingService;

private ITransformService transformService;


private IDbDialect dbDialect;

private BeanFactory beanFactory;
Expand Down Expand Up @@ -260,8 +258,7 @@ protected boolean registerExtension(String beanName, IExtensionPoint ext) {

if (ext instanceof IColumnTransform) {
IColumnTransform<?> t = (IColumnTransform<?>)ext;
// TODO
//transformService.addColumnTransform(t.getName(), t);
TransformWriter.addColumnTransform(t);
}

return installed;
Expand Down Expand Up @@ -319,8 +316,5 @@ public void setBeanFactory(BeanFactory beanFactory) throws BeansException {
public void setDbDialect(IDbDialect dbDialect) {
this.dbDialect = dbDialect;
}

public void setTransformService(ITransformService transformService) {
this.transformService = transformService;
}

}
Expand Down
Expand Up @@ -23,7 +23,7 @@ public class TransformService extends AbstractService implements ITransformServi
private Map<NodeGroupLink, Map<TransformPoint, List<TransformTableNodeGroupLink>>> transformsCacheByNodeGroupLinkByTransformPoint;

private long lastCacheTimeInMs;

public List<TransformTableNodeGroupLink> findTransformsFor(NodeGroupLink nodeGroupLink,
TransformPoint transformPoint, boolean useCache) {

Expand Down
Expand Up @@ -19,7 +19,6 @@
<property name="transportManager" ref="transportManager" />
<property name="routingService" ref="routingService" />
<property name="dbDialect" ref="dbDialect" />
<property name="transformService" ref="transformService" />
<property name="offlineDetectorServices">
<list>
<ref bean="pullService"/>
Expand Down

0 comments on commit c12558f

Please sign in to comment.