LateralTCPSender (Commons JCS 2.0.0-SNAPSHOT API)

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.apache.jcs.auxiliary.lateral.socket.tcp
Class LateralTCPSender

java.lang.Object
  org.apache.jcs.auxiliary.lateral.socket.tcp.LateralTCPSender

public class LateralTCPSender
extends Object
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
`LateralTCPSender(ITCPLateralCacheAttributes lca)` Constructor for the LateralTCPSender object.

Method Summary

void dispose(String cache)
Closes connection used by all LateralTCPSenders for this lateral connection.

String getRemoteHost()

ITCPLateralCacheAttributes getTcpLateralCacheAttributes()

protected void init(String host, int port)
Creates a connection to a TCP server.





<K extends Serializable,V extends Serializable> 


void

send(LateralElementDescriptor<K,V> led)
Sends commands to the lateral cache listener.





<K extends Serializable,V extends Serializable> 


Object

sendAndReceive(LateralElementDescriptor<K,V> led)
Sends commands to the lateral cache listener and gets a response.

void setRemoteHost(String remoteHost)

void setTcpLateralCacheAttributes(ITCPLateralCacheAttributes tcpLateralCacheAttributes)

Methods inherited from class java.lang.Object
`clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

Constructor Detail

LateralTCPSender

public LateralTCPSender(ITCPLateralCacheAttributes lca)
                 throws IOException

Constructor for the LateralTCPSender object.

Parameters:: lca -
Throws:: IOException

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 extends Serializable,V extends Serializable> void send(LateralElementDescriptor<K,V> led)
          throws IOException

Sends commands to the lateral cache listener.

Parameters:: led -
Throws:: IOException

sendAndReceive

public <K extends Serializable,V extends Serializable> 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(String cache)
             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.

Parameters:: cache -
Throws:: IOException

setTcpLateralCacheAttributes

public void setTcpLateralCacheAttributes(ITCPLateralCacheAttributes tcpLateralCacheAttributes)

Parameters:: tcpLateralCacheAttributes - The tcpLateralCacheAttributes to set.

getTcpLateralCacheAttributes

public ITCPLateralCacheAttributes getTcpLateralCacheAttributes()

Returns:: Returns the tcpLateralCacheAttributes.

setRemoteHost

public void setRemoteHost(String remoteHost)

Parameters:: remoteHost - The remoteHost to set.

getRemoteHost

public String getRemoteHost()

Returns:: Returns the remoteHost.