org.apache.camel.component.sparkrest

Class DefaultSparkBinding

java.lang.Object

org.apache.camel.component.sparkrest.DefaultSparkBinding

All Implemented Interfaces:

SparkBinding

public class DefaultSparkBinding
extends Object
implements SparkBinding

Constructor Summary

Constructors

Constructor and Description
DefaultSparkBinding()

Method Summary

Modifier and Type	Method and Description
protected String	mapKey(String key)
void	populateCamelHeaders(spark.Request request, Map<String,Object> headers, org.apache.camel.Exchange exchange, SparkConfiguration configuration) Binds from Spark Request to Camel headers as a Map.
protected String	shouldUrlDecodeHeader(SparkConfiguration configuration, String headerName, Object value, String charset) Decodes the header if needed to, or returns the header value as is.
org.apache.camel.Message	toCamelMessage(spark.Request request, org.apache.camel.Exchange exchange, SparkConfiguration configuration) Binds from Spark Request to Camel Message.
void	toSparkResponse(org.apache.camel.Message message, spark.Response response, SparkConfiguration configuration) Binds from Camel Message to Spark Response.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSparkBinding

public DefaultSparkBinding()

Method Detail

toCamelMessage

public org.apache.camel.Message toCamelMessage(spark.Request request,
                                               org.apache.camel.Exchange exchange,
                                               SparkConfiguration configuration)
                                        throws Exception

Description copied from interface: SparkBinding

Binds from Spark Request to Camel Message.

Specified by:

toCamelMessage in interface SparkBinding

Parameters:

request - the Spark request

exchange - the exchange that should contain the returned message.

configuration - configuration

Returns:

the message to store on the given exchange

Throws:

Exception - is thrown if error during binding

populateCamelHeaders

public void populateCamelHeaders(spark.Request request,
                                 Map<String,Object> headers,
                                 org.apache.camel.Exchange exchange,
                                 SparkConfiguration configuration)
                          throws Exception

Description copied from interface: SparkBinding

Binds from Spark Request to Camel headers as a Map.

Specified by:

populateCamelHeaders in interface SparkBinding

Parameters:

request - the Spark request

headers - the Camel headers that should be populated

exchange - the exchange that should contain the returned message.

configuration - the endpoint configuration

Throws:

Exception - is thrown if error during binding

toSparkResponse

public void toSparkResponse(org.apache.camel.Message message,
                            spark.Response response,
                            SparkConfiguration configuration)
                     throws Exception

Description copied from interface: SparkBinding

Binds from Camel Message to Spark Response.

Specified by:

toSparkResponse in interface SparkBinding

Parameters:

message - the Camel message

response - the Spark response to bind to

configuration - the endpoint configuration

Throws:

Exception - is thrown if error during binding

shouldUrlDecodeHeader

protected String shouldUrlDecodeHeader(SparkConfiguration configuration,
                                       String headerName,
                                       Object value,
                                       String charset)
                                throws UnsupportedEncodingException

Decodes the header if needed to, or returns the header value as is.

Parameters:

configuration - the configuration

headerName - the header name

value - the current header value

charset - the charset to use for decoding

Returns:

the decoded value (if decoded was needed) or a toString representation of the value.

Throws:

UnsupportedEncodingException - is thrown if error decoding.

mapKey

protected String mapKey(String key)