org.apache.river.discovery.internal

Class MulticastClient

java.lang.Object

org.apache.river.discovery.internal.MulticastClient

All Implemented Interfaces:

DelayedMulticastAnnouncementDecoder, DiscoveryFormatProvider, MulticastAnnouncementDecoder, MulticastRequestEncoder

Direct Known Subclasses:

Client, Client, Client, Client, Client, Client

public abstract class MulticastClient
extends Object
implements DelayedMulticastAnnouncementDecoder, MulticastRequestEncoder

Author:

peter

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MulticastClient(X500Client impl) Constructs a new instance.

Method Summary

Modifier and Type	Method and Description
MulticastAnnouncement	decodeMulticastAnnouncement(ByteBuffer buf, InvocationConstraints constraints)
MulticastAnnouncement	decodeMulticastAnnouncement(ByteBuffer buf, InvocationConstraints constraints, boolean delayConstraintCheck)
void	encodeMulticastRequest(MulticastRequest request, DatagramBufferFactory bufs, InvocationConstraints constraints)
String	getFormatName()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MulticastClient

protected MulticastClient(X500Client impl)

Constructs a new instance.

Parameters:

impl -

Method Detail

getFormatName

public String getFormatName()

Specified by:

getFormatName in interface DiscoveryFormatProvider

encodeMulticastRequest

public void encodeMulticastRequest(MulticastRequest request,
                                   DatagramBufferFactory bufs,
                                   InvocationConstraints constraints)
                            throws IOException

Specified by:

encodeMulticastRequest in interface MulticastRequestEncoder

Throws:

IOException

decodeMulticastAnnouncement

public MulticastAnnouncement decodeMulticastAnnouncement(ByteBuffer buf,
                                                         InvocationConstraints constraints)
                                                  throws IOException

Specified by:

decodeMulticastAnnouncement in interface MulticastAnnouncementDecoder

Throws:

IOException

decodeMulticastAnnouncement

public MulticastAnnouncement decodeMulticastAnnouncement(ByteBuffer buf,
                                                         InvocationConstraints constraints,
                                                         boolean delayConstraintCheck)
                                                  throws IOException

Specified by:

decodeMulticastAnnouncement in interface DelayedMulticastAnnouncementDecoder

Throws:

IOException