flex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aha...@apache.org
Subject [26/51] [partial] BlazeDS Donation from Adobe Systems Inc
Date Fri, 25 Apr 2014 05:34:24 GMT
http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/cluster/messaging_SecureAMF_Poll_Cluster.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/cluster/messaging_SecureAMF_Poll_Cluster.mxml b/apps/team/features/messaging/cluster/messaging_SecureAMF_Poll_Cluster.mxml
new file mode 100755
index 0000000..57367b6
--- /dev/null
+++ b/apps/team/features/messaging/cluster/messaging_SecureAMF_Poll_Cluster.mxml
@@ -0,0 +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_SecureAMF_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_SecureAMF_Poll_Cluster"
+        fault="faultHandler(event)"/>
+               
+    <mx:Consumer id="consumer" 
+        destination="messaging_SecureAMF_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/7a58369c/apps/team/features/messaging/cluster/messaging_SecureHTTP_Poll_Cluster.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/cluster/messaging_SecureHTTP_Poll_Cluster.mxml b/apps/team/features/messaging/cluster/messaging_SecureHTTP_Poll_Cluster.mxml
new file mode 100755
index 0000000..d5da650
--- /dev/null
+++ b/apps/team/features/messaging/cluster/messaging_SecureHTTP_Poll_Cluster.mxml
@@ -0,0 +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>
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/customadapter/messaging_CustomAdapter.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/customadapter/messaging_CustomAdapter.mxml b/apps/team/features/messaging/customadapter/messaging_CustomAdapter.mxml
new file mode 100755
index 0000000..190b737
--- /dev/null
+++ b/apps/team/features/messaging/customadapter/messaging_CustomAdapter.mxml
@@ -0,0 +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>
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/discardedMessaging.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/discardedMessaging.mxml b/apps/team/features/messaging/discardedMessaging.mxml
new file mode 100755
index 0000000..d65c395
--- /dev/null
+++ b/apps/team/features/messaging/discardedMessaging.mxml
@@ -0,0 +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>

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/jms/messaging_AMF_LongPoll_JMS_Topic.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/jms/messaging_AMF_LongPoll_JMS_Topic.mxml b/apps/team/features/messaging/jms/messaging_AMF_LongPoll_JMS_Topic.mxml
new file mode 100755
index 0000000..576f7f4
--- /dev/null
+++ b/apps/team/features/messaging/jms/messaging_AMF_LongPoll_JMS_Topic.mxml
@@ -0,0 +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>
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Queue.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Queue.mxml b/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Queue.mxml
new file mode 100755
index 0000000..0e08155
--- /dev/null
+++ b/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Queue.mxml
@@ -0,0 +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>
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Topic.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Topic.mxml b/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Topic.mxml
new file mode 100755
index 0000000..c75e5c3
--- /dev/null
+++ b/apps/team/features/messaging/jms/messaging_AMF_Poll_JMS_Topic.mxml
@@ -0,0 +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>
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Queue.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Queue.mxml b/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Queue.mxml
new file mode 100755
index 0000000..dda51fe
--- /dev/null
+++ b/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Queue.mxml
@@ -0,0 +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>
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Topic.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Topic.mxml b/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Topic.mxml
new file mode 100755
index 0000000..c8306af
--- /dev/null
+++ b/apps/team/features/messaging/jms/messaging_HTTP_Poll_JMS_Topic.mxml
@@ -0,0 +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>
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/messaging_AMF.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/messaging_AMF.mxml b/apps/team/features/messaging/messaging_AMF.mxml
new file mode 100755
index 0000000..5ff2534
--- /dev/null
+++ b/apps/team/features/messaging/messaging_AMF.mxml
@@ -0,0 +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>
+
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/messaging_AMF_LongPoll.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/messaging_AMF_LongPoll.mxml b/apps/team/features/messaging/messaging_AMF_LongPoll.mxml
new file mode 100755
index 0000000..dfa7593
--- /dev/null
+++ b/apps/team/features/messaging/messaging_AMF_LongPoll.mxml
@@ -0,0 +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>
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/messaging_AMF_Piggyback.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/messaging_AMF_Piggyback.mxml b/apps/team/features/messaging/messaging_AMF_Piggyback.mxml
new file mode 100755
index 0000000..9312b8c
--- /dev/null
+++ b/apps/team/features/messaging/messaging_AMF_Piggyback.mxml
@@ -0,0 +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>
+
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/messaging_AMF_Poll.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/messaging_AMF_Poll.mxml b/apps/team/features/messaging/messaging_AMF_Poll.mxml
new file mode 100755
index 0000000..5dba032
--- /dev/null
+++ b/apps/team/features/messaging/messaging_AMF_Poll.mxml
@@ -0,0 +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>
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/messaging_AMF_Stream.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/messaging_AMF_Stream.mxml b/apps/team/features/messaging/messaging_AMF_Stream.mxml
new file mode 100755
index 0000000..c134fbb
--- /dev/null
+++ b/apps/team/features/messaging/messaging_AMF_Stream.mxml
@@ -0,0 +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>
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/messaging_HTTP.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/messaging_HTTP.mxml b/apps/team/features/messaging/messaging_HTTP.mxml
new file mode 100755
index 0000000..7491e2b
--- /dev/null
+++ b/apps/team/features/messaging/messaging_HTTP.mxml
@@ -0,0 +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>
+
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/messaging_HTTP_LongPoll.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/messaging_HTTP_LongPoll.mxml b/apps/team/features/messaging/messaging_HTTP_LongPoll.mxml
new file mode 100755
index 0000000..233c2be
--- /dev/null
+++ b/apps/team/features/messaging/messaging_HTTP_LongPoll.mxml
@@ -0,0 +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>
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/messaging_HTTP_Piggyback.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/messaging_HTTP_Piggyback.mxml b/apps/team/features/messaging/messaging_HTTP_Piggyback.mxml
new file mode 100755
index 0000000..244263d
--- /dev/null
+++ b/apps/team/features/messaging/messaging_HTTP_Piggyback.mxml
@@ -0,0 +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>
+
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/messaging_HTTP_Poll.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/messaging_HTTP_Poll.mxml b/apps/team/features/messaging/messaging_HTTP_Poll.mxml
new file mode 100755
index 0000000..d385345
--- /dev/null
+++ b/apps/team/features/messaging/messaging_HTTP_Poll.mxml
@@ -0,0 +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>
+</mx:Application>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/7a58369c/apps/team/features/messaging/messaging_HTTP_Stream.mxml
----------------------------------------------------------------------
diff --git a/apps/team/features/messaging/messaging_HTTP_Stream.mxml b/apps/team/features/messaging/messaging_HTTP_Stream.mxml
new file mode 100755
index 0000000..51516dc
--- /dev/null
+++ b/apps/team/features/messaging/messaging_HTTP_Stream.mxml
@@ -0,0 +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>
+</mx:Application>
\ No newline at end of file


Mime
View raw message