Channel test according to documentation

ChannelTest.java (text/x-java), 1.76 KB, created by Matthias Müller on 2014-03-22 10:46:38 UTC

(hide)

Description: Channel test according to documentation

Filename:

MIME Type:

Creator: Matthias Müller

Created: 2014-03-22 10:46:38 UTC

Size: 1.76 KB

patch

obsolete

>import java.io.Serializable; > >import org.apache.catalina.tribes.Channel; >import org.apache.catalina.tribes.ChannelException; >import org.apache.catalina.tribes.ChannelListener; >import org.apache.catalina.tribes.Member; >import org.apache.catalina.tribes.MembershipListener; >import org.apache.catalina.tribes.group.GroupChannel; > >public class ChannelTest { > public static void main(String[] args) throws ChannelException { > // create a channel > Channel myChannel = new GroupChannel(); > > // create my listeners > ChannelListener msgListener = new ChannelListener() { > public void messageReceived(Serializable msg, Member sender) { > System.out.println("ChannelListener#messageReceived message:" + msg + " sender: " + sender); > } > > public boolean accept(Serializable msg, Member sender) { > System.out.println("ChannelListener#accept message:" + msg + " sender: " + sender); > return true; > } > }; > > MembershipListener mbrListener = new MembershipListener() { > public void memberDisappeared(Member member) { > System.out.println("MembershipListener#memberDisappeared " + member); > } > > public void memberAdded(Member member) { > System.out.println("MembershipListener#memberAdded " + member); > } > }; > > // attach the listeners to the channel > myChannel.addMembershipListener(mbrListener); > myChannel.addChannelListener(msgListener); > > // start the channel > myChannel.start(Channel.DEFAULT); > > // create a message to be sent, message must implement > // java.io.Serializable > // for performance reasons you probably want them to implement > // java.io.Externalizable > Serializable myMsg = "testmessage"; > > // retrieve my current members > Member[] group = myChannel.getMembers(); > > // send the message > myChannel.send(group, myMsg, Channel.SEND_OPTIONS_DEFAULT); > } >} View Attachment As Raw

This is ASF Bugzilla: the Apache Software Foundation bug system. In case of problems with the functioning of ASF Bugzilla, please contact bugzilla-admin@apache.org. Please Note: this e-mail address is only for reporting problems with ASF Bugzilla. Mail about any other subject will be silently ignored.

• • Home
  • | New
  • | Browse
  • | Search
  • |
    [?]
  • | Reports
  • | Help
  • | New Account
  • | Log In
    Remember [x]
  • | Forgot Password
    Login: [x]