eu.javaexperience.electronic.uartbus.rpc

Class UartbusConnectionDistributor

java.lang.Object

eu.javaexperience.electronic.uartbus.rpc.UartbusConnectionDistributor

All Implemented Interfaces:

UartbusConnection, Closeable, AutoCloseable

public class UartbusConnectionDistributor
extends Object
implements UartbusConnection

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	UartbusConnectionDistributor.PacketEndpointQueue

Field Summary

Fields

Modifier and Type	Field and Description
protected static eu.javaexperience.log.Logger	LOG
protected eu.javaexperience.interfaces.simple.publish.SimplePublish1<byte[]>	sendPacket
protected String	sessionKey
protected Set<UartbusConnectionDistributor.PacketEndpointQueue>	sessions

Constructor Summary

Constructors

Constructor and Description
UartbusConnectionDistributor(eu.javaexperience.interfaces.simple.publish.SimplePublish1<byte[]> sendPacket)

Method Summary

Modifier and Type	Method and Description
void	close()
void	feedPacketToDistribute(byte[] packet)
String	getAttribute(String key)
byte[]	getNextPacket()
protected UartbusConnectionDistributor.PacketEndpointQueue	getSessionQueue()
void	init()
Map<String,String>	listAttributes()
void	sendPacket(byte[] data)
void	setAttribute(String key, String value)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final eu.javaexperience.log.Logger LOG

sendPacket

protected eu.javaexperience.interfaces.simple.publish.SimplePublish1<byte[]> sendPacket

sessionKey

protected String sessionKey

sessions

protected Set<UartbusConnectionDistributor.PacketEndpointQueue> sessions

Constructor Detail

UartbusConnectionDistributor

public UartbusConnectionDistributor(eu.javaexperience.interfaces.simple.publish.SimplePublish1<byte[]> sendPacket)

Method Detail

feedPacketToDistribute

public void feedPacketToDistribute(byte[] packet)

getSessionQueue

protected UartbusConnectionDistributor.PacketEndpointQueue getSessionQueue()

sendPacket

public void sendPacket(byte[] data)
                throws IOException

Specified by:

sendPacket in interface UartbusConnection

Throws:

IOException

listAttributes

public Map<String,String> listAttributes()

Specified by:

listAttributes in interface UartbusConnection

getAttribute

public String getAttribute(String key)

Specified by:

getAttribute in interface UartbusConnection

setAttribute

public void setAttribute(String key,
                         String value)

Specified by:

setAttribute in interface UartbusConnection

getNextPacket

public byte[] getNextPacket()
                     throws IOException

Specified by:

getNextPacket in interface UartbusConnection

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

init

public void init()

Specified by:

init in interface UartbusConnection