Class DataSourceProvider
- java.lang.Object
-
- org.jboss.resteasy.plugins.providers.AbstractEntityProvider<jakarta.activation.DataSource>
-
- org.jboss.resteasy.plugins.providers.DataSourceProvider
-
- All Implemented Interfaces:
jakarta.ws.rs.ext.MessageBodyReader<jakarta.activation.DataSource>
,jakarta.ws.rs.ext.MessageBodyWriter<jakarta.activation.DataSource>
,AsyncMessageBodyWriter<jakarta.activation.DataSource>
@Provider @Consumes("*/*") @Produces("*/*") public class DataSourceProvider extends AbstractEntityProvider<jakarta.activation.DataSource>
- Version:
- $Revision:$
- Author:
- Ryan J. McDonough
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected static class
DataSourceProvider.SequencedDataSource
-
Constructor Summary
Constructors Constructor Description DataSourceProvider()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description CompletionStage<Void>
asyncWriteTo(jakarta.activation.DataSource dataSource, Class<?> type, Type genericType, Annotation[] annotations, jakarta.ws.rs.core.MediaType mediaType, jakarta.ws.rs.core.MultivaluedMap<String,Object> httpHeaders, AsyncOutputStream entityStream)
Write a type to an HTTP message using async IO.boolean
isReadable(Class<?> type, Type genericType, Annotation[] annotations, jakarta.ws.rs.core.MediaType mediaType)
Ascertain if the MessageBodyReader can produce an instance of a particular type.boolean
isWriteable(Class<?> type, Type genericType, Annotation[] annotations, jakarta.ws.rs.core.MediaType mediaType)
Ascertain if the MessageBodyWriter supports a particular type.static jakarta.activation.DataSource
readDataSource(InputStream in, jakarta.ws.rs.core.MediaType mediaType)
jakarta.activation.DataSource
readFrom(Class<jakarta.activation.DataSource> type, Type genericType, Annotation[] annotations, jakarta.ws.rs.core.MediaType mediaType, jakarta.ws.rs.core.MultivaluedMap<String,String> httpHeaders, InputStream entityStream)
Read a type from theInputStream
.void
writeTo(jakarta.activation.DataSource dataSource, Class<?> type, Type genericType, Annotation[] annotations, jakarta.ws.rs.core.MediaType mediaType, jakarta.ws.rs.core.MultivaluedMap<String,Object> httpHeaders, OutputStream entityStream)
Write a type to an HTTP message.-
Methods inherited from class org.jboss.resteasy.plugins.providers.AbstractEntityProvider
getSize
-
-
-
-
Method Detail
-
readDataSource
public static jakarta.activation.DataSource readDataSource(InputStream in, jakarta.ws.rs.core.MediaType mediaType) throws IOException
- Parameters:
in
- input streammediaType
- media type- Returns:
- data source
- Throws:
IOException
- if I/O error occurred
-
isReadable
public boolean isReadable(Class<?> type, Type genericType, Annotation[] annotations, jakarta.ws.rs.core.MediaType mediaType)
Ascertain if the MessageBodyReader can produce an instance of a particular type. Thetype
parameter gives the class of the instance that should be produced, thegenericType
parameter gives thejava.lang.reflect.Type
of the instance that should be produced. E.g. if the instance to be produced isList<String>
, thetype
parameter will bejava.util.List
and thegenericType
parameter will bejava.lang.reflect.ParameterizedType
.- Parameters:
type
- the class of instance to be produced.genericType
- the type of instance to be produced. E.g. if the message body is to be converted into a method parameter, this will be the formal type of the method parameter as returned byMethod.getGenericParameterTypes
.annotations
- an array of the annotations on the declaration of the artifact that will be initialized with the produced instance. E.g. if the message body is to be converted into a method parameter, this will be the annotations on that parameter returned byMethod.getParameterAnnotations
.mediaType
- the media type of the HTTP entity, if one is not specified in the request thenapplication/octet-stream
is used.- Returns:
true
if the type is supported, otherwisefalse
.
-
readFrom
public jakarta.activation.DataSource readFrom(Class<jakarta.activation.DataSource> type, Type genericType, Annotation[] annotations, jakarta.ws.rs.core.MediaType mediaType, jakarta.ws.rs.core.MultivaluedMap<String,String> httpHeaders, InputStream entityStream) throws IOException
Read a type from theInputStream
.In case the entity input stream is empty, the reader is expected to either return a Java representation of a zero-length entity or throw a
NoContentException
in case no zero-length entity representation is defined for the supported Java type. ANoContentException
, if thrown by a message body reader while reading a server request entity, is automatically translated by JAX-RS server runtime into aBadRequestException
wrapping the originalNoContentException
and rethrown for a standard processing by the registeredexception mappers
.- Parameters:
type
- the type that is to be read from the entity stream.genericType
- the type of instance to be produced. E.g. if the message body is to be converted into a method parameter, this will be the formal type of the method parameter as returned byMethod.getGenericParameterTypes
.annotations
- an array of the annotations on the declaration of the artifact that will be initialized with the produced instance. E.g. if the message body is to be converted into a method parameter, this will be the annotations on that parameter returned byMethod.getParameterAnnotations
.mediaType
- the media type of the HTTP entity.httpHeaders
- the read-only HTTP headers associated with HTTP entity.entityStream
- theInputStream
of the HTTP entity. The caller is responsible for ensuring that the input stream ends when the entity has been consumed. The implementation should not close the input stream.- Returns:
- the type that was read from the stream. In case the entity input stream is empty, the reader
is expected to either return an instance representing a zero-length entity or throw
a
NoContentException
in case no zero-length entity representation is defined for the supported Java type. - Throws:
IOException
- if an IO error arises. In case the entity input stream is empty and the reader is not able to produce a Java representation for a zero-length entity,NoContentException
is expected to be thrown.jakarta.ws.rs.WebApplicationException
- if a specific HTTP error response needs to be produced. Only effective if thrown prior to the response being committed.
-
isWriteable
public boolean isWriteable(Class<?> type, Type genericType, Annotation[] annotations, jakarta.ws.rs.core.MediaType mediaType)
Ascertain if the MessageBodyWriter supports a particular type.- Parameters:
type
- the class of instance that is to be written.genericType
- the type of instance to be written, obtained either by reflection of a resource method return type or via inspection of the returned instance.GenericEntity
provides a way to specify this information at runtime.annotations
- an array of the annotations attached to the message entity instance.mediaType
- the media type of the HTTP entity.- Returns:
true
if the type is supported, otherwisefalse
.
-
writeTo
public void writeTo(jakarta.activation.DataSource dataSource, Class<?> type, Type genericType, Annotation[] annotations, jakarta.ws.rs.core.MediaType mediaType, jakarta.ws.rs.core.MultivaluedMap<String,Object> httpHeaders, OutputStream entityStream) throws IOException
Write a type to an HTTP message. The message header map is mutable but any changes must be made before writing to the output stream since the headers will be flushed prior to writing the message body.- Parameters:
dataSource
- the instance to write.type
- the class of instance that is to be written.genericType
- the type of instance to be written.GenericEntity
provides a way to specify this information at runtime.annotations
- an array of the annotations attached to the message entity instance.mediaType
- the media type of the HTTP entity.httpHeaders
- a mutable map of the HTTP message headers.entityStream
- theOutputStream
for the HTTP entity. The implementation should not close the output stream.- Throws:
IOException
- if an IO error arises.jakarta.ws.rs.WebApplicationException
- if a specific HTTP error response needs to be produced. Only effective if thrown prior to the message being committed.
-
asyncWriteTo
public CompletionStage<Void> asyncWriteTo(jakarta.activation.DataSource dataSource, Class<?> type, Type genericType, Annotation[] annotations, jakarta.ws.rs.core.MediaType mediaType, jakarta.ws.rs.core.MultivaluedMap<String,Object> httpHeaders, AsyncOutputStream entityStream)
Description copied from interface:AsyncMessageBodyWriter
Write a type to an HTTP message using async IO. The message header map is mutable but any changes must be made before writing to the async output stream since the headers will be flushed prior to writing the message body.- Parameters:
dataSource
- the instance to write.type
- the class of instance that is to be written.genericType
- the type of instance to be written.GenericEntity
provides a way to specify this information at runtime.annotations
- an array of the annotations attached to the message entity instance.mediaType
- the media type of the HTTP entity.httpHeaders
- a mutable map of the HTTP message headers.entityStream
- theAsyncOutputStream
for the HTTP entity. The implementation should not close the output stream.- Returns:
- a
CompletionStage
indicating completion
-
-