/// <summary>
/// Process given data from cluster and write the processed data back to the cluster.
/// This processing unit is also responsible for starting up the space that it processes the
/// data from.
/// </summary>
public class DataProcessor : IProcessingUnitContainer
{
[..]
  ///<summary>
  ///Initializes the processing unit
  public void Initialize()
  {
    //Get the space name from the properties
    string spaceUrl;
    _properties.TryGetValue(Consts.SpaceUrlProperty, out spaceUrl);
    if (String.IsNullOrEmpty(spaceUrl))
      throw new ArgumentNullException("spaceUrl", "Custom Properties must contain a space name property (" + Consts.SpaceUrlProperty + ")");
    //Gets the use transaction state from the custom properties
    string useTransactionStr;
    _properties.TryGetValue(Consts.UseTransactionsProperty, out useTransactionStr);
    _useTransactions = (String.IsNullOrEmpty(useTransactionStr) ? false : bool.Parse(useTransactionStr));      
    //Starts the space as a part of the cluster, the DataProcessor takes data from its embedded space only
    SpaceConfig spaceConfig = new SpaceConfig();
    spaceConfig.ClusterInfo = _clusterInfo;
    ISpaceProxy clusterProxy = SpaceProxyProviderFactory.Instance.FindSpace(spaceUrl, spaceConfig);
    //Gets the direct proxy from the cluster proxy that will be used by this processing unit
    _proxy = clusterProxy.GetServerAdmin().GetDirectProxy();
    //Create the event listener container 
    _eventListenerContainer = EventListenerContainerFactory.CreateContainer<Data>(_proxy, new ExampleProcessor());
    //If transaction should be used, supply the container with a local transaction manager
    if (useTransactions)
        _eventListenerContainer.TransactionManager = _proxy.LocalTransactionManager;
    //Start the event listener container
    _eventListenerContainer.Start();

    Console.Write("DataProcessor started, waiting for data that needs processing...");     
  }        

  ///<summary>
  ///Destroys the processing unit, any allocated resources should be cleaned up in this method
  ///</summary>
  public void Dispose()
  {
    if (_eventListenerContainer != null)
    {
       _eventListenerContainer.Stop();
       _eventListenerContainer.Dispose();
    }
    //This processing unit created the space, therefor it should also close it
    //by calling Shutdown on the server admin
    _proxy.GetServerAdmin().Shutdown();
    //Dispose the space proxy. to clean up any used resources      
    _proxy.Dispose();
  }
  
  /// <summary>
  /// This property is set at deploy-time by the service grid, it contains the cluster
  /// information of this processing unit instance
  /// </summary>
  public ClusterInfo ClusterInfo
  {
    set { _clusterInfo = value; }
  }
  /// <summary>
  /// This property is set at deploy time by the service grid, it contains deploy-time context
  /// properties and any additional properties passed by the user
  /// </summary>
  public IDictionary<string, string> Properties
  {
    set { _properties = value; }
  }	  
}

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <configSections>
    <section name="GigaSpaces.XAP" type="GigaSpaces.XAP.Configuration.GigaSpacesXAPConfiguration, GigaSpaces.Core"/>
  </configSections>
  <appSettings>
    <add key="SpaceUrl" value="/./dotnetProcessingUnitDataExample"/>
    <add key="UseTransactions" value="false"/>
  </appSettings>
  <GigaSpaces.XAP>
    <ProcessingUnitContainer ImplementingType="GigaSpaces.Examples.ProcessingUnit.Processor.DataProcessor, GigaSpaces.Examples.ProcessingUnit.Processor"/>
  </GigaSpaces.XAP>
</configuration>

/// <summary>
/// Data feeder feeds new data to the space that needs to be processed
/// </summary>
public class DataFeeder : IProcessingUnitContainer
{
  [..]
  
  ///<summary>  
  /// Initializes the processing unit    
  ///</summary>    
  public void Initialize()
  {
    //Get the space name from the properties
    string spaceUrl;
    _properties.TryGetValue(Consts.SpaceUrlProperty, out spaceUrl);
    if (String.IsNullOrEmpty(spaceUrl))
      throw new ArgumentNullException("spaceUrl", "Custom Properties must contain a space name property (" + Consts.SpaceUrlProperty + ")");
    //Get feed delay from the custom properties, if none found uses the default one
    string feedDelayStr;
    _properties.TryGetValue(Consts.FeedDelayProperty, out feedDelayStr);
    _feedDelay = (String.IsNullOrEmpty(feedDelayStr) ? DefaultFeedDelay : int.Parse(feedDelayStr));            
    //Connects to the space
    _proxy = SpaceProxyProviderFactory.Instance.FindSpace(spaceUrl);
    //Set the started state to true
    _started = true;
    //Create a working thread
    _feedingThread = new Thread(new ThreadStart(StartWorking));
    //Starts the working thread
    _feedingThread.Start();
  }    

  ///<summary>
  ///Destroys the processing unit, any allocated resources should be cleaned up in this method
  ///</summary>
  public void Dispose()
  {
    //Set the started state to false
    _started = false;
    //Wait for the working thread to finish its work
    _feedingThread.Join(_feedDelay * 5);
    //It is very important to dispose the space when done to clean up
    //any uses resources
    _proxy.Dispose();
  }
  
  /// <summary>
  /// This property is set at deploy time by the service grid, it contains deploy-time context
  /// properties and any additional properties passed by the user
  /// </summary>
  public IDictionary<string, string> Properties
  {
    set { _properties = value; }
  }

  /// <summary>
  /// Generates and feeds data to the space
  /// </summary>
  private void StartWorking()
  {
    try
    {
      Random random = new Random();
      while (_started)
      {
        //Create a new data object with random info and random type
        Data data = new Data(Guid.NewGuid().ToString(), random.Next(0, DataTypesCount));
        Console.WriteLine("Added data object with info {0} and type {1}", data.Info, data.Type);
        //Feed the data into the cluster
        _proxy.Write(data);
        Thread.Sleep(_feedDelay);
      }
    }
    [..]
  }
}

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <configSections>
    <section name="GigaSpaces.XAP" type="GigaSpaces.XAP.Configuration.GigaSpacesXAPConfiguration, GigaSpaces.Core"/>
  </configSections>
  <appSettings>
    <add key="SpaceUrl" value="jini://*/*/dataExampleSpace"/>
  </appSettings>
  <GigaSpaces.XAP>
    <ProcessingUnitContainer ImplementingType="GigaSpaces.Examples.ProcessingUnit.Feeder.DataFeeder, GigaSpaces.Examples.ProcessingUnit.Feeder"/>
  </GigaSpaces.XAP>
</configuration>