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

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

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

UUIDGenerator.getInstance介绍

[英]Method used for accessing the singleton generator instance.
[中]用于访问singleton generator实例的方法。

代码示例

代码示例来源: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 ActiveMQConnection(final ConnectionFactoryOptions options,
             final String username,
             final String password,
             final int connectionType,
             final String clientID,
             final int dupsOKBatchSize,
             final int transactionBatchSize,
             final boolean cacheDestinations,
             final boolean enable1xPrefixes,
             final ClientSessionFactory sessionFactory) {
 this.options = options;
 this.username = username;
 this.password = password;
 this.connectionType = connectionType;
 this.clientID = clientID;
 this.sessionFactory = sessionFactory;
 uid = UUIDGenerator.getInstance().generateSimpleStringUUID();
 thisVersion = VersionLoader.getVersion();
 this.dupsOKBatchSize = dupsOKBatchSize;
 this.transactionBatchSize = transactionBatchSize;
 this.cacheDestinations = cacheDestinations;
 this.enable1xPrefixes = enable1xPrefixes;
 creationStack = new Exception();
}

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

public ClientProducerImpl(final ClientSessionInternal session,
             final SimpleString address,
             final TokenBucketLimiter rateLimiter,
             final boolean blockOnNonDurableSend,
             final boolean blockOnDurableSend,
             final boolean autoGroup,
             final SimpleString groupID,
             final int minLargeMessageSize,
             final SessionContext sessionContext) {
 this.sessionContext = sessionContext;
 this.session = session;
 this.address = address;
 this.rateLimiter = rateLimiter;
 this.blockOnNonDurableSend = blockOnNonDurableSend;
 this.blockOnDurableSend = blockOnDurableSend;
 if (autoGroup) {
   this.groupID = UUIDGenerator.getInstance().generateSimpleStringUUID();
 } else {
   this.groupID = groupID;
 }
 this.minLargeMessageSize = minLargeMessageSize;
 if (address != null) {
   producerCredits = session.getCredits(address, false);
 } else {
   producerCredits = null;
 }
}

代码示例来源: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: wildfly/wildfly

UUID uid = UUIDGenerator.getInstance().generateUUID();

代码示例来源: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

public InVMNodeManager(boolean replicatedBackup, File directory) {
 super(replicatedBackup, directory);
 liveLock = new Semaphore(1);
 backupLock = new Semaphore(1);
 setUUID(UUIDGenerator.getInstance().generateUUID());
}

代码示例来源: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

protected TransportConfiguration generateTC(String debug) {
 String className = "org.foo.bar." + debug + "|" + UUIDGenerator.getInstance().generateStringUUID() + "";
 String name = UUIDGenerator.getInstance().generateStringUUID();
 Map<String, Object> params = new HashMap<>();
 params.put(UUIDGenerator.getInstance().generateStringUUID(), 123);
 params.put(UUIDGenerator.getInstance().generateStringUUID(), UUIDGenerator.getInstance().generateStringUUID());
 params.put(UUIDGenerator.getInstance().generateStringUUID(), true);
 TransportConfiguration tc = new TransportConfiguration(className, params, name);
 return tc;
}

代码示例来源: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);
}

相关文章