org.apache.qpid.proton.amqp.Binary类的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(13.4k)|赞(0)|评价(0)|浏览(133)

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

Binary介绍

暂无

代码示例

代码示例来源：origin: org.eclipse.hono/hono-core

  1. /**
  2.  * Set the payload of the message using a {@link Data} section.
  3.  * <p>
  4.  * If the payload is {@code null}, then neither the payload, nor content type will be set.
  5.  * </p>
  6.  * 
  7.  * @param message The message to update.
  8.  * @param contentType An optional content type.
  9.  * @param payload The optional message payload.
  10.  * 
  11.  * @throws NullPointerException If the parameter {@code message} was {@code null}.
  12.  */
  13. public static void setPayload(final Message message, final String contentType, final byte[] payload) {
  14.   Objects.requireNonNull(message);
  15.   if (contentType != null) {
  16.     message.setContentType(contentType);
  17.   }
  18.   if (payload != null) {
  19.     message.setBody(new Data(new Binary(payload)));
  20.   }
  21. }

代码示例来源：origin: apache/qpid-jms

  1. @Override
  2. public byte[] getUserIdBytes() {
  3.   if(properties == null || properties.getUserId() == null) {
  4.     return null;
  5.   } else {
  6.     final Binary userId = properties.getUserId();
  7.     byte[] id = new byte[userId.getLength()];
  8.     System.arraycopy(userId.getArray(), userId.getArrayOffset(), id, 0, userId.getLength());
  9.     return id;
  10.   }
  11. }

代码示例来源：origin: Azure/azure-iot-sdk-java

  1. /**
  2.  * Returns the amqp body used in the message
  3.  * @return Byte array
  4.  */
  5. public byte[] getAmqpBody()
  6. {
  7.   Data msgData = (Data)this.messageImpl.getBody();
  8.   Binary binData = msgData.getValue();
  9.   byte[] msgBody = new byte[binData.getLength()];
  10.   ByteBuffer buffer = binData.asByteBuffer();
  11.   buffer.get(msgBody);
  12.   return msgBody;
  13. }

代码示例来源：origin: org.apache.qpid/proton-j

  1. BinaryElement(Element parent, Element prev, Binary b)
  2. {
  3.   super(parent, prev);
  4.   byte[] data = new byte[b.getLength()];
  5.   System.arraycopy(b.getArray(),b.getArrayOffset(),data,0,b.getLength());
  6.   _value = new Binary(data);
  7. }

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

  1. @Override
  2. public Object get(String key) {
  3.   Object value = messageBodyMap.get(key);
  4.   if (value instanceof Binary) {
  5.     // Copy to a byte[], ensure we copy only the required portion.
  6.     Binary bin = ((Binary) value);
  7.     value = Arrays.copyOfRange(bin.getArray(), bin.getArrayOffset(), bin.getLength());
  8.   }
  9.   return value;
  10. }

