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

java.lang.Object
  extended byorg.apache.jcs.auxiliary.lateral.socket.tcp.LateralTCPSender

public class LateralTCPSender
extends java.lang.Object

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

Version:
$Id: LateralTCPSender.java,v 1.13 2005/06/03 20:25:55 asmuts Exp $

Constructor Summary
LateralTCPSender(ILateralCacheAttributes lca)
          Constructor for the LateralTCPSender object
 
Method Summary
 void dispose(java.lang.String cache)
          Closes connection used by all LateralTCPSenders for this lateral conneciton.
protected  void init(java.lang.String host, int port)
          Description of the Method
static void main(java.lang.String[] args)
          Description of the Method
 void release()
          Description of the Method
 void remove(java.lang.String cacheName, java.io.Serializable key)
          Description of the Method
 void remove(java.lang.String cacheName, java.io.Serializable key, long requesterId)
          Description of the Method
 void removeAll(java.lang.String cacheName)
          Description of the Method
 void removeAll(java.lang.String cacheName, long requesterId)
          Description of the Method
 void send(LateralElementDescriptor led)
          Sends commands to the lateral cache listener.
 ICacheElement sendAndReceive(LateralElementDescriptor led)
          Sends commands to the lateral cache listener and gets a response.
 void update(ICacheElement item, long requesterId)
          Description of the Method
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LateralTCPSender

public LateralTCPSender(ILateralCacheAttributes lca)
                 throws java.io.IOException
Constructor for the LateralTCPSender object

Parameters:
lca -
Throws:
java.io.IOException
Method Detail

init

protected void init(java.lang.String host,
                    int port)
             throws java.io.IOException
Description of the Method

Throws:
java.io.IOException

send

public void send(LateralElementDescriptor led)
          throws java.io.IOException
Sends commands to the lateral cache listener.

Throws:
java.io.IOException

sendAndReceive

public ICacheElement sendAndReceive(LateralElementDescriptor led)
                             throws java.io.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.

Throws:
java.io.IOException

update

public void update(ICacheElement item,
                   long requesterId)
            throws java.io.IOException
Description of the Method

Throws:
java.io.IOException

remove

public void remove(java.lang.String cacheName,
                   java.io.Serializable key)
            throws java.io.IOException
Description of the Method

Throws:
java.io.IOException

remove

public void remove(java.lang.String cacheName,
                   java.io.Serializable key,
                   long requesterId)
            throws java.io.IOException
Description of the Method

Throws:
java.io.IOException

release

public void release()
             throws java.io.IOException
Description of the Method

Throws:
java.io.IOException

dispose

public void dispose(java.lang.String cache)
             throws java.io.IOException
Closes connection used by all LateralTCPSenders for this lateral conneciton. Dispose request should come into the facade and be sent to all lateral cache sevices. The lateral cache service will then call this method.

Throws:
java.io.IOException

removeAll

public void removeAll(java.lang.String cacheName)
               throws java.io.IOException
Description of the Method

Throws:
java.io.IOException

removeAll

public void removeAll(java.lang.String cacheName,
                      long requesterId)
               throws java.io.IOException
Description of the Method

Throws:
java.io.IOException

main

public static void main(java.lang.String[] args)
Description of the Method



Copyright © 2002-2005 Apache Software Foundation. All Rights Reserved.