Package org.jgroups

Examples of org.jgroups.ReceiverAdapter

39
40
41
42
43
44
45
46
47
48
49
            if(line.startsWith("subscribe")) {
                final String topic=line.substring("subscribe".length()).trim();
                if(!topics.containsKey(topic)) {
                    // we need to make sure "singleton_name" is set in the transport
                    JChannel ch=createSharedChannel("pubsub", props);
                    ch.setReceiver(new ReceiverAdapter() {
                        public void receive(Message msg) {
                            System.out.println("[" + topic + "] << " + msg.getObject());
                        }
                    });
                    ch.connect(topic);
View Full Code Here
16
17
18
19
20
21
22
23
24
25
26
    protected JChannel ch;

    void start(String props, String channel_name) throws Exception {
        ch=new JChannel(props);
        ch.setName(channel_name);
        ch.setReceiver(new ReceiverAdapter() {
            public void viewAccepted(View view) {
                System.out.println("-- view: " + view);
            }
        });
        loop();
View Full Code Here
26
27
28
29
30
31
32
33
34
35
36
        loop();
    }

    public void start(JChannel ch) throws Exception {
        this.ch=ch;
        ch.setReceiver(new ReceiverAdapter() {
            public void viewAccepted(View view) {
                System.out.println("-- view: " + view);
            }
        });
        loop();
View Full Code Here
31
32
33
34
35
36
37
38
39
40
41
                                 new GMS(),
                                 new UFC(),
                                 new MFC(),
                                 new FRAG2());

        ch.setReceiver(new ReceiverAdapter() {
            public void viewAccepted(View new_view) {
                System.out.println("view: " + new_view);
            }

            public void receive(Message msg) {
View Full Code Here
327
328
329
330
331
332
333
334
335
336
337
         }

         public synchronized void connect() throws Exception
         {
            if (channel.isConnected()) return;
            channel.setReceiver(new ReceiverAdapter() {

               @Override
               public void receive(Message msg)
               {
                  synchronized(receivers)
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
                .addProtocol(new UFC())
                .addProtocol(new MFC())
                .addProtocol(new FRAG2());
        stack.init();

        ch.setReceiver(new ReceiverAdapter() {
            public void viewAccepted(View new_view) {
                System.out.println("view: " + new_view);
            }

            public void receive(Message msg) {
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
                .addProtocol(new UFC())
                .addProtocol(new MFC())
                .addProtocol(new FRAG2());
        stack.init();

        ch.setReceiver(new ReceiverAdapter() {
            public void viewAccepted(View new_view) {
                System.out.println("view: " + new_view);
            }

            public void receive(Message msg) {
View Full Code Here
327
328
329
330
331
332
333
334
335
336
337
         }

         public synchronized void connect() throws Exception
         {
            if (channel.isConnected()) return;
            channel.setReceiver(new ReceiverAdapter() {

               @Override
               public void receive(Message msg)
               {
                  synchronized(receivers)
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
    @Override
    protected void doPreSetup() throws Exception {
        super.doPreSetup();
        channel = new JChannel();
        channel.setReceiver(new ReceiverAdapter() {
            @Override
            public void receive(Message msg) {
                messageReceived = msg.getObject();
            }
        });
View Full Code Here
37
38
39
40
41
42
43
44
45
46
47
        Message message = new Message(null, null, data);
        this.channel.send(message);
    }

    public void addReceiver(final Recipient recipient) {
        ReceiverAdapter adapter = new ReceiverAdapter() {
            @Override
            public void receive(Message message) {
                if (message.getSrc().equals(channel.getAddress())) {
                    // Ignore my own messages
                    return;
View Full Code Here
TOP

Related Classes of org.jgroups.ReceiverAdapter

  • co.paralleluniverse.galaxy.jgroups.ControlTreeTKB
  • co.paralleluniverse.galaxy.jgroups.JGroupsComm
  • co.paralleluniverse.galaxy.jgroups.JGroupsDistributedTreeTKB
  • co.paralleluniverse.galaxy.jgroups.JGroupsTKB
  • com.kylin.jgroups.demo.ProgrammaticChat
  • com.kylin.jgroups.demo.SimplisticChat
  • com.kylin.jgroups.demo.TopologySwing
  • com.kylin.jgroups.protocol.CustomizeProtocol
  • com.kylin.jgroups.test.TPTest
  • net.windwards.dnsfrontend.client.Client
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.