Fails when using from node

[grendo]

My server looks like

process.env.NODE_ENV = process.env.NODE_ENV || 'development';
var config = require('./config/environment');
var redisMessageConnector = require( "deepstream.io-msg-redis" );
var redisCacheConnector = require( "deepstream.io-cache-redis" );
var rethinkDBStorageConnector = require( "deepstream.io-storage-rethinkdb" );

const DeepstreamServer = require('deepstream.io')
const C = DeepstreamServer.constants
const server = new DeepstreamServer(config.deepstream);
server.set( 'messageConnector', new redisCacheConnector(config.messageConnector));
server.set( 'cache', new redisCacheConnector( config.cacheConnector));
server.set( 'storage', new rethinkDBStorageConnector(config.storageConnector));
server.start()

When I try and use with the latest deepstream get the following error

            this._options.messageConnector.subscribe( C.TOPIC.CLUSTER, this.

_onMessageFn );
^

TypeError: this._options.messageConnector.subscribe is not a function
at new ClusterRegistry (C:\dev\testdeepstream\src\node\testdeepstream\node_modules\deepstr
eam.io\src\cluster\cluster-registry.js:40:34)
at Deepstream._init (C:\dev\testdeepstream\src\node\testdeepstream\node_modules\deepstream
.io\src\deepstream.io.js:289:34)
at Deepstream._checkReady (C:\dev\testdeepstream\src\node\testdeepstream\node_modules\deep
stream.io\src\deepstream.io.js:333:8)
at DependencyInitialiser.g (events.js:291:16)
at emitNone (events.js:86:13)
at DependencyInitialiser.emit (events.js:185:7)
at DependencyInitialiser._emitReady (C:\dev\testdeepstream\src\node\testdeepstream\node_mo
dules\deepstream.io\src\utils\dependency-initialiser.js:113:7)
at _combinedTickCallback (internal/process/next_tick.js:67:7)
at process._tickCallback (internal/process/next_tick.js:98:9)