org.mule.runtime.api.message.Message.builder()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(8.9k)|赞(0)|评价(0)|浏览(356)

本文整理了Java中org.mule.runtime.api.message.Message.builder()方法的一些代码示例，展示了Message.builder()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Message.builder()方法的具体详情如下：
包路径：org.mule.runtime.api.message.Message
类名称：Message
方法名：builder

Message.builder介绍

[英]Provides a builder to create Message objects.
[中]提供用于创建消息对象的生成器。

代码示例

代码示例来源：origin: mulesoft/mule

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public Message.Builder toMessageBuilder(Map value) {
  6.  return Message.builder().payload(new TypedValue<>(value, getDataType()));
  7. }

代码示例来源：origin: mulesoft/mule

  1. @Benchmark
  2. public CoreEvent deepCopyEventWith50VariablesProperties() {
  3.  return CoreEvent.builder(eventWith50VariablesProperties)
  4.    .message(Message.builder(eventWith50VariablesProperties.getMessage()).build()).build();
  5. }

代码示例来源：origin: mulesoft/mule

  1. @Benchmark
  2. public CoreEvent deepCopyEventWith100VariablesProperties() {
  3.  return CoreEvent.builder(eventWith100VariablesProperties)
  4.    .message(Message.builder(eventWith100VariablesProperties.getMessage()).build()).build();
  5. }

代码示例来源：origin: mulesoft/mule

  1. @Test
  2. public void createNewMessageViaMessageInterface() {
  3.  Message message = Message.builder().value(TEST_PAYLOAD).build();
  4.  assertThat(message.getPayload().getValue(), is(TEST_PAYLOAD));
  5.  assertThat(message.getPayload().getDataType(), is(STRING));
  6.  assertThat(message.getAttributes().getValue(), is(nullValue()));
  7. }

代码示例来源：origin: mulesoft/mule

  1. @Test
  2. public void createAPIMessageViaMessageInterfaceFromCopy() {
  3.  org.mule.runtime.api.message.Message message;
  4.  message = org.mule.runtime.api.message.Message.builder().value(TEST_PAYLOAD).build();
  5.  org.mule.runtime.api.message.Message messageCopy;
  6.  messageCopy = org.mule.runtime.api.message.Message.builder(message).value(true).attributesValue(BASE_ATTRIBUTES).build();
  7.  assertThat(messageCopy.getPayload().getValue(), is(true));
  8.  assertThat(messageCopy.getPayload().getDataType(), is(BOOLEAN));
  9.  assertThat(messageCopy.getAttributes().getValue(), is(BASE_ATTRIBUTES));
  10.  assertThat(messageCopy.getAttributes().getDataType(), is(BASE_ATTRIBUTES_DATATYPE));
  11. }

代码示例来源：origin: mulesoft/mule

  1. @Test
  2. public void updatesEncodingOnTransformation() throws Exception {
  3.  Message message = Message.builder().value(TEST_PAYLOAD).mediaType(APPLICATION_XML_DEFAULT).build();
  4.  Transformer transformer = mock(Transformer.class);
  5.  when(transformer.isSourceDataTypeSupported(any())).thenReturn(true);
  6.  DataType outputDataType = DataType.builder().type(Integer.class).charset(CUSTOM_ENCODING).build();
  7.  when(transformer.getReturnDataType()).thenReturn(outputDataType);
  8.  when(transformer.transform(anyObject())).thenReturn(Integer.valueOf(1));
  9.  CoreEvent muleEvent = mock(CoreEvent.class);
  10.  Message result = transformationService.applyTransformers(message, muleEvent, singletonList(transformer));
  11.  assertDataType(result, Integer.class, APPLICATION_XML, CUSTOM_ENCODING);
  12. }

