org.springframework.ws.client.core.WebServiceTemplate.sendAndReceive()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(10.7k)|赞(0)|评价(0)|浏览(172)

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

WebServiceTemplate.sendAndReceive介绍

暂无

代码示例

代码示例来源：origin: spring-projects/spring-integration

  1. @Override
  2. protected Object doHandle(String uri, final Message<?> requestMessage,
  3.     final WebServiceMessageCallback requestCallback) {
  4.   Object requestPayload = requestMessage.getPayload();
  5.   Result responseResultInstance = null;
  6.   if (requestPayload instanceof String) {
  7.     responseResultInstance = new StringResult();
  8.   }
  9.   else if (requestPayload instanceof Document) {
  10.     responseResultInstance = new DOMResult();
  11.   }
  12.   return getWebServiceTemplate()
  13.       .sendAndReceive(uri,
  14.           new SimpleRequestMessageCallback(requestCallback, requestMessage),
  15.           new SimpleResponseMessageExtractor(responseResultInstance));
  16. }

代码示例来源：origin: spring-projects/spring-integration

  1. @Test
  2. @SuppressWarnings("unchecked")
  3. public void jmsUri() {
  4.   AbstractEndpoint endpoint = this.context.getBean("gatewayWithJmsUri", AbstractEndpoint.class);
  5.   assertEquals(EventDrivenConsumer.class, endpoint.getClass());
  6.   MessageHandler handler = TestUtils.getPropertyValue(endpoint, "handler", MessageHandler.class);
  7.   assertNull(TestUtils.getPropertyValue(handler, "destinationProvider"));
  8.   assertFalse(TestUtils.getPropertyValue(handler, "encodeUri", Boolean.class));
  9.   WebServiceTemplate webServiceTemplate = TestUtils.getPropertyValue(handler, "webServiceTemplate",
  10.       WebServiceTemplate.class);
  11.   webServiceTemplate = spy(webServiceTemplate);
  12.   doReturn(null).when(webServiceTemplate).sendAndReceive(anyString(),
  13.       any(WebServiceMessageCallback.class),
  14.       ArgumentMatchers.<WebServiceMessageExtractor<Object>>any());
  15.   new DirectFieldAccessor(handler).setPropertyValue("webServiceTemplate", webServiceTemplate);
  16.   handler.handleMessage(new GenericMessage<String>("foo"));
  17.   verify(webServiceTemplate).sendAndReceive(eq("jms:wsQueue"),
  18.       any(WebServiceMessageCallback.class),
  19.       ArgumentMatchers.<WebServiceMessageExtractor<Object>>any());
  20. }

代码示例来源：origin: spring-projects/spring-integration

  1. @Test
  2. @SuppressWarnings("unchecked")
  3. public void testHttpUriVariables() {
  4.   WebServiceTemplate webServiceTemplate = TestUtils.getPropertyValue(this.httpOutboundGateway,
  5.       "webServiceTemplate", WebServiceTemplate.class);
  6.   webServiceTemplate = Mockito.spy(webServiceTemplate);
  7.   final AtomicReference<String> uri = new AtomicReference<>();
  8.   doAnswer(invocation -> {
  9.     uri.set(invocation.getArgument(0));
  10.     throw new WebServiceIOException("intentional");
  11.   }).when(webServiceTemplate)
  12.       .sendAndReceive(Mockito.anyString(),
  13.           Mockito.any(WebServiceMessageCallback.class),
  14.           (WebServiceMessageExtractor<Object>) Mockito.any(WebServiceMessageExtractor.class));
  15.   new DirectFieldAccessor(this.httpOutboundGateway).setPropertyValue("webServiceTemplate", webServiceTemplate);
  16.   Message<?> message = MessageBuilder.withPayload("<spring/>")
  17.       .setHeader("x", "integration")
  18.       .setHeader("param", "test1 & test2")
  19.       .build();
  20.   try {
  21.     this.inputHttp.send(message);
  22.   }
  23.   catch (MessageHandlingException e) {
  24.     // expected
  25.     assertThat(e.getCause(), Matchers.is(Matchers.instanceOf(WebServiceIOException.class))); // offline
  26.   }
  27.   assertEquals("http://localhost/spring-integration?param=test1%20&%20test2", uri.get());
  28. }

