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

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

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

UUIDGenerator.generateStringUUID介绍

暂无

代码示例

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

/**
* Creates a TransportConfiguration providing the class name of the {@link org.apache.activemq.artemis.spi.core.remoting.ConnectorFactory}
* and any parameters needed.
*
* @param className The class name of the ConnectorFactory
* @param params    The parameters needed by the ConnectorFactory
*/
public TransportConfiguration(final String className, final Map<String, Object> params) {
 this(className, params, UUIDGenerator.getInstance().generateStringUUID());
}

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

/**
* Creates a TransportConfiguration providing the class name of the {@link org.apache.activemq.artemis.spi.core.remoting.ConnectorFactory}
*
* @param className The class name of the ConnectorFactory
*/
public TransportConfiguration(final String className) {
 this(className, new HashMap<String, Object>(), UUIDGenerator.getInstance().generateStringUUID());
}

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

public SimpleString generateSimpleStringUUID() {
 return new SimpleString(generateStringUUID());
}

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

this.nodeID = UUIDGenerator.getInstance().generateStringUUID();

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

this.name = UUIDGenerator.getInstance().generateStringUUID();

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

private ClientSession createSessionInternal(final String username,
                      final String password,
                      final boolean xa,
                      final boolean autoCommitSends,
                      final boolean autoCommitAcks,
                      final boolean preAcknowledge,
                      final int ackBatchSize) throws ActiveMQException {
 String name = UUIDGenerator.getInstance().generateStringUUID();
 SessionContext context = createSessionChannel(name, username, password, xa, autoCommitSends, autoCommitAcks, preAcknowledge);
 ClientSessionInternal session = new ClientSessionImpl(this, name, username, password, xa, autoCommitSends, autoCommitAcks, preAcknowledge, serverLocator.isBlockOnAcknowledge(), serverLocator.isAutoGroup(), ackBatchSize, serverLocator.getConsumerWindowSize(), serverLocator.getConsumerMaxRate(), serverLocator.getConfirmationWindowSize(), serverLocator.getProducerWindowSize(), serverLocator.getProducerMaxRate(), serverLocator.isBlockOnNonDurableSend(), serverLocator.isBlockOnDurableSend(), serverLocator.isCacheLargeMessagesClient(), serverLocator.getMinLargeMessageSize(), serverLocator.isCompressLargeMessage(), serverLocator.getInitialMessagePacketSize(), serverLocator.getGroupID(), context, orderedExecutorFactory.getExecutor(), orderedExecutorFactory.getExecutor(), orderedExecutorFactory.getExecutor());
 synchronized (sessions) {
   if (closed || !clientProtocolManager.isAlive()) {
    session.close();
    return null;
   }
   sessions.add(session);
 }
 return session;
}

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

/**
* Creates a TransportConfiguration providing the class name of the {@link org.apache.activemq.artemis.spi.core.remoting.ConnectorFactory}
* and any parameters needed.
*
* @param className The class name of the ConnectorFactory
* @param params    The parameters needed by the ConnectorFactory
*/
public TransportConfiguration(final String className, final Map<String, Object> params) {
 this(className, params, UUIDGenerator.getInstance().generateStringUUID());
}

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

/**
* Creates a TransportConfiguration providing the class name of the {@link org.apache.activemq.artemis.spi.core.remoting.ConnectorFactory}
*
* @param className The class name of the ConnectorFactory
*/
public TransportConfiguration(final String className) {
 this(className, new HashMap<String, Object>(), UUIDGenerator.getInstance().generateStringUUID());
}

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

/**
* Creates a TransportConfiguration providing the class name of the {@link org.apache.activemq.artemis.spi.core.remoting.ConnectorFactory}
* and any parameters needed.
*
* @param className The class name of the ConnectorFactory
* @param params    The parameters needed by the ConnectorFactory
*/
public TransportConfiguration(final String className, final Map<String, Object> params) {
 this(className, params, UUIDGenerator.getInstance().generateStringUUID());
}

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

/**
* Creates a TransportConfiguration providing the class name of the {@link org.apache.activemq.artemis.spi.core.remoting.ConnectorFactory}
*
* @param className The class name of the ConnectorFactory
*/
public TransportConfiguration(final String className) {
 this(className, new HashMap<String, Object>(), UUIDGenerator.getInstance().generateStringUUID());
}

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

