org.apache.activemq.artemis.core.version.Version.getFullVersion()方法的使用及代码示例

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

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

Version.getFullVersion介绍

暂无

代码示例

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

@Override
public String getProviderVersion() throws JMSException {
 return serverVersion.getFullVersion();
}

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

@Override
public String getProviderVersion() throws JMSException {
 return serverVersion.getFullVersion();
}

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

@Override
public String getProviderVersion() throws JMSException {
 return serverVersion.getFullVersion();
}

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

@Override
public String getProviderVersion() throws JMSException {
 return serverVersion.getFullVersion();
}

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

@Override
public String getProviderVersion() throws JMSException {
 return serverVersion.getFullVersion();
}

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

@Override
public synchronized String getVersion() {
 checkInitialised();
 return server.getVersion().getFullVersion();
}

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

@Override
public String getVersion() {
 checkStarted();
 clearIO();
 try {
   return server.getVersion().getFullVersion();
 } finally {
   blockOnIO();
 }
}

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

/**
* Get the XAResource for the connection.
*
* @return The XAResource for the connection.
* @throws ResourceException XA transaction not supported
*/
@Override
public XAResource getXAResource() throws ResourceException {
 if (logger.isTraceEnabled()) {
   ActiveMQRALogger.LOGGER.trace("getXAResource()");
 }
 //
 // Spec says a mc must always return the same XA resource,
 // so we cache it.
 //
 if (xaResource == null) {
   ClientSessionInternal csi = (ClientSessionInternal) xaSession.getXAResource();
   ActiveMQRAXAResource activeMQRAXAResource = new ActiveMQRAXAResource(this, xaSession.getXAResource());
   Map<String, Object> xaResourceProperties = new HashMap<>();
   xaResourceProperties.put(ActiveMQXAResourceWrapper.ACTIVEMQ_JNDI_NAME, ra.getJndiName());
   xaResourceProperties.put(ActiveMQXAResourceWrapper.ACTIVEMQ_NODE_ID, csi.getNodeId());
   xaResourceProperties.put(ActiveMQXAResourceWrapper.ACTIVEMQ_PRODUCT_NAME, ActiveMQResourceAdapter.PRODUCT_NAME);
   xaResourceProperties.put(ActiveMQXAResourceWrapper.ACTIVEMQ_PRODUCT_VERSION, VersionLoader.getVersion().getFullVersion());
   xaResource = ServiceUtils.wrapXAResource(activeMQRAXAResource, xaResourceProperties);
 }
 if (logger.isTraceEnabled()) {
   ActiveMQRALogger.LOGGER.trace("XAResource=" + xaResource);
 }
 return xaResource;
}

代码示例来源：origin: org.jboss.eap/wildfly-messaging-activemq

private void handleReadAttribute(OperationContext context, ModelNode operation, final ActiveMQServer server) throws OperationFailedException {
  final String name = operation.require(ModelDescriptionConstants.NAME).asString();
  if (STARTED.getName().equals(name)) {
    boolean started = server != null ? server.isStarted() : false;
    context.getResult().set(started);
  } else if (VERSION.getName().equals(name)) {
    if (server != null) {
      String version = server.getVersion().getFullVersion();
      context.getResult().set(version);
    }
  } else if (ACTIVE.getName().equals(name)) {
    boolean active = server != null ? server.isActive() : false;
    context.getResult().set(active);
  } else {
    // Bug
    throw MessagingLogger.ROOT_LOGGER.unsupportedAttribute(name);
  }
}

代码示例来源：origin: org.wildfly/wildfly-messaging-activemq

private void handleReadAttribute(OperationContext context, ModelNode operation, final ActiveMQServer server) throws OperationFailedException {
  final String name = operation.require(ModelDescriptionConstants.NAME).asString();
  if (STARTED.getName().equals(name)) {
    boolean started = server != null ? server.isStarted() : false;
    context.getResult().set(started);
  } else if (VERSION.getName().equals(name)) {
    if (server != null) {
      String version = server.getVersion().getFullVersion();
      context.getResult().set(version);
    }
  } else if (ACTIVE.getName().equals(name)) {
    boolean active = server != null ? server.isActive() : false;
    context.getResult().set(active);
  } else {
    // Bug
    throw MessagingLogger.ROOT_LOGGER.unsupportedAttribute(name);
  }
}

代码示例来源：origin: org.jboss.activemq.artemis.integration/artemis-wildfly-integration

xaResourceProperties.put(org.apache.activemq.artemis.service.extensions.xa.ActiveMQXAResourceWrapper.ACTIVEMQ_NODE_ID, nodeID);
xaResourceProperties.put(org.apache.activemq.artemis.service.extensions.xa.ActiveMQXAResourceWrapper.ACTIVEMQ_PRODUCT_NAME, PRODUCT_NAME);
xaResourceProperties.put(org.apache.activemq.artemis.service.extensions.xa.ActiveMQXAResourceWrapper.ACTIVEMQ_PRODUCT_VERSION, VersionLoader.getVersion().getFullVersion());

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

