You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I'm new to amqp,I want connect flex to rabbitmq, and get get information from rabbitmq. I write code like this, but it donot work. Is this right?
help me please
protected function application1_creationCompleteHandler(event:FlexEvent):void
{
var param:ConnectionParameters=new ConnectionParameters();
param.username="guest";
param.password="guest";
param.serverhost="192.168.30.1";
param.serverport=8080;
param.vhostpath="/";
this.amqpConnection=new Connection(param);
var myClient:SubscribeClientImpl=new SubscribeClientImpl(this.amqpConnection);
myClient.serializer=this.serializer;
myClient.exchange="fanOutExchange";
myClient.exchangeType="fanout";
myClient.subscribe("QUEUE4TU", onConsumeAmqpMessage);
}
private function onConsumeAmqpMessage(event:CorrelatedMessageEvent):void
{
var lMessage:String=event.result;
trace(lMessage);
}
The text was updated successfully, but these errors were encountered:
I'm new to amqp,I want connect flex to rabbitmq, and get get information from rabbitmq. I write code like this, but it donot work. Is this right?
help me please
The text was updated successfully, but these errors were encountered: