kieker.tools.bridge.connector.http
Class HTTPConnector

java.lang.Object
  kieker.tools.bridge.connector.AbstractConnector
      kieker.tools.bridge.connector.http.HTTPConnector

All Implemented Interfaces:

IServiceConnector

public final class HTTPConnector
extends AbstractConnector

A connector receiving records via a REST URL.

Since:

1.11

Author:

Nils Christian Ehmke

Field Summary

static java.lang.String	CONTEXT
static java.lang.String	PORT
static java.lang.String	REST_URL

Fields inherited from class kieker.tools.bridge.connector.AbstractConnector

configuration, lookupEntityMap

Constructor Summary

HTTPConnector(Configuration configuration, java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap)

Method Summary

void	close() Called to close the previously initialize record source.
IMonitoringRecord	deserializeNextRecord() The deserialize method reads source data and returns an IMonitoringRecord.
void	initialize() Called to initialize the channel to read record information.

Methods inherited from class java.lang.Object

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

Field Detail

PORT

public static final java.lang.String PORT

CONTEXT

public static final java.lang.String CONTEXT

REST_URL

public static final java.lang.String REST_URL

Constructor Detail

HTTPConnector

public HTTPConnector(Configuration configuration,
                     java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap)

Method Detail

deserializeNextRecord

public IMonitoringRecord deserializeNextRecord()
                                        throws ConnectorDataTransmissionException,
                                               ConnectorEndOfDataException

Description copied from interface: IServiceConnector

The deserialize method reads source data and returns an IMonitoringRecord.

Returns:

A IMonitoringRecord or null on read error or end of line.

Throws:

ConnectorDataTransmissionException - if a read error or an unknown record id occurs

ConnectorEndOfDataException - if the transmission is terminated or otherwise signaled that the last record has been received.

initialize

public void initialize()
                throws ConnectorDataTransmissionException

Description copied from interface: IServiceConnector

Called to initialize the channel to read record information.

Throws:

ConnectorDataTransmissionException - when an error occurred setting up the record source.

close

public void close()
           throws ConnectorDataTransmissionException

Description copied from interface: IServiceConnector

Called to close the previously initialize record source.

Throws:

ConnectorDataTransmissionException - when an error occurred during connection close.