org.apache.camel.Message.getMessageId()方法的使用及代码示例

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

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

Message.getMessageId介绍

暂无

代码示例

代码示例来源：origin: stackoverflow.com

  1. public class MessageAdapter implements JsonSerializer<Message> {
  3.   @Override
  4.   public JsonElement serialize(Message message, Type type, JsonSerializationContext jsc) {
  5.     JsonObject jsonObject = new JsonObject();
  6.     jsonObject.addProperty("message_id", message.getMessageId());
  7.     jsonObject.addProperty("message", message.getMessage());
  8.     jsonObject.addProperty("user", message.getUsers().getUsername());
  9.     jsonObject.addProperty("date", message.getDate().toString());
  10.     return jsonObject;      
  11.   }
  12. }

代码示例来源：origin: stackoverflow.com

  1. List<Message> msgList = getList();
  2. // just in case the getNewList() returns null
  3. // check it here---V
  4. for (int i = 0; null!=msgList && i < msgList.size(); i++) {
  5.   Message message = msgList.get(i);
  6.   String msgType = getMsgTypeFromId(message.getMessageId());
  8.   // no need for cascading two ifs. I'm assuming
  9.   // MessageType.INCOMING is a "constant" thus bound to never return null
  10.   if (MessageType.INCOMING.getType().equals(msgType)) {
  11.     // Do some operation
  12.     msgList = getNewList();
  13.     i = 0;
  14.   }
  15. }

代码示例来源：origin: stackoverflow.com

  1. public static void main(String[] args) {
  2.   Message m = new Message(23);
  3.   System.out.println(m.getMessageId());
  4. }

代码示例来源：origin: io.rhiot/camel-webcam

  1. /**
  2.  * Creates an OutOnly exchange with the BufferedImage.
  3.  */
  4. static Exchange createOutOnlyExchangeWithBodyAndHeaders(WebcamEndpoint endpoint, BufferedImage image) throws IOException {
  5.   Exchange exchange = endpoint.createExchange(ExchangePattern.OutOnly);
  6.   Message message = exchange.getIn();
  7.   try (ByteArrayOutputStream output = new ByteArrayOutputStream()) {
  8.     ImageIO.write(image, endpoint.getFormat(), output);
  9.     message.setBody(new BufferedInputStream(new ByteArrayInputStream(output.toByteArray())));
  10.     message.setHeader(Exchange.FILE_NAME, message.getMessageId() + "" + endpoint.getFormat());
  11.   } 
  12.   return exchange;
  13. }

代码示例来源：origin: stackoverflow.com

  1. for (;;) {
  2.   ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest(myQueueUrl);
  3.   List<Message> messages = sqs.receiveMessage(receiveMessageRequest).getMessages();
  4.   for (Message message : messages) {
  5.     System.out.println(" Message");
  6.     System.out.println(" MessageId: " + message.getMessageId());
  7.     System.out.println(" ReceiptHandle: " + message.getReceiptHandle());
  8.     System.out.println(" MD5OfBody: " + message.getMD5OfBody());
  9.     System.out.println(" Body: " + message.getBody());
  10.     for (Entry<String, String> entry : message.getAttributes().entrySet()) {
  11.       System.out.println(" Attribute");
  12.       System.out.println(" Name: " + entry.getKey());
  13.       System.out.println(" Value: " + entry.getValue());
  14.     }
  15.   }
  16.   System.out.println();
  17. }

代码示例来源：origin: org.apache.camel/camel-dropbox

  1. name = exchange.getIn().getMessageId();

