eu.hgross.blaubot.core

Class ServerConnectionManager.BlaubotServerRelayConnection

java.lang.Object

eu.hgross.blaubot.core.AbstractBlaubotConnection

eu.hgross.blaubot.mock.BlaubotConnectionQueueMock

eu.hgross.blaubot.core.ServerConnectionManager.BlaubotServerRelayConnection

All Implemented Interfaces:

IBlaubotConnection, IBlaubotAdminMessageListener

Enclosing class:

ServerConnectionManager

public class ServerConnectionManager.BlaubotServerRelayConnection
extends BlaubotConnectionQueueMock
implements IBlaubotAdminMessageListener

A relay connection is a connection that uses admin messages to transport bytes from A to C using an intermediate participant B (mediator). There are connections A to B and B to C and the relay connection uses an established network to make the transitive connection between A and C (recipient). The BlaubotServerRelayConnection is only created on A (the king). It needs the RelayMessageMediator instance running on B. B needs to have a IBlaubotConnection to C. Note that it only seems like the connection is capable of sending arbitrary bytes through it but since we are using MessageReceivers internally it is only capable of sending and receiving full blaubot message byte packages!

Field Summary

Fields inherited from class eu.hgross.blaubot.mock.BlaubotConnectionQueueMock

connected, disconnnectMonitor, inputQueue, outputQueue

Fields inherited from class eu.hgross.blaubot.core.AbstractBlaubotConnection

connectionListeners

Constructor Summary

Constructors

Constructor and Description
BlaubotServerRelayConnection(java.lang.String mediatorUniqueDeviceId, java.lang.String recipientUniqueDeviceId) Note: starts a thread!

Method Summary

Modifier and Type	Method and Description
void	disconnect() Disconnects the connection (if connected), nothing otherwise
boolean	equals(java.lang.Object o)
java.lang.String	getMediatorUniqueDeviceId()
java.lang.String	getRecipientUniqueDeviceId()
int	hashCode()
protected void	notifyDisconnected() Notifies all registered listeners that this connection is now disconnected
void	onAdminMessage(AbstractAdminMessage adminMessage) Called when an admin message was received
java.lang.String	toString()

Methods inherited from class eu.hgross.blaubot.mock.BlaubotConnectionQueueMock

getInputStreamForWrittenConnectionData, getOtherEndpointConnection, getRemoteDevice, isConnected, read, read, read, readFully, readFully, write, write, write, writeMockDataToInputStream

Methods inherited from class eu.hgross.blaubot.core.AbstractBlaubotConnection

addConnectionListener, removeConnectionListener

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

BlaubotServerRelayConnection

public BlaubotServerRelayConnection(java.lang.String mediatorUniqueDeviceId,
                                    java.lang.String recipientUniqueDeviceId)

Note: starts a thread!

Parameters:

mediatorUniqueDeviceId - the uniqueDeviceId to which the data should be send (via relay message) when using the write(*) methods.

recipientUniqueDeviceId - the recipient's unique device id (Server/King)

Method Detail

onAdminMessage

public void onAdminMessage(AbstractAdminMessage adminMessage)

Description copied from interface: IBlaubotAdminMessageListener

Called when an admin message was received

Specified by:

onAdminMessage in interface IBlaubotAdminMessageListener

Parameters:

adminMessage - the received admin message

notifyDisconnected

protected void notifyDisconnected()

Description copied from class: AbstractBlaubotConnection

Notifies all registered listeners that this connection is now disconnected

Overrides:

notifyDisconnected in class AbstractBlaubotConnection

disconnect

public void disconnect()

Description copied from interface: IBlaubotConnection

Disconnects the connection (if connected), nothing otherwise

Specified by:

disconnect in interface IBlaubotConnection

Overrides:

disconnect in class BlaubotConnectionQueueMock

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class BlaubotConnectionQueueMock

hashCode

public int hashCode()

Overrides:

hashCode in class BlaubotConnectionQueueMock

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getMediatorUniqueDeviceId

public java.lang.String getMediatorUniqueDeviceId()

getRecipientUniqueDeviceId

public java.lang.String getRecipientUniqueDeviceId()