org.tapchain.core

Class Connector

java.lang.Object

org.tapchain.core.Connector

All Implemented Interfaces:

java.io.Serializable, IConnector

Direct Known Subclasses:

Connector.DummyConnector, Connector.InConnector, Connector.OutConnector

public abstract class Connector
extends java.lang.Object
implements IConnector, java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Connector.DummyConnector
static class	Connector.InConnector
static class	Connector.OutConnector

Constructor Summary

Constructors

Constructor and Description
Connector()
Connector(IPiece parent, java.lang.Class<?> c)

Method Summary

Methods

Modifier and Type	Method and Description
<T> boolean	__async_push(Packet<T> packet, T obj)
<T> boolean	async_push(Packet<T> packet)
void	detach()
<T> T	getCache()
IPiece	getCacheSource()
IPiece	getParent()
Path	getParentPath()
Path	getParentPathNoWait()
boolean	isConnected()
boolean	isNotEmpty()
void	reset()
boolean	send_reset()
Connector	setListener(Chain.IPathListener _listen)
IConnector	setParentPath(Path _path)
Connector	setPartner(Connector i)
void	setPushWithNoPath(Packet obj)
Connector	setResetHandler(Chain.IPathListener _reset)
Connector	setUsed(boolean b)
<T> Packet<T>	sync_peek()
<T> Packet<T>	sync_pop()
<T> boolean	sync_push(Packet<T> packet)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.tapchain.core.IConnector

end, getPack

Constructor Detail

Connector

public Connector()

Connector

public Connector(IPiece parent,
         java.lang.Class<?> c)

Method Detail

setParentPath

public IConnector setParentPath(Path _path)

Specified by:

setParentPath in interface IConnector

getParentPath

public Path getParentPath()
                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getParentPathNoWait

public Path getParentPathNoWait()
                         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

setPushWithNoPath

public void setPushWithNoPath(Packet obj)

getParent

public IPiece getParent()

setUsed

public Connector setUsed(boolean b)

setPartner

public Connector setPartner(Connector i)

setListener

public Connector setListener(Chain.IPathListener _listen)

setResetHandler

public Connector setResetHandler(Chain.IPathListener _reset)

isConnected

public boolean isConnected()

isNotEmpty

public boolean isNotEmpty()

getCache

public <T> T getCache()
           throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getCacheSource

public IPiece getCacheSource()
                      throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

detach

public void detach()
            throws Chain.ChainException

Throws:

Chain.ChainException

sync_pop

public <T> Packet<T> sync_pop()
                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

sync_peek

public <T> Packet<T> sync_peek()
                    throws java.lang.InterruptedException,
                           IAxon.AxonException

Throws:

java.lang.InterruptedException

IAxon.AxonException

sync_push

public <T> boolean sync_push(Packet<T> packet)
                  throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

async_push

public <T> boolean async_push(Packet<T> packet)
                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

__async_push

public <T> boolean __async_push(Packet<T> packet,
                       T obj)
                     throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

send_reset

public boolean send_reset()

reset

public void reset()