com.airepublic.microverse.rest.server

Class RestServiceServer

java.lang.Object

com.airepublic.microverse.core.server.AbstractServiceServer

com.airepublic.microverse.rest.server.RestServiceServer

All Implemented Interfaces:

Closeable, AutoCloseable

@Singleton
 @Path(value="/server")
public class RestServiceServer
extends AbstractServiceServer

Base class for all Service-Servers which provides functionality manage the server and to handle requests generically in separate threads.

Author:

Torsten Oltmanns

Constructor Summary

Constructors

Constructor and Description
RestServiceServer()

Method Summary

Modifier and Type	Method and Description
javax.ws.rs.core.Response	addService(javax.ws.rs.core.UriInfo uriInfo, javax.servlet.http.HttpServletRequest request, javax.ws.rs.core.HttpHeaders headers, InputStream inputStream) Adds a service described by the ServiceDescriptor in the request content stream.
protected IClassLoaderCreator	getClassLoaderCreator()
protected com.airepublic.microverse.core.descriptor.WebCall	getHeartbeatWebCall(String serviceId, String serviceVersion)
protected String	getMimeTypeForResponse(javax.ws.rs.core.HttpHeaders headers) Gets the mime-type from the request header 'accept' to determine the content-type of the response content.
protected String	getMimeTypeFromRequest(javax.ws.rs.core.HttpHeaders headers) Gets the mime-type from the request header 'content-type' to determine the mime-type of the request content.
protected com.airepublic.microverse.core.descriptor.WebCall	getServiceWebCall(String serviceId, String serviceVersion)
javax.ws.rs.core.Response	getSupportedMediaTypes()
javax.ws.rs.core.Response	heartbeat() This method should be called by a monitoring service to check whether this service-server is still running.
void	init()
protected void	onServiceRegistration(com.airepublic.microverse.core.descriptor.ServiceDescriptor serviceDescriptor)
protected void	onServiceUnregistration(com.airepublic.microverse.core.descriptor.ServiceDescriptor serviceDescriptor)
javax.ws.rs.core.Response	process(javax.ws.rs.core.HttpHeaders headers, InputStream inputStream, javax.ws.rs.core.UriInfo uriInfo) Processes the request and answers to the response using the context information.
javax.ws.rs.core.Response	removeService(javax.ws.rs.core.HttpHeaders headers, String serviceId, String serviceVersion) Removes a service described by the ServiceDescriptor in the request content stream.
protected com.airepublic.microverse.core.descriptor.ServiceDescriptor	unmarshalServiceDescriptor(javax.ws.rs.core.HttpHeaders headers, InputStream inputStream) Unmarshal the ServiceDescriptor from the request input-stream.

Methods inherited from class com.airepublic.microverse.core.server.AbstractServiceServer

addService, close, getServiceDescriptors, getSupportedMimeTypes, process, removeService, unmarshal

Methods inherited from class java.lang.Object

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

Constructor Detail

RestServiceServer

public RestServiceServer()

Method Detail

init

@PostConstruct
public void init()

Overrides:

init in class AbstractServiceServer

getClassLoaderCreator

protected IClassLoaderCreator getClassLoaderCreator()

Specified by:

getClassLoaderCreator in class AbstractServiceServer

getSupportedMediaTypes

@Path(value="mediatypes")
 @GET
 @Produces(value="text/plain")
public javax.ws.rs.core.Response getSupportedMediaTypes()

addService

@Path(value="add")
 @POST
public javax.ws.rs.core.Response addService(@Context
                                                                        javax.ws.rs.core.UriInfo uriInfo,
                                                                        @Context
                                                                        javax.servlet.http.HttpServletRequest request,
                                                                        @Context
                                                                        javax.ws.rs.core.HttpHeaders headers,
                                                                        InputStream inputStream)

Adds a service described by the ServiceDescriptor in the request content stream. If no mime-type is set in the ServiceDescriptor the mime-type of the request will be set as service mime-type.

Parameters:

request - the request

headers - the http-headers

inputStream - the request content input stream

Returns:

getServiceWebCall

protected com.airepublic.microverse.core.descriptor.WebCall getServiceWebCall(String serviceId,
                                                                              String serviceVersion)

Specified by:

getServiceWebCall in class AbstractServiceServer

getHeartbeatWebCall

protected com.airepublic.microverse.core.descriptor.WebCall getHeartbeatWebCall(String serviceId,
                                                                                String serviceVersion)

Specified by:

getHeartbeatWebCall in class AbstractServiceServer

removeService

@Path(value="remove/{serviceId}/{serviceVersion : .+}")
 @POST
public javax.ws.rs.core.Response removeService(@Context
                                                                                                                javax.ws.rs.core.HttpHeaders headers,
                                                                                                                @PathParam(value="serviceId")
                                                                                                                String serviceId,
                                                                                                                @PathParam(value="serviceVersion")
                                                                                                                String serviceVersion)

Removes a service described by the ServiceDescriptor in the request content stream.

Parameters:

headers - the http-headers

inputStream - the request content input stream

Returns:

onServiceRegistration

protected void onServiceRegistration(com.airepublic.microverse.core.descriptor.ServiceDescriptor serviceDescriptor)

Specified by:

onServiceRegistration in class AbstractServiceServer

onServiceUnregistration

protected void onServiceUnregistration(com.airepublic.microverse.core.descriptor.ServiceDescriptor serviceDescriptor)

Specified by:

onServiceUnregistration in class AbstractServiceServer

getMimeTypeFromRequest

protected String getMimeTypeFromRequest(javax.ws.rs.core.HttpHeaders headers)

Gets the mime-type from the request header 'content-type' to determine the mime-type of the request content.

Parameters:

headers - the request headers

Returns:

the mime-type

getMimeTypeForResponse

protected String getMimeTypeForResponse(javax.ws.rs.core.HttpHeaders headers)

Gets the mime-type from the request header 'accept' to determine the content-type of the response content.

Parameters:

headers - the request headers

Returns:

the response mime-type

unmarshalServiceDescriptor

protected com.airepublic.microverse.core.descriptor.ServiceDescriptor unmarshalServiceDescriptor(javax.ws.rs.core.HttpHeaders headers,
                                                                                                 InputStream inputStream)

Unmarshal the ServiceDescriptor from the request input-stream.

Parameters:

headers - the request headers

inputStream - the InputStream

Returns:

the ServiceDescriptor

process

@Path(value="process/{serviceClass : .+}")
 @POST
public javax.ws.rs.core.Response process(@Context
                                                                                             javax.ws.rs.core.HttpHeaders headers,
                                                                                             InputStream inputStream,
                                                                                             @Context
                                                                                             javax.ws.rs.core.UriInfo uriInfo)

Processes the request and answers to the response using the context information.

Parameters:

request - the request

response - the response

context - the context

heartbeat

@Path(value="heartbeat")
 @GET
public javax.ws.rs.core.Response heartbeat()

This method should be called by a monitoring service to check whether this service-server is still running.

Specified by:

heartbeat in class AbstractServiceServer

Returns:

Response OK