/**
* Get the XAResource for the connection.
*
* @return The XAResource for the connection.
* @throws ResourceException XA transaction not supported
*/
@Override
public XAResource getXAResource() throws ResourceException {
 if (logger.isTraceEnabled()) {
   ActiveMQRALogger.LOGGER.trace("getXAResource()");
 }
 //
 // Spec says a mc must always return the same XA resource,
 // so we cache it.
 //
 if (xaResource == null) {
   ClientSessionInternal csi = (ClientSessionInternal) xaSession.getXAResource();
   ActiveMQRAXAResource activeMQRAXAResource = new ActiveMQRAXAResource(this, xaSession.getXAResource());
   Map<String, Object> xaResourceProperties = new HashMap<>();
   xaResourceProperties.put(ActiveMQXAResourceWrapper.ACTIVEMQ_JNDI_NAME, ra.getJndiName());
   xaResourceProperties.put(ActiveMQXAResourceWrapper.ACTIVEMQ_NODE_ID, csi.getNodeId());
   xaResourceProperties.put(ActiveMQXAResourceWrapper.ACTIVEMQ_PRODUCT_NAME, ActiveMQResourceAdapter.PRODUCT_NAME);
   xaResourceProperties.put(ActiveMQXAResourceWrapper.ACTIVEMQ_PRODUCT_VERSION, VersionLoader.getVersion().getFullVersion());
   xaResource = ServiceUtils.wrapXAResource(activeMQRAXAResource, xaResourceProperties);
 }
 if (logger.isTraceEnabled()) {
   ActiveMQRALogger.LOGGER.trace("XAResource=" + xaResource);
 }
 return xaResource;
}

代码示例来源：origin: org.apache.activemq/artemis-proton-plug

public AbstractConnectionContext(AMQPConnectionCallback connectionCallback,
                String containerId,
                int idleTimeout,
                int maxFrameSize,
                int channelMax,
                Executor dispatchExecutor,
                ScheduledExecutorService scheduledPool) {
 this.connectionCallback = connectionCallback;
 this.containerId = (containerId != null) ? containerId : UUID.randomUUID().toString();
 connectionProperties.put(Symbol.valueOf("product"), "apache-activemq-artemis");
 connectionProperties.put(Symbol.valueOf("version"), VersionLoader.getVersion().getFullVersion());
 this.scheduledPool = scheduledPool;
 connectionCallback.setConnection(this);
 this.handler =   ProtonHandler.Factory.create(dispatchExecutor);
 Transport transport = handler.getTransport();
 transport.setEmitFlowEventOnSend(false);
 if (idleTimeout > 0) {
   transport.setIdleTimeout(idleTimeout);
 }
 transport.setChannelMax(channelMax);
 transport.setMaxFrameSize(maxFrameSize);
 handler.addEventHandler(listener);
}

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

@Override
  public void inspectOpenedResource(Connection connection) {
   Map<Symbol, Object> properties = connection.getRemoteProperties();
   if (!properties.containsKey(PRODUCT)) {
     markAsInvalid("Broker did not send a queue product name value");
     return;
   }
   if (!properties.containsKey(VERSION)) {
     markAsInvalid("Broker did not send a queue version value");
     return;
   }
   if (!PRODUCT_NAME.equals(properties.get(PRODUCT))) {
     markAsInvalid("Broker did not send a the expected product name");
     return;
   }
   String brokerVersion = VersionLoader.getVersion().getFullVersion();
   if (!brokerVersion.equals(properties.get(VERSION))) {
     markAsInvalid("Broker did not send a the expected product version");
     return;
   }
  }
});

代码示例来源：origin: org.apache.activemq/artemis-amqp-protocol

this.connectionProperties.put(AmqpSupport.VERSION, VersionLoader.getVersion().getFullVersion());

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

this.connectionProperties.put(AmqpSupport.VERSION, VersionLoader.getVersion().getFullVersion());

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

activationThread.start();
} else {
 ActiveMQServerLogger.LOGGER.serverStarted(getVersion().getFullVersion(), configuration.getName(), nodeManager.getNodeId(), identity != null ? identity : "");

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

@Test
public void testOutgoingXAResourceWrapper() throws Exception {
 XAQueueConnection queueConnection = qraConnectionFactory.createXAQueueConnection();
 XASession s = queueConnection.createXASession();
 XAResource resource = s.getXAResource();
 assertTrue(resource instanceof ActiveMQXAResourceWrapper);
 ActiveMQXAResourceWrapperImpl xaResourceWrapper = (ActiveMQXAResourceWrapperImpl) resource;
 assertTrue(xaResourceWrapper.getJndiName().equals("java://jmsXA NodeId:" + server.getNodeID()));
 assertTrue(xaResourceWrapper.getProductVersion().equals(VersionLoader.getVersion().getFullVersion()));
 assertTrue(xaResourceWrapper.getProductName().equals(ActiveMQResourceAdapter.PRODUCT_NAME));
}

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

ActiveMQServerLogger.LOGGER.backupServerStarted(activeMQServer.getVersion().getFullVersion(), activeMQServer.getNodeManager().getNodeId());

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

ActiveMQServerControl serverControl = createManagementControl();
Assert.assertEquals(server.getVersion().getFullVersion(), serverControl.getVersion());

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

version

相关文章

    查看更多

    热门标签

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

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com