info.pppc.base.plugin.ip

Class MxIPMulticastTransceiver

java.lang.Object

info.pppc.base.plugin.ip.IPMulticastTransceiver

info.pppc.base.plugin.ip.MxIPMulticastTransceiver

All Implemented Interfaces:

IMultiplexPlugin, IIPPlugin, IExtension, IOperation, IPlugin, IStreamer, ITransceiver

public class MxIPMulticastTransceiver
extends IPMulticastTransceiver
implements IMultiplexPlugin

The multiplexing ip transceiver is a net transceiver that performs connection multiplexing in order to reduce the number of tcp connections opened by the transceiver. This should greatly reduce the delay of invocations at the cost of double-buffered messages.

Author:

Marcus Handte

Field Summary

Fields inherited from interface info.pppc.base.system.IExtension

EXTENSION_COMPRESSION, EXTENSION_DISCOVERY, EXTENSION_ENCRYPTION, EXTENSION_ROUTING, EXTENSION_SEMANTIC, EXTENSION_SERIALIZATION, EXTENSION_TRANSCEIVER

Fields inherited from interface info.pppc.base.system.plugin.ITransceiver

EVENT_TRANCEIVER_DISABLED, EVENT_TRANCEIVER_ENABLED

Constructor Summary

Constructors

Constructor and Description
MxIPMulticastTransceiver() Creates a transceiver that binds to any address.
MxIPMulticastTransceiver(byte[] address) Creates a transceiver that binds to the specified address.

Method Summary

Methods

Modifier and Type	Method and Description
void	acceptConnector(MultiplexFactory source, IStreamConnector connector) Called by a multiplexer whenever a new connector is opened due to remote system request.
void	closeMultiplexer(MultiplexFactory multiplexer) Called by a multiplexer whenever the multiplexer is closed.
PluginDescription	getPluginDescription() Returns the plug-in description of the transceiver.
IPluginManager	getPluginManager() Returns a reference to the plug-in manager as required by the multiplexer plug-in interface.
IStreamConnector	openSession(ISession session) Called whenever a connection should be established.
void	setTransceiverManager(ITransceiverManager manager) Sets the transceiver manager to a wrapper in order to enable the interception of session accepts.

Methods inherited from class info.pppc.base.plugin.ip.IPMulticastTransceiver

addTransceiverListener, getAddress, getPort, isEnabled, openGroup, perform, prepareSession, release, release, removeTransceiverListener, setAddress, setEnabled, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface info.pppc.base.system.plugin.IPlugin

start, stop

Constructor Detail

MxIPMulticastTransceiver

public MxIPMulticastTransceiver()

Creates a transceiver that binds to any address.

MxIPMulticastTransceiver

public MxIPMulticastTransceiver(byte[] address)

Creates a transceiver that binds to the specified address.

Parameters:

address - A byte array of length 4 that contains the ip address to bind to.

Method Detail

getPluginDescription

public PluginDescription getPluginDescription()

Returns the plug-in description of the transceiver.

Specified by:

getPluginDescription in interface IPlugin

Overrides:

getPluginDescription in class IPMulticastTransceiver

Returns:

The plug-in description of the transceiver.

acceptConnector

public void acceptConnector(MultiplexFactory source,
                   IStreamConnector connector)

Called by a multiplexer whenever a new connector is opened due to remote system request.

Specified by:

acceptConnector in interface IMultiplexPlugin

Parameters:

source - The multiplexer that received the request.

connector - The connector that has been established by the multiplexer.

closeMultiplexer

public void closeMultiplexer(MultiplexFactory multiplexer)

Called by a multiplexer whenever the multiplexer is closed.

Specified by:

closeMultiplexer in interface IMultiplexPlugin

Parameters:

multiplexer - The multiplexer that closed the connection.

openSession

public IStreamConnector openSession(ISession session)
                             throws java.io.IOException

Called whenever a connection should be established. This method will first determine whether there are any cached connections and then it might decide to open a new one if the existing ones do not satisfy the needs.

Specified by:

openSession in interface IStreamer

Overrides:

openSession in class IPMulticastTransceiver

Parameters:

session - The session that contains the necessary data. The local data object contains the port and the ip address of the remote system.

Returns:

The stream connector for the session.

Throws:

java.io.IOException - Thrown if the connector could not be created.

setTransceiverManager

public void setTransceiverManager(ITransceiverManager manager)

Sets the transceiver manager to a wrapper in order to enable the interception of session accepts.

Specified by:

setTransceiverManager in interface ITransceiver

Overrides:

setTransceiverManager in class IPMulticastTransceiver

Parameters:

manager - The real manager provided by the plug-in manager.

getPluginManager

public IPluginManager getPluginManager()

Returns a reference to the plug-in manager as required by the multiplexer plug-in interface.

Specified by:

getPluginManager in interface IMultiplexPlugin

Returns:

The plug-in manager of the plug-in.