本文整理了Java中org.mule.runtime.api.metadata.MediaType
类的一些代码示例,展示了MediaType
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MediaType
类的具体详情如下:
包路径:org.mule.runtime.api.metadata.MediaType
类名称:MediaType
[英]Immutable representation of Media Types as defined in RFC-2046 Part Two.
Also provides constants for common media types used in Mule.
[中][RFC-2046 Part Two](https://www.ietf.org/rfc/rfc2046.txt)中定义的媒体类型的不可变表示。
还为Mule中使用的常见媒体类型提供常量。
代码示例来源:origin: mulesoft/mule
@Test
public void parseTemplateWithOverriddenDataTypeAsExpression() throws Exception {
String customEncoding = "UTF-16";
MediaType customMediaType = create("application", "lrmextension");
parseTemplateProcessor.setLocation(UNKNOWN_MEDIATYPE_LOCATION);
parseTemplateProcessor.setOutputMimeType(customMediaType.toRfcString());
parseTemplateProcessor.setOutputEncoding(customEncoding);
parseTemplateProcessor.initialise();
String expectedExpression = IOUtils.getResourceAsString(UNKNOWN_MEDIATYPE_LOCATION, this.getClass());
when(mockExpressionManager.parseLogTemplate(eq(expectedExpression), eq(event), any(), any())).thenReturn("Parsed");
CoreEvent response = parseTemplateProcessor.process(event);
assertThat(response.getMessage().getPayload().getDataType().getMediaType().getPrimaryType(),
is(equalTo(customMediaType.getPrimaryType())));
assertThat(response.getMessage().getPayload().getDataType().getMediaType().getSubType(),
is(equalTo(customMediaType.getSubType())));
assertThat(response.getMessage().getPayload().getDataType().getMediaType().getCharset().get().toString(),
is(equalTo(customEncoding)));
}
代码示例来源:origin: mulesoft/mule
private Optional<MediaType> getContextMimeType(Map<String, Object> params) {
return ofNullable((String) params.get(MIME_TYPE_PARAMETER_NAME)).map(mimeType -> MediaType.parse(mimeType));
}
代码示例来源:origin: mulesoft/mule
@Override
protected boolean matchesSafely(DataType dataType) {
boolean sameType = type == null ? dataType.getType() == null : type.equals(dataType.getType());
boolean sameEncoding = dataType.getMediaType().getCharset().equals(Optional.ofNullable(encoding));
boolean sameMimeType = mimeType == null ? dataType.getMediaType() == null : mimeType.matches(dataType.getMediaType());
return sameType && sameEncoding && sameMimeType;
}
代码示例来源:origin: mulesoft/mule
protected MediaType resolveMediaType(Object value) {
Charset existingEncoding = defaultEncoding;
MediaType mediaType = defaultMediaType;
if (value instanceof Result) {
final Optional<MediaType> optionalMediaType = ((Result) value).getMediaType();
if (optionalMediaType.isPresent()) {
mediaType = optionalMediaType.get();
existingEncoding = mediaType.getCharset().orElse(existingEncoding);
}
}
return mimeTypeInitParam.orElse(mediaType).withCharset(encodingParam.orElse(existingEncoding));
}
代码示例来源:origin: mulesoft/mule
@Test
public void validMediaTypeWithCharset() throws TransformerException {
final StringToMediaTypeTransformer transformer = new StringToMediaTypeTransformer();
final MediaType transformed = (MediaType) transformer.transform("text/plain;charset=" + US_ASCII.name());
assertThat(transformed.getPrimaryType(), is("text"));
assertThat(transformed.getSubType(), is("plain"));
assertThat(transformed.getCharset().get(), is(US_ASCII));
}
代码示例来源:origin: mulesoft/mule
@Test
public void newExecutionContextForNonInterceptedProcessor() throws MuleException {
final AtomicReference<PrecalculatedExecutionContextAdapter> context = new AtomicReference<>();
Map<String, String> newContextParameters = ImmutableMap.of(MIME_TYPE_PARAMETER_NAME, MediaType.ANY.toRfcString(),
ENCODING_PARAMETER_NAME, Charset.defaultCharset().name());
doReturn(newContextParameters).when(parameters).asMap();
doReturn(parameters).when(resolverSet).resolve(any(ValueResolvingContext.class));
messageProcessor.resolveParameters(CoreEvent.builder(event), (params, ctx) -> {
assertThat(ctx, instanceOf(PrecalculatedExecutionContextAdapter.class));
context.set(spy((PrecalculatedExecutionContextAdapter) ctx));
});
messageProcessor.process(quickCopy(event, singletonMap(INTERCEPTION_RESOLVED_CONTEXT, context.get())));
verify(operationExecutor, never()).execute(context.get());
verify(operationExecutor).execute(any(ExecutionContext.class));
messageProcessor.disposeResolvedParameters(context.get());
}
代码示例来源:origin: mulesoft/mule
private void assertCustomMimeType(DataType dataType) {
assertThat(dataType.getMediaType().getPrimaryType(), is("dead"));
assertThat(dataType.getMediaType().getSubType(), is("dead"));
}
代码示例来源:origin: org.mule.runtime/mule-module-extensions-support
if (optionalMediaType.isPresent()) {
mediaType = optionalMediaType.get();
if (mediaType.getCharset().isPresent()) {
existingEncoding = mediaType.getCharset().get();
mediaType = MediaType.parse(operationContext.getParameter(MIME_TYPE_PARAMETER_NAME));
mediaType = mediaType.withCharset(parseCharset(operationContext.getParameter(ENCODING_PARAMETER_NAME)));
} else {
mediaType = mediaType.withCharset(existingEncoding);
代码示例来源:origin: com.mulesoft.munit/munit-assert
public static TypedValue fromMuleTypedValue(org.mule.runtime.api.metadata.TypedValue typedValue) {
MediaType mediaType = typedValue.getDataType().getMediaType();
return new TypedValue(typedValue.getValue(),
mediaType.withoutParameters().toRfcString(),
mediaType.getCharset().orElse(null));
}
代码示例来源:origin: org.mule.transports/mule-transport-core
@Override
public Event process(Event event) throws MessagingException {
MediaType endpointMimeType = endpoint.getMimeType();
if (endpointMimeType != null) {
InternalMessage message = event.getMessage();
final DataType dataType = message.getPayload().getDataType();
if (DataType.OBJECT.getMediaType().matches(dataType.getMediaType())) {
event =
Event.builder(event).message(InternalMessage.builder(event.getMessage()).mediaType(endpointMimeType).build()).build();
} else {
if (!dataType.getMediaType().matches(endpointMimeType)) {
throw new MessagingException(CoreMessages.unexpectedMIMEType(dataType.getMediaType().toRfcString(),
endpointMimeType.toRfcString()),
event, this);
}
}
}
return event;
}
代码示例来源:origin: org.mule/mule-api
/**
* Creates a new {@link MediaType} instance keeping the {@code type} and {@code sub-type} but removing all the
* parameters (like the {@code charset})
*
* @return new immutable {@link MediaType} instance.
*/
public MediaType withoutParameters() {
return create(this.getPrimaryType(), this.getSubType());
}
代码示例来源:origin: mulesoft/mule
@Test
public void updatesMimeTypeOnTransformation() throws Exception {
Message message = Message.builder().value(TEST_PAYLOAD).mediaType(ANY.withCharset(CUSTOM_ENCODING)).build();
Transformer transformer = mock(Transformer.class);
when(transformer.isSourceDataTypeSupported(any())).thenReturn(true);
DataType outputDataType = DataType.builder().type(Integer.class).mediaType(APPLICATION_XML).build();
when(transformer.getReturnDataType()).thenReturn(outputDataType);
when(transformer.transform(any(Message.class))).thenReturn(1);
CoreEvent muleEvent = mock(CoreEvent.class);
Message result = transformationService.applyTransformers(message, muleEvent, singletonList(transformer));
assertDataType(result, Integer.class, APPLICATION_XML, CUSTOM_ENCODING);
}
代码示例来源:origin: mulesoft/mule
@Test
public void strictMimeType() throws Exception {
CoreEvent response = runFlow("strictMimeType");
assertThat(response.getMessage().getPayload().getDataType().getMediaType().matches(TEXT), is(true));
}
代码示例来源:origin: org.mule.runtime/mule-core
private boolean mediaTypesMatch(DataType other) {
if (this.getMediaType() == null && other.getMediaType() != null) {
return false;
}
if (this.getMediaType() != null && other.getMediaType() == null) {
return false;
}
if (!this.getMediaType().getCharset().isPresent()) {
return this.getMediaType().matches(other.getMediaType());
} else {
return this.getMediaType().equals(other.getMediaType());
}
}
代码示例来源:origin: mulesoft/mule
private void doFileMimeTypeTest(String fileExtension, MediaType expectedMimeType) throws IOException {
String filename = "test." + fileExtension;
String mimeType = mimetypesFileTypeMap.getContentType(filename);
assertThat(mimeType, equalTo(expectedMimeType.toString()));
}
}
代码示例来源:origin: org.mule.services/mule-service-oauth
.uri(tokenUrl).method(POST.name())
.entity(new ByteArrayHttpEntity(encodeString(tokenRequestFormToSend, encoding).getBytes()))
.addHeader(CONTENT_TYPE, APPLICATION_X_WWW_FORM_URLENCODED.toRfcString());
response.getHeaderValueIgnoreCase(CONTENT_TYPE) != null ? parse(response.getHeaderValueIgnoreCase(CONTENT_TYPE)) : ANY;
代码示例来源:origin: mulesoft/mule
@Override
protected void describeMismatchSafely(DataType dataType, Description mismatchDescription) {
mismatchDescription
.appendText("got a dataType with type = ").appendValue(dataType.getType().getName())
.appendText(", mimeType = ").appendValue(dataType.getMediaType())
.appendText(", encoding = ").appendValue(dataType.getMediaType().getCharset());
}
代码示例来源:origin: com.mulesoft.munit/munit-assert
private String getDescription(MediaType mediaType) {
return mediaType.withoutParameters().toRfcString();
}
代码示例来源:origin: com.mulesoft.munit/munit-mock
MediaType mediaType = MediaType.parse(mockedEventPayload.getMediaType());
if (mockedEventPayload.getEncoding() != null) {
mediaType = mediaType.withCharset(Charset.forName(mockedEventPayload.getEncoding()));
代码示例来源:origin: mulesoft/mule
@Benchmark
public Object noCharset() {
return MediaType.create("text", "plain" + System.nanoTime());
}
内容来源于网络,如有侵权,请联系作者删除!