org.apache.camel.Message类的使用及代码示例

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

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

Message介绍

暂无

代码示例

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

  1. /**
  2.  * A strategy method to populate an exchange with some example values for use
  3.  * by language plugins
  4.  */
  5. protected void populateExchange(Exchange exchange) {
  6.   Message in = exchange.getIn();
  7.   in.setHeader("foo", "abc");
  8.   in.setHeader("bar", 123);
  9.   in.setBody("<hello id='m123'>world!</hello>");
  10. }

代码示例来源：origin: deeplearning4j/nd4j

  1. @Override
  2.   public void process(Exchange exchange) throws Exception {
  3.     final INDArray arr = (INDArray) exchange.getIn().getBody();
  4.     ByteArrayOutputStream bos = new ByteArrayOutputStream();
  5.     DataOutputStream dos = new DataOutputStream(bos);
  6.     Nd4j.write(arr, dos);
  7.     byte[] bytes = bos.toByteArray();
  8.     String base64 = Base64.encodeBase64String(bytes);
  9.     exchange.getIn().setBody(base64, String.class);
  10.     String id = UUID.randomUUID().toString();
  11.     exchange.getIn().setHeader(KafkaConstants.KEY, id);
  12.     exchange.getIn().setHeader(KafkaConstants.PARTITION_KEY, id);
  13.   }
  14. }).to(kafkaUri);

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

  1. public static Object assertMessageHeader(Message message, String name, Object expected) {
  2.   Object value = message.getHeader(name);
  3.   assertEquals("Header: " + name + " on Message: " + message, expected, value);
  4.   return value;
  5. }

