[flexcoders] problem with Consumer

[Dominic Pazula]

I have a flex project using BlazeDS where I am trying to create a 
message destination dynamically and then subscribe to it in Flex.  
I've been using the sample from Blaze as a reference.

Java method returns the string of the new destination:
...
ms = (MessageService) MessageBroker.getMessageBroker(null).getService
("message-service");
MessageDestination destination = (MessageDestination) 
ms.createDestination(dStr);
                
if (ms.isStarted())
{
   System.out.println("Starting Destination " + dStr);
   destination.start();
}
... 
return dStr;

In Flex, this Java method is called through a RemoteObject and the 
handle on the result does the following:
var consumer:Consumer = new Consumer();
if (event.result != null){
   var destination:String = event.result as String;
   var myStreamingAMF:AMFChannel = new StreamingAMFChannel("my-
streaming-amf", "../messagebroker/streamingamf");
   var myPollingAMF:AMFChannel = new AMFChannel("my-polling-
amf", "../messagebroker/amfpolling");
   myPollingAMF.pollingEnabled = true;
   myPollingAMF.pollingInterval = 2000;
   var channelSet:ChannelSet = new ChannelSet();
   channelSet.addChannel(myStreamingAMF);
   channelSet.addChannel(myPollingAMF);
   consumer.channelSet = channelSet;                    
   consumer.destination = destination;
   consumer.addEventListener(MessageEvent.MESSAGE, handleMessage);
   consumer.subscribe();
}
Alert.show("Subscrided: " + consumer.subscribed);

The Alert box is showing the consumer is not subscribed.  I've traced 
through and everything looks ok.  Anyone know what I am doing wrong?

Thanks
Dom