StreamLayer example

gistfile1.js

//create stream layer from feature service URL
function createStreamLayer() {
  var fl_url =  'http://arcgis-commse-1029264944.us-east-1.elb.amazonaws.com/arcgis/rest/services/amiller/FMS_datalayers/FeatureServer/2';
  var streamLayer = new StreamLayer(fl_url, {
    //websocket URL from GeoEvent Processor
  	socketUrl: 'ws://172.16.183.137:6180/ws_pg',
  	trackIdField: 'ROUTE_ID',
  	outFields: ['*']
  });

  streamLayer.on("message", lang.hitch(this, this.processMessage));
  this._streamLayer = this._map.addLayer(streamLayer);
}

function processMessage(message) {
  var i=0;
  for (i;i<this._streamLayer.graphics.length;i++) {
    if (this._streamLayer.graphics[i].attributes['ROUTE_ID'] == message.ROUTE_ID) {
      var pt = new Point(message.X, message.Y, new SpatialReference(102100));
      this._streamLayer.graphics[i].setGeometry(pt);
      
      //update dGrid
      this._gridStore.notify({
        id: message.ROUTE_ID,
        sku1: message.SKU1,
        eta: message.ETA,
        cross_dock: message.cross_dock
      }, message.ROUTE_ID);
  
      break;
    }
  }
}