代码示例来源：origin: mulesoft/mule

  1. @Test
  2. public void updatesMimeTypeOnTransformation() throws Exception {
  3.  Message message = Message.builder().value(TEST_PAYLOAD).mediaType(ANY.withCharset(CUSTOM_ENCODING)).build();
  4.  Transformer transformer = mock(Transformer.class);
  5.  when(transformer.isSourceDataTypeSupported(any())).thenReturn(true);
  6.  DataType outputDataType = DataType.builder().type(Integer.class).mediaType(APPLICATION_XML).build();
  7.  when(transformer.getReturnDataType()).thenReturn(outputDataType);
  8.  when(transformer.transform(any(Message.class))).thenReturn(1);
  9.  CoreEvent muleEvent = mock(CoreEvent.class);
  10.  Message result = transformationService.applyTransformers(message, muleEvent, singletonList(transformer));
  11.  assertDataType(result, Integer.class, APPLICATION_XML, CUSTOM_ENCODING);
  12. }

代码示例来源：origin: mulesoft/mule

  1. @Before
  2. public void before() throws MuleException {
  3.  expressionManager = muleContext.getExpressionManager();
  4.  event = eventBuilder(muleContext).message(Message.builder().value("").attributesValue(attributes).build()).build();
  5.  when(operationContext.getEvent()).thenReturn(event);
  6.  when(operationContext.getMuleContext()).thenReturn(muleContext);
  7.  when(componentModel.getModelProperty(MediaTypeModelProperty.class)).thenReturn(empty());
  8. }

代码示例来源：origin: mulesoft/mule

  1. @Benchmark
  2. @Threads(Threads.MAX)
  3. public Either<SourcePolicyFailureResult, SourcePolicySuccessResult> source() {
  4.  CoreEvent event;
  5.  Message.Builder messageBuilder = Message.builder().value(PAYLOAD);
  6.  CoreEvent.Builder eventBuilder =
  7.    CoreEvent.builder(create("", "", CONNECTOR_LOCATION, NullExceptionHandler.getInstance())).message(messageBuilder.build());
  8.  event = eventBuilder.build();
  9.  return from(handler.process(event, sourceRpp)).block();
  10. }

代码示例来源：origin: mulesoft/mule

  1. @Benchmark
  2. @Threads(Threads.MAX)
  3. public Either<SourcePolicyFailureResult, SourcePolicySuccessResult> source() {
  4.  CoreEvent event;
  5.  Message.Builder messageBuilder = Message.builder().value(PAYLOAD);
  6.  CoreEvent.Builder eventBuilder =
  7.    CoreEvent.builder(create("", "", CONNECTOR_LOCATION, NullExceptionHandler.getInstance())).message(messageBuilder.build());
  8.  event = eventBuilder.build();
  9.  return from(handler.process(event, sourceRpp)).block();
  10. }

代码示例来源：origin: mulesoft/mule

  1. @Test
  2. public void wholePayload() {
  3.  Message message = Message.builder().payload(new TypedValue<>(EMPTY_JSON, JSON_STRING)).build();
  4.  assertThat(message.getPayload().getValue(), equalTo(EMPTY_JSON));
  5.  assertThat(message.getPayload().getDataType().getType(), equalTo(String.class));
  6.  assertThat(message.getPayload().getDataType().getMediaType(), is(APPLICATION_JSON));
  7. }

代码示例来源：origin: mulesoft/mule

  1. @Override
  2. public void process(Object payload, Object attributes, Consumer<Result> onSuccess, BiConsumer<Throwable, Result> onError) {
  3.  CoreEvent customEvent = CoreEvent.builder(originalEvent)
  4.    .message(Message.builder()
  5.      .payload(TypedValue.of(payload))
  6.      .attributes(TypedValue.of(attributes))
  7.      .build())
  8.    .build();
  9.  doProcess(customEvent, onSuccess, onError);
  10. }

代码示例来源：origin: mulesoft/mule

  1. @Test
  2. public void wholeAttributes() {
  3.  Message message = Message.builder().nullValue().attributes(new TypedValue<>(EMPTY_JSON, JSON_STRING)).build();
  4.  assertThat(message.getAttributes().getValue(), equalTo(EMPTY_JSON));
  5.  assertThat(message.getAttributes().getDataType().getType(), equalTo(String.class));
  6.  assertThat(message.getAttributes().getDataType().getMediaType(), is(APPLICATION_JSON));
  7. }

