List of joinGroup() Examples

Examples of joinGroup()

com.linkedin.databus.groupleader.pub.GroupLeadershipConnection.joinGroup()
Join the group {@code groupName}. Either at the time of joining the group, or at any future time, the {@code GroupLeadershipConnection} will call {@code acceptLeadershipCallback}when the member must accept the leadership role. The member name can be specified by the caller, or can be {@code null}, in which case the {@code GroupLeadershipConnection} will generate and assign a unique name.The member name must be unique within the group. If a non-unique name is passed in, an {@code IllegalArgumentException} will be thrown. @param groupName the name of the group to join @param memberName the name of the member joining the group, or {@code null} if thename should be generated and assigned @param acceptLeadershipCallback the callback that will be called when this membermust accept leadership @return a session representing the membership of the given {@code memberName} in the given{@code groupName}. The {@code memberName} in the session will be either what was passed in tothis method (if the input name was not null), or the assigned name (if the input name was null). @throws IllegalArgumentException if {@code memberName} is not unique within the group
io.netty.channel.socket.DatagramChannel.joinGroup()
Joins a multicast group.
java.net.MulticastSocket.joinGroup()
Joins a multicast group. Its behavior may be affected by setInterface or setNetworkInterface.
If there is a security manager, this method first calls its checkMulticast method with the mcastaddr argument as its argument. @param mcastaddr is the multicast address to join @exception IOException if there is an error joiningor when the address is not a multicast address. @exception SecurityException if a security manager exists and its checkMulticast method doesn't allow the join. @see SecurityManager#checkMulticast(InetAddress)
org.apache.stratos.cartridge.agent.ClusteringClient.joinGroup()
Join a cluster group of the Elastic Load Balancer @param registrant Registrant @param configurationContext ConfigurationContext @throws CartridgeAgentException If an error occurs while joining a cluster group

Examples of java.net.MulticastSocket.joinGroup()

    MulticastSocket reqSock = new MulticastSocket();
    reqSock.send(request);
    
    // Wait for Response
    MulticastSocket resSock = new MulticastSocket(SERVICE_PORT);
    resSock.joinGroup(SERVICE_RESPONSE_IP);
    
    // 9 = # of bytes for an IP Address + 5 byte port
    DatagramPacket response = new DatagramPacket(new byte[9],9);
    
    // Receive

View Full Code Here

Examples of java.net.MulticastSocket.joinGroup()

    MulticastSocket reqSock = new MulticastSocket();
    reqSock.send(request);
    
    // Response Socket
    MulticastSocket resSock = new MulticastSocket(SERVICE_PORT);
    resSock.joinGroup(SERVICE_RESPONSE_IP);
    
    // 9 = # of bytes for an IP Address + 5 byte port
    DatagramPacket response = new DatagramPacket(new byte[9],9);
    
    // Set Socket Timeout

View Full Code Here

Examples of java.net.MulticastSocket.joinGroup()

         }
         s.setSoTimeout(timeout);
         s.setTimeToLive(ttl);
         if(log.isTraceEnabled())
            log.trace("TTL on multicast discovery socket is " + ttl);
         s.joinGroup(iaGroup);
         if (trace)
            log.trace("MulticastSocket: " + s);
         DatagramPacket packet;
         // Send a request optionally restricted to a cluster partition
         StringBuffer data = new StringBuffer("GET_ADDRESS");

View Full Code Here

Examples of java.net.MulticastSocket.joinGroup()

         }
         s.setSoTimeout(timeout);
         s.setTimeToLive(ttl);
         if(log.isTraceEnabled())
            log.trace("TTL on multicast discovery socket is " + ttl);
         s.joinGroup(iaGroup);
         if (trace)
            log.trace("MulticastSocket: " + s);
         DatagramPacket packet;
         // Send a request optionally restricted to a cluster partition
         StringBuffer data = new StringBuffer("GET_ADDRESS");

View Full Code Here

Examples of java.net.MulticastSocket.joinGroup()

            return existingKey;
        }


        boolean success = false;
        try {
            msocket.joinGroup(mcastaddr, interf);
            success = true;
            return newKey;
        } finally {
            if (!success) {
                mcastKeys.remove(newKey);

View Full Code Here

Examples of java.net.MulticastSocket.joinGroup()

                String multicastGroup = System.getProperty("hazelcast.multicast.group");
                if (multicastGroup == null) {
                    multicastGroup = multicastConfig.getMulticastGroup();
                }
                multicastConfig.setMulticastGroup(multicastGroup);
                multicastSocket.joinGroup(InetAddress.getByName(multicastGroup));
                multicastSocket.setSoTimeout(1000);
                mcService = new MulticastService(this, multicastSocket);
                mcService.addMulticastListener(new NodeMulticastListener(this));
            }
        } catch (Exception e) {

View Full Code Here

Examples of java.net.MulticastSocket.joinGroup()

        InetAddress inetAddress = InetAddress.getByName(host);


        InetSocketAddress address = new InetSocketAddress(inetAddress, port);


        MulticastSocket multicast = new MulticastSocket(port);
        multicast.joinGroup(inetAddress);


        if (ttl != null) {
            multicast.setTimeToLive(ttl);
        }

View Full Code Here

Examples of java.net.MulticastSocket.joinGroup()

                ms.setSoTimeout(0);
                ms.setTimeToLive(TTL);
                if (!ms.getBroadcast()) {
                    ms.setBroadcast(true);
                }
                ms.joinGroup(ia);


                list.add(ms);


                log.debug(String.format("Created MulticastSocket for '%1$s:%2$s' on network adapter: %3$s", ia.getHostName(), port, ni));

View Full Code Here

Examples of java.net.MulticastSocket.joinGroup()

            if (group != null)
            {
               MulticastSocket socket = new MulticastSocket(bindAddress);


               m_socket = socket;
               socket.joinGroup(group);
            }
            else if (bindAddress.getPort() <= 0)
            {
               DatagramChannel channel = DatagramChannel.open();

View Full Code Here

Examples of java.net.MulticastSocket.joinGroup()


        @Override
        public void run() {
            try (MulticastSocket s = new MulticastSocket(PORT)) {
                s.setLoopbackMode(false);
                s.joinGroup(INET_ADDRESS);
                DatagramPacket p = new DatagramPacket(new byte[4], 4);
                p.setAddress(INET_ADDRESS);
                p.setPort(PORT);
                while (run) {
                    s.receive(p);

View Full Code Here

0 1 2 3 4 5

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.