ca.uqac.dim.turtledb

Class HttpCommunicator

java.lang.Object

ca.uqac.dim.turtledb.Communicator

ca.uqac.dim.turtledb.HttpCommunicator

All Implemented Interfaces:

java.lang.Runnable

public class HttpCommunicator
extends Communicator

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	HttpCommunicator.HttpQueryProcessor
protected class	HttpCommunicator.SiteInfo Information about a site

Nested classes/interfaces inherited from class ca.uqac.dim.turtledb.Communicator

Communicator.QueryExecutionException

Field Summary

Fields

Modifier and Type	Field and Description
protected Engine	m_engine
protected java.util.Map<java.lang.String,HttpCommunicator.SiteInfo>	m_siteInfo

Constructor Summary

Constructors

Constructor and Description
HttpCommunicator()

Method Summary

Modifier and Type	Method and Description
void	addSiteInfo(java.lang.String name, java.lang.String url)
QueryProcessor	getQueryProcessor(QueryPlan qp)
QueryProcessor	getQueryProcessor(Relation query)
protected java.lang.String	postData(java.lang.String destination_url, java.lang.String payload) Sends a string of data through an TCP connection at a given URL:port using an HTTP POST request
void	run() Listen to the connection for any incoming messages
protected java.lang.String	sendData(java.net.URL url, java.lang.String data) Sends a string of data through an TCP connection at a given URL:port
protected void	sendQuery(java.lang.String site_name, Relation r)
protected void	sendQuery(java.lang.String site_name, java.util.Set<Relation> rels)

Methods inherited from class java.lang.Object

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

Field Detail

m_siteInfo

protected java.util.Map<java.lang.String,HttpCommunicator.SiteInfo> m_siteInfo

m_engine

protected Engine m_engine

Constructor Detail

HttpCommunicator

public HttpCommunicator()

Method Detail

addSiteInfo

public void addSiteInfo(java.lang.String name,
                        java.lang.String url)

sendQuery

protected void sendQuery(java.lang.String site_name,
                         Relation r)
                  throws Communicator.QueryExecutionException

Throws:

Communicator.QueryExecutionException

sendQuery

protected void sendQuery(java.lang.String site_name,
                         java.util.Set<Relation> rels)
                  throws Communicator.QueryExecutionException

Throws:

Communicator.QueryExecutionException

sendData

protected java.lang.String sendData(java.net.URL url,
                                    java.lang.String data)
                             throws java.io.IOException

Sends a string of data through an TCP connection at a given URL:port

Parameters:

destination_url - The destination URL

data - The data to send

Returns:

The response returned by the destination (if any)

Throws:

java.io.IOException

postData

protected java.lang.String postData(java.lang.String destination_url,
                                    java.lang.String payload)
                             throws java.io.IOException

Sends a string of data through an TCP connection at a given URL:port using an HTTP POST request

Parameters:

host - The destination host

location - The location on the host (i.e. the page name)

payload - The data to send

Returns:

The response returned by the destination (if any)

Throws:

java.io.IOException

getQueryProcessor

public QueryProcessor getQueryProcessor(Relation query)

Specified by:

getQueryProcessor in class Communicator

getQueryProcessor

public QueryProcessor getQueryProcessor(QueryPlan qp)

Specified by:

getQueryProcessor in class Communicator

run

public void run()

Listen to the connection for any incoming messages