Package org.jgrapes.net

Class TcpConnector

java.lang.Object

org.jgrapes.core.internal.ComponentVertex

org.jgrapes.core.Component

org.jgrapes.net.TcpConnectionManager

org.jgrapes.net.TcpConnector

All Implemented Interfaces:

Iterable<ComponentType>, Channel, ComponentType, Eligible, Manager

public class TcpConnector
extends TcpConnectionManager

A component that reads from or write to a TCP connection.

Nested Class Summary

Nested classes/interfaces inherited from class org.jgrapes.net.TcpConnectionManager

TcpConnectionManager.TcpChannelImpl

Nested classes/interfaces inherited from interface org.jgrapes.core.Channel

Channel.Default

Field Summary

Fields inherited from class org.jgrapes.net.TcpConnectionManager

channels

Fields inherited from interface org.jgrapes.core.Channel

BROADCAST, SELF

Constructor Summary

Constructors

Constructor	Description
TcpConnector()	Creates a new connector, using itself as component channel.
TcpConnector(Channel channel)	Create a new instance using the given channel.

Method Summary

Modifier and Type	Method	Description
void	onClose(Close event)	Shuts down the one of the connections.
void	onOpenConnection(OpenTcpConnection event)	Opens a connection to the end point specified in the event.
void	onRegistered(NioRegistration.Completed event)	Called when the new socket channel has successfully been registered with the nio dispatcher.
TcpConnector	setBufferSize(int size)	Sets the buffer size for the send an receive buffers.

Methods inherited from class org.jgrapes.net.TcpConnectionManager

bufferSize, executorService, onOutput, removeChannel, setExecutorService, toString

Methods inherited from class org.jgrapes.core.Component

channel, component, defaultCriterion, isEligibleFor, setName

Methods inherited from class org.jgrapes.core.internal.ComponentVertex

activeEventPipeline, addHandler, attach, children, componentPath, componentVertex, detach, fire, initComponentsHandlers, iterator, name, newEventPipeline, newEventPipeline, parent, registerAsGenerator, root, unregisterAsGenerator

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface org.jgrapes.core.Manager

stream

Constructor Details

TcpConnector

public TcpConnector(Channel channel)

Create a new instance using the given channel.

Parameters:

channel - the component’s channel

TcpConnector

public TcpConnector()

Creates a new connector, using itself as component channel.

Method Details

setBufferSize

public TcpConnector setBufferSize(int size)

Description copied from class: TcpConnectionManager

Sets the buffer size for the send an receive buffers.

If no size is set, a default value of 32768 will be used.

Overrides:

setBufferSize in class TcpConnectionManager

Parameters:

size - the size to use for the send and receive buffers

Returns:

the TCP connection manager for easy chaining

onOpenConnection

@Handler
public void onOpenConnection(OpenTcpConnection event)

Opens a connection to the end point specified in the event.

Parameters:

event - the event

onRegistered

@Handler(channels=Self.class)
public void onRegistered(NioRegistration.Completed event)
                  throws InterruptedException,
IOException

Called when the new socket channel has successfully been registered with the nio dispatcher.

Parameters:

event - the event

Throws:

InterruptedException - the interrupted exception

IOException - Signals that an I/O exception has occurred.

onClose

@Handler
public void onClose(Close event)
             throws IOException,
InterruptedException

Shuts down the one of the connections.

Parameters:

event - the event

Throws:

IOException - if an I/O exception occurred

InterruptedException - if the execution was interrupted