群组成员资格

功能 > ActiveMQ Classic 实时 > 群组成员资格

ActiveBlaze 通过 GroupChannel 支持群组成员资格，GroupChannel 可以从 GroupChannelFactory 创建。您必须明确说明要加入/离开哪个组 - 并且可以加入多个组。每个 GroupChannel 都有一个全局唯一的 ID 和一个名称。

import org.apache.activeblaze.group.*;

...
BlazeGroupChannelFactory factory = new BlazeGroupChannelFactory();

BlazeGroupChannel channel = factory.createGroupChannel("My Channel");
//join a group
channel.addToGroup("test");
channel.start();

//listen for other members

channel.addMemberChangedListener(new MemberChangedListener(){

     public void memberStarted(Member member) {
         System.out.println("Member started");
     }

     public void memberStopped(Member member) {
         System.out.println("Member stopped");
     }
            
 });