MessageBroker msgBroker = MessageBroker.getMessageBroker(null);
MessageService service = (MessageService) msgBroker.getService( SERVICE );
MessageDestination msgDest = (MessageDestination)service.getDestination( DESTINATION );
MessageClient msgClient = msgDest.getSubscriptionManager().getSubscriber(clientId);
if (msgClient != null) {
msgDest.getSubscriptionManager().removeSubscriber(msgClient);
System.out.println("删除Flex客户端[" + clientId + "]" );
} else {
System.out.println("Flex客户端[" + clientId + "]已经注销!");
}
在别的地方看到的,还没测试,先留下。
分享到:
相关推荐
Consumer_api_client
Go-consumergroup:采用golang编写的kafka consumer库
kafka_client_producer_consumer
mulesoft3.8 webService consumer
kafka_hdfs_consumer实现
HL7 PIX Consumer发送的消息和接收消息的解析。
dubbo provider consumer 基于zookeeper的远程调用代码服务样例,直接运行
标签:archiva-consumer-api-1.0.jar,archiva,consumer,api,1.0,jar包下载,依赖包
整合spring3 blazeds activeMQ(jms) 通过flex consumer来订阅消息。时时更新消息内容
这是使用java操作kafka consumer api的一个demo,欢迎下载交流,博客地址:https://blog.csdn.net/qq_26803795
spring boot 集成 dubbo consumer provider 例子
spring-boot-activemq-consumer 源码
Artificial Intelligence Marketing and Predicting Consumer Choice: An Overview of Tools and Techniques by Steven Struhl English | 3 Apr. 2017 | ASIN: B06XW8DS8G | 270 Pages | AZW3 | 6.16 MB The ...
dubbo-consumer 最简单测试案例
feign例子,创建一个接口并用注解的方式来配置它,即可完成对服务提供方的接口绑定。
dubbo-consumer.zip
dubbo的consumer和provider,注册中心用的是redis,maven项目。pom文件中有包的引入和版本,直接main方法启动即可。
dubbo_provider_and_consumer,dubbo消费和提供者实例,博文教程:http://blog.csdn.net/u013142781/article/details/50387583
Consumer lending is the sleeping giant of the financial sector. The growth in consumer credit over the last 50 years is truly spectacular. The marketplace for total retail banking and consumer lending...
dubbo-provider dubbo-consumer