ds.funnel.data.msglink.protocol3

Class MessageLinkFactory

java.lang.Object

ds.funnel.data.msglink.protocol3.MessageLinkFactory

All Implemented Interfaces:

ChannelProtocolFactory

public class MessageLinkFactory
extends java.lang.Object
implements ChannelProtocolFactory

Constructor Summary

Constructors

Constructor and Description
MessageLinkFactory(int inMaxChannels) Create a new protocol store.

Method Summary

Modifier and Type	Method and Description
ChannelProtocol	createProtocol()
MessageProtocol	getGroupProtocol(NodeDetails inDetails) Get the stored group protocol associated with the given node.
MessageLink	openLink(NodeDetails inDetails) Open a new connection to the given node.
MessageLink	openVirtualLink(NodeDetails inDetails) Open a new virtual connection using the stored group protocol.

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageLinkFactory

public MessageLinkFactory(int inMaxChannels)

Create a new protocol store.

Parameters:

inMaxChannels - - The max number of channels to open to each destination.

Method Detail

createProtocol

public ChannelProtocol createProtocol()

Specified by:

createProtocol in interface ChannelProtocolFactory

Returns:

A newly created protocol instance.

getGroupProtocol

public MessageProtocol getGroupProtocol(NodeDetails inDetails)

Get the stored group protocol associated with the given node.

Parameters:

inDetails - - The associated node.

Returns:

The associated group protocol.

Throws:

java.io.IOException

openLink

public MessageLink openLink(NodeDetails inDetails)
                     throws LinkException

Open a new connection to the given node.

Parameters:

inDetails - - The node to connect to.

Returns:

A message link for the new connection.

Throws:

java.io.IOException

LinkException

openVirtualLink

public MessageLink openVirtualLink(NodeDetails inDetails)
                            throws LinkException

Open a new virtual connection using the stored group protocol.

Parameters:

inDetails - - The node to connect to.

Returns:

A message link for the new connection.

Throws:

java.io.IOException

LinkException