代码示例来源：origin: deeplearning4j/nd4j

  1. @Override
  2.   public void process(Exchange exchange) throws Exception {
  3.     byte[] body2 = (byte[]) exchange.getIn().getBody();
  4.     String body = new String(body2);
  5.     INDArray arr = Nd4jBase64.fromBase64(body);
  6.     exchange.getIn().setBody(arr);
  7.   }
  8. }).to("direct:receive");

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

  1. Session session = Session.getInstance(props, null);
  2. Message msg = new MimeMessage(session);
  3. msg.setFrom(new InternetAddress("mail@tovare.com"));;
  4. msg.setRecipients(Message.RecipientType.TO,
  5. InternetAddress.parse("tov.are.jacobsen@iss.no", false));
  6. msg.setSubject("Heisann "+System.currentTimeMillis());
  7. msg.setText("Med vennlig hilsennTov Are Jacobsen");
  8. msg.setHeader("X-Mailer", "Tov Are's program");
  9. msg.setSentDate(new Date());
  10. SMTPTransport t =
  11.   (SMTPTransport)session.getTransport("smtps");
  12. t.connect("smtp.gmail.com", "admin@tovare.com", "<insert password here>");
  13. t.sendMessage(msg, msg.getAllRecipients());
  14. System.out.println("Response: " + t.getLastServerResponse());
  15. t.close();

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

  1. private void restoreDroplet(Exchange exchange) throws Exception {
  2.   if (ObjectHelper.isEmpty(exchange.getIn().getHeader(DigitalOceanHeaders.IMAGE_ID))) {
  3.     throw new IllegalArgumentException(DigitalOceanHeaders.IMAGE_ID + " must be specified");
  4.   }
  5.   Action action = getEndpoint().getDigitalOceanClient().restoreDroplet(dropletId, exchange.getIn().getHeader(DigitalOceanHeaders.IMAGE_ID, Integer.class));
  6.   LOG.trace("DropletAction Restore [{}] ", action);
  7.   exchange.getOut().setBody(action);
  8. }

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

  1. protected void doGetHPA(Exchange exchange, String operation) throws Exception {
  2.   HorizontalPodAutoscaler hpa = null;
  3.   String podName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_HPA_NAME, String.class);
  4.   String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
  5.   if (ObjectHelper.isEmpty(podName)) {
  6.     LOG.error("Get a specific hpa require specify an hpa name");
  7.     throw new IllegalArgumentException("Get a specific hpa require specify an hpa name");
  8.   }
  9.   if (ObjectHelper.isEmpty(namespaceName)) {
  10.     LOG.error("Get a specific hpa require specify a namespace name");
  11.     throw new IllegalArgumentException("Get a specific hpa require specify a namespace name");
  12.   }
  13.   hpa = getEndpoint().getKubernetesClient().autoscaling().horizontalPodAutoscalers().inNamespace(namespaceName).withName(podName).get();
  14.   MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
  15.   exchange.getOut().setBody(hpa);
  16. }

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

  1. protected void doDeleteConfigMap(Exchange exchange, String operation) throws Exception {
  2.     String configMapName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_CONFIGMAP_NAME, String.class);
  3.     String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
  4.     if (ObjectHelper.isEmpty(configMapName)) {
  5.       LOG.error("Delete a specific config map require specify a config map name");
  6.       throw new IllegalArgumentException("Delete a specific config map require specify a config map name");
  7.     }
  8.     if (ObjectHelper.isEmpty(namespaceName)) {
  9.       LOG.error("Delete a specific config map require specify a namespace name");
  10.       throw new IllegalArgumentException("Delete a specific config map require specify a namespace name");
  11.     }
  12.     boolean cfMapDeleted = getEndpoint().getKubernetesClient().configMaps().inNamespace(namespaceName).withName(configMapName).delete();
  14.     MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
  15.     exchange.getOut().setBody(cfMapDeleted);
  16.   }
  17. }

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

  1. protected void doGetNamespace(Exchange exchange, String operation) {
  2.   String namespaceName = exchange.getIn().getHeader(
  3.       KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
  4.   if (ObjectHelper.isEmpty(namespaceName)) {
  5.     LOG.error("Get a specific namespace require specify a namespace name");
  6.     throw new IllegalArgumentException(
  7.         "Get a specific namespace require specify a namespace name");
  8.   }
  9.   Namespace namespace = getEndpoint().getKubernetesClient().namespaces()
  10.       .withName(namespaceName).get();
  11.   
  12.   MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
  13.   exchange.getOut().setBody(namespace);
  14. }

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

  1. protected void doDeleteDeployment(Exchange exchange, String operation) {
  2.   String deploymentName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_DEPLOYMENT_NAME, String.class);
  3.   String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
  4.   if (ObjectHelper.isEmpty(deploymentName)) {
  5.     LOG.error("Delete a specific deployment require specify a deployment name");
  6.     throw new IllegalArgumentException("Delete a specific deployment require specify a deployment name");
  7.   }
  8.   if (ObjectHelper.isEmpty(namespaceName)) {
  9.     LOG.error("Delete a specific deployment require specify a namespace name");
  10.     throw new IllegalArgumentException("Delete a specific deployment require specify a namespace name");
  11.   }
  12.   Boolean deployment = getEndpoint().getKubernetesClient().apps().deployments().inNamespace(namespaceName).withName(deploymentName).delete();
  13.   MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
  14.   exchange.getOut().setBody(deployment);
  15. }

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

  1. protected void doGetJob(Exchange exchange, String operation) throws Exception {
  2.   Job job = null;
  3.   String jobName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_JOB_NAME, String.class);
  4.   String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
  5.   if (ObjectHelper.isEmpty(jobName)) {
  6.     LOG.error("Get a specific job require specify a job name");
  7.     throw new IllegalArgumentException("Get a specific job require specify a job name");
  8.   }
  9.   if (ObjectHelper.isEmpty(namespaceName)) {
  10.     LOG.error("Get a specific job require specify a namespace name");
  11.     throw new IllegalArgumentException("Get a specific job require specify a namespace name");
  12.   }
  13.   job = getEndpoint().getKubernetesClient().batch().jobs().inNamespace(namespaceName).withName(jobName).get();
  14.   MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
  15.   exchange.getOut().setBody(job);
  16. }

