http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/012fad7c/attic/apps/team/features/messaging/messaging_AMF_Piggyback.mxml ---------------------------------------------------------------------- diff --git a/attic/apps/team/features/messaging/messaging_AMF_Piggyback.mxml b/attic/apps/team/features/messaging/messaging_AMF_Piggyback.mxml index 9668867..9312b8c 100755 --- a/attic/apps/team/features/messaging/messaging_AMF_Piggyback.mxml +++ b/attic/apps/team/features/messaging/messaging_AMF_Piggyback.mxml @@ -1,104 +1,104 @@ -<?xml version="1.0"?> -<!-- - - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - ---> -<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" - creationComplete="creationCompleteHandler();"> - - <!-- An example where the client relies on piggybacking for server updates. - The intended use for piggybacking is to support very light-weight psuedo-polling, - where rather than the client channel polling the server on a fixed or adaptive interval, - when the client sends a non-command message to the server (via a Producer or RemoteObject or DataService) - we'll piggyback any pending data for the client's messaging or data management subscriptions - along with the response to the client's message. Piggybacking can also be used - on a channel that has polling enabled but on a wide interval like 5 or 10 seconds or more, - in which case the app will feel more responsive if the client is sending messages to the server. - --> - <mx:Panel id="mainPanel" height="100%" width="100%"> - <mx:HBox> - <mx:Label text="Producer"/> - <mx:Button label="Send Foo{counter}" click="sendMessage()"/> - <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> - <mx:CheckBox label="Connected?" selected="{producer.connected}"/> - </mx:HBox> - <mx:HBox> - <mx:Label text="Consumer"/> - <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> - <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> - <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> - <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> - <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> - </mx:HBox> - <mx:Button label="Clear" click='ta.text = ""'/> - <mx:TextArea id="ta" width="100%" height="100%"/> - </mx:Panel> - - <mx:Producer id="producer" - destination="messaging_AMF_Piggyback" - fault="faultHandler(event)"/> - - <mx:Consumer id="consumer" - destination="messaging_AMF_Piggyback" - fault="faultHandler(event)" - message="messageHandler(event)"/> - - <mx:Script> - <![CDATA[ - - import mx.messaging.events.MessageFaultEvent; - import mx.messaging.events.MessageEvent; - - import mx.messaging.ChannelSet; - import mx.messaging.Producer; - import mx.messaging.Consumer; - import mx.messaging.messages.AsyncMessage; - - import mx.logging.Log; - import mx.logging.targets.TraceTarget; - - [Bindable] - public var counter:int = 0; - - private function creationCompleteHandler():void - { - var target:TraceTarget = new TraceTarget(); - target.includeLevel = true; - target.filters = ["mx.messaging.*", "mx.rpc.*"]; - Log.addTarget(target); - } - - private function sendMessage():void - { - var msg:AsyncMessage = new AsyncMessage(); - msg.body = "Foo" + counter++; - producer.send(msg); - } - - private function messageHandler(event:MessageEvent):void - { - ta.text += "Consumer received message: "+ event.message.body + "\n"; - } - - private function faultHandler(event:Object):void - { - ta.text += "Received fault: " + event.faultString + "\n"; - } - ]]> - </mx:Script> - +<?xml version="1.0"?> +<!-- + + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +--> +<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" + creationComplete="creationCompleteHandler();"> + + <!-- An example where the client relies on piggybacking for server updates. + The intended use for piggybacking is to support very light-weight psuedo-polling, + where rather than the client channel polling the server on a fixed or adaptive interval, + when the client sends a non-command message to the server (via a Producer or RemoteObject or DataService) + we'll piggyback any pending data for the client's messaging or data management subscriptions + along with the response to the client's message. Piggybacking can also be used + on a channel that has polling enabled but on a wide interval like 5 or 10 seconds or more, + in which case the app will feel more responsive if the client is sending messages to the server. + --> + <mx:Panel id="mainPanel" height="100%" width="100%"> + <mx:HBox> + <mx:Label text="Producer"/> + <mx:Button label="Send Foo{counter}" click="sendMessage()"/> + <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> + <mx:CheckBox label="Connected?" selected="{producer.connected}"/> + </mx:HBox> + <mx:HBox> + <mx:Label text="Consumer"/> + <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> + <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> + <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> + <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> + <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> + </mx:HBox> + <mx:Button label="Clear" click='ta.text = ""'/> + <mx:TextArea id="ta" width="100%" height="100%"/> + </mx:Panel> + + <mx:Producer id="producer" + destination="messaging_AMF_Piggyback" + fault="faultHandler(event)"/> + + <mx:Consumer id="consumer" + destination="messaging_AMF_Piggyback" + fault="faultHandler(event)" + message="messageHandler(event)"/> + + <mx:Script> + <![CDATA[ + + import mx.messaging.events.MessageFaultEvent; + import mx.messaging.events.MessageEvent; + + import mx.messaging.ChannelSet; + import mx.messaging.Producer; + import mx.messaging.Consumer; + import mx.messaging.messages.AsyncMessage; + + import mx.logging.Log; + import mx.logging.targets.TraceTarget; + + [Bindable] + public var counter:int = 0; + + private function creationCompleteHandler():void + { + var target:TraceTarget = new TraceTarget(); + target.includeLevel = true; + target.filters = ["mx.messaging.*", "mx.rpc.*"]; + Log.addTarget(target); + } + + private function sendMessage():void + { + var msg:AsyncMessage = new AsyncMessage(); + msg.body = "Foo" + counter++; + producer.send(msg); + } + + private function messageHandler(event:MessageEvent):void + { + ta.text += "Consumer received message: "+ event.message.body + "\n"; + } + + private function faultHandler(event:Object):void + { + ta.text += "Received fault: " + event.faultString + "\n"; + } + ]]> + </mx:Script> + </mx:Application> \ No newline at end of file
http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/012fad7c/attic/apps/team/features/messaging/messaging_AMF_Poll.mxml ---------------------------------------------------------------------- diff --git a/attic/apps/team/features/messaging/messaging_AMF_Poll.mxml b/attic/apps/team/features/messaging/messaging_AMF_Poll.mxml index ab551ab..5dba032 100755 --- a/attic/apps/team/features/messaging/messaging_AMF_Poll.mxml +++ b/attic/apps/team/features/messaging/messaging_AMF_Poll.mxml @@ -1,91 +1,91 @@ -<?xml version="1.0"?> -<!-- - - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - ---> -<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" - creationComplete="creationCompleteHandler();"> - - <mx:Panel id="mainPanel" height="100%" width="100%"> - <mx:HBox> - <mx:Label text="Producer"/> - <mx:Button label="Send Foo{counter}" click="sendMessage()"/> - <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> - <mx:CheckBox label="Connected?" selected="{producer.connected}"/> - </mx:HBox> - <mx:HBox> - <mx:Label text="Consumer"/> - <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> - <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> - <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> - <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> - <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> - </mx:HBox> - <mx:Button label="Clear" click='ta.text = ""'/> - <mx:TextArea id="ta" width="100%" height="100%"/> - </mx:Panel> - - <mx:Producer id="producer" - destination="messaging_AMF_Poll" - fault="faultHandler(event)"/> - - <mx:Consumer id="consumer" - destination="messaging_AMF_Poll" - fault="faultHandler(event)" - message="messageHandler(event)"/> - - <mx:Script> - <![CDATA[ - import mx.messaging.events.MessageFaultEvent; - import mx.messaging.events.MessageEvent; - import mx.messaging.messages.AsyncMessage; - import mx.messaging.Producer; - import mx.messaging.Consumer; - - import mx.logging.Log; - import mx.logging.targets.TraceTarget; - - [Bindable] - public var counter:int = 0; - - private function creationCompleteHandler():void - { - var target:TraceTarget = new TraceTarget(); - target.includeLevel = true; - target.filters = ["mx.messaging.*", "mx.rpc.*"]; - Log.addTarget(target); - } - - private function sendMessage():void - { - var msg:AsyncMessage = new AsyncMessage(); - msg.body = "Foo" + counter++; - producer.send(msg); - } - - private function messageHandler(event:MessageEvent):void - { - ta.text += "Consumer received message: "+ event.message.body + "\n"; - } - - private function faultHandler(event:MessageFaultEvent):void - { - ta.text += "Received fault: " + event.faultString + "\n"; - } - ]]> - </mx:Script> +<?xml version="1.0"?> +<!-- + + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +--> +<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" + creationComplete="creationCompleteHandler();"> + + <mx:Panel id="mainPanel" height="100%" width="100%"> + <mx:HBox> + <mx:Label text="Producer"/> + <mx:Button label="Send Foo{counter}" click="sendMessage()"/> + <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> + <mx:CheckBox label="Connected?" selected="{producer.connected}"/> + </mx:HBox> + <mx:HBox> + <mx:Label text="Consumer"/> + <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> + <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> + <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> + <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> + <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> + </mx:HBox> + <mx:Button label="Clear" click='ta.text = ""'/> + <mx:TextArea id="ta" width="100%" height="100%"/> + </mx:Panel> + + <mx:Producer id="producer" + destination="messaging_AMF_Poll" + fault="faultHandler(event)"/> + + <mx:Consumer id="consumer" + destination="messaging_AMF_Poll" + fault="faultHandler(event)" + message="messageHandler(event)"/> + + <mx:Script> + <![CDATA[ + import mx.messaging.events.MessageFaultEvent; + import mx.messaging.events.MessageEvent; + import mx.messaging.messages.AsyncMessage; + import mx.messaging.Producer; + import mx.messaging.Consumer; + + import mx.logging.Log; + import mx.logging.targets.TraceTarget; + + [Bindable] + public var counter:int = 0; + + private function creationCompleteHandler():void + { + var target:TraceTarget = new TraceTarget(); + target.includeLevel = true; + target.filters = ["mx.messaging.*", "mx.rpc.*"]; + Log.addTarget(target); + } + + private function sendMessage():void + { + var msg:AsyncMessage = new AsyncMessage(); + msg.body = "Foo" + counter++; + producer.send(msg); + } + + private function messageHandler(event:MessageEvent):void + { + ta.text += "Consumer received message: "+ event.message.body + "\n"; + } + + private function faultHandler(event:MessageFaultEvent):void + { + ta.text += "Received fault: " + event.faultString + "\n"; + } + ]]> + </mx:Script> </mx:Application> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/012fad7c/attic/apps/team/features/messaging/messaging_AMF_Stream.mxml ---------------------------------------------------------------------- diff --git a/attic/apps/team/features/messaging/messaging_AMF_Stream.mxml b/attic/apps/team/features/messaging/messaging_AMF_Stream.mxml index 46d3a46..c134fbb 100755 --- a/attic/apps/team/features/messaging/messaging_AMF_Stream.mxml +++ b/attic/apps/team/features/messaging/messaging_AMF_Stream.mxml @@ -1,91 +1,91 @@ -<?xml version="1.0"?> -<!-- - - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - ---> -<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" - creationComplete="creationCompleteHandler();"> - - <mx:Panel id="mainPanel" height="100%" width="100%"> - <mx:HBox> - <mx:Label text="Producer"/> - <mx:Button label="Send Foo{counter}" click="sendMessage()"/> - <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> - <mx:CheckBox label="Connected?" selected="{producer.connected}"/> - </mx:HBox> - <mx:HBox> - <mx:Label text="Consumer"/> - <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> - <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> - <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> - <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> - <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> - </mx:HBox> - <mx:Button label="Clear" click='ta.text = ""'/> - <mx:TextArea id="ta" width="100%" height="100%"/> - </mx:Panel> - - <mx:Producer id="producer" - destination="messaging_AMF_Stream" - fault="faultHandler(event)"/> - - <mx:Consumer id="consumer" - destination="messaging_AMF_Stream" - fault="faultHandler(event)" - message="messageHandler(event)"/> - - <mx:Script> - <![CDATA[ - import mx.messaging.events.MessageFaultEvent; - import mx.messaging.events.MessageEvent; - import mx.messaging.messages.AsyncMessage; - import mx.messaging.Producer; - import mx.messaging.Consumer; - - import mx.logging.Log; - import mx.logging.targets.TraceTarget; - - [Bindable] - public var counter:int = 0; - - private function creationCompleteHandler():void - { - var target:TraceTarget = new TraceTarget(); - target.includeLevel = true; - target.filters = ["mx.messaging.*", "mx.rpc.*"]; - Log.addTarget(target); - } - - private function sendMessage():void - { - var msg:AsyncMessage = new AsyncMessage(); - msg.body = "Foo" + counter++; - producer.send(msg); - } - - private function messageHandler(event:MessageEvent):void - { - ta.text += "Consumer received message: "+ event.message.body + "\n"; - } - - private function faultHandler(event:MessageFaultEvent):void - { - ta.text += "Received fault: " + event.faultString + "\n"; - } - ]]> - </mx:Script> +<?xml version="1.0"?> +<!-- + + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +--> +<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" + creationComplete="creationCompleteHandler();"> + + <mx:Panel id="mainPanel" height="100%" width="100%"> + <mx:HBox> + <mx:Label text="Producer"/> + <mx:Button label="Send Foo{counter}" click="sendMessage()"/> + <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> + <mx:CheckBox label="Connected?" selected="{producer.connected}"/> + </mx:HBox> + <mx:HBox> + <mx:Label text="Consumer"/> + <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> + <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> + <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> + <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> + <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> + </mx:HBox> + <mx:Button label="Clear" click='ta.text = ""'/> + <mx:TextArea id="ta" width="100%" height="100%"/> + </mx:Panel> + + <mx:Producer id="producer" + destination="messaging_AMF_Stream" + fault="faultHandler(event)"/> + + <mx:Consumer id="consumer" + destination="messaging_AMF_Stream" + fault="faultHandler(event)" + message="messageHandler(event)"/> + + <mx:Script> + <![CDATA[ + import mx.messaging.events.MessageFaultEvent; + import mx.messaging.events.MessageEvent; + import mx.messaging.messages.AsyncMessage; + import mx.messaging.Producer; + import mx.messaging.Consumer; + + import mx.logging.Log; + import mx.logging.targets.TraceTarget; + + [Bindable] + public var counter:int = 0; + + private function creationCompleteHandler():void + { + var target:TraceTarget = new TraceTarget(); + target.includeLevel = true; + target.filters = ["mx.messaging.*", "mx.rpc.*"]; + Log.addTarget(target); + } + + private function sendMessage():void + { + var msg:AsyncMessage = new AsyncMessage(); + msg.body = "Foo" + counter++; + producer.send(msg); + } + + private function messageHandler(event:MessageEvent):void + { + ta.text += "Consumer received message: "+ event.message.body + "\n"; + } + + private function faultHandler(event:MessageFaultEvent):void + { + ta.text += "Received fault: " + event.faultString + "\n"; + } + ]]> + </mx:Script> </mx:Application> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/012fad7c/attic/apps/team/features/messaging/messaging_HTTP.mxml ---------------------------------------------------------------------- diff --git a/attic/apps/team/features/messaging/messaging_HTTP.mxml b/attic/apps/team/features/messaging/messaging_HTTP.mxml index 2ed8fbd..7491e2b 100755 --- a/attic/apps/team/features/messaging/messaging_HTTP.mxml +++ b/attic/apps/team/features/messaging/messaging_HTTP.mxml @@ -1,117 +1,117 @@ -<?xml version="1.0"?> -<!-- - - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - ---> -<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" - creationComplete="creationCompleteHandler();"> - - <!-- An example where the client manually initiates a poll request without - relying on polling-interval - --> - <mx:Panel id="mainPanel" height="100%" width="100%"> - <mx:HBox> - <mx:Label text="Producer"/> - <mx:Button label="Send Foo{counter}" click="sendMessage()"/> - <mx:Button label="Disconnect" click="producer.disconnect();"/> - </mx:HBox> - <mx:HBox> - <mx:Label text="Consumer"/> - <mx:Button label="Subcribe" click="subscribeConsumer();" enabled="{!consumer.subscribed}"/> - <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> - <mx:Button label="Poll" click="poll();"/> - <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> - <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> - <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> - </mx:HBox> - <mx:Button label="Clear" click='ta.text = ""'/> - <mx:TextArea id="ta" width="100%" height="100%"/> - </mx:Panel> - - <mx:Producer id="producer" - destination="messaging_HTTP" - fault="faultHandler(event)"/> - - <mx:Consumer id="consumer" - destination="messaging_HTTP" - fault="faultHandler(event)" - message="messageHandler(event)"/> - - <mx:Script> - <![CDATA[ - import mx.messaging.events.MessageFaultEvent; - import mx.messaging.events.MessageEvent; - - import mx.messaging.ChannelSet; - import mx.messaging.Producer; - import mx.messaging.Consumer; - import mx.messaging.channels.PollingChannel; - import mx.messaging.messages.AsyncMessage; - - import mx.logging.Log; - import mx.logging.targets.TraceTarget; - - public var pc:PollingChannel; - - [Bindable] - public var counter:int = 0; - - private function creationCompleteHandler():void - { - var target:TraceTarget = new TraceTarget(); - target.includeLevel = true; - target.filters = ["mx.messaging.*", "mx.rpc.*"]; - Log.addTarget(target); - } - - private function sendMessage():void - { - var msg:AsyncMessage = new AsyncMessage(); - msg.body = "Foo" + counter++; - producer.send(msg); - } - - private function messageHandler(event:MessageEvent):void - { - ta.text += "Consumer: received message: "+ event.message.body + "\n"; - } - - private function faultHandler(event:Object):void - { - ta.text += "Received fault: " + event.faultString + "\n"; - } - - private function poll():void - { - ta.text += "Polling" + "\n"; - if (!consumer.subscribed) - subscribeConsumer(); - pc.poll(); - } - - private function subscribeConsumer():void - { - ta.text += "Subscribing Consumer \n"; - consumer.subscribe(); - - var pcs:ChannelSet = consumer.channelSet; - pc = PollingChannel(pcs.currentChannel); - } - ]]> - </mx:Script> - +<?xml version="1.0"?> +<!-- + + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +--> +<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" + creationComplete="creationCompleteHandler();"> + + <!-- An example where the client manually initiates a poll request without + relying on polling-interval + --> + <mx:Panel id="mainPanel" height="100%" width="100%"> + <mx:HBox> + <mx:Label text="Producer"/> + <mx:Button label="Send Foo{counter}" click="sendMessage()"/> + <mx:Button label="Disconnect" click="producer.disconnect();"/> + </mx:HBox> + <mx:HBox> + <mx:Label text="Consumer"/> + <mx:Button label="Subcribe" click="subscribeConsumer();" enabled="{!consumer.subscribed}"/> + <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> + <mx:Button label="Poll" click="poll();"/> + <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> + <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> + <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> + </mx:HBox> + <mx:Button label="Clear" click='ta.text = ""'/> + <mx:TextArea id="ta" width="100%" height="100%"/> + </mx:Panel> + + <mx:Producer id="producer" + destination="messaging_HTTP" + fault="faultHandler(event)"/> + + <mx:Consumer id="consumer" + destination="messaging_HTTP" + fault="faultHandler(event)" + message="messageHandler(event)"/> + + <mx:Script> + <![CDATA[ + import mx.messaging.events.MessageFaultEvent; + import mx.messaging.events.MessageEvent; + + import mx.messaging.ChannelSet; + import mx.messaging.Producer; + import mx.messaging.Consumer; + import mx.messaging.channels.PollingChannel; + import mx.messaging.messages.AsyncMessage; + + import mx.logging.Log; + import mx.logging.targets.TraceTarget; + + public var pc:PollingChannel; + + [Bindable] + public var counter:int = 0; + + private function creationCompleteHandler():void + { + var target:TraceTarget = new TraceTarget(); + target.includeLevel = true; + target.filters = ["mx.messaging.*", "mx.rpc.*"]; + Log.addTarget(target); + } + + private function sendMessage():void + { + var msg:AsyncMessage = new AsyncMessage(); + msg.body = "Foo" + counter++; + producer.send(msg); + } + + private function messageHandler(event:MessageEvent):void + { + ta.text += "Consumer: received message: "+ event.message.body + "\n"; + } + + private function faultHandler(event:Object):void + { + ta.text += "Received fault: " + event.faultString + "\n"; + } + + private function poll():void + { + ta.text += "Polling" + "\n"; + if (!consumer.subscribed) + subscribeConsumer(); + pc.poll(); + } + + private function subscribeConsumer():void + { + ta.text += "Subscribing Consumer \n"; + consumer.subscribe(); + + var pcs:ChannelSet = consumer.channelSet; + pc = PollingChannel(pcs.currentChannel); + } + ]]> + </mx:Script> + </mx:Application> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/012fad7c/attic/apps/team/features/messaging/messaging_HTTP_LongPoll.mxml ---------------------------------------------------------------------- diff --git a/attic/apps/team/features/messaging/messaging_HTTP_LongPoll.mxml b/attic/apps/team/features/messaging/messaging_HTTP_LongPoll.mxml index f6e9fce..233c2be 100755 --- a/attic/apps/team/features/messaging/messaging_HTTP_LongPoll.mxml +++ b/attic/apps/team/features/messaging/messaging_HTTP_LongPoll.mxml @@ -1,91 +1,91 @@ -<?xml version="1.0"?> -<!-- - - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - ---> -<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" - creationComplete="creationCompleteHandler();"> - - <mx:Panel id="mainPanel" height="100%" width="100%"> - <mx:HBox> - <mx:Label text="Producer"/> - <mx:Button label="Send Foo{counter}" click="sendMessage()"/> - <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> - <mx:CheckBox label="Connected?" selected="{producer.connected}"/> - </mx:HBox> - <mx:HBox> - <mx:Label text="Consumer"/> - <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> - <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> - <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> - <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> - <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> - </mx:HBox> - <mx:Button label="Clear" click='ta.text = ""'/> - <mx:TextArea id="ta" width="100%" height="100%"/> - </mx:Panel> - - <mx:Producer id="producer" - destination="messaging_HTTP_LongPoll" - fault="faultHandler(event)"/> - - <mx:Consumer id="consumer" - destination="messaging_HTTP_LongPoll" - fault="faultHandler(event)" - message="messageHandler(event)"/> - - <mx:Script> - <![CDATA[ - import mx.messaging.events.MessageFaultEvent; - import mx.messaging.events.MessageEvent; - import mx.messaging.messages.AsyncMessage; - import mx.messaging.Producer; - import mx.messaging.Consumer; - - import mx.logging.Log; - import mx.logging.targets.TraceTarget; - - [Bindable] - public var counter:int = 0; - - private function creationCompleteHandler():void - { - var target:TraceTarget = new TraceTarget(); - target.includeLevel = true; - target.filters = ["mx.messaging.*", "mx.rpc.*"]; - Log.addTarget(target); - } - - private function sendMessage():void - { - var msg:AsyncMessage = new AsyncMessage(); - msg.body = "Foo" + counter++; - producer.send(msg); - } - - private function messageHandler(event:MessageEvent):void - { - ta.text += "Consumer received message: "+ event.message.body + "\n"; - } - - private function faultHandler(event:MessageFaultEvent):void - { - ta.text += "Received fault: " + event.faultString + "\n"; - } - ]]> - </mx:Script> +<?xml version="1.0"?> +<!-- + + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +--> +<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" + creationComplete="creationCompleteHandler();"> + + <mx:Panel id="mainPanel" height="100%" width="100%"> + <mx:HBox> + <mx:Label text="Producer"/> + <mx:Button label="Send Foo{counter}" click="sendMessage()"/> + <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> + <mx:CheckBox label="Connected?" selected="{producer.connected}"/> + </mx:HBox> + <mx:HBox> + <mx:Label text="Consumer"/> + <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> + <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> + <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> + <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> + <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> + </mx:HBox> + <mx:Button label="Clear" click='ta.text = ""'/> + <mx:TextArea id="ta" width="100%" height="100%"/> + </mx:Panel> + + <mx:Producer id="producer" + destination="messaging_HTTP_LongPoll" + fault="faultHandler(event)"/> + + <mx:Consumer id="consumer" + destination="messaging_HTTP_LongPoll" + fault="faultHandler(event)" + message="messageHandler(event)"/> + + <mx:Script> + <![CDATA[ + import mx.messaging.events.MessageFaultEvent; + import mx.messaging.events.MessageEvent; + import mx.messaging.messages.AsyncMessage; + import mx.messaging.Producer; + import mx.messaging.Consumer; + + import mx.logging.Log; + import mx.logging.targets.TraceTarget; + + [Bindable] + public var counter:int = 0; + + private function creationCompleteHandler():void + { + var target:TraceTarget = new TraceTarget(); + target.includeLevel = true; + target.filters = ["mx.messaging.*", "mx.rpc.*"]; + Log.addTarget(target); + } + + private function sendMessage():void + { + var msg:AsyncMessage = new AsyncMessage(); + msg.body = "Foo" + counter++; + producer.send(msg); + } + + private function messageHandler(event:MessageEvent):void + { + ta.text += "Consumer received message: "+ event.message.body + "\n"; + } + + private function faultHandler(event:MessageFaultEvent):void + { + ta.text += "Received fault: " + event.faultString + "\n"; + } + ]]> + </mx:Script> </mx:Application> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/012fad7c/attic/apps/team/features/messaging/messaging_HTTP_Piggyback.mxml ---------------------------------------------------------------------- diff --git a/attic/apps/team/features/messaging/messaging_HTTP_Piggyback.mxml b/attic/apps/team/features/messaging/messaging_HTTP_Piggyback.mxml index 7ab771c..244263d 100755 --- a/attic/apps/team/features/messaging/messaging_HTTP_Piggyback.mxml +++ b/attic/apps/team/features/messaging/messaging_HTTP_Piggyback.mxml @@ -1,104 +1,104 @@ -<?xml version="1.0"?> -<!-- - - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - ---> -<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" - creationComplete="creationCompleteHandler();"> - - <!-- An example where the client relies on piggybacking for server updates. - The intended use for piggybacking is to support very light-weight psuedo-polling, - where rather than the client channel polling the server on a fixed or adaptive interval, - when the client sends a non-command message to the server (via a Producer or RemoteObject or DataService) - we'll piggyback any pending data for the client's messaging or data management subscriptions - along with the response to the client's message. Piggybacking can also be used - on a channel that has polling enabled but on a wide interval like 5 or 10 seconds or more, - in which case the app will feel more responsive if the client is sending messages to the server. - --> - <mx:Panel id="mainPanel" height="100%" width="100%"> - <mx:HBox> - <mx:Label text="Producer"/> - <mx:Button label="Send Foo{counter}" click="sendMessage()"/> - <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> - <mx:CheckBox label="Connected?" selected="{producer.connected}"/> - </mx:HBox> - <mx:HBox> - <mx:Label text="Consumer"/> - <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> - <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> - <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> - <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> - <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> - </mx:HBox> - <mx:Button label="Clear" click='ta.text = ""'/> - <mx:TextArea id="ta" width="100%" height="100%"/> - </mx:Panel> - - <mx:Producer id="producer" - destination="messaging_HTTP_Piggyback" - fault="faultHandler(event)"/> - - <mx:Consumer id="consumer" - destination="messaging_HTTP_Piggyback" - fault="faultHandler(event)" - message="messageHandler(event)"/> - - <mx:Script> - <![CDATA[ - - import mx.messaging.events.MessageFaultEvent; - import mx.messaging.events.MessageEvent; - - import mx.messaging.ChannelSet; - import mx.messaging.Producer; - import mx.messaging.Consumer; - import mx.messaging.messages.AsyncMessage; - - import mx.logging.Log; - import mx.logging.targets.TraceTarget; - - [Bindable] - public var counter:int = 0; - - private function creationCompleteHandler():void - { - var target:TraceTarget = new TraceTarget(); - target.includeLevel = true; - target.filters = ["mx.messaging.*", "mx.rpc.*"]; - Log.addTarget(target); - } - - private function sendMessage():void - { - var msg:AsyncMessage = new AsyncMessage(); - msg.body = "Foo" + counter++; - producer.send(msg); - } - - private function messageHandler(event:MessageEvent):void - { - ta.text += "Consumer received message: "+ event.message.body + "\n"; - } - - private function faultHandler(event:Object):void - { - ta.text += "Received fault: " + event.faultString + "\n"; - } - ]]> - </mx:Script> - +<?xml version="1.0"?> +<!-- + + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +--> +<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" + creationComplete="creationCompleteHandler();"> + + <!-- An example where the client relies on piggybacking for server updates. + The intended use for piggybacking is to support very light-weight psuedo-polling, + where rather than the client channel polling the server on a fixed or adaptive interval, + when the client sends a non-command message to the server (via a Producer or RemoteObject or DataService) + we'll piggyback any pending data for the client's messaging or data management subscriptions + along with the response to the client's message. Piggybacking can also be used + on a channel that has polling enabled but on a wide interval like 5 or 10 seconds or more, + in which case the app will feel more responsive if the client is sending messages to the server. + --> + <mx:Panel id="mainPanel" height="100%" width="100%"> + <mx:HBox> + <mx:Label text="Producer"/> + <mx:Button label="Send Foo{counter}" click="sendMessage()"/> + <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> + <mx:CheckBox label="Connected?" selected="{producer.connected}"/> + </mx:HBox> + <mx:HBox> + <mx:Label text="Consumer"/> + <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> + <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> + <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> + <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> + <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> + </mx:HBox> + <mx:Button label="Clear" click='ta.text = ""'/> + <mx:TextArea id="ta" width="100%" height="100%"/> + </mx:Panel> + + <mx:Producer id="producer" + destination="messaging_HTTP_Piggyback" + fault="faultHandler(event)"/> + + <mx:Consumer id="consumer" + destination="messaging_HTTP_Piggyback" + fault="faultHandler(event)" + message="messageHandler(event)"/> + + <mx:Script> + <![CDATA[ + + import mx.messaging.events.MessageFaultEvent; + import mx.messaging.events.MessageEvent; + + import mx.messaging.ChannelSet; + import mx.messaging.Producer; + import mx.messaging.Consumer; + import mx.messaging.messages.AsyncMessage; + + import mx.logging.Log; + import mx.logging.targets.TraceTarget; + + [Bindable] + public var counter:int = 0; + + private function creationCompleteHandler():void + { + var target:TraceTarget = new TraceTarget(); + target.includeLevel = true; + target.filters = ["mx.messaging.*", "mx.rpc.*"]; + Log.addTarget(target); + } + + private function sendMessage():void + { + var msg:AsyncMessage = new AsyncMessage(); + msg.body = "Foo" + counter++; + producer.send(msg); + } + + private function messageHandler(event:MessageEvent):void + { + ta.text += "Consumer received message: "+ event.message.body + "\n"; + } + + private function faultHandler(event:Object):void + { + ta.text += "Received fault: " + event.faultString + "\n"; + } + ]]> + </mx:Script> + </mx:Application> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/012fad7c/attic/apps/team/features/messaging/messaging_HTTP_Poll.mxml ---------------------------------------------------------------------- diff --git a/attic/apps/team/features/messaging/messaging_HTTP_Poll.mxml b/attic/apps/team/features/messaging/messaging_HTTP_Poll.mxml index c4f2e1b..d385345 100755 --- a/attic/apps/team/features/messaging/messaging_HTTP_Poll.mxml +++ b/attic/apps/team/features/messaging/messaging_HTTP_Poll.mxml @@ -1,91 +1,91 @@ -<?xml version="1.0"?> -<!-- - - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - ---> -<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" - creationComplete="creationCompleteHandler();"> - - <mx:Panel id="mainPanel" height="100%" width="100%"> - <mx:HBox> - <mx:Label text="Producer"/> - <mx:Button label="Send Foo{counter}" click="sendMessage()"/> - <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> - <mx:CheckBox label="Connected?" selected="{producer.connected}"/> - </mx:HBox> - <mx:HBox> - <mx:Label text="Consumer"/> - <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> - <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> - <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> - <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> - <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> - </mx:HBox> - <mx:Button label="Clear" click='ta.text = ""'/> - <mx:TextArea id="ta" width="100%" height="100%"/> - </mx:Panel> - - <mx:Producer id="producer" - destination="messaging_HTTP_Poll" - fault="faultHandler(event)"/> - - <mx:Consumer id="consumer" - destination="messaging_HTTP_Poll" - fault="faultHandler(event)" - message="messageHandler(event)"/> - - <mx:Script> - <![CDATA[ - import mx.messaging.events.MessageFaultEvent; - import mx.messaging.events.MessageEvent; - import mx.messaging.messages.AsyncMessage; - import mx.messaging.Producer; - import mx.messaging.Consumer; - - import mx.logging.Log; - import mx.logging.targets.TraceTarget; - - [Bindable] - public var counter:int = 0; - - private function creationCompleteHandler():void - { - var target:TraceTarget = new TraceTarget(); - target.includeLevel = true; - target.filters = ["mx.messaging.*", "mx.rpc.*"]; - Log.addTarget(target); - } - - private function sendMessage():void - { - var msg:AsyncMessage = new AsyncMessage(); - msg.body = "Foo" + counter++; - producer.send(msg); - } - - private function messageHandler(event:MessageEvent):void - { - ta.text += "Consumer received message: "+ event.message.body + "\n"; - } - - private function faultHandler(event:MessageFaultEvent):void - { - ta.text += "Received fault: " + event.faultString + "\n"; - } - ]]> - </mx:Script> +<?xml version="1.0"?> +<!-- + + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +--> +<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" + creationComplete="creationCompleteHandler();"> + + <mx:Panel id="mainPanel" height="100%" width="100%"> + <mx:HBox> + <mx:Label text="Producer"/> + <mx:Button label="Send Foo{counter}" click="sendMessage()"/> + <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> + <mx:CheckBox label="Connected?" selected="{producer.connected}"/> + </mx:HBox> + <mx:HBox> + <mx:Label text="Consumer"/> + <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> + <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> + <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> + <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> + <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> + </mx:HBox> + <mx:Button label="Clear" click='ta.text = ""'/> + <mx:TextArea id="ta" width="100%" height="100%"/> + </mx:Panel> + + <mx:Producer id="producer" + destination="messaging_HTTP_Poll" + fault="faultHandler(event)"/> + + <mx:Consumer id="consumer" + destination="messaging_HTTP_Poll" + fault="faultHandler(event)" + message="messageHandler(event)"/> + + <mx:Script> + <![CDATA[ + import mx.messaging.events.MessageFaultEvent; + import mx.messaging.events.MessageEvent; + import mx.messaging.messages.AsyncMessage; + import mx.messaging.Producer; + import mx.messaging.Consumer; + + import mx.logging.Log; + import mx.logging.targets.TraceTarget; + + [Bindable] + public var counter:int = 0; + + private function creationCompleteHandler():void + { + var target:TraceTarget = new TraceTarget(); + target.includeLevel = true; + target.filters = ["mx.messaging.*", "mx.rpc.*"]; + Log.addTarget(target); + } + + private function sendMessage():void + { + var msg:AsyncMessage = new AsyncMessage(); + msg.body = "Foo" + counter++; + producer.send(msg); + } + + private function messageHandler(event:MessageEvent):void + { + ta.text += "Consumer received message: "+ event.message.body + "\n"; + } + + private function faultHandler(event:MessageFaultEvent):void + { + ta.text += "Received fault: " + event.faultString + "\n"; + } + ]]> + </mx:Script> </mx:Application> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/012fad7c/attic/apps/team/features/messaging/messaging_HTTP_Stream.mxml ---------------------------------------------------------------------- diff --git a/attic/apps/team/features/messaging/messaging_HTTP_Stream.mxml b/attic/apps/team/features/messaging/messaging_HTTP_Stream.mxml index a5620c3..51516dc 100755 --- a/attic/apps/team/features/messaging/messaging_HTTP_Stream.mxml +++ b/attic/apps/team/features/messaging/messaging_HTTP_Stream.mxml @@ -1,91 +1,91 @@ -<?xml version="1.0"?> -<!-- - - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - ---> -<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" - creationComplete="creationCompleteHandler();"> - - <mx:Panel id="mainPanel" height="100%" width="100%"> - <mx:HBox> - <mx:Label text="Producer"/> - <mx:Button label="Send Foo{counter}" click="sendMessage()"/> - <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> - <mx:CheckBox label="Connected?" selected="{producer.connected}"/> - </mx:HBox> - <mx:HBox> - <mx:Label text="Consumer"/> - <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> - <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> - <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> - <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> - <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> - </mx:HBox> - <mx:Button label="Clear" click='ta.text = ""'/> - <mx:TextArea id="ta" width="100%" height="100%"/> - </mx:Panel> - - <mx:Producer id="producer" - destination="messaging_HTTP_Stream" - fault="faultHandler(event)"/> - - <mx:Consumer id="consumer" - destination="messaging_HTTP_Stream" - fault="faultHandler(event)" - message="messageHandler(event)"/> - - <mx:Script> - <![CDATA[ - import mx.messaging.events.MessageFaultEvent; - import mx.messaging.events.MessageEvent; - import mx.messaging.messages.AsyncMessage; - import mx.messaging.Producer; - import mx.messaging.Consumer; - - import mx.logging.Log; - import mx.logging.targets.TraceTarget; - - [Bindable] - public var counter:int = 0; - - private function creationCompleteHandler():void - { - var target:TraceTarget = new TraceTarget(); - target.includeLevel = true; - target.filters = ["mx.messaging.*", "mx.rpc.*"]; - Log.addTarget(target); - } - - private function sendMessage():void - { - var msg:AsyncMessage = new AsyncMessage(); - msg.body = "Foo" + counter++; - producer.send(msg); - } - - private function messageHandler(event:MessageEvent):void - { - ta.text += "Consumer received message: "+ event.message.body + "\n"; - } - - private function faultHandler(event:MessageFaultEvent):void - { - ta.text += "Received fault: " + event.faultString + "\n"; - } - ]]> - </mx:Script> +<?xml version="1.0"?> +<!-- + + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +--> +<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" + creationComplete="creationCompleteHandler();"> + + <mx:Panel id="mainPanel" height="100%" width="100%"> + <mx:HBox> + <mx:Label text="Producer"/> + <mx:Button label="Send Foo{counter}" click="sendMessage()"/> + <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> + <mx:CheckBox label="Connected?" selected="{producer.connected}"/> + </mx:HBox> + <mx:HBox> + <mx:Label text="Consumer"/> + <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> + <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> + <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> + <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> + <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> + </mx:HBox> + <mx:Button label="Clear" click='ta.text = ""'/> + <mx:TextArea id="ta" width="100%" height="100%"/> + </mx:Panel> + + <mx:Producer id="producer" + destination="messaging_HTTP_Stream" + fault="faultHandler(event)"/> + + <mx:Consumer id="consumer" + destination="messaging_HTTP_Stream" + fault="faultHandler(event)" + message="messageHandler(event)"/> + + <mx:Script> + <![CDATA[ + import mx.messaging.events.MessageFaultEvent; + import mx.messaging.events.MessageEvent; + import mx.messaging.messages.AsyncMessage; + import mx.messaging.Producer; + import mx.messaging.Consumer; + + import mx.logging.Log; + import mx.logging.targets.TraceTarget; + + [Bindable] + public var counter:int = 0; + + private function creationCompleteHandler():void + { + var target:TraceTarget = new TraceTarget(); + target.includeLevel = true; + target.filters = ["mx.messaging.*", "mx.rpc.*"]; + Log.addTarget(target); + } + + private function sendMessage():void + { + var msg:AsyncMessage = new AsyncMessage(); + msg.body = "Foo" + counter++; + producer.send(msg); + } + + private function messageHandler(event:MessageEvent):void + { + ta.text += "Consumer received message: "+ event.message.body + "\n"; + } + + private function faultHandler(event:MessageFaultEvent):void + { + ta.text += "Received fault: " + event.faultString + "\n"; + } + ]]> + </mx:Script> </mx:Application> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/012fad7c/attic/apps/team/features/messaging/multipleendpoints/messaging_AMFLongPoll_and_SecureAMFLongPoll.mxml ---------------------------------------------------------------------- diff --git a/attic/apps/team/features/messaging/multipleendpoints/messaging_AMFLongPoll_and_SecureAMFLongPoll.mxml b/attic/apps/team/features/messaging/multipleendpoints/messaging_AMFLongPoll_and_SecureAMFLongPoll.mxml index aadd6e4..87c24e6 100755 --- a/attic/apps/team/features/messaging/multipleendpoints/messaging_AMFLongPoll_and_SecureAMFLongPoll.mxml +++ b/attic/apps/team/features/messaging/multipleendpoints/messaging_AMFLongPoll_and_SecureAMFLongPoll.mxml @@ -1,160 +1,160 @@ -<?xml version="1.0"?> -<!-- - - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - ---> -<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" - creationComplete="creationCompleteHandler();"> - - <mx:Panel id="mainPanel1" height="100%" width="100%"> - <mx:HBox> - <mx:Label text="Producer"/> - <mx:Button label="Send Foo{counter}" click="sendMessage()"/> - <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> - <mx:CheckBox label="Connected?" selected="{producer.connected}"/> - </mx:HBox> - <mx:HBox> - <mx:Label text="Consumer"/> - <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> - <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> - <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> - <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> - <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> - </mx:HBox> - <mx:Button label="Clear" click='ta.text = ""'/> - <mx:TextArea id="ta" width="100%" height="100%"/> - </mx:Panel> - -<mx:Panel id="mainPanel2" height="100%" width="100%"> - <mx:HBox> - <mx:Label text="Producer2"/> - <mx:Button label="Send Foo{counter2}" click="sendMessage2()"/> - <mx:Button label="Disconnect" click="producer2.disconnect();" enabled="{producer2.connected}"/> - <mx:CheckBox label="Connected?" selected="{producer2.connected}"/> - </mx:HBox> - <mx:HBox> - <mx:Label text="Consumer2"/> - <mx:Button label="Subcribe" click="consumer2.subscribe();" enabled="{!consumer2.subscribed}"/> - <mx:Button label="Unsubscribe" click="consumer2.unsubscribe();" enabled="{consumer2.subscribed}"/> - <mx:Button label="Disconnect" click="consumer2.disconnect();" enabled="{consumer2.connected}"/> - <mx:Button label="Poll" click="(consumer2.channelSet.currentChannel as PollingChannel).poll();" enabled="{consumer2.connected}"/> - <mx:CheckBox label="Connected?" selected="{consumer2.connected}"/> - <mx:CheckBox label="Subscribed?" selected="{consumer2.subscribed}"/> - </mx:HBox> - <mx:Button label="Clear" click='ta2.text = ""'/> - <mx:TextArea id="ta2" width="100%" height="100%"/> - </mx:Panel> - - - <mx:Producer id="producer" - destination="messaging_AMF_LongPoll" - fault="faultHandler(event)"/> - - <mx:Consumer id="consumer" - destination="messaging_AMF_LongPoll" - fault="faultHandler(event)" - message="messageHandler(event)"/> - - <mx:Producer id="producer2" - destination="messaging_AMF_SecureLongPoll" - fault="faultHandler2(event)"/> - - <mx:Consumer id="consumer2" - destination="messaging_AMF_SecureLongPoll" - fault="faultHandler2(event)" - message="messageHandler2(event)"/> - - <mx:Script> - <![CDATA[ - import mx.messaging.events.MessageFaultEvent; - import mx.messaging.events.MessageEvent; - import mx.messaging.messages.AsyncMessage; - import mx.messaging.Producer; - import mx.messaging.Consumer; - import mx.messaging.channels.PollingChannel; - import mx.logging.Log; - import mx.logging.targets.TraceTarget; - - [Bindable] - public var counter:int = 0; - - private function creationCompleteHandler():void - { - var target:TraceTarget = new TraceTarget(); - target.includeLevel = true; - target.filters = ["mx.messaging.*", "mx.rpc.*"]; - Log.addTarget(target); - } - - private function sendMessage():void - { - var msg:AsyncMessage = new AsyncMessage(); - msg.body = "Foo" + counter++; - producer.send(msg); - } - - private function messageHandler(event:MessageEvent):void - { - ta.text += "Consumer received message: "+ event.message.body + "\n"; - } - - private function faultHandler(event:MessageFaultEvent):void - { - ta.text += "Received fault: " + event.faultString + "\n"; - } - - [Bindable] - public var counter2:int = 0; - - - private function sendMessage2():void - { - var msg:AsyncMessage = new AsyncMessage(); - msg.body = "Foo" + counter2++; - producer2.send(msg); - } - - private function messageHandler2(event:MessageEvent):void - { - ta2.text += "Consumer received message: "+ event.message.body + "\n"; - } - - private function faultHandler2(event:MessageFaultEvent):void - { - ta2.text += "Received fault: " + event.faultString + "\n"; - } - ]]> - </mx:Script> - - - - - <mx:Script> - <![CDATA[ - import mx.messaging.events.MessageFaultEvent; - import mx.messaging.events.MessageEvent; - import mx.messaging.messages.AsyncMessage; - import mx.messaging.Producer; - import mx.messaging.Consumer; - - import mx.logging.Log; - import mx.logging.targets.TraceTarget; - - - ]]> - </mx:Script> +<?xml version="1.0"?> +<!-- + + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +--> +<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"; width="100%" height="100%" + creationComplete="creationCompleteHandler();"> + + <mx:Panel id="mainPanel1" height="100%" width="100%"> + <mx:HBox> + <mx:Label text="Producer"/> + <mx:Button label="Send Foo{counter}" click="sendMessage()"/> + <mx:Button label="Disconnect" click="producer.disconnect();" enabled="{producer.connected}"/> + <mx:CheckBox label="Connected?" selected="{producer.connected}"/> + </mx:HBox> + <mx:HBox> + <mx:Label text="Consumer"/> + <mx:Button label="Subcribe" click="consumer.subscribe();" enabled="{!consumer.subscribed}"/> + <mx:Button label="Unsubscribe" click="consumer.unsubscribe();" enabled="{consumer.subscribed}"/> + <mx:Button label="Disconnect" click="consumer.disconnect();" enabled="{consumer.connected}"/> + <mx:CheckBox label="Connected?" selected="{consumer.connected}"/> + <mx:CheckBox label="Subscribed?" selected="{consumer.subscribed}"/> + </mx:HBox> + <mx:Button label="Clear" click='ta.text = ""'/> + <mx:TextArea id="ta" width="100%" height="100%"/> + </mx:Panel> + +<mx:Panel id="mainPanel2" height="100%" width="100%"> + <mx:HBox> + <mx:Label text="Producer2"/> + <mx:Button label="Send Foo{counter2}" click="sendMessage2()"/> + <mx:Button label="Disconnect" click="producer2.disconnect();" enabled="{producer2.connected}"/> + <mx:CheckBox label="Connected?" selected="{producer2.connected}"/> + </mx:HBox> + <mx:HBox> + <mx:Label text="Consumer2"/> + <mx:Button label="Subcribe" click="consumer2.subscribe();" enabled="{!consumer2.subscribed}"/> + <mx:Button label="Unsubscribe" click="consumer2.unsubscribe();" enabled="{consumer2.subscribed}"/> + <mx:Button label="Disconnect" click="consumer2.disconnect();" enabled="{consumer2.connected}"/> + <mx:Button label="Poll" click="(consumer2.channelSet.currentChannel as PollingChannel).poll();" enabled="{consumer2.connected}"/> + <mx:CheckBox label="Connected?" selected="{consumer2.connected}"/> + <mx:CheckBox label="Subscribed?" selected="{consumer2.subscribed}"/> + </mx:HBox> + <mx:Button label="Clear" click='ta2.text = ""'/> + <mx:TextArea id="ta2" width="100%" height="100%"/> + </mx:Panel> + + + <mx:Producer id="producer" + destination="messaging_AMF_LongPoll" + fault="faultHandler(event)"/> + + <mx:Consumer id="consumer" + destination="messaging_AMF_LongPoll" + fault="faultHandler(event)" + message="messageHandler(event)"/> + + <mx:Producer id="producer2" + destination="messaging_AMF_SecureLongPoll" + fault="faultHandler2(event)"/> + + <mx:Consumer id="consumer2" + destination="messaging_AMF_SecureLongPoll" + fault="faultHandler2(event)" + message="messageHandler2(event)"/> + + <mx:Script> + <![CDATA[ + import mx.messaging.events.MessageFaultEvent; + import mx.messaging.events.MessageEvent; + import mx.messaging.messages.AsyncMessage; + import mx.messaging.Producer; + import mx.messaging.Consumer; + import mx.messaging.channels.PollingChannel; + import mx.logging.Log; + import mx.logging.targets.TraceTarget; + + [Bindable] + public var counter:int = 0; + + private function creationCompleteHandler():void + { + var target:TraceTarget = new TraceTarget(); + target.includeLevel = true; + target.filters = ["mx.messaging.*", "mx.rpc.*"]; + Log.addTarget(target); + } + + private function sendMessage():void + { + var msg:AsyncMessage = new AsyncMessage(); + msg.body = "Foo" + counter++; + producer.send(msg); + } + + private function messageHandler(event:MessageEvent):void + { + ta.text += "Consumer received message: "+ event.message.body + "\n"; + } + + private function faultHandler(event:MessageFaultEvent):void + { + ta.text += "Received fault: " + event.faultString + "\n"; + } + + [Bindable] + public var counter2:int = 0; + + + private function sendMessage2():void + { + var msg:AsyncMessage = new AsyncMessage(); + msg.body = "Foo" + counter2++; + producer2.send(msg); + } + + private function messageHandler2(event:MessageEvent):void + { + ta2.text += "Consumer received message: "+ event.message.body + "\n"; + } + + private function faultHandler2(event:MessageFaultEvent):void + { + ta2.text += "Received fault: " + event.faultString + "\n"; + } + ]]> + </mx:Script> + + + + + <mx:Script> + <![CDATA[ + import mx.messaging.events.MessageFaultEvent; + import mx.messaging.events.MessageEvent; + import mx.messaging.messages.AsyncMessage; + import mx.messaging.Producer; + import mx.messaging.Consumer; + + import mx.logging.Log; + import mx.logging.targets.TraceTarget; + + + ]]> + </mx:Script> </mx:Application> \ No newline at end of file
