xdi2.transport.impl

Class AbstractTransport<REQUEST extends TransportRequest,RESPONSE extends TransportResponse>

java.lang.Object

xdi2.transport.impl.AbstractTransport<REQUEST,RESPONSE>

All Implemented Interfaces:

Transport<REQUEST,RESPONSE>

Direct Known Subclasses:

LocalTransport, UriTransport

public abstract class AbstractTransport<REQUEST extends TransportRequest,RESPONSE extends TransportResponse>
extends Object
implements Transport<REQUEST,RESPONSE>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractTransport()

Method Summary

Modifier and Type	Method and Description
ExecutionContext	createExecutionContext(REQUEST request, RESPONSE response)
protected TransportMessagingResponse	execute(MessageEnvelope messageEnvelope, MessagingContainer messagingContainer, REQUEST request, RESPONSE response)
Date	getCurrent()
String	getCurrentAsString()
InterceptorList<Transport<?,?>>	getInterceptors()
static TransportRequest	getRequest(ExecutionContext executionContext)
static TransportResponse	getResponse(ExecutionContext executionContext)
Date	getStartup()
long	getStartupAsSeconds()
String	getStartupAsString()
static Transport<?,?>	getTransport(ExecutionContext executionContext)
void	init()
boolean	isInitialized()
static boolean	isResponseMessage(MessageEnvelope messageEnvelope)
static void	putRequest(ExecutionContext executionContext, TransportRequest request)
static void	putResponse(ExecutionContext executionContext, TransportResponse response)
static void	putTransport(ExecutionContext executionContext, Transport<?,?> transport)
void	setInterceptors(InterceptorList<Transport<?,?>> interceptors)
void	shutdown()

Methods inherited from class java.lang.Object

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

Methods inherited from interface xdi2.transport.Transport

execute

Constructor Detail

AbstractTransport

protected AbstractTransport()

Method Detail

init

public void init()
          throws Exception

Specified by:

init in interface Transport<REQUEST extends TransportRequest,RESPONSE extends TransportResponse>

Throws:

Exception

shutdown

public void shutdown()
              throws Exception

Specified by:

shutdown in interface Transport<REQUEST extends TransportRequest,RESPONSE extends TransportResponse>

Throws:

Exception

execute

protected TransportMessagingResponse execute(MessageEnvelope messageEnvelope,
                                             MessagingContainer messagingContainer,
                                             REQUEST request,
                                             RESPONSE response)
                                      throws Xdi2TransportException

Throws:

Xdi2TransportException

createExecutionContext

public ExecutionContext createExecutionContext(REQUEST request,
                                               RESPONSE response)

Specified by:

createExecutionContext in interface Transport<REQUEST extends TransportRequest,RESPONSE extends TransportResponse>

getCurrent

public Date getCurrent()

getCurrentAsString

public String getCurrentAsString()

getStartup

public Date getStartup()

getStartupAsString

public String getStartupAsString()

getStartupAsSeconds

public long getStartupAsSeconds()

isInitialized

public boolean isInitialized()

getInterceptors

public InterceptorList<Transport<?,?>> getInterceptors()

setInterceptors

public void setInterceptors(InterceptorList<Transport<?,?>> interceptors)

isResponseMessage

public static boolean isResponseMessage(MessageEnvelope messageEnvelope)

getTransport

public static Transport<?,?> getTransport(ExecutionContext executionContext)

putTransport

public static void putTransport(ExecutionContext executionContext,
                                Transport<?,?> transport)

getRequest

public static TransportRequest getRequest(ExecutionContext executionContext)

putRequest

public static void putRequest(ExecutionContext executionContext,
                              TransportRequest request)

getResponse

public static TransportResponse getResponse(ExecutionContext executionContext)

putResponse

public static void putResponse(ExecutionContext executionContext,
                               TransportResponse response)