To the discussion in the [[http://trac.prcn.bitcoin-analytics.com/ceasy/ticket/515]] 

We discussed list of modules affected.
* collector/bin/collector.js - entry point for collector process
* server/lib/config.js - constants {{{enabledCurrencies}}}, {{{streamAPIModes}}} the latter intended to be used in {{{exchangeAPIObj.init}}} method
* server/lib/depthAPI.js - all actual configuration of exchange objects defined here. Every exchange is represented by its exchange object instance. Module is responsible for creating instances and provides hash storage for them. Orderbooks accessed from collector structures through public method by exchange string tickers. Trades on the other hand broadcasted thru central event emitter object defined in {{events}} module. Trades messages source is every exchange instance. Collector structures register listeners for trades messages. 


Collector side:
* collector/bin/collector.js method {{{nextTick}}}
{{{ 
process.nextTick(function ()
{ 
...
var     exchangeApi = require('../../server/lib/depthAPI')

exchangeApi.init(config.tickersToFetch, config.streamAPIModes, config.enabledCurrencies)
...
}
}}}
* server/lib/config.js constants {{{enabledCurrencies}}}, {{{streamAPIModes}}} the latter intended to be used in {{{exchangeAPIObj.init}}} method to select specific version of internal adapter implementation (REST or Websocket real time synchronized)
{{{
exports.enabledCurrencies = ['USD', 'EUR', 'CNY',

exports.streamAPIModes = {..., coinbaseUSD: 'coinbase1'}
}}}
* server/lib/depthAPI.js
each exchange represented by instance of exchangeAPIObj, collector requests each order book using method {{{getCurrentBook2}}}
while published {{{events}}} is global event emitter instance to pass trades events.
{{{
...

exports.events = new (require('events').EventEmitter)() //trade events, orderbook events

var exchangeAPIObjs = {}

...

exports.getCurrentBook2 = function(ticker)
{
        return exchangeAPIObjs[ticker].currentHashBook
}
...
}}}

method {{{init}}} takes list of exchanges specific for current server to instantiate and initialize exchange objects which is returned as hash(key=ticker,value=exObj) and stored in {{{exchangeAPIObjs}}} in the module scope.
{{{
exports.init = function (tickersToFetch, streamApiModes, currencies)
{
        exchangeAPIObjs = arr.mapToHash(tickersToFetch, function(ticker)
        {
                var exObj = apiParams[ticker].exAPIObj ? new apiParams[ticker].exAPIObj() : new api.exAPIDefault()

                exObj.init(ticker, apiParams, exports.events, streamApiModes)
                return exObj
        })
...
}
}}}

{{{apiParams}}} is initialize from execution of the method {{{makeApiParams}}}
{{{
...

var apiParams = makeApiParams()
exports.apiParams = apiParams
}}}

where definition of the method {{{makeApiParams}}} is as following
{{{
function makeApiParams()
{
        return {
...
,       mtgoxUSD: makeMtgox('USD')
,       btceUSD: {
                url: 'https://btc-e.com/api/3/depth/btc_usd?limit=2000',
                cur : 'USD',
                parse :  fixPriceKeysEx(
                        function (x){ return x['btc_usd']},
                        'bids', 'asks',
                        fn.id),
                exAPIObj: api.btcePollingTrades,
                trades_url: 'https://btc-e.com/api/3/trades/btc_usd?limit=2000',
                trades_key: 'btc_usd',
                polling_freq: 3600 / 30,
                pollingAliveTimeout: 5 * 60 * 1000,
    DoRejectUnauthorized : true
        }
...

}}}

where {{{coinbaseUSD}}} is defined as 
{{{
...

, coinbaseUSD: {
        cur: 'USD',
        exAPIObj: require('./exchange-api/coinbaseAPIClass').exAPICoinbase
}
...
}}}

where {{{api.exAPICoinbase}}} is included from 
{{{
...
, api = require('./exchange-api/apiClasses')
...
}}}