代码示例来源：origin: org.springframework.ws/org.springframework.ws

  1. public Object marshalSendAndReceive(String uri,
  2.                   final Object requestPayload,
  3.                   final WebServiceMessageCallback requestCallback) {
  4.   return sendAndReceive(uri, new WebServiceMessageCallback() {
  5.     public void doWithMessage(WebServiceMessage request) throws IOException, TransformerException {
  6.       if (requestPayload != null) {
  7.         Marshaller marshaller = getMarshaller();
  8.         if (marshaller == null) {
  9.           throw new IllegalStateException(
  10.               "No marshaller registered. Check configuration of WebServiceTemplate.");
  11.         }
  12.         MarshallingUtils.marshal(marshaller, requestPayload, request);
  13.         if (requestCallback != null) {
  14.           requestCallback.doWithMessage(request);
  15.         }
  16.       }
  17.     }
  18.   }, new WebServiceMessageExtractor<Object>() {
  19.     public Object extractData(WebServiceMessage response) throws IOException {
  20.       Unmarshaller unmarshaller = getUnmarshaller();
  21.       if (unmarshaller == null) {
  22.         throw new IllegalStateException(
  23.             "No unmarshaller registered. Check configuration of WebServiceTemplate.");
  24.       }
  25.       return MarshallingUtils.unmarshal(unmarshaller, response);
  26.     }
  27.   });
  28. }

代码示例来源：origin: spring-projects/spring-ws

  1. @Override
  2. public <T> T sendAndReceive(WebServiceMessageCallback requestCallback,
  3.                WebServiceMessageExtractor<T> responseExtractor) {
  4.   return sendAndReceive(getDefaultUri(), requestCallback, responseExtractor);
  5. }

代码示例来源：origin: org.springframework.ws/spring-ws-core

  1. @Override
  2. public boolean sendAndReceive(String uri,
  3.                WebServiceMessageCallback requestCallback,
  4.                WebServiceMessageCallback responseCallback) {
  5.   Assert.notNull(responseCallback, "responseCallback must not be null");
  6.   Boolean result = sendAndReceive(uri, requestCallback,
  7.       new WebServiceMessageCallbackMessageExtractor(responseCallback));
  8.   return result != null && result;
  9. }

代码示例来源：origin: org.springframework.ws/spring-ws-core

  1. @Override
  2. public <T> T sendAndReceive(WebServiceMessageCallback requestCallback,
  3.                WebServiceMessageExtractor<T> responseExtractor) {
  4.   return sendAndReceive(getDefaultUri(), requestCallback, responseExtractor);
  5. }

代码示例来源：origin: org.springframework.ws/spring-ws-core

  1. @Override
  2. public boolean sendAndReceive(WebServiceMessageCallback requestCallback,
  3.                WebServiceMessageCallback responseCallback) {
  4.   return sendAndReceive(getDefaultUri(), requestCallback, responseCallback);
  5. }

代码示例来源：origin: org.springframework.ws/org.springframework.ws

  1. public boolean sendAndReceive(String uri,
  2.                WebServiceMessageCallback requestCallback,
  3.                WebServiceMessageCallback responseCallback) {
  4.   Assert.notNull(responseCallback, "responseCallback must not be null");
  5.   Boolean result = sendAndReceive(uri, requestCallback,
  6.       new WebServiceMessageCallbackMessageExtractor(responseCallback));
  7.   return result != null && result;
  8. }

代码示例来源：origin: spring-projects/spring-ws

  1. @Override
  2. public boolean sendAndReceive(String uri,
  3.                WebServiceMessageCallback requestCallback,
  4.                WebServiceMessageCallback responseCallback) {
  5.   Assert.notNull(responseCallback, "responseCallback must not be null");
  6.   Boolean result = sendAndReceive(uri, requestCallback,
  7.       new WebServiceMessageCallbackMessageExtractor(responseCallback));
  8.   return result != null && result;
  9. }

代码示例来源：origin: org.springframework.ws/org.springframework.ws

  1. public <T> T sendAndReceive(WebServiceMessageCallback requestCallback,
  2.                WebServiceMessageExtractor<T> responseExtractor) {
  3.   return sendAndReceive(getDefaultUri(), requestCallback, responseExtractor);
  4. }

代码示例来源：origin: spring-projects/spring-ws

  1. @Override
  2. public boolean sendAndReceive(WebServiceMessageCallback requestCallback,
  3.                WebServiceMessageCallback responseCallback) {
  4.   return sendAndReceive(getDefaultUri(), requestCallback, responseCallback);
  5. }

代码示例来源：origin: apache/servicemix-bundles

  1. @Override
  2. public <T> T sendAndReceive(WebServiceMessageCallback requestCallback,
  3.                WebServiceMessageExtractor<T> responseExtractor) {
  4.   return sendAndReceive(getDefaultUri(), requestCallback, responseExtractor);
  5. }