代码示例来源：origin: org.apache.activemq/activemq-all

  1. @SuppressWarnings("unchecked")
  2. protected void populateMessage(ActiveMQMessage jms, org.apache.qpid.proton.message.Message amqp) throws Exception {
  3.   Header header = amqp.getHeader();
  4.   if (header != null) {
  5.     jms.setBooleanProperty(JMS_AMQP_HEADER, true);
  6.   final ApplicationProperties ap = amqp.getApplicationProperties();
  7.   if (ap != null) {
  8.     for (Map.Entry<String, Object> entry : ((Map<String, Object>) ap.getValue()).entrySet()) {
  9.   if (properties != null) {
  10.     jms.setBooleanProperty(JMS_AMQP_PROPERTIES, true);
  11.     if (properties.getMessageId() != null) {
  12.       jms.setJMSMessageID(AMQPMessageIdHelper.INSTANCE.toBaseMessageIdString(properties.getMessageId()));
  13.     Binary userId = properties.getUserId();
  14.     if (userId != null) {
  15.       jms.setUserID(new String(userId.getArray(), userId.getArrayOffset(), userId.getLength(), StandardCharsets.UTF_8));
  16.     if (properties.getTo() != null) {
  17.     if (properties.getContentType() != null) {
  18.       jms.setStringProperty(JMS_AMQP_CONTENT_TYPE, properties.getContentType().toString());
  19.     if (properties.getContentEncoding() != null) {
  20.       jms.setStringProperty(JMS_AMQP_CONTENT_ENCODING, properties.getContentEncoding().toString());
  21.     if (properties.getCreationTime() != null) {

代码示例来源：origin: EnMasseProject/enmasse

  1. /**
  2.  * Return a raw AMQP message
  3.  *
  4.  * @return
  5.  */
  6. public Message toAmqp() {
  7.   Message message = ProtonHelper.message();
  8.   message.setMessageId(this.messageId);
  9.   Map<Symbol, Object> map = new HashMap<>();
  10.   map.put(Symbol.valueOf(AMQP_RETAIN_ANNOTATION), this.isRetain);
  11.   map.put(Symbol.valueOf(AMQP_QOS_ANNOTATION), this.qos.value());
  12.   MessageAnnotations messageAnnotations = new MessageAnnotations(map);
  13.   message.setMessageAnnotations(messageAnnotations);
  14.   message.setAddress(this.topic);
  15.   Header header = new Header();
  16.   header.setDurable(this.qos != MqttQoS.AT_MOST_ONCE);
  17.   message.setHeader(header);
  18.   message.setDeliveryCount(this.isDup ? 1 : 0);
  19.   // the payload could be null (or empty)
  20.   if (this.payload != null)
  21.     message.setBody(new Data(new Binary(this.payload.getBytes())));
  22.   return message;
  23. }

代码示例来源：origin: apache/activemq-artemis

  1. private static ServerJMSMessage processProperties(ServerJMSMessage jms, Properties properties) throws Exception {
  2.  if (properties != null) {
  3.    if (properties.getMessageId() != null) {
  4.     jms.setJMSMessageID(AMQPMessageIdHelper.INSTANCE.toMessageIdString(properties.getMessageId()));
  5.    Binary userId = properties.getUserId();
  6.    if (userId != null) {
  7.     jms.setStringProperty("JMSXUserID", new String(userId.getArray(), userId.getArrayOffset(), userId.getLength(), StandardCharsets.UTF_8));
  8.    if (properties.getTo() != null) {
  9.    if (properties.getContentType() != null) {
  10.     jms.setStringProperty(JMS_AMQP_CONTENT_TYPE, properties.getContentType().toString());
  11.    if (properties.getContentEncoding() != null) {
  12.     jms.setStringProperty(JMS_AMQP_CONTENT_ENCODING, properties.getContentEncoding().toString());
  13.    if (properties.getCreationTime() != null) {

代码示例来源：origin: apache/activemq-artemis

  1. final Properties properties = new Properties();
  2. Map<Symbol, Object> daMap = null;
  3. final Map<Symbol, Object> maMap = new HashMap<>();
  4.   properties.setSubject(type);
  5.    properties.setMessageId(AMQPMessageIdHelper.INSTANCE.toIdObject(messageId));
  6.   } catch (ActiveMQAMQPIllegalStateException e) {
  7.    properties.setMessageId(messageId);
  8.      String value = message.getStringProperty(key);
  9.      if (value != null) {
  10.       properties.setUserId(Binary.create(StandardCharsets.UTF_8.encode(value)));
  11.    objectProperty = new Binary((byte[]) objectProperty);
  12.    encoder.writeObject(new DeliveryAnnotations(daMap));
  13.   encoder.writeObject(new MessageAnnotations(maMap));
  14.   encoder.writeObject(properties);
  15.   if (apMap != null) {

代码示例来源：origin: EnMasseProject/enmasse

  1. MqttQoS qos = MqttQoS.AT_MOST_ONCE;
  2. String topic = message.getAddress();
  3. MessageAnnotations messageAnnotations = message.getMessageAnnotations();
  4. if (messageAnnotations == null) {
  5.   if (message.getHeader() != null) {
  6.     qos = ((message.getHeader().getDurable() == null) || !message.getHeader().getDurable())
  7.   if (messageAnnotations.getValue().containsKey(Symbol.valueOf(AMQ_ORIG_ADDRESS_ANNOTATION))) {
  8.     topic = (String) messageAnnotations.getValue().get(Symbol.valueOf(AMQ_ORIG_ADDRESS_ANNOTATION));
  9.   if (messageAnnotations.getValue().containsKey(Symbol.valueOf(AMQP_RETAIN_ANNOTATION))) {
  10.     isRetain = (boolean) messageAnnotations.getValue().get(Symbol.valueOf(AMQP_RETAIN_ANNOTATION));
  11. if ((section != null) && (section instanceof Data)) {
  12.   Buffer payload = Buffer.buffer(((Data) section).getValue().getArray());
  13.   return new AmqpPublishMessage(message.getMessageId(), qos, isDup, isRetain, topic, payload);

代码示例来源：origin: Azure/azure-service-bus-java

  1. amqpMessage.setBody(new AmqpValue(body.getValueData()));
  2.     amqpMessage.setBody(new AmqpSequence(Utils.getSequenceFromMessageBody(body)));
  3.     amqpMessage.setBody(new Data(new Binary(Utils.getDataFromMessageBody(body))));
  4. amqpMessage.setCorrelationId(brokeredMessage.getCorrelationId());
  5. amqpMessage.setSubject(brokeredMessage.getLabel());
  6. amqpMessage.getProperties().setTo(brokeredMessage.getTo());
  7. amqpMessage.setReplyTo(brokeredMessage.getReplyTo());
  8. amqpMessage.setReplyToGroupId(brokeredMessage.getReplyToSessionId());
  9. if(brokeredMessage.getScheduledEnqueueTimeUtc() != null)
  10.   messageAnnotationsMap.put(Symbol.valueOf(ClientConstants.SCHEDULEDENQUEUETIMENAME), Date.from(brokeredMessage.getScheduledEnqueueTimeUtc()));
  11.   messageAnnotationsMap.put(Symbol.valueOf(ClientConstants.PARTITIONKEYNAME), brokeredMessage.getPartitionKey());
  12.   messageAnnotationsMap.put(Symbol.valueOf(ClientConstants.VIAPARTITIONKEYNAME), brokeredMessage.getViaPartitionKey());
  13. amqpMessage.setMessageAnnotations(new MessageAnnotations(messageAnnotationsMap));

代码示例来源：origin: strimzi/strimzi-kafka-bridge

  1. message.setAddress(address);
  2.         message.setMessageId(entry.getValue());
  3.       } else if (entry.getKey().equals(AmqpJsonMessageConverter.TO)) {
  4.         message.setAddress(entry.getValue().toString());
  5.       } else if (entry.getKey().equals(AmqpJsonMessageConverter.SUBJECT)) {
  6.         message.setSubject(entry.getValue().toString());
  7. messageAnnotationsMap.put(Symbol.valueOf(AmqpBridge.AMQP_PARTITION_ANNOTATION), record.partition());
  8. messageAnnotationsMap.put(Symbol.valueOf(AmqpBridge.AMQP_OFFSET_ANNOTATION), record.offset());
  9. messageAnnotationsMap.put(Symbol.valueOf(AmqpBridge.AMQP_KEY_ANNOTATION), record.key());
  10. messageAnnotationsMap.put(Symbol.valueOf(AmqpBridge.AMQP_TOPIC_ANNOTATION), record.topic());
  11. MessageAnnotations messageAnnotations = new MessageAnnotations(messageAnnotationsMap);
  12. message.setMessageAnnotations(messageAnnotations);
  13.     message.setBody(new Data(new Binary(Base64.getDecoder().decode(value))));

代码示例来源：origin: EnMasseProject/enmasse

  1. if (!message.getSubject().equals(AMQP_SUBJECT)) {
  2.   throw new IllegalArgumentException(String.format("AMQP message subject is no %s", AMQP_SUBJECT));
  3. MessageAnnotations messageAnnotations = message.getMessageAnnotations();
  4. if (messageAnnotations == null) {
  5.   throw new IllegalArgumentException("AMQP message has no annotations");
  6.   if (messageAnnotations.getValue().containsKey(Symbol.valueOf(AMQP_RETAIN_ANNOTATION))) {
  7.     isRetain = (boolean) messageAnnotations.getValue().get(Symbol.valueOf(AMQP_RETAIN_ANNOTATION));
  8.   if (messageAnnotations.getValue().containsKey(Symbol.valueOf(AMQP_QOS_ANNOTATION))) {
  9.     int value = (int) messageAnnotations.getValue().get(Symbol.valueOf(AMQP_QOS_ANNOTATION));
  10.     qos = MqttQoS.valueOf(value);
  11.   } else {
  12.     if (message.getHeader() != null) {
  13.       qos = ((message.getHeader().getDurable() == null) || !message.getHeader().getDurable())
  14.   if ((section != null) && (section instanceof Data)) {
  15.     Buffer payload = Buffer.buffer(((Data) section).getValue().getArray());
  16.     return new AmqpWillMessage(isRetain, topic, qos, payload);

代码示例来源：origin: Azure/azure-iot-sdk-java

  1. if (d != null)
  2.   Binary b = d.getValue();
  3.   msgBody = new byte[b.getLength()];
  4.   ByteBuffer buffer = b.asByteBuffer();
  5.   buffer.get(msgBody);
  6. if (properties != null)
  7.   if (properties.getCorrelationId() != null)
  8.     iotHubTransportMessage.setCorrelationId(properties.getCorrelationId().toString());
  9.   if (properties.getMessageId() != null)
  10.     iotHubTransportMessage.setMessageId(properties.getMessageId().toString());
  11.   if (properties.getUserId() != null)
  12.     iotHubTransportMessage.setProperty(AMQPS_APP_PROPERTY_PREFIX + USER_ID_KEY, properties.getUserId().toString());
  13.   if (properties.getContentEncoding() != null)
  14.     iotHubTransportMessage.setContentEncoding(properties.getContentEncoding().toString());
  15.   if (properties.getContentType() != null)
  16.     iotHubTransportMessage.setContentType(properties.getContentType().toString());

代码示例来源：origin: strimzi/strimzi-kafka-bridge

  1. @Override
  2. public Message toMessage(String address, KafkaConsumerRecord<String, byte[]> record) {
  3.   
  4.   Message message = Proton.message();
  5.   message.setAddress(address);
  6.   
  7.   // put message annotations about partition, offset and key (if not null)
  8.   Map<Symbol, Object> map = new HashMap<>();
  9.   map.put(Symbol.valueOf(AmqpBridge.AMQP_PARTITION_ANNOTATION), record.partition());
  10.   map.put(Symbol.valueOf(AmqpBridge.AMQP_OFFSET_ANNOTATION), record.offset());
  11.   map.put(Symbol.valueOf(AmqpBridge.AMQP_KEY_ANNOTATION), record.key());
  12.   map.put(Symbol.valueOf(AmqpBridge.AMQP_TOPIC_ANNOTATION), record.topic());
  13.   
  14.   MessageAnnotations messageAnnotations = new MessageAnnotations(map);
  15.   message.setMessageAnnotations(messageAnnotations);
  16.   
  17.   message.setBody(new Data(new Binary(record.value())));
  18.   
  19.   return message;
  20. }

代码示例来源：origin: strimzi/strimzi-kafka-bridge

  1. String topic = (message.getAddress() == null) ?
  2.     kafkaTopic :
  3.     message.getAddress().replace('/', '.');
  4. Section body = message.getBody();
  5.     Binary binary = ((Data)body).getValue();
  6.     value = binary.getArray();
  7.   partition = messageAnnotations.getValue().get(Symbol.getSymbol(AmqpBridge.AMQP_PARTITION_ANNOTATION));
  8.   key = messageAnnotations.getValue().get(Symbol.getSymbol(AmqpBridge.AMQP_KEY_ANNOTATION));

代码示例来源：origin: org.apache.qpid/proton-hawtdispatch

  1. public Message createBinaryMessage(byte value[], int offset, int len) {
  2.     Message msg = Message.Factory.create();
  3.     Data body = new Data(new Binary(value, offset,len));
  4.     msg.setBody(body);
  5.     return msg;
  6.   }
  7. }

代码示例来源：origin: Azure/azure-service-bus-java

  1. messageEntry.put(ClientConstants.REQUEST_RESPONSE_MESSAGE, new Binary(encodedPair.getFirstItem(), 0, encodedPair.getSecondItem()));
  2. messageEntry.put(ClientConstants.REQUEST_RESPONSE_MESSAGE_ID, message.getMessageId());
  3. String sessionId = message.getGroupId();
  4. if(!StringUtil.isNullOrEmpty(sessionId))
  5. Object partitionKey = message.getMessageAnnotations().getValue().get(Symbol.valueOf(ClientConstants.PARTITIONKEYNAME));
  6. if(partitionKey != null && !((String)partitionKey).isEmpty())
  7. Object viaPartitionKey = message.getMessageAnnotations().getValue().get(Symbol.valueOf(ClientConstants.VIAPARTITIONKEYNAME));
  8. if(viaPartitionKey != null && !((String)viaPartitionKey).isEmpty())

代码示例来源：origin: io.vertx/vertx-amqp-bridge

  1. @Test
  2. public void testJSON_to_AMQP_VerifyDataBody() {
  3.  String testContent = "myTestContent";
  4.  JsonObject jsonObject = new JsonObject();
  5.  jsonObject.put(AmqpConstants.BODY, testContent.getBytes(StandardCharsets.UTF_8));
  6.  jsonObject.put(AmqpConstants.BODY_TYPE, AmqpConstants.BODY_TYPE_DATA);
  7.  Message protonMsg = translator.convertToAmqpMessage(jsonObject);
  8.  assertNotNull("Expected converted msg", protonMsg);
  9.  Section body = protonMsg.getBody();
  10.  assertTrue("Unexpected body type", body instanceof Data);
  11.  assertNotNull("Unexpected body content", body);
  12.  assertEquals("Unexpected message body value", new Binary(testContent.getBytes(StandardCharsets.UTF_8)),
  13.    ((Data) body).getValue());
  14. }

代码示例来源：origin: org.apache.qpid/proton

  1. public void plain(String username, String password)
  2. {
  3.   client();
  4.   _chosenMechanism = Symbol.valueOf("PLAIN");
  5.   byte[] usernameBytes = username.getBytes();
  6.   byte[] passwordBytes = password.getBytes();
  7.   byte[] data = new byte[usernameBytes.length+passwordBytes.length+2];
  8.   System.arraycopy(usernameBytes, 0, data, 1, usernameBytes.length);
  9.   System.arraycopy(passwordBytes, 0, data, 2+usernameBytes.length, passwordBytes.length);
  10.   setChallengeResponse(new Binary(data));
  11. }

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

Binary

相关文章

    查看更多

    热门标签

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

    最新文章

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