org.apache.commons.jcs3.auxiliary.lateral.socket.tcp

Class LateralTCPSender

java.lang.Object

org.apache.commons.jcs3.auxiliary.lateral.socket.tcp.LateralTCPSender

public class LateralTCPSender
extends Object

This class is based on the log4j SocketAppender class. I'm using a different repair structure, so it is significantly different.

Constructor Summary

Constructors

Constructor and Description
LateralTCPSender(ITCPLateralCacheAttributes lca) Deprecated. Specify serializer
LateralTCPSender(ITCPLateralCacheAttributes lca, IElementSerializer serializer) Constructor for the LateralTCPSender object.

Method Summary

Modifier and Type	Method and Description
void	dispose() Closes connection used by all LateralTCPSenders for this lateral connection.
protected void	init(String host, int port) Creates a connection to a TCP server.
<K,V> void	send(LateralElementDescriptor<K,V> led) Sends commands to the lateral cache listener.
<K,V> Object	sendAndReceive(LateralElementDescriptor<K,V> led) Sends commands to the lateral cache listener and gets a response.

Methods inherited from class java.lang.Object

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

Constructor Detail

LateralTCPSender

@Deprecated
public LateralTCPSender(ITCPLateralCacheAttributes lca)
                             throws IOException

Deprecated. Specify serializer

Constructor for the LateralTCPSender object.

Parameters:

lca -

Throws:

IOException

LateralTCPSender

public LateralTCPSender(ITCPLateralCacheAttributes lca,
                        IElementSerializer serializer)
                 throws IOException

Constructor for the LateralTCPSender object.

Parameters:

lca - the configuration object

serializer - the serializer to use when sending

Throws:

IOException

Since:

3.1

Method Detail

init

protected void init(String host,
                    int port)
             throws IOException

Creates a connection to a TCP server.

Parameters:

host -

port -

Throws:

IOException

send

public <K,V> void send(LateralElementDescriptor<K,V> led)
                throws IOException

Sends commands to the lateral cache listener.

Parameters:

led -

Throws:

IOException

sendAndReceive

public <K,V> Object sendAndReceive(LateralElementDescriptor<K,V> led)
                            throws IOException

Sends commands to the lateral cache listener and gets a response. I'm afraid that we could get into a pretty bad blocking situation here. This needs work. I just wanted to get some form of get working. However, get is not recommended for performance reasons. If you have 10 laterals, then you have to make 10 failed gets to find out none of the caches have the item.

Parameters:

led -

Returns:

ICacheElement

Throws:

IOException

dispose

public void dispose()
             throws IOException

Closes connection used by all LateralTCPSenders for this lateral connection. Dispose request should come into the facade and be sent to all lateral cache services. The lateral cache service will then call this method.

Throws:

IOException