[Spread-users] simplified code to illustrate groups problem I'm having
John de la Garza
john at jjdev.com
Tue Apr 1 12:30:34 EDT 2008
I knew I was doing something wrong... Thanks, it is really clear to
me now.
On Apr 1, 2008, at 9:28 AM, John Schultz wrote:
> A "group message," as you are calling it, is a MEMBERSHIP message
> that tells you the current membership of the group.
>
> These messages are generated by Spread, not users, and are only
> delivered when the membership of a group changes. The first
> message you get is a group message telling you (and any other group
> members) that you've joined the group.
>
> The other messages you get are the ones you sent to the group being
> delivered back to you. These are regular messages, not membership
> messages.
>
> Cheers!
>
> ---
> John Schultz
> Spread Concepts
> Phn: 443 838 2200
>
> On Mon, 31 Mar 2008, John de la Garza wrote:
>
>> Here is my latest code and output. I pass true in as the last arg
>> to connect. I still don't get group messages...
>>
>> output:
>> -------------------------------------------
>> group message
>> msgrcv grp: flooder
>> non group message
>> non group message
>> non group message
>> non group message
>> non group message
>> non group message
>> non group message
>> non group message
>> non group message
>> non group message
>>
>>
>>
>> code:
>> -------------------------------------------
>> import spread.*;
>> import java.net.*;
>>
>> public class Flooder implements AdvancedMessageListener
>> {
>> SpreadConnection connection;
>> SpreadMessage out;
>>
>> public static void main(String[] args) {
>> Flooder f = new Flooder();
>> f.run();
>> }
>>
>> public void run() {
>> try {
>> connection = new SpreadConnection();
>> connection.connect(InetAddress.getByName(null), 0,
>> "flooder", false, true);
>> connection.add(this);
>> SpreadGroup group = new SpreadGroup();
>> group.join(connection, "flooder");
>> out = null;
>> out = new SpreadMessage();
>> out.setData(new byte[1000]);
>> out.setSafe();
>> out.setReliable();
>> out.addGroup("flooder");
>> sendLoop();
>> Thread.sleep(100000);
>> }
>> catch(Exception e) {
>> e.printStackTrace();
>> }
>> }
>>
>> void sendLoop() throws Exception{
>> for(int i = 1 ; i <= 10 ; i++) {
>> connection.multicast(out);
>> }
>> }
>> public void regularMessageReceived(SpreadMessage msg) {
>> System.out.println("non group message");
>> }
>> public void membershipMessageReceived(SpreadMessage msg) {
>> System.out.println("group message");
>> System.out.println("msgrcv "+" grp: "+msg.getMembershipInfo
>> ().getGroup());
>> }
>>
>> }
>>
>> _______________________________________________
>> Spread-users mailing list
>> Spread-users at lists.spread.org
>> http://lists.spread.org/mailman/listinfo/spread-users
>>
More information about the Spread-users
mailing list