AIR : コンパイラオプション無しで Producer/Consumer を使う方法

このサンプルのキーは AS3 で AMFChannel を
作成しているところです。
もちろん、引数の uri にはサーブレットの
フルパスをセットする必要があります。

AIR : Producer サンプルコード
<mx:WindowedApplication layout="vertical" xmlns:mx="http://www.adobe.com/2006/mxml" applicationComplete="init()"> <mx:Script> <![CDATA[ import mx.messaging.channels.AMFChannel; import mx.messaging.Producer; import mx.messaging.ChannelSet; import mx.controls.Alert; import mx.utils.ObjectUtil; import mx.messaging.events.*; import mx.messaging.messages.AsyncMessage; private var prod:Producer; private function init():void { // channel id and uri in services-config.xml var amf:AMFChannel = new AMFChannel("cf-polling-amf", "http://127.0.0.1/flex2gateway/cfamfpolling"); amf.pollingEnabled = true; amf.pollingInterval = 3000; prod = new Producer(); // destination id in messaging-config.xml prod.destination = "ColdFusionGateway"; prod.channelSet = new ChannelSet(); prod.channelSet.addChannel(amf); prod.connect(); } 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; prod.send(msg); inText.text = ""; } ]]> </mx:Script> <mx:HBox> <mx:TextInput id="inText" width="200" /> <mx:Button label="send" click="sendMessage()" /> </mx:HBox> </mx:WindowedApplication>

AIR : Consumer サンプルコード
<?xml version="1.0" encoding="utf-8"?> <mx:WindowedApplication layout="vertical" xmlns:mx="http://www.adobe.com/2006/mxml" applicationComplete="init()"> <mx:Script> <![CDATA[ import mx.messaging.channels.AMFChannel; import mx.messaging.Consumer; import mx.messaging.ChannelSet; import mx.controls.Alert; import mx.utils.ObjectUtil; import mx.messaging.events.*; import mx.messaging.messages.AsyncMessage; private var cons:Consumer; private function init():void { // channel id and uri in services-config.xml var amf:AMFChannel = new AMFChannel("cf-polling-amf", "http://127.0.0.1/flex2gateway/cfamfpolling"); amf.pollingEnabled = true; amf.pollingInterval = 3000; cons = new Consumer(); // destination id in messaging-config.xml cons.destination = "ColdFusionGateway"; cons.channelSet = new ChannelSet(); cons.channelSet.addChannel(amf); cons.addEventListener(MessageEvent.MESSAGE, messageHandler); cons.addEventListener(MessageFaultEvent.FAULT, faultHandler); cons.subscribe(); } private function messageHandler(e:MessageEvent):void { trace(ObjectUtil.toString(e)); outText.text = e.message.body + "\n" + outText.text; } private function faultHandler(e:MessageFaultEvent):void { trace(ObjectUtil.toString(e)); Alert.show(e.faultString); } ]]> </mx:Script> <mx:TextArea id="outText" width="240" height="300" /> </mx:WindowedApplication>


"BlazeDSMessagingGateway"と名づけられた
イベントゲートウェイによって呼ばれる
CFC のソースコード
<cfcomponent> <cffunction name="onIncomingMessage" output="no"> <cfargument name="event" type="struct" required="yes"> <!--- Get the message ---> <cfset var messageBody = arguments.event.data.body> <cfset var message = messageBody.message> <cfset var retValue = structNew()> <cfset retValue.body = message> <!--- set AMF destination id ---> <cfset retValue.destination = "ColdFusionGateway"> <!--- send the return message back ---> <!--- set EventGateway id ---> <cfset ret = SendGatewayMessage("BlazeDSMessagingGateway", retValue)> </cffunction> </cfcomponent>