org.apache.cxf.message.Message.getAttachments()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(9.5k)|赞(0)|评价(0)|浏览(231)

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

Message.getAttachments介绍

[英]Retrieve any binary attachments associated with the message.
[中]检索与邮件关联的任何二进制附件。

代码示例

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

  1. MultiPartDataSource(Message message, DataSource root) {
  2.   atts = message.getAttachments().iterator();
  3.   String s = (String)message.get(Message.CONTENT_TYPE);
  4.   boundary = findBoundary(s);
  5.   start = findStart(s);
  6.   if (!s.contains(boundary)) {
  7.     s += "; boundary=\"" + boundary + "\"";
  8.   }
  9.   contentType = s;
  10.   rootPart = root;
  11.   try {
  12.     writer = new OutputStreamWriter(bout, "ASCII");
  13.     writer.append("Content-Type: ").append(contentType).append("\r\n\r\n");
  14.     writer.flush();
  15.     current = bout.createInputStream();
  16.   } catch (Exception e) {
  17.     //nothing
  18.   }
  19. }

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

  1. private void doDataSource(final Message message) {
  2.   MessageContentsList list = (MessageContentsList)message.getContent(List.class);
  3.   //reconstitute all the parts into a Mime data source
  4.   if (message.getAttachments() != null && !message.getAttachments().isEmpty()
  5.     && list != null
  6.     && !list.isEmpty() && list.get(0) instanceof DataSource) {
  7.     list.set(0, new MultiPartDataSource(message, (DataSource)list.get(0)));
  8.   }
  9. }

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

  1. throw new Fault(ex);
  2. message.setAttachments(msg.getAttachments());
  3. final InputStream in = msg.getContent(InputStream.class);
  4. final String ct2 = (String)msg.get(Message.CONTENT_TYPE);

代码示例来源：origin: org.apache.servicemix/servicemix-cxf-bc

  1. private void loadAttachments(Message message) {
  2.   //get chance to cache the attachments
  3.   if (message.getAttachments() != null) {
  4.     LazyAttachmentCollection attachments = (LazyAttachmentCollection) message.getAttachments();
  5.     attachments.size();
  6.   }
  7. }

代码示例来源：origin: org.apache.servicemix/servicemix-cxf-bc

  1. public void handleMessage(Message message) throws Fault {
  2.   if (message.getAttachments() != null && message.getAttachments().size() > 0) {
  3.     message.put(org.apache.cxf.message.Message.MTOM_ENABLED, mtomEnabled);
  4.     message.put("write.attachments", mtomEnabled);
  5.   }
  6. }

