org.apache.activemq.artemis.utils.UUID.asBytes()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(5.8k)|赞(0)|评价(0)|浏览(110)

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

UUID.asBytes介绍

暂无

代码示例

代码示例来源:origin: wildfly/wildfly

public void encodeHeadersAndProperties(final ByteBuf buffer) {
 checkProperties();
 messageIDPosition = buffer.writerIndex();
 buffer.writeLong(messageID);
 SimpleString.writeNullableSimpleString(buffer, address);
 if (userID == null) {
   buffer.writeByte(DataConstants.NULL);
 } else {
   buffer.writeByte(DataConstants.NOT_NULL);
   buffer.writeBytes(userID.asBytes());
 }
 buffer.writeByte(type);
 buffer.writeBoolean(durable);
 buffer.writeLong(expiration);
 buffer.writeLong(timestamp);
 buffer.writeByte(priority);
 properties.encode(buffer);
}

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

public static final byte[] getDuplicateBytes(final UUID nodeUUID, final long messageID) {
 byte[] bytes = new byte[24];
 ByteBuffer bb = ByteBuffer.wrap(bytes);
 bb.put(nodeUUID.asBytes());
 bb.putLong(messageID);
 return bytes;
}

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

public void encodeHeadersAndProperties(final ByteBuf buffer) {
 final TypedProperties properties = getProperties();
 messageIDPosition = buffer.writerIndex();
 buffer.writeLong(messageID);
 SimpleString.writeNullableSimpleString(buffer, address);
 if (userID == null) {
   buffer.writeByte(DataConstants.NULL);
 } else {
   buffer.writeByte(DataConstants.NOT_NULL);
   buffer.writeBytes(userID.asBytes());
 }
 buffer.writeByte(type);
 buffer.writeBoolean(durable);
 buffer.writeLong(expiration);
 buffer.writeLong(timestamp);
 buffer.writeByte(priority);
 properties.encode(buffer);
}

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

public void encodeHeadersAndProperties(final ByteBuf buffer) {
 final TypedProperties properties = getProperties();
 messageIDPosition = buffer.writerIndex();
 buffer.writeLong(messageID);
 SimpleString.writeNullableSimpleString(buffer, address);
 if (userID == null) {
   buffer.writeByte(DataConstants.NULL);
 } else {
   buffer.writeByte(DataConstants.NOT_NULL);
   buffer.writeBytes(userID.asBytes());
 }
 buffer.writeByte(type);
 buffer.writeBoolean(durable);
 buffer.writeLong(expiration);
 buffer.writeLong(timestamp);
 buffer.writeByte(priority);
 properties.encode(buffer);
}

代码示例来源:origin: org.apache.activemq/artemis-jms-client-all

public void encodeHeadersAndProperties(final ByteBuf buffer) {
 checkProperties();
 messageIDPosition = buffer.writerIndex();
 buffer.writeLong(messageID);
 SimpleString.writeNullableSimpleString(buffer, address);
 if (userID == null) {
   buffer.writeByte(DataConstants.NULL);
 } else {
   buffer.writeByte(DataConstants.NOT_NULL);
   buffer.writeBytes(userID.asBytes());
 }
 buffer.writeByte(type);
 buffer.writeBoolean(durable);
 buffer.writeLong(expiration);
 buffer.writeLong(timestamp);
 buffer.writeByte(priority);
 properties.encode(buffer);
}

代码示例来源:origin: org.apache.activemq/artemis-core-client

public void encodeHeadersAndProperties(final ByteBuf buffer) {
 checkProperties();
 messageIDPosition = buffer.writerIndex();
 buffer.writeLong(messageID);
 SimpleString.writeNullableSimpleString(buffer, address);
 if (userID == null) {
   buffer.writeByte(DataConstants.NULL);
 } else {
   buffer.writeByte(DataConstants.NOT_NULL);
   buffer.writeBytes(userID.asBytes());
 }
 buffer.writeByte(type);
 buffer.writeBoolean(durable);
 buffer.writeLong(expiration);
 buffer.writeLong(timestamp);
 buffer.writeByte(priority);
 properties.encode(buffer);
}

代码示例来源:origin: org.jboss.eap/wildfly-client-all

public void encodeHeadersAndProperties(final ByteBuf buffer) {
 checkProperties();
 messageIDPosition = buffer.writerIndex();
 buffer.writeLong(messageID);
 SimpleString.writeNullableSimpleString(buffer, address);
 if (userID == null) {
   buffer.writeByte(DataConstants.NULL);
 } else {
   buffer.writeByte(DataConstants.NOT_NULL);
   buffer.writeBytes(userID.asBytes());
 }
 buffer.writeByte(type);
 buffer.writeBoolean(durable);
 buffer.writeLong(expiration);
 buffer.writeLong(timestamp);
 buffer.writeByte(priority);
 properties.encode(buffer);
}

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

protected final synchronized void createNodeId() throws IOException {
 synchronized (nodeIDGuard) {
   ByteBuffer id = ByteBuffer.allocateDirect(16);
   int read = channel.read(id, 3);
   if (replicatedBackup) {
    id.position(0);
    id.put(getUUID().asBytes(), 0, 16);
    id.position(0);
    channel.write(id, 3);
    channel.force(true);
   } else if (read != 16) {
    setUUID(UUIDGenerator.getInstance().generateUUID());
    id.put(getUUID().asBytes(), 0, 16);
    id.position(0);
    channel.write(id, 3);
    channel.force(true);
   } else {
    byte[] bytes = new byte[16];
    id.position(0);
    id.get(bytes);
    setUUID(new UUID(UUID.TYPE_TIME_BASED, bytes));
   }
 }
}

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

@Test
public void testId() throws Exception {
 NodeManager nodeManager = new FileLockNodeManager(new File(getTemporaryDir()), false);
 nodeManager.start();
 UUID id1 = nodeManager.getUUID();
 nodeManager.stop();
 nodeManager.start();
 ActiveMQTestBase.assertEqualsByteArrays(id1.asBytes(), nodeManager.getUUID().asBytes());
 nodeManager.stop();
}

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

public void encodeHeadersAndProperties(final ByteBuf buffer) {
 final TypedProperties properties = getProperties();
 messageIDPosition = buffer.writerIndex();
 buffer.writeLong(messageID);
 SimpleString.writeNullableSimpleString(buffer, address);
 if (userID == null) {
   buffer.writeByte(DataConstants.NULL);
 } else {
   buffer.writeByte(DataConstants.NOT_NULL);
   buffer.writeBytes(userID.asBytes());
 }
 buffer.writeByte(type);
 buffer.writeBoolean(durable);
 buffer.writeLong(expiration);
 buffer.writeLong(timestamp);
 buffer.writeByte(priority);
 properties.encode(buffer);
}

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

@Test
  public void testStringToUuidConversion() {
   UUIDGenerator gen = UUIDGenerator.getInstance();
   for (int i = 0; i < MANY_TIMES; i++) {
     final UUID uuid = gen.generateUUID();
     final String uuidString = uuid.toString();
     byte[] data2 = UUID.stringToBytes(uuidString);
     final UUID uuid2 = new UUID(UUID.TYPE_TIME_BASED, data2);
     assertEqualsByteArrays(uuid.asBytes(), data2);
     assertEquals(uuidString, uuid, uuid2);
     assertEquals(uuidString, uuidString, uuid2.toString());
   }
  }
}

相关文章