Integrating Flex and MSMQ Messaging

                                                                //
init is called through the creationComplete event
public function init():void
{
  // map server-side to the client-side type
  // ORBExamples.Car is a full type name of the class
  // of the objects sent by the server
  // Car is a client-side class the remote objects
  // should be mapped to
  flash.net.registerClassAlias( "ORBExamples.Car", Car );
}
                

                                                                
package
{ 
  [Bindable]
  public class Car
  {
    public var Make:String;
    public var Model:String;
    public var Mileage:Number;
  }
}
                

Running the Example

1. Download publisher and 'shared classes' projects, compile and run Windows Publisher.
2. Download and install WebORB. Make sure WebORB messaging destination is added to messaging-config.xml. 
3. Make sure to add "-services WEB-INF/flex/weborb-services-config.xml" to the "Additional compiler arguments" in Flex Compiler section of your Flash Builder project. 
4. Deploy shared classes assembly into weborb, by copying the DLL into the /bin folder under WebORB installation root directory.
5. Open a command prompt window and change the directory to the WebORB product installation (/Inetpub/wwwroot/weborb30)
6. Run weborbee.exe. This is the standalone mode of the WebORB Messaging Server. It runs as an independent process and does not require IIS.
7. Download flex project, compile and run Flex client.
8. Click 'Connect' in the Flex client interface. You should see some activity in the weborbee process.
9. Click 'Start' in the Windows Publisher window. Messages will be published to MSMQ and delivered to Flex.

1. Add additional Flex clients, connect and see messages delivered to all Flex clients;
2. Try stopping and starting Windows Publisher;
3. Open Control Panel > Administrative Tools > Computer Management > Services and Applications > Message Queing > Private Queues. Locate the weborb-mppush queue and check the queue messages.

Conditional Message Delivery

                                                                   
            using System;
using System.Collections.Generic;
using System.Text;

using Weborb.V3Types;
namespace Weborb.Messaging.V3
{
  public interface IMessageSelector
  {
    /**
     * Passes the selector value from consumer.
     * Consumer instances can assign a value to the 
     * 'selector' property of the Consumer class
     */ 
    void setClientSelectorValue( String selectorValue );

    /**
     * Process a message originally sent by a Flex publisher.
     * Return null to cancel message delivery.
     */ 
    Object processClientMessage( V3Message message );

    /**
     * Process a message sent from a non-Flex client.
     * Return null to cancel message delivery.
     */ 
    Object processServerMessage( Object message );

    /**
     * Set the id of a client associated with this selector
     */ 
    void setClientID( String clientID );
  }
}
                  

                                                                   
                    using System;
using Weborb.Messaging.V3;
using Weborb.V3Types;

namespace ORBExamples.Messaging
{
    public class CustomSelector : IMessageSelector
    {
        private string clientID;


        public void setClientSelectorValue( String selectorValue )
         {
         }

        public object processClientMessage( V3Message message )
        {
            // no filtering for messages published from Flex
clients
            return message;
        }

        public object processServerMessage( object message )
        {
            Car carObj = (Car) message;
           
            // rollback a few miles. 
            // don't tell anyone we did it:
            carObj.Mileage /= 2;
            return carObj;
        }

        public void setClientID( string clientID )
        {
            this.clientID = clientID;
        }
    }
}
                      

                                                                   
                            <destination id="mqtoflex">
  <properties>
    
<selector>ORBExamples.Messaging.CustomSelector</selector>
    <msmq>
      <path>.\private$\weborb-mqpush</path>
      <!-- zero means 'do not send past messages'. 
           Set to -1 to receive previously sent messages -->
      <deliverPastMessages>0</deliverPastMessages>
      <BasePriority>0</BasePriority>
     
<Category>00000000-0000-0000-0000-000000000000</Category>
      <Label>WebORB MessageQueue for Messages from Windows
client</Label>
      <MaximumQueueSize>4294967295</MaximumQueueSize>
      <UseJournalQueue>false</UseJournalQueue>
     
<MaximumJournalSize>4294967295</MaximumJournalSize> 
    </msmq>
  </properties>
  <channels>
    <channel ref="weborb-rtmp"/>
  </channels>
</destination>