Examples of org.jgroups.JChannel.send()

org.jgroups.JChannel.send()
Sends a message through the protocol stack. Implements the Transport interface. @param msg the message to be sent through the protocol stack,the destination of the message is specified inside the message itself @exception ChannelNotConnectedException @exception ChannelClosedException

            Message startJgMessage=new Message();
            startJgMessage.setObject(startMessage);


            JChannel sender= channel2;


            sender.send(startJgMessage);


            for(int i=0; i < MESSAGE_NUMBER; i++) {
                Long message=new Long(System.currentTimeMillis());

View Full Code Here

                
                Message jgMessage=new Message();
                jgMessage.putHeader("EncryptOrderTest", new EncryptOrderTestHeader(i));
                jgMessage.setObject(message);


                sender.send(jgMessage);


                if(i % 1000 == 0)
                    System.out.println("sent " + i + " messages.");


                if(SLEEP_BETWEEN_SENDING)

View Full Code Here

                    org.jgroups.util.Util.sleep(1, true);
            }


            Message stopJgMessage=new Message();
            stopJgMessage.setObject(stopMessage);
            sender.send(stopJgMessage);


            time=System.currentTimeMillis() - time;


            System.out.println("Finished sending messages. Operation took " + time);

View Full Code Here

            int index=line.indexOf(":");
            if(index == -1) {
                // post to all topics
                for(JChannel ch: topics.values()) {
                    Message msg=new Message(null, null, line);
                    ch.send(msg);
                }
                continue;
            }
            String topic=line.substring(0, index).trim();
            String message=line.substring(index).trim();

View Full Code Here

            if(ch == null) {
                System.err.println("sending to topic \"" + topic + "\" failed as topic doesn't exist, subscribe first");
                continue;
            }
            Message msg=new Message(null, null, message);
            ch.send(msg);
        }
        for(JChannel ch: topics.values())
            Util.close(ch);
    }

View Full Code Here

        ch.connect("ChatCluster");




        for(;;) {
            String line=Util.readStringFromStdin(": ");
            ch.send(null, line);
        }
    }


}

View Full Code Here

                buf=output.getRawBuffer();
                out.close();


                if(jg) {
                    send_msg=new Message(null, null, buf, 0, buf.length);
                    channel.send(send_msg);
                }
                else {
                    packet=new DatagramPacket(buf, buf.length, group_addr, group_port);
                    sock.send(packet);
                }

View Full Code Here

            ch1.connect("x");
            ch2=new JChannel(props);
            ch2.setReceiver(new MyReceiver());
            ch2.connect("x");
            for(int i=0; i < 10; i++) {
                ch1.send(new Message(null, null, System.currentTimeMillis()));
                Util.sleep(1000);
            }
            ch2.close();
            ch1.close();
            return;

View Full Code Here

                bb.putInt(i);
                buf=(byte[])(bb.array()).clone();


                if(jg) {
                    send_msg=new Message(null, null, buf);
                    channel.send(send_msg);
                }
                else {
                    packet=new DatagramPacket(buf, buf.length, group_addr, 7777);
                    sock.send(packet);
                }

View Full Code Here

            ch2.connect("x");
            for(int i=0; i < 10; i++) {
                Message msg=new Message();
                msg.setFlag((byte)(Message.DONT_BUNDLE | Message.NO_FC));
                msg.setObject(System.nanoTime());
                ch1.send(msg);
                Util.sleep(1000);
            }
            ch2.close();
            ch1.close();
            return;

View Full Code Here

0 1 2

TOP

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.