flex消息机制 flex-blazeds-java
发布时间:2020-12-15 01:20:54 所属栏目:百科 来源:网络整理
导读:java后台:消息的发布 ? MessageBroker msgBroker = MessageBroker.getMessageBroker(null); String clientID = UUIDUtils.createUUID(); AsyncMessage message = new AsyncMessage();message.setDestination("consumer"); message.setHeader("DSSubtopic","
java后台:消息的发布 ? MessageBroker msgBroker = MessageBroker.getMessageBroker(null); String clientID = UUIDUtils.createUUID(); AsyncMessage message = new AsyncMessage();message.setDestination("consumer"); message.setHeader("DSSubtopic","test"); message.setClientId(clientID); message.setMessageId(UUIDUtils.createUUID()); message.setTimestamp(System.currentTimeMillis()); message.setBody(clientID); msgBroker.routeMessageToService(message,null);
var fileReceiveConsumer:Consumer=new Consumer(); fileReceiveConsumer.destination="consumer"; fileReceiveConsumer.subtopic="test"; var channelSet:ChannelSet = new ChannelSet(); channelSet.addChannel( new StreamingAMFChannel( "my-streaming-amf","http://localhost:8080/szdlIM/messagebroker/streamingamf");); fileReceiveConsumer.channelSet=channelSet; fileReceiveConsumer.addEventListener(MessageEvent.MESSAGE,handle); fileReceiveConsumer.subscribe();
<destination id="consumer"> <properties> <server> <allow-subtopics>true</allow-subtopics> <subtopic-separator>.</subtopic-separator> </server> </properties> <channels> <channel ref="my-streaming-amf" /> <channel ref="my-polling-amf" /> </channels> </destination> (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |