Package test.de.iip_ecosphere.platform.transport.spring

Class FakeTransportConnector2

java.lang.Object

test.de.iip_ecosphere.platform.transport.spring.FakeTransportConnector2

All Implemented Interfaces:

de.iip_ecosphere.platform.transport.connectors.TransportConnector

public class FakeTransportConnector2
extends Object
implements de.iip_ecosphere.platform.transport.connectors.TransportConnector

Just for testing the Spring configuration.

Author:

Holger Eichelberger, SSE

Field Summary

Fields inherited from interface de.iip_ecosphere.platform.transport.connectors.TransportConnector

EMPTY_PARENT

Constructor Summary

Constructors

Constructor	Description
FakeTransportConnector2()

Method Summary

Modifier and Type	Method	Description
void	asyncSend(String stream, Object data)
String	composeStreamName(String parent, String name)
void	connect(de.iip_ecosphere.platform.transport.connectors.TransportParameter params)
void	detachReceptionCallback(String stream, de.iip_ecosphere.platform.transport.connectors.ReceptionCallback<?> callback)
void	disconnect()
String	enabledEncryption()
String	getName()
void	setReceptionCallback(String stream, de.iip_ecosphere.platform.transport.connectors.ReceptionCallback<?> callback)
void	setSerializerProvider(de.iip_ecosphere.platform.transport.serialization.SerializerRegistry.SerializerProvider serializerProvider)
String	supportedEncryption()
void	syncSend(String stream, Object data)
void	unsubscribe(String stream, boolean delete)

Methods inherited from class java.lang.Object

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

Constructor Details

FakeTransportConnector2

public FakeTransportConnector2()

Method Details

syncSend

public void syncSend(String stream,
 Object data)
              throws IOException

Specified by:

syncSend in interface de.iip_ecosphere.platform.transport.connectors.TransportConnector

Throws:

IOException

asyncSend

public void asyncSend(String stream,
 Object data)
               throws IOException

Specified by:

asyncSend in interface de.iip_ecosphere.platform.transport.connectors.TransportConnector

Throws:

IOException

setReceptionCallback

public void setReceptionCallback(String stream,
 de.iip_ecosphere.platform.transport.connectors.ReceptionCallback<?> callback)
                          throws IOException

Specified by:

setReceptionCallback in interface de.iip_ecosphere.platform.transport.connectors.TransportConnector

Throws:

IOException

detachReceptionCallback

public void detachReceptionCallback(String stream,
 de.iip_ecosphere.platform.transport.connectors.ReceptionCallback<?> callback)
                             throws IOException

Specified by:

detachReceptionCallback in interface de.iip_ecosphere.platform.transport.connectors.TransportConnector

Throws:

IOException

unsubscribe

public void unsubscribe(String stream,
 boolean delete)
                 throws IOException

Specified by:

unsubscribe in interface de.iip_ecosphere.platform.transport.connectors.TransportConnector

Throws:

IOException

composeStreamName

public String composeStreamName(String parent,
 String name)

Specified by:

composeStreamName in interface de.iip_ecosphere.platform.transport.connectors.TransportConnector

connect

public void connect(de.iip_ecosphere.platform.transport.connectors.TransportParameter params)
             throws IOException

Specified by:

connect in interface de.iip_ecosphere.platform.transport.connectors.TransportConnector

Throws:

IOException

disconnect

public void disconnect()
                throws IOException

Specified by:

disconnect in interface de.iip_ecosphere.platform.transport.connectors.TransportConnector

Throws:

IOException

getName

public String getName()

Specified by:

getName in interface de.iip_ecosphere.platform.transport.connectors.TransportConnector

supportedEncryption

public String supportedEncryption()

Specified by:

supportedEncryption in interface de.iip_ecosphere.platform.transport.connectors.TransportConnector

enabledEncryption

public String enabledEncryption()

Specified by:

enabledEncryption in interface de.iip_ecosphere.platform.transport.connectors.TransportConnector

setSerializerProvider

public void setSerializerProvider(de.iip_ecosphere.platform.transport.serialization.SerializerRegistry.SerializerProvider serializerProvider)

Specified by:

setSerializerProvider in interface de.iip_ecosphere.platform.transport.connectors.TransportConnector