代码示例来源：origin: org.apache.cxf/cxf-rt-transports-http

  1. DelegatingInputStream in = inMessage.getContent(DelegatingInputStream.class);
  2. if (PropertyUtils.isTrue(o)) {
  3.   Collection<Attachment> atts = inMessage.getAttachments();
  4.   if (atts != null) {
  5.     for (Attachment a : atts) {

代码示例来源：origin: org.apache.servicemix/servicemix-cxf-bc

  1. private void toNMSAttachments(NormalizedMessage normalizedMessage,
  2.     Message soapMessage) throws MessagingException {
  3.   if (soapMessage.getAttachments() != null) {
  4.     for (Attachment att : soapMessage.getAttachments()) {
  5.       normalizedMessage.addAttachment(att.getId(), att
  6.           .getDataHandler());
  7.     }
  8.   }
  9. }

代码示例来源：origin: org.apache.servicemix/servicemix-cxf-bc

  1. /**
  2.  * Convert SoapMessage attachments to NormalizedMessage attachments
  3.  */
  4. private void toNMSAttachments(NormalizedMessage normalizedMessage,
  5.     Message soapMessage) throws MessagingException {
  6.   if (soapMessage.getAttachments() != null) {
  7.     for (Attachment att : soapMessage.getAttachments()) {
  8.       normalizedMessage.addAttachment(att.getId(), att
  9.           .getDataHandler());
  10.     }
  11.   }
  12. }

代码示例来源：origin: apache/cxf

  1. private void assertIsNotTextMessageAndMtom(final Message outMessage) {
  2.   boolean isTextPayload = JMSConstants.TEXT_MESSAGE_TYPE.equals(jmsConfig.getMessageType());
  3.   if (isTextPayload && MessageUtils.getContextualBoolean(outMessage, org.apache.cxf.message.Message.MTOM_ENABLED)
  4.     && outMessage.getAttachments() != null && outMessage.getAttachments().size() > 0) {
  5.     org.apache.cxf.common.i18n.Message msg =
  6.       new org.apache.cxf.common.i18n.Message("INVALID_MESSAGE_TYPE", LOG);
  7.     throw new ConfigurationException(msg);
  8.   }
  9. }

代码示例来源：origin: org.mule.services/mule-service-soap

  1. @Override
  2. public void handleMessage(Message message) throws Fault {
  3.  final ImmutableMap.Builder<String, SoapAttachment> result = ImmutableMap.builder();
  4.  Collection<Attachment> attachments = message.getAttachments();
  5.  if (attachments != null && !attachments.isEmpty()) {
  6.   attachments.forEach(a -> result.put(getName(a), getSoapAttachment(a)));
  7.  }
  8.  message.getExchange().put(MULE_ATTACHMENTS_KEY, result.build());
  9. }

代码示例来源：origin: apache/cxf

  1. private void doDataSource(final Message message) {
  2.   MessageContentsList list = (MessageContentsList)message.getContent(List.class);
  3.   //reconstitute all the parts into a Mime data source
  4.   if (message.getAttachments() != null && !message.getAttachments().isEmpty()
  5.     && list != null
  6.     && !list.isEmpty() && list.get(0) instanceof DataSource) {
  7.     list.set(0, new MultiPartDataSource(message, (DataSource)list.get(0)));
  8.   }
  9. }

代码示例来源：origin: apache/cxf

  1. public void handleMessage(Message message) throws Fault {
  2.     Assert.assertNotNull(message.getAttachments());
  3.     Assert.assertEquals(1, message.getAttachments().size());
  4.   }
  5. }

代码示例来源：origin: org.mule.modules/mule-module-cxf

  1. public void handleMessage(Message message) throws Fault
  2. {
  3.   MuleEvent event = (MuleEvent) message.getExchange().get(CxfConstants.MULE_EVENT);
  4.   MuleMessage muleMsg = event.getMessage();
  5.   Collection<Attachment> atts = message.getAttachments();
  6.   if (atts != null && !atts.isEmpty())
  7.   {
  8.     muleMsg.setInvocationProperty(CxfConstants.ATTACHMENTS, atts);
  9.     muleMsg.setOutboundProperty(HttpConstants.HEADER_CONTENT_TYPE, muleMsg.getInboundProperty(HttpConstants.HEADER_CONTENT_TYPE));
  10.   }
  11. }

代码示例来源：origin: apache/cxf

  1. public void handleMessage(Message message) throws Fault {
  2.   Assert.assertEquals("check attachment count", 1, message.getAttachments().size());
  3.   Attachment att = message.getAttachments().iterator().next();
  4.   Assert.assertNotNull("Attachment is null", att);
  5.   Assert.assertNotNull("Attachment content-type is null", att.getDataHandler().getDataSource()
  6.       .getContentType());
  7. }

代码示例来源：origin: apache/cxf

  1. protected <T> DataReader<T> getDataReader(Message message, Class<T> input) {
  2.   Service service = ServiceModelUtil.getService(message.getExchange());
  3.   DataReader<T> dataReader = service.getDataBinding().createReader(input);
  4.   if (dataReader == null) {
  5.     throw new Fault(new org.apache.cxf.common.i18n.Message("NO_DATAREADER",
  6.                                 BUNDLE, service.getName()));
  7.   }
  8.   dataReader.setAttachments(message.getAttachments());
  9.   dataReader.setProperty(DataReader.ENDPOINT, message.getExchange().getEndpoint());
  10.   dataReader.setProperty(Message.class.getName(), message);
  11.   setDataReaderValidation(service, message, dataReader);
  12.   return dataReader;
  13. }

代码示例来源：origin: apache/cxf

  1. protected DataWriter<XMLStreamWriter> getDataWriter(Message message) {
  2.   Service service = ServiceModelUtil.getService(message.getExchange());
  3.   DataWriter<XMLStreamWriter> dataWriter = service.getDataBinding().createWriter(XMLStreamWriter.class);
  4.   if (dataWriter == null) {
  5.     throw new Fault(new org.apache.cxf.common.i18n.Message("NO_DATAWRITER", BUNDLE, service
  6.       .getName()));
  7.   }
  8.   dataWriter.setAttachments(message.getAttachments());
  9.   setDataWriterValidation(service, message, dataWriter);
  10.   return dataWriter;
  11. }
  12. private void setDataWriterValidation(Service service, Message message, DataWriter<?> writer) {

代码示例来源：origin: org.apache.cxf/cxf-core

  1. protected <T> DataReader<T> getDataReader(Message message, Class<T> input) {
  2.   Service service = ServiceModelUtil.getService(message.getExchange());
  3.   DataReader<T> dataReader = service.getDataBinding().createReader(input);
  4.   if (dataReader == null) {
  5.     throw new Fault(new org.apache.cxf.common.i18n.Message("NO_DATAREADER",
  6.                                 BUNDLE, service.getName()));
  7.   }
  8.   dataReader.setAttachments(message.getAttachments());
  9.   dataReader.setProperty(DataReader.ENDPOINT, message.getExchange().getEndpoint());
  10.   dataReader.setProperty(Message.class.getName(), message);
  11.   setDataReaderValidation(service, message, dataReader);
  12.   return dataReader;
  13. }

代码示例来源：origin: org.apache.cxf/cxf-api

  1. protected <T> DataReader<T> getDataReader(Message message, Class<T> input) {
  2.   Service service = ServiceModelUtil.getService(message.getExchange());
  3.   DataReader<T> dataReader = service.getDataBinding().createReader(input);
  4.   if (dataReader == null) {
  5.     throw new Fault(new org.apache.cxf.common.i18n.Message("NO_DATAREADER", 
  6.                                 BUNDLE, service.getName()));
  7.   }
  8.   dataReader.setAttachments(message.getAttachments());
  9.   dataReader.setProperty(DataReader.ENDPOINT, message.getExchange().getEndpoint());
  10.   dataReader.setProperty(Message.class.getName(), message);
  11.   setDataReaderValidation(service, message, dataReader);
  12.   return dataReader;
  13. }

代码示例来源：origin: org.apache.cxf/cxf-bundle-jaxrs

  1. protected <T> DataReader<T> getDataReader(Message message, Class<T> input) {
  2.   Service service = ServiceModelUtil.getService(message.getExchange());
  3.   DataReader<T> dataReader = service.getDataBinding().createReader(input);
  4.   if (dataReader == null) {
  5.     throw new Fault(new org.apache.cxf.common.i18n.Message("NO_DATAREADER", 
  6.                                 BUNDLE, service.getName()));
  7.   }
  8.   dataReader.setAttachments(message.getAttachments());
  9.   dataReader.setProperty(DataReader.ENDPOINT, message.getExchange().getEndpoint());
  10.   dataReader.setProperty(Message.class.getName(), message);
  11.   setDataReaderValidation(service, message, dataReader);
  12.   return dataReader;
  13. }

代码示例来源：origin: org.apache.cxf/cxf-rt-bindings-soap

  1. protected DataWriter<XMLStreamWriter> getDataWriter(Message message) {
  2.   Service service = ServiceModelUtil.getService(message.getExchange());
  3.   DataWriter<XMLStreamWriter> dataWriter = service.getDataBinding().createWriter(XMLStreamWriter.class);
  4.   if (dataWriter == null) {
  5.     throw new Fault(new org.apache.cxf.common.i18n.Message("NO_DATAWRITER", BUNDLE, service
  6.       .getName()));
  7.   }
  8.   dataWriter.setAttachments(message.getAttachments());
  9.   setDataWriterValidation(service, message, dataWriter);
  10.   return dataWriter;
  11. }
  12. private void setDataWriterValidation(Service service, Message message, DataWriter<?> writer) {

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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