代码示例来源：origin: mulesoft/mule

  1. @Test
  2. public void attributesBinding() throws Exception {
  3.  CoreEvent event = getEventWithError(empty());
  4.  SomeAttributes attributes = new SomeAttributes();
  5.  InternalMessage message = (InternalMessage) Message.builder().nullValue().attributesValue(attributes).build();
  6.  when(event.getMessage()).thenReturn(message);
  7.  TypedValue result = expressionLanguage.evaluate(ATTRIBUTES, event, BindingContext.builder().build());
  8.  assertThat(result.getValue(), is(equalTo(attributes)));
  9.  assertThat(result.getDataType().getType(), is((equalTo(SomeAttributes.class))));
  10. }

代码示例来源：origin: mulesoft/mule

  1. @Test
  2. public void operationReturnsOperationResultThatOnlySpecifiesPayload() throws Exception {
  3.  Object payload = "hello world!";
  4.  when(operationExecutor.execute(any(ExecutionContext.class))).thenReturn(just(builder().output(payload).build()));
  5.  event =
  6.    CoreEvent.builder(event).message(Message.builder().value("").attributesValue(mock(Object.class)).build()).build();
  7.  Message message = messageProcessor.process(event).getMessage();
  8.  assertThat(message, is(notNullValue()));
  9.  assertThat(message.getPayload().getValue(), is(sameInstance(payload)));
  10.  assertThat(message.getAttributes().getValue(), is(nullValue()));
  11.  assertThat(message.getPayload().getDataType().getType().equals(String.class), is(true));
  12. }

代码示例来源：origin: mulesoft/mule

  1. @Test
  2. public void usesCustomEncodingWithNoProperty() throws Exception {
  3.  Message message = Message.builder().value(TEST_PAYLOAD).mediaType(ANY.withCharset(CUSTOM_ENCODING)).build();
  4.  assertThat(message.getPayload().getDataType().getMediaType().getCharset().get(), equalTo(CUSTOM_ENCODING));
  5.  assertCustomEncoding(message);
  6. }

代码示例来源：origin: mulesoft/mule

  1. @Setup
  2. public void setup() throws Exception {
  3.  muleContext = createMuleContextWithServices();
  4.  muleContext.start();
  5.  flow = createFlow(muleContext);
  6.  registerObject(muleContext, FLOW_NAME, flow, FlowConstruct.class);
  7.  Message.Builder messageBuilder = Message.builder().value(PAYLOAD);
  8.  CoreEvent.Builder eventBuilder =
  9.    CoreEvent.builder(create(flow, CONNECTOR_LOCATION)).message(messageBuilder.build());
  10.  event = eventBuilder.build();
  11. }

代码示例来源：origin: mulesoft/mule

  1. @Test
  2. public void overridesDataTypeFromPreviousMessageOnCreation() throws Exception {
  3.  Message message = Message.builder().value(1).mediaType(APPLICATION_XML_CUSTOM).build();
  4.  assertDataType(InternalMessage.builder(message).value("TEST").build(), String.class, APPLICATION_XML, CUSTOM_ENCODING);
  5. }

代码示例来源：origin: mulesoft/mule

  1. private CoreEvent createStreamPayloadEventWithLength(OptionalLong length) throws MuleException {
  2.  return builder(testEvent())
  3.    .message(Message.builder().payload(new TypedValue(new NullInputStream(length.orElse(-1l)), INPUT_STREAM, length))
  4.      .build())
  5.    .build();
  6. }

代码示例来源：origin: mulesoft/mule

  1. private CoreEvent createStreamPayloadEventWithLength(OptionalLong length) throws MuleException {
  2.  return builder(testEvent())
  3.    .message(Message.builder().payload(new TypedValue(new NullInputStream(length.orElse(-1l)), INPUT_STREAM, length))
  4.      .build())
  5.    .build();
  6. }

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com