AIR + BlazeDS : Producer/Consumer を使う方法（MXML version）

投稿日時 : 2007/12/19 15:05 | ビュー : 509

関連カテゴリー: AIR,ActionScript3,ColdFusion

前の投稿「AIR : コンパイラオプション無しで Producer/Consumer を使う方法」では ActionScript で記述していましたが、MXMLでも可能です。

Producer (BlazeDSAirTest5.mxml)

<?xml version="1.0" encoding="utf-8"?>
<mx:WindowedApplication layout="vertical"
   xmlns:mx="http://www.adobe.com/2006/mxml"
   width="460" height="400">
  
  <mx:Script>
    <![CDATA[
      import mx.controls.Alert;
      import mx.utils.ObjectUtil;
      import mx.messaging.events.*;
      import mx.messaging.messages.AsyncMessage;
    
      private function sendMessage():void
      {
        var msg:AsyncMessage = new AsyncMessage();
        // set EventGateway id of ColdFusion
        msg.headers.gatewayid  = "BlazeDSMessagingGateway";
        
        msg.body = new Object();
        msg.body.message = inText.text;

if(!prod.connected){
          prod.connect();
        }
        prod.send(msg);
        inText.text = "";
      }
    ]]>
  </mx:Script>
  
  <mx:ChannelSet id="channelSet">
    <mx:channels>
      <mx:AMFChannel 
         uri="http://127.0.0.1/flex2gateway/cfamfpolling"
         pollingEnabled="true"
         pollingInterval="3000">
        <mx:id>cf-polling-amf</mx:id>
      </mx:AMFChannel>
    </mx:channels>
  </mx:ChannelSet>
  
  <mx:Producer id="prod" autoConnect="false"
       destination="ColdFusionGateway"
       channelSet="{channelSet}"
       acknowledge="acknowledgeHandler(event)"
       channelConnect="channelConnectHnadler(event)"
       channelFault="channelFaultHandler(event)"
       channelDisconnect="channelDisconnectHandler(event)"
       fault="faultHandler(event)" />
  
  <mx:HBox>
    <mx:Button label="connect" click="prod.connect()" />
    <mx:Button label="disconnect" click="prod.disconnect()" />
  </mx:HBox>

<mx:HBox>
    <mx:TextInput id="inText" width="200" />
    <mx:Button label="send" click="sendMessage()" />
  </mx:HBox>
  
  <mx:TextArea id="log" width="400" height="300" />
  
  
  <mx:Script>
    <![CDATA[
      private function acknowledgeHandler(e:MessageAckEvent):void
      {
        traceProperties("Event : acknowledge\n", e,["acknowledgeMessage", "correlation", "message", "correlationId", "messageId"]);
      }
      
      private function channelConnectHnadler(e:ChannelEvent):void
      {
        traceProperties("Event : channelConnect\n", e,["channel", "connected", "reconnecting", "rejected", "channelId"]);
      }
      
      private function channelFaultHandler(e:ChannelFaultEvent):void
      {
        traceProperties("Event : channelFault\n", e, ["channel", "connected", "reconnecting", "rejected", "channelId", "faultCode", "faultDetail", "faultString", "rootCause"]);
      }
      
      private function channelDisconnectHandler(e:ChannelEvent):void
      {
        traceProperties("Event : channelDisconnect\n", e,["channel", "connected", "reconnecting", "rejected", "channelId"]);
      }
      
      private function faultHandler(e:MessageFaultEvent):void
      {
        traceProperties("Event : fault\n", e, ["faultCode", "faultDetail", "faultString", "message"]);
      }
      
      private function traceProperties(msg:String, target:Object, properties:Array):void
      {
        var obj:Object = new Object();
        for(var i:int = 0; i < properties.length; i++){
          obj[properties[i]] = target[properties[i]];
        }
        trace(msg + " : " + ObjectUtil.toString(obj));
        
        log.text = msg + " : " + ObjectUtil.toString(obj) + "\n\n" + log.text;
      }
      
    ]]>
  </mx:Script>
  
</mx:WindowedApplication>

Consumer (BlazeDSAirTest6.mxml)

<?xml version="1.0" encoding="utf-8"?>
<mx:WindowedApplication layout="vertical"
   xmlns:mx="http://www.adobe.com/2006/mxml"
   width="460" height="460">