/**
* Creates a TransportConfiguration providing the class name of the {@link org.apache.activemq.artemis.spi.core.remoting.ConnectorFactory}
* and any parameters needed.
*
* @param className The class name of the ConnectorFactory
* @param params    The parameters needed by the ConnectorFactory
*/
public TransportConfiguration(final String className, final Map<String, Object> params) {
 this(className, params, UUIDGenerator.getInstance().generateStringUUID());
}

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

/**
* @param routingName the routingName to set
*/
public DivertConfiguration setRoutingName(final String routingName) {
 if (routingName == null) {
   this.routingName = UUIDGenerator.getInstance().generateStringUUID();
 } else {
   this.routingName = routingName;
 }
 return this;
}

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

/**
* Creates a TransportConfiguration providing the class name of the {@link org.apache.activemq.artemis.spi.core.remoting.ConnectorFactory}
*
* @param className The class name of the ConnectorFactory
*/
public TransportConfiguration(final String className) {
 this(className, new HashMap<String, Object>(), UUIDGenerator.getInstance().generateStringUUID());
}

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

@Override
public synchronized SequentialFileFactory newFileFactory(final SimpleString address) throws Exception {
 String guid = UUIDGenerator.getInstance().generateStringUUID();
 SequentialFileFactory factory = newFileFactory(guid);
 factory.createDirs();
 File fileWithID = new File(directory, guid + File.separatorChar + PagingStoreFactoryNIO.ADDRESS_FILE);
 try (BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(fileWithID)))) {
   writer.write(address.toString());
   writer.newLine();
 }
 return factory;
}

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

public BroadcastGroupImpl(final NodeManager nodeManager,
             final String name,
             final long broadCastPeriod,
             final ScheduledExecutorService scheduledExecutor,
             final BroadcastEndpointFactory endpointFactory) throws Exception {
 this.nodeManager = nodeManager;
 this.name = name;
 this.scheduledExecutor = scheduledExecutor;
 this.broadCastPeriod = broadCastPeriod;
 this.endpoint = endpointFactory.createBroadcastEndpoint();
 uniqueID = UUIDGenerator.getInstance().generateStringUUID();
}

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

@Test
public void testManyUUIDs() throws Exception {
 Set<String> uuidsSet = new HashSet<>();
 UUIDGenerator gen = UUIDGenerator.getInstance();
 for (int i = 0; i < getTimes(); i++) {
   uuidsSet.add(gen.generateStringUUID());
 }
 // we put them in a set to check duplicates
 Assert.assertEquals(getTimes(), uuidsSet.size());
}

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

private Message createQueueInfoMessage(final NotificationType type, final SimpleString queueName) {
 Message message = new CoreMessage().initBuffer(50).setMessageID(storageManager.generateID());
 message.setAddress(queueName);
 String uid = UUIDGenerator.getInstance().generateStringUUID();
 message.putStringProperty(ManagementHelper.HDR_NOTIFICATION_TYPE, new SimpleString(type.toString()));
 message.putLongProperty(ManagementHelper.HDR_NOTIFICATION_TIMESTAMP, System.currentTimeMillis());
 message.putStringProperty(new SimpleString("foobar"), new SimpleString(uid));
 return message;
}

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

private StompSession internalGetSession(StompConnection connection, Map<Object, StompSession> sessions, Object id, boolean transacted) throws Exception {
 StompSession stompSession = sessions.get(id);
 if (stompSession == null) {
   stompSession = new StompSession(connection, this, server.getStorageManager().newContext(server.getExecutorFactory().getExecutor()));
   String name = UUIDGenerator.getInstance().generateStringUUID();
   ServerSession session = server.createSession(name, connection.getLogin(), connection.getPasscode(), ActiveMQClient.DEFAULT_MIN_LARGE_MESSAGE_SIZE, connection, !transacted, false, false, false, null, stompSession, true, server.newOperationContext(), getPrefixes());
   stompSession.setServerSession(session);
   sessions.put(id, stompSession);
 }
 server.getStorageManager().setContext(stompSession.getContext());
 return stompSession;
}

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

protected final ServerLocator createInVMLocator(final int serverID) {
 TransportConfiguration tnspConfig = createInVMTransportConnectorConfig(serverID, UUIDGenerator.getInstance().generateStringUUID());
 ServerLocator locator = ActiveMQClient.createServerLocatorWithHA(tnspConfig);
 return addServerLocator(locator);
}

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

void prepare() throws Exception {
  session = sf.createSession(true, true, 0);
  queueName = UUIDGenerator.getInstance().generateStringUUID();
  session.createQueue(dest, RoutingType.ANYCAST, queueName);
  consumer = session.createConsumer(queueName);
  consumer.setMessageHandler(this);
}

相关文章