代码示例来源：origin: org.apache.camel/camel-zipfile

  1. @Override
  2. public void marshal(final Exchange exchange, final Object graph, final OutputStream stream) throws Exception {
  3.   String filename;
  4.   String filepath = exchange.getIn().getHeader(FILE_NAME, String.class);
  5.   if (filepath == null) {
  6.     // generate the file name as the camel file component would do
  7.     filename = filepath = StringHelper.sanitize(exchange.getIn().getMessageId());
  8.   } else {
  9.     filename = Paths.get(filepath).getFileName().toString(); // remove any path elements
  10.   }
  11.   ZipOutputStream zos = new ZipOutputStream(stream);
  12.   if (preservePathElements) {
  13.     createZipEntries(zos, filepath);
  14.   } else {
  15.     createZipEntries(zos, filename);
  16.   }
  17.   InputStream is = exchange.getContext().getTypeConverter().mandatoryConvertTo(InputStream.class, exchange, graph);
  18.   try {
  19.     IOHelper.copy(is, zos);
  20.   } finally {
  21.     IOHelper.close(is, zos);
  22.   }
  23.   String newFilename = filename + ".zip";
  24.   exchange.getOut().setHeader(FILE_NAME, newFilename);
  25. }

代码示例来源：origin: org.apache.camel/camel-tarfile

  1. String entryName = preserveFolderStructure ? newExchange.getIn().getHeader(Exchange.FILE_NAME, String.class) : newExchange.getIn().getMessageId();
  2. addFileToTar(tarFile, appendFile, this.preserveFolderStructure ? entryName : null);
  3. GenericFile<File> genericFile =
  4. String entryName = useFilenameHeader ? newExchange.getIn().getHeader(Exchange.FILE_NAME, String.class) : newExchange.getIn().getMessageId();
  5. addEntryToTar(tarFile, entryName, buffer, buffer.length);
  6. GenericFile<File> genericFile = FileConsumer.asGenericFile(

代码示例来源：origin: org.apache.camel/camel-zipfile

  1. String entryName = preserveFolderStructure ? newExchange.getIn().getHeader(Exchange.FILE_NAME, String.class) : newExchange.getIn().getMessageId();
  2. addFileToZip(zipFile, appendFile, this.preserveFolderStructure ? entryName : null);
  3. GenericFile<File> genericFile = 
  4. String entryName = useFilenameHeader ? newExchange.getIn().getHeader(Exchange.FILE_NAME, String.class) : newExchange.getIn().getMessageId();
  5. addEntryToZip(zipFile, entryName, buffer, buffer.length);
  6. GenericFile<File> genericFile = FileConsumer.asGenericFile(

代码示例来源：origin: org.apache.camel/camel-tarfile

  1. if (filepath == null) {
  2.   filename = filepath = StringHelper.sanitize(exchange.getIn().getMessageId());
  3. } else {

代码示例来源：origin: com.bosch.bis.monitoring/bis-event-publisher-impl

  1. private RouteExecution beginRouteExecution(Route route, Exchange exchange) {
  2.   Date now = Date.from(Instant.now());
  3.   RouteExecution routeExchange = new RouteExecution();
  4.   routeExchange.setRouteBeginDate(now);
  5.   routeExchange.setRouteId(route.getId());
  6.   routeExchange.setExchangeId(exchange.getExchangeId());
  7.   routeExchange.setMessageId(exchange.getIn().getMessageId());
  8.   routeExchange.setFromEndpointUri(exchange.getFromEndpoint().getEndpointUri());
  9.   routeExchange.setFromEndpointId(getEndpointId(exchange.getFromEndpoint()));
  10.   routeExchange.setFromRouteId(exchange.getFromRouteId());
  11.   Date created = exchange.getProperty(Exchange.CREATED_TIMESTAMP, Date.class);
  12.   routeExchange.setExchangeCreatedDate(created.getTime());
  13.   return routeExchange;
  14. }

代码示例来源：origin: org.apache.camel/camel-spring-integration

  1. @Override
  2. public void copyFrom(org.apache.camel.Message that) {
  3.   if (that == this) {
  4.     // the same instance so do not need to copy
  5.     return;
  6.   }
  7.   if (that instanceof CamelContextAware) {
  8.     this.setCamelContext(((CamelContextAware) that).getCamelContext());
  9.   }
  10.   // cover over exchange if none has been assigned
  11.   if (getExchange() == null) {
  12.     setExchange(that.getExchange());
  13.   }
  14.   setMessageId(that.getMessageId());
  15.   setBody(that.getBody());
  16.   super.getHeaders().putAll(that.getHeaders());
  17.   if (that instanceof SpringIntegrationMessage) {
  18.     SpringIntegrationMessage orig = (SpringIntegrationMessage) that;
  19.     setMessage(orig.getMessage());
  20.   }
  21.   getAttachments().putAll(that.getAttachments());
  22. }

代码示例来源：origin: org.apache.camel/camel-jms

  1. setMessageId(that.getMessageId());

代码示例来源：origin: org.apache.camel/camel-mail

  1. public void copyFrom(org.apache.camel.Message that) {
  2.   // only do a deep copy if we need to (yes when that is not a mail message, or if the mapMailMessage is true)
  3.   boolean needCopy = !(that instanceof MailMessage) || (((MailMessage) that).mapMailMessage);
  4.   if (needCopy) {
  5.     super.copyFrom(that);
  6.   } else {
  7.     // no deep copy needed, but copy message id
  8.     setMessageId(that.getMessageId());
  9.     setFault(that.isFault());
  10.   }
  11.   if (that instanceof MailMessage) {
  12.     MailMessage mailMessage = (MailMessage) that;
  13.     this.originalMailMessage = mailMessage.originalMailMessage;
  14.     this.mailMessage = mailMessage.mailMessage;
  15.     this.mapMailMessage = mailMessage.mapMailMessage;
  16.   }
  17.   // cover over exchange if none has been assigned
  18.   if (getExchange() == null) {
  19.     setExchange(that.getExchange());
  20.   }
  21. }

代码示例来源：origin: com.bluelock/camel-spring-amqp

  1. @Override
  2.   public Message postProcessMessage(Message msg) throws AmqpException {
  3.     if(camelMessage == null || camelMessage.getHeaders() == null)
  4.       return msg;
  5.           
  6.     //Set headers
  7.     msg = SpringAMQPHeader.setBasicPropertiesFromHeaders(msg, camelMessage.getHeaders());
  8.     msg = SpringAMQPHeader.copyHeaders(msg, camelMessage.getHeaders());
  9.     
  10.     //Set the exchange pattern so we can re-set it upon receipt
  11.     if(camelMessage.getExchange() != null) {
  12.       String exchangePattern = camelMessage.getExchange().getPattern().name();
  13.       msg.getMessageProperties().setHeader(EXCHANGE_PATTERN, exchangePattern);
  14.     } else {
  15.       throw new IllegalStateException("No exchange was found for this message "+camelMessage.getMessageId());
  16.     }
  17.     
  18.     return msg;
  19.   }
  20. }

代码示例来源：origin: Bluelock/camel-spring-amqp

  1. @Override
  2.   public Message postProcessMessage(Message msg) throws AmqpException {
  3.     if(camelMessage == null || camelMessage.getHeaders() == null)
  4.       return msg;
  5.           
  6.     //Set headers
  7.     msg = SpringAMQPHeader.setBasicPropertiesFromHeaders(msg, camelMessage.getHeaders());
  8.     msg = SpringAMQPHeader.copyHeaders(msg, camelMessage.getHeaders());
  9.     
  10.     //Set the exchange pattern so we can re-set it upon receipt
  11.     if(camelMessage.getExchange() != null) {
  12.       String exchangePattern = camelMessage.getExchange().getPattern().name();
  13.       msg.getMessageProperties().setHeader(EXCHANGE_PATTERN, exchangePattern);
  14.     } else {
  15.       throw new IllegalStateException("No exchange was found for this message "+camelMessage.getMessageId());
  16.     }
  17.     
  18.     return msg;
  19.   }
  20. }

代码示例来源：origin: org.switchyard/switchyard-bus-camel

  1. @Override
  2. public void send(Message message) {
  3.   org.apache.camel.Message camelMsg = extract(message);
  4.   if (getPhase() == null) {
  5.     _exchange.setProperty(PHASE, ExchangePhase.IN);
  6.     _exchange.setIn(camelMsg);
  7.     getContext().setProperty(Exchange.MESSAGE_ID, camelMsg.getMessageId());
  8.     initInContentType();
  9.   } else {
  10.     _exchange.setProperty(PHASE, ExchangePhase.OUT);
  11.     String id = getContext().getPropertyValue(MESSAGE_ID);
  12.     _exchange.setIn(camelMsg);
  13.     getContext().setProperty(Exchange.RELATES_TO, id);
  14.     getContext().setProperty(Exchange.MESSAGE_ID, camelMsg.getMessageId());
  15.     initOutContentType();
  16.   }
  17.   sendInternal();
  18. }

代码示例来源：origin: jboss-switchyard/core

  1. @Override
  2. public void send(Message message) {
  3.   org.apache.camel.Message camelMsg = extract(message);
  4.   if (getPhase() == null) {
  5.     _exchange.setProperty(PHASE, ExchangePhase.IN);
  6.     _exchange.setIn(camelMsg);
  7.     getContext().setProperty(Exchange.MESSAGE_ID, camelMsg.getMessageId());
  8.     initInContentType();
  9.   } else {
  10.     _exchange.setProperty(PHASE, ExchangePhase.OUT);
  11.     String id = getContext().getPropertyValue(MESSAGE_ID);
  12.     _exchange.setIn(camelMsg);
  13.     getContext().setProperty(Exchange.RELATES_TO, id);
  14.     getContext().setProperty(Exchange.MESSAGE_ID, camelMsg.getMessageId());
  15.     initOutContentType();
  16.   }
  17.   sendInternal();
  18. }

代码示例来源：origin: org.switchyard/switchyard-bus-camel

  1. @Override
  2. public void sendFault(Message message) {
  3.   org.apache.camel.Message extract = extract(message);
  4.   _exchange.setProperty(PHASE, ExchangePhase.OUT);
  5.   String id = getContext().getPropertyValue(MESSAGE_ID);
  6.   _exchange.setIn(extract);
  7.   _exchange.setProperty(FAULT, true);
  8.   getContext().setProperty(Exchange.RELATES_TO, id);
  9.   getContext().setProperty(Exchange.MESSAGE_ID, extract.getMessageId());
  10.   org.switchyard.Property rollbackOnFaultProperty = getContext().getProperty(org.switchyard.Exchange.ROLLBACK_ON_FAULT);
  11.   if (rollbackOnFaultProperty == null || rollbackOnFaultProperty.getValue() == null) {
  12.     getContext().setProperty(org.switchyard.Exchange.ROLLBACK_ON_FAULT, Boolean.FALSE, Scope.EXCHANGE);
  13.   }
  14.   
  15.   sendInternal();
  16. }

代码示例来源：origin: jboss-switchyard/core

  1. @Override
  2. public void sendFault(Message message) {
  3.   org.apache.camel.Message extract = extract(message);
  4.   _exchange.setProperty(PHASE, ExchangePhase.OUT);
  5.   String id = getContext().getPropertyValue(MESSAGE_ID);
  6.   _exchange.setIn(extract);
  7.   _exchange.setProperty(FAULT, true);
  8.   getContext().setProperty(Exchange.RELATES_TO, id);
  9.   getContext().setProperty(Exchange.MESSAGE_ID, extract.getMessageId());
  10.   org.switchyard.Property rollbackOnFaultProperty = getContext().getProperty(org.switchyard.Exchange.ROLLBACK_ON_FAULT);
  11.   if (rollbackOnFaultProperty == null || rollbackOnFaultProperty.getValue() == null) {
  12.     getContext().setProperty(org.switchyard.Exchange.ROLLBACK_ON_FAULT, Boolean.FALSE, Scope.EXCHANGE);
  13.   }
  14.   
  15.   sendInternal();
  16. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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