You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flex.apache.org by cd...@apache.org on 2015/08/04 12:16:12 UTC
[04/51] [partial] flex-blazeds git commit: Refactored the directory
structure
http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/012fad7c/attic/apps/team/features/messaging/cluster/messaging_SecureHTTP_Poll_Cluster.mxml
----------------------------------------------------------------------
diff --git a/attic/apps/team/features/messaging/cluster/messaging_SecureHTTP_Poll_Cluster.mxml b/attic/apps/team/features/messaging/cluster/messaging_SecureHTTP_Poll_Cluster.mxml
index 5671022..d5da650 100755
--- a/attic/apps/team/features/messaging/cluster/messaging_SecureHTTP_Poll_Cluster.mxml
+++ b/attic/apps/team/features/messaging/cluster/messaging_SecureHTTP_Poll_Cluster.mxml
@@ -1,95 +1,95 @@
-<?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();">
-
- <!-- Before running this test, make sure messaging_SecureHTTP_Poll_Cluster is
- uncommented from messaging-config.xml and you request the sample with
- secure protocol (https) and port.
- -->
- <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_SecureHTTP_Poll_Cluster"
- fault="faultHandler(event)"/>
-
- <mx:Consumer id="consumer"
- destination="messaging_SecureHTTP_Poll_Cluster"
- 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();">
+
+ <!-- Before running this test, make sure messaging_SecureHTTP_Poll_Cluster is
+ uncommented from messaging-config.xml and you request the sample with
+ secure protocol (https) and port.
+ -->
+ <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_SecureHTTP_Poll_Cluster"
+ fault="faultHandler(event)"/>
+
+ <mx:Consumer id="consumer"
+ destination="messaging_SecureHTTP_Poll_Cluster"
+ 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/customadapter/messaging_CustomAdapter.mxml
----------------------------------------------------------------------
diff --git a/attic/apps/team/features/messaging/customadapter/messaging_CustomAdapter.mxml b/attic/apps/team/features/messaging/customadapter/messaging_CustomAdapter.mxml
index 2c1f22e..190b737 100755
--- a/attic/apps/team/features/messaging/customadapter/messaging_CustomAdapter.mxml
+++ b/attic/apps/team/features/messaging/customadapter/messaging_CustomAdapter.mxml
@@ -1,101 +1,101 @@
-<?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();">
-
- <!--
- A sample that talks to a destination that has a custom Actionscript adapter.
- -->
- <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_CustomAdapter"
- fault="faultHandler(event)"/>
-
- <mx:Consumer id="consumer"
- destination="messaging_CustomAdapter"
- acknowledge="ackHandler(event)"
- fault="faultHandler(event)"
- message="messageHandler(event)"/>
-
- <mx:Script>
- <![CDATA[
- import mx.messaging.events.MessageAckEvent;
- 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 ackHandler(event:MessageAckEvent):void
- {
- ta.text += "Consumer received ACK: " + event.message.body + "\n";
- }
-
- 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();">
+
+ <!--
+ A sample that talks to a destination that has a custom Actionscript adapter.
+ -->
+ <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_CustomAdapter"
+ fault="faultHandler(event)"/>
+
+ <mx:Consumer id="consumer"
+ destination="messaging_CustomAdapter"
+ acknowledge="ackHandler(event)"
+ fault="faultHandler(event)"
+ message="messageHandler(event)"/>
+
+ <mx:Script>
+ <![CDATA[
+ import mx.messaging.events.MessageAckEvent;
+ 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 ackHandler(event:MessageAckEvent):void
+ {
+ ta.text += "Consumer received ACK: " + event.message.body + "\n";
+ }
+
+ 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/discardedMessaging.mxml
----------------------------------------------------------------------
diff --git a/attic/apps/team/features/messaging/discardedMessaging.mxml b/attic/apps/team/features/messaging/discardedMessaging.mxml
index 6087c62..d65c395 100755
--- a/attic/apps/team/features/messaging/discardedMessaging.mxml
+++ b/attic/apps/team/features/messaging/discardedMessaging.mxml
@@ -1,119 +1,119 @@
-<?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:TextInput id="msgInput"/>
- <mx:Button label="Send" 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="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="dev/null"
- fault="faultHandler(event)"/>
-
- <mx:Consumer id="consumer"
- destination="dev/null"
- 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;
-
- 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 = msgInput.text;
- 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>
+<?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:TextInput id="msgInput"/>
+ <mx:Button label="Send" 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="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="dev/null"
+ fault="faultHandler(event)"/>
+
+ <mx:Consumer id="consumer"
+ destination="dev/null"
+ 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;
+
+ 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 = msgInput.text;
+ 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>
http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/012fad7c/attic/apps/team/features/messaging/jms/messaging_AMF_LongPoll_JMS_Topic.mxml
----------------------------------------------------------------------
diff --git a/attic/apps/team/features/messaging/jms/messaging_AMF_LongPoll_JMS_Topic.mxml b/attic/apps/team/features/messaging/jms/messaging_AMF_LongPoll_JMS_Topic.mxml
index 51f18d1..576f7f4 100755
--- a/attic/apps/team/features/messaging/jms/messaging_AMF_LongPoll_JMS_Topic.mxml
+++ b/attic/apps/team/features/messaging/jms/messaging_AMF_LongPoll_JMS_Topic.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_LongPoll_JMS_Topic"
- fault="faultHandler(event)"/>
-
- <mx:Consumer id="consumer"
- destination="messaging_AMF_LongPoll_JMS_Topic"
- 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_LongPoll_JMS_Topic"
+ fault="faultHandler(event)"/>
+
+ <mx:Consumer id="consumer"
+ destination="messaging_AMF_LongPoll_JMS_Topic"
+ 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/jms/messaging_AMF_Poll_JMS_Queue.mxml
----------------------------------------------------------------------
diff --git a/attic/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Queue.mxml b/attic/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Queue.mxml
index 06c71da..0e08155 100755
--- a/attic/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Queue.mxml
+++ b/attic/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Queue.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_JMS_Queue"
- fault="faultHandler(event)"/>
-
- <mx:Consumer id="consumer"
- destination="messaging_AMF_Poll_JMS_Queue"
- 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_JMS_Queue"
+ fault="faultHandler(event)"/>
+
+ <mx:Consumer id="consumer"
+ destination="messaging_AMF_Poll_JMS_Queue"
+ 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/jms/messaging_AMF_Poll_JMS_Topic.mxml
----------------------------------------------------------------------
diff --git a/attic/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Topic.mxml b/attic/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Topic.mxml
index 42ca748..c75e5c3 100755
--- a/attic/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Topic.mxml
+++ b/attic/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Topic.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_JMS_Topic"
- fault="faultHandler(event)"/>
-
- <mx:Consumer id="consumer"
- destination="messaging_AMF_Poll_JMS_Topic"
- 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_JMS_Topic"
+ fault="faultHandler(event)"/>
+
+ <mx:Consumer id="consumer"
+ destination="messaging_AMF_Poll_JMS_Topic"
+ 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/jms/messaging_HTTP_Poll_JMS_Queue.mxml
----------------------------------------------------------------------
diff --git a/attic/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Queue.mxml b/attic/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Queue.mxml
index 00805e7..dda51fe 100755
--- a/attic/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Queue.mxml
+++ b/attic/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Queue.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_JMS_Queue"
- fault="faultHandler(event)"/>
-
- <mx:Consumer id="consumer"
- destination="messaging_HTTP_Poll_JMS_Queue"
- 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_JMS_Queue"
+ fault="faultHandler(event)"/>
+
+ <mx:Consumer id="consumer"
+ destination="messaging_HTTP_Poll_JMS_Queue"
+ 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/jms/messaging_HTTP_Poll_JMS_Topic.mxml
----------------------------------------------------------------------
diff --git a/attic/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Topic.mxml b/attic/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Topic.mxml
index 71c36e7..c8306af 100755
--- a/attic/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Topic.mxml
+++ b/attic/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Topic.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_JMS_Topic"
- fault="faultHandler(event)"/>
-
- <mx:Consumer id="consumer"
- destination="messaging_HTTP_Poll_JMS_Topic"
- 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_JMS_Topic"
+ fault="faultHandler(event)"/>
+
+ <mx:Consumer id="consumer"
+ destination="messaging_HTTP_Poll_JMS_Topic"
+ 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.mxml
----------------------------------------------------------------------
diff --git a/attic/apps/team/features/messaging/messaging_AMF.mxml b/attic/apps/team/features/messaging/messaging_AMF.mxml
index 9786ba7..5ff2534 100755
--- a/attic/apps/team/features/messaging/messaging_AMF.mxml
+++ b/attic/apps/team/features/messaging/messaging_AMF.mxml
@@ -1,121 +1,121 @@
-<?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();" enabled="{producer.connected}"/>
- <mx:CheckBox label="Connected?" selected="{producer.connected}"/>
- </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_AMF"
- fault="faultHandler(event)"/>
-
- <mx:Consumer id="consumer"
- destination="messaging_AMF"
- 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();" enabled="{producer.connected}"/>
+ <mx:CheckBox label="Connected?" selected="{producer.connected}"/>
+ </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_AMF"
+ fault="faultHandler(event)"/>
+
+ <mx:Consumer id="consumer"
+ destination="messaging_AMF"
+ 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_AMF_LongPoll.mxml
----------------------------------------------------------------------
diff --git a/attic/apps/team/features/messaging/messaging_AMF_LongPoll.mxml b/attic/apps/team/features/messaging/messaging_AMF_LongPoll.mxml
index 17da470..dfa7593 100755
--- a/attic/apps/team/features/messaging/messaging_AMF_LongPoll.mxml
+++ b/attic/apps/team/features/messaging/messaging_AMF_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_AMF_LongPoll"
- fault="faultHandler(event)"/>
-
- <mx:Consumer id="consumer"
- destination="messaging_AMF_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_AMF_LongPoll"
+ fault="faultHandler(event)"/>
+
+ <mx:Consumer id="consumer"
+ destination="messaging_AMF_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