<mx:Script>
    <![CDATA[
      import mx.controls.Alert;
      import mx.utils.ObjectUtil;
      import mx.messaging.events.*;
      
      private function messageHandler(e:MessageEvent):void
      {
        traceProperties("Event : message\n", e, ["message", "messageId"]);
        
        outText.text = e.message.body + "\n" + outText.text;
      }
      
    ]]>
  </mx:Script>
  
  <mx:ChannelSet id="channelSet">
    <mx:channels>
      <mx:AMFChannel 
         uri="http://127.0.0.1/flex2gateway/cfamfpolling"
         pollingEnabled="true"
         pollingInterval="3000">
        <mx:id>cf-polling-amf</mx:id>
      </mx:AMFChannel>
    </mx:channels>
  </mx:ChannelSet>
  
  <mx:Consumer id="cons"
       destination="ColdFusionGateway"
       message="messageHandler(event)"
       channelSet="{channelSet}"
       acknowledge="acknowledgeHandler(event)"
       channelConnect="channelConnectHnadler(event)"
       channelFault="channelFaultHandler(event)"
       channelDisconnect="channelDisconnectHandler(event)"
       fault="faultHandler(event)" />
  
  <mx:Button label="subscribe" click="cons.subscribe()" />
  <mx:TextArea id="outText" width="240" height="80" />

<mx:TextArea id="log" width="400" height="300" />

<mx:Script>
    <![CDATA[
      private function acknowledgeHandler(e:MessageAckEvent):void
      {
        traceProperties("Event : acknowledge\n", e,["acknowledgeMessage", "correlation", "message", "correlationId", "messageId"]);
      }
      
      private function channelConnectHnadler(e:ChannelEvent):void
      {
        traceProperties("Event : channelConnect\n", e,["channel", "connected", "reconnecting", "rejected", "channelId"]);
      }
      
      private function channelFaultHandler(e:ChannelFaultEvent):void
      {
        traceProperties("Event : channelFault\n", e, ["channel", "connected", "reconnecting", "rejected", "channelId", "faultCode", "faultDetail", "faultString", "rootCause"]);
      }
      
      private function channelDisconnectHandler(e:ChannelEvent):void
      {
        traceProperties("Event : channelDisconnect\n", e,["channel", "connected", "reconnecting", "rejected", "channelId"]);
      }
      
      private function faultHandler(e:MessageFaultEvent):void
      {
        traceProperties("Event : fault\n", e, ["faultCode", "faultDetail", "faultString", "message"]);
      }
      
      private function traceProperties(msg:String, target:Object, properties:Array):void
      {
        var obj:Object = new Object();
        for(var i:int = 0; i < properties.length; i++){
          obj[properties[i]] = target[properties[i]];
        }
        
        trace(msg + " : " + ObjectUtil.toString(target));
        
        log.text = msg + " : " + ObjectUtil.toString(obj) + "\n\n" + log.text;
      }
      
    ]]>
  </mx:Script>
  
</mx:WindowedApplication>

CF8 の EventGateway によって
コール（invoke）される CFC

ソースのダウンロードはこちら

コメント (0)

お仕事募集中
※個人契約が無理な場合は知り合いの会社経由での契約も可能です。

常駐作業（Flex3/4, AIR）
諸事情により期間限定で常駐作業をいたします。小生が向いている作業はプロジェクトリーダー、リーダー補佐、問題解決コンサルなどです。もちろん、その他の開発作業も可能です。但し、「大量の作業を超高速に処理してほしい」ってのは向いていないと思います。
Flex3/4 コンサルティング
Flex3/4でのアプリケーション/システムを考えておられます発注会社様向けのコンサルティングです。開発会社との間に立ち、アプリケーションの仕様を技術的な面からサポートします。
Flex3/4, AIR 有償アドバイザー
主に技術的な説明資料や単純なサンプル作成になります。料金は月額ではなく課題一つへの回答に対する技術料やアイデア料になります。都度請求、又は、月末請求のどちらでも対応可能です。また、擬似的に人月請求することも可能です。
Flex3 のトレーニング
御社の要望にあったカリキュラムを作成いたします。
請負開発
設計や実開発作業を行います。但し、人月ではなく案件単位で"ギャランティ"を請求いたします。擬似的に人月請求することも可能です。

ご依頼はこちらから

PHP よりも遥かに簡単で、生産性があり、拡張性（Java, .NET）も備えた ColdFusion

小難しいことを、超～簡単にする、それが ColdFusion

日	月	火	水	木	金	土
				1	2	3
4	5	6	7	8	9	10
11	12	13	14	15	16	17
18	19	20	21	22	23	24
25	26	27	28	29	30	31

AIR + BlazeDS : Producer/Consumer を使う方法 （MXML version）

AIR + BlazeDS : Producer/Consumer を使う方法（MXML version）