代码示例来源：origin: apache/servicemix-bundles

  1. @Override
  2. public boolean sendAndReceive(WebServiceMessageCallback requestCallback,
  3.                WebServiceMessageCallback responseCallback) {
  4.   return sendAndReceive(getDefaultUri(), requestCallback, responseCallback);
  5. }

代码示例来源：origin: apache/servicemix-bundles

  1. @Override
  2. public boolean sendAndReceive(String uri,
  3.                WebServiceMessageCallback requestCallback,
  4.                WebServiceMessageCallback responseCallback) {
  5.   Assert.notNull(responseCallback, "responseCallback must not be null");
  6.   Boolean result = sendAndReceive(uri, requestCallback,
  7.       new WebServiceMessageCallbackMessageExtractor(responseCallback));
  8.   return result != null && result;
  9. }

代码示例来源：origin: org.springframework.ws/org.springframework.ws

  1. public boolean sendAndReceive(WebServiceMessageCallback requestCallback,
  2.                WebServiceMessageCallback responseCallback) {
  3.   return sendAndReceive(getDefaultUri(), requestCallback, responseCallback);
  4. }

代码示例来源：origin: org.springframework.ws/spring-ws-core

  1. private <T> T doSendAndReceive(String uri,
  2.                 final Transformer transformer,
  3.                 final Source requestPayload,
  4.                 final WebServiceMessageCallback requestCallback,
  5.                 final SourceExtractor<T> responseExtractor) {
  6.   Assert.notNull(responseExtractor, "responseExtractor must not be null");
  7.   return sendAndReceive(uri, new WebServiceMessageCallback() {
  8.     public void doWithMessage(WebServiceMessage message) throws IOException, TransformerException {
  9.       transformer.transform(requestPayload, message.getPayloadResult());
  10.       if (requestCallback != null) {
  11.         requestCallback.doWithMessage(message);
  12.       }
  13.     }
  14.   }, new SourceExtractorMessageExtractor<T>(responseExtractor));
  15. }

代码示例来源：origin: apache/servicemix-bundles

  1. private <T> T doSendAndReceive(String uri,
  2.                 final Transformer transformer,
  3.                 final Source requestPayload,
  4.                 final WebServiceMessageCallback requestCallback,
  5.                 final SourceExtractor<T> responseExtractor) {
  6.   Assert.notNull(responseExtractor, "responseExtractor must not be null");
  7.   return sendAndReceive(uri, new WebServiceMessageCallback() {
  8.     public void doWithMessage(WebServiceMessage message) throws IOException, TransformerException {
  9.       transformer.transform(requestPayload, message.getPayloadResult());
  10.       if (requestCallback != null) {
  11.         requestCallback.doWithMessage(message);
  12.       }
  13.     }
  14.   }, new SourceExtractorMessageExtractor<T>(responseExtractor));
  15. }

代码示例来源：origin: spring-projects/spring-ws

  1. private <T> T doSendAndReceive(String uri,
  2.                 final Transformer transformer,
  3.                 final Source requestPayload,
  4.                 final WebServiceMessageCallback requestCallback,
  5.                 final SourceExtractor<T> responseExtractor) {
  6.   Assert.notNull(responseExtractor, "responseExtractor must not be null");
  7.   return sendAndReceive(uri, new WebServiceMessageCallback() {
  8.     public void doWithMessage(WebServiceMessage message) throws IOException, TransformerException {
  9.       transformer.transform(requestPayload, message.getPayloadResult());
  10.       if (requestCallback != null) {
  11.         requestCallback.doWithMessage(message);
  12.       }
  13.     }
  14.   }, new SourceExtractorMessageExtractor<T>(responseExtractor));
  15. }

代码示例来源：origin: org.springframework.ws/org.springframework.ws

  1. private <T> T doSendAndReceive(String uri,
  2.                 final Transformer transformer,
  3.                 final Source requestPayload,
  4.                 final WebServiceMessageCallback requestCallback,
  5.                 final SourceExtractor<T> responseExtractor) {
  6.   Assert.notNull(responseExtractor, "responseExtractor must not be null");
  7.   return sendAndReceive(uri, new WebServiceMessageCallback() {
  8.     public void doWithMessage(WebServiceMessage message) throws IOException, TransformerException {
  9.       transformer.transform(requestPayload, message.getPayloadResult());
  10.       if (requestCallback != null) {
  11.         requestCallback.doWithMessage(message);
  12.       }
  13.     }
  14.   }, new SourceExtractorMessageExtractor<T>(responseExtractor));
  15. }

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

webservicetemplate

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    WebServiceTemplate类方法

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