代码示例来源：origin: redhat-developer-demos/istio-tutorial

  1. private void handleHttpFailure(Exchange exchange) {
  2.     HttpOperationFailedException e = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, HttpOperationFailedException.class);
  3.     exchange.getOut().setHeaders(exchange.getIn().getHeaders());
  4.     exchange.getOut().setBody(String.format(RESPONSE_STRING_FORMAT,
  5.         String.format("%d %s", e.getStatusCode(), e.getResponseBody())
  6.     ));
  7.   }
  8. }

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

  1. protected void doListConfigMapsByLabels(Exchange exchange, String operation) throws Exception {
  2.   ConfigMapList configMapsList = null;
  3.   Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_CONFIGMAPS_LABELS, Map.class);
  4.   FilterWatchListMultiDeletable<ConfigMap, ConfigMapList, Boolean, Watch, Watcher<ConfigMap>> configMaps = getEndpoint().getKubernetesClient().configMaps().inAnyNamespace();
  5.   for (Map.Entry<String, String> entry : labels.entrySet()) {
  6.     configMaps.withLabel(entry.getKey(), entry.getValue());
  7.   }
  8.   configMapsList = configMaps.list();
  9.   MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
  10.   exchange.getOut().setBody(configMapsList.getItems());
  11. }

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

  1. protected static boolean hasParameter(String nextParam, Exchange exchange, Object body) {
  2.   Map<?, ?> bodyMap = safeMap(exchange.getContext().getTypeConverter().tryConvertTo(Map.class, body));
  3.   Map<?, ?> headersMap = safeMap(exchange.getIn().getHeaders());
  4.   if ((nextParam.startsWith("$simple{") || nextParam.startsWith("${")) && nextParam.endsWith("}")) {
  5.     return true;
  6.   } else if (bodyMap.containsKey(nextParam)) {
  7.     return true;
  8.   } else if (headersMap.containsKey(nextParam)) {
  9.     return true;
  10.   }
  11.   return false;
  12. }

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

  1. private Object getMultiInsertBody(Exchange exchange) {
  2.   Object insert;
  3.   // we try List first, because it should be the common case
  4.   insert = exchange.getIn().getBody(List.class);
  5.   if (insert != null) {
  6.     // if the body of type List was obtained, ensure that all items are of type DBObject and cast the List to List<DBObject>
  7.     insert = attemptConvertToList((List<?>) insert, exchange);
  8.   } else {
  9.     insert = exchange.getContext().getTypeConverter().tryConvertTo(BasicDBList.class, exchange, exchange.getIn().getBody());
  10.   }
  11.   if (insert == null) {
  12.     throw new CamelMongoDbException("MongoDB operation = insert, Body is not conversible to type DBObject nor List<DBObject>");
  13.   }
  14.   return insert;
  15. }

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

  1. protected void doGetBuild(Exchange exchange, String operation) throws Exception {
  2.     Build build = null;
  3.     String buildName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_BUILD_NAME, String.class);
  4.     String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
  5.     if (ObjectHelper.isEmpty(buildName)) {
  6.       LOG.error("Get a specific Build require specify a Build name");
  7.       throw new IllegalArgumentException("Get a specific Build require specify a Build name");
  8.     }
  9.     if (ObjectHelper.isEmpty(namespaceName)) {
  10.       LOG.error("Get a specific Build require specify a namespace name");
  11.       throw new IllegalArgumentException("Get a specific Build require specify a namespace name");
  12.     }
  13.     build = getEndpoint().getKubernetesClient().adapt(OpenShiftClient.class).builds().inNamespace(namespaceName).withName(buildName).get();
  15.     MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
  16.     exchange.getOut().setBody(build);
  17.   }
  18. }

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

  1. protected void doGetNode(Exchange exchange, String operation) throws Exception {
  2.     Node node = null;
  3.     String pvName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NODE_NAME, String.class);
  4.     if (ObjectHelper.isEmpty(pvName)) {
  5.       LOG.error("Get a specific Node require specify a Node name");
  6.       throw new IllegalArgumentException("Get a specific Node require specify a Node name");
  7.     }
  8.     node = getEndpoint().getKubernetesClient().nodes().withName(pvName).get();
  10.     MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
  11.     exchange.getOut().setBody(node);
  12.   }
  13. }

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

  1. protected void doGetPersistentVolume(Exchange exchange, String operation)
  2.       throws Exception {
  3.     PersistentVolume pv = null;
  4.     String pvName = exchange.getIn().getHeader(
  5.         KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_NAME,
  6.         String.class);
  7.     if (ObjectHelper.isEmpty(pvName)) {
  8.       LOG.error("Get a specific Persistent Volume require specify a Persistent Volume name");
  9.       throw new IllegalArgumentException(
  10.           "Get a specific Persistent Volume require specify a Persistent Volume name");
  11.     }
  12.     pv = getEndpoint().getKubernetesClient().persistentVolumes().withName(pvName).get();
  13.     
  14.     MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
  15.     exchange.getOut().setBody(pv);
  16.   }
  17. }

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

  1. private void compare(long expected, Exchange exchange) {
  2.   long update = exchange.getIn().getBody(Long.class);
  3.   if (ObjectHelper.isEmpty(expected)) {
  4.     throw new IllegalArgumentException("Expected value must be specified");
  5.   }
  6.   exchange.getOut().setBody(this.atomicnumber.compareAndSet(expected, update));
  7. }

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

  1. protected void doList(Exchange exchange, String operation) throws Exception {
  2.   ServiceList servicesList = null;
  3.   String namespaceName = exchange.getIn().getHeader(
  4.       KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
  5.   if (!ObjectHelper.isEmpty(namespaceName)) {
  6.     servicesList = getEndpoint().getKubernetesClient().services()
  7.         .inNamespace(namespaceName).list();
  8.   } else {
  9.     servicesList = getEndpoint().getKubernetesClient().services().inAnyNamespace()
  10.         .list();
  11.   }
  12.   MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
  13.   exchange.getOut().setBody(servicesList.getItems());
  14. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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