ds.funnel.overlay

Class OverlayLinkImpl

java.lang.Object

ds.funnel.overlay.OverlayLinkImpl

All Implemented Interfaces:

MessageLink, OverlayLink, java.lang.AutoCloseable

public class OverlayLinkImpl
extends java.lang.Object
implements OverlayLink

Nested Class Summary

Nested classes/interfaces inherited from interface ds.funnel.overlay.OverlayLink

OverlayLink.LinkState

Constructor Summary

Constructors

Constructor and Description
OverlayLinkImpl(OverlayManagerImpl inManager, OverlayVersionImpl inOverlay, MessageLink inLink, boolean inPrimary)

Method Summary

Modifier and Type	Method and Description
void	close() Close the connection used by this message handler.
EventDispatcher	getDispatcher() Deprecated.
EventHandler<? super MessageEvent>	getEventHandler() Deprecated.
EventProcessor<MessageEvent>	getEventProcessor() Deprecated.
OverlayPath	getLinkedLoc()
NodeDetails	getLinkedTo()
long	getOverlayVer()
LinkStatistics	getRecvStats()
long	getRedirectVer()
LinkStatistics	getSendStats()
boolean	isAlive()
boolean	isClient()
boolean	isDataOut()
boolean	isPrimary()
void	sendMessage(MessageEvent inMessage) Send a message to the connected destination.
<M extends MessageEvent> Task<M>	sendMessage(MessageEvent inMessage, java.lang.Class<M> respType) Send a message to the connected destination, and get a reply task.
void	sendMessage(TopicEvent inMessage, java.util.List<OverlayPath> inDests) Send a message to the connected destination.
void	setEventHandler(EventHandler<? super MessageEvent> inHandler) Set the event handler that incoming events are passed to.
void	setEventProcessor(EventProcessor<MessageEvent> inProcess) Set the event handler that incoming events are passed to.
boolean	setPrimary(boolean inPrimary) Set the primary status of this link.
java.lang.String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

OverlayLinkImpl

public OverlayLinkImpl(OverlayManagerImpl inManager,
                       OverlayVersionImpl inOverlay,
                       MessageLink inLink,
                       boolean inPrimary)

Method Detail

isAlive

public boolean isAlive()

Specified by:

isAlive in interface MessageLink

Returns:

True if the connection is still able to send messages.

isClient

public boolean isClient()

Specified by:

isClient in interface MessageLink

Returns:

True if this is the client (opening) side of a connection.

isPrimary

public boolean isPrimary()

Specified by:

isPrimary in interface OverlayLink

Returns:

True if this is a primary link used for routing data.

isDataOut

public boolean isDataOut()

Specified by:

isDataOut in interface OverlayLink

Returns:

True if there are subscribers though this link.

getLinkedTo

public NodeDetails getLinkedTo()

Specified by:

getLinkedTo in interface MessageLink

Returns:

The details of the connected node.

getRecvStats

public LinkStatistics getRecvStats()

Specified by:

getRecvStats in interface MessageLink

Returns:

Statistics for messages received by this message handler.

getSendStats

public LinkStatistics getSendStats()

Specified by:

getSendStats in interface MessageLink

Returns:

Statistics for messages sent using this message handler.

getOverlayVer

public long getOverlayVer()

Specified by:

getOverlayVer in interface OverlayLink

Returns:

The version of the associated overlay.

getRedirectVer

public long getRedirectVer()

getLinkedLoc

public OverlayPath getLinkedLoc()

Specified by:

getLinkedLoc in interface OverlayLink

Returns:

The location of the linked node in the overlay.

getDispatcher

@Deprecated
public EventDispatcher getDispatcher()

Deprecated.

Specified by:

getDispatcher in interface MessageLink

Returns:

The event dispatcher used for received messages.

getEventHandler

@Deprecated
public EventHandler<? super MessageEvent> getEventHandler()

Deprecated.

Specified by:

getEventHandler in interface MessageLink

Returns:

The event handler that incoming events are passed to.

getEventProcessor

@Deprecated
public EventProcessor<MessageEvent> getEventProcessor()

Deprecated.

Specified by:

getEventProcessor in interface MessageLink

Returns:

The event processor that incoming events are passed to.

setEventHandler

public void setEventHandler(EventHandler<? super MessageEvent> inHandler)
                     throws LinkException

Description copied from interface: MessageLink

Set the event handler that incoming events are passed to.

Specified by:

setEventHandler in interface MessageLink

Throws:

LinkException

setEventProcessor

public void setEventProcessor(EventProcessor<MessageEvent> inProcess)
                       throws LinkException

Description copied from interface: MessageLink

Set the event handler that incoming events are passed to.

Specified by:

setEventProcessor in interface MessageLink

Throws:

LinkException

sendMessage

public void sendMessage(MessageEvent inMessage)
                 throws LinkException

Description copied from interface: MessageLink

Send a message to the connected destination.

Specified by:

sendMessage in interface MessageLink

Parameters:

inMessage - - The message to send.

Throws:

LinkException

sendMessage

public <M extends MessageEvent> Task<M> sendMessage(MessageEvent inMessage,
                                                    java.lang.Class<M> respType)
                                             throws LinkException

Description copied from interface: MessageLink

Send a message to the connected destination, and get a reply task.

Specified by:

sendMessage in interface MessageLink

Parameters:

inMessage - - The message to send.

respType - - The class of the expected response message.

Returns:

A task that will return the response message.

Throws:

LinkException

sendMessage

public void sendMessage(TopicEvent inMessage,
                        java.util.List<OverlayPath> inDests)
                 throws LinkException

Description copied from interface: OverlayLink

Send a message to the connected destination.

Specified by:

sendMessage in interface OverlayLink

Parameters:

inMessage - - The message to send.

inDests - - A list of overlay locations to send the message to.

Throws:

LinkException

setPrimary

public boolean setPrimary(boolean inPrimary)
                   throws OverlayException

Description copied from interface: OverlayLink

Set the primary status of this link.

Specified by:

setPrimary in interface OverlayLink

Parameters:

inPrimary - - True if this link should be primary.

Returns:

True if the status was changed, false otherwise.

Throws:

OverlayException

close

public void close()

Description copied from interface: MessageLink

Close the connection used by this message handler.

Specified by:

close in interface MessageLink

Specified by:

close in interface java.lang.AutoCloseable

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object