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

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

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

Version.getIncrementingVersion介绍

暂无

代码示例

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

@Override
public int compare(Version version1, Version version2) {
 return version2.getIncrementingVersion() - version1.getIncrementingVersion();
}

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

protected Packet newCreateSessionPacket(Version clientVersion,
                    String name,
                    String username,
                    String password,
                    boolean xa,
                    boolean autoCommitSends,
                    boolean autoCommitAcks,
                    boolean preAcknowledge,
                    int minLargeMessageSize,
                    int confirmationWindowSize,
                    long sessionChannelID) {
 return new CreateSessionMessage(name, sessionChannelID, clientVersion.getIncrementingVersion(), username, password, minLargeMessageSize, xa, autoCommitSends, autoCommitAcks, preAcknowledge, confirmationWindowSize, null);
}

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

@Override
public void sendSubscribeTopology(final boolean isServer) {
 getChannel0().send(new SubscribeClusterTopologyUpdatesMessageV2(isServer, VersionLoader.getVersion().getIncrementingVersion()));
}

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

private final int versionID = VersionLoader.getVersion().getIncrementingVersion();

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

@Override
public int compare(Version version1, Version version2) {
 return version2.getIncrementingVersion() - version1.getIncrementingVersion();
}

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

@Override
public int compare(Version version1, Version version2) {
 return version2.getIncrementingVersion() - version1.getIncrementingVersion();
}

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

@Override
public int compare(Version version1, Version version2) {
 return version2.getIncrementingVersion() - version1.getIncrementingVersion();
}

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

@Override
public int compare(Version version1, Version version2) {
 return version2.getIncrementingVersion() - version1.getIncrementingVersion();
}

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

protected Packet newCreateSessionPacket(Version clientVersion,
                    String name,
                    String username,
                    String password,
                    boolean xa,
                    boolean autoCommitSends,
                    boolean autoCommitAcks,
                    boolean preAcknowledge,
                    int minLargeMessageSize,
                    int confirmationWindowSize,
                    long sessionChannelID) {
 return new CreateSessionMessage(name, sessionChannelID, clientVersion.getIncrementingVersion(), username, password, minLargeMessageSize, xa, autoCommitSends, autoCommitAcks, preAcknowledge, confirmationWindowSize, null);
}

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

protected Packet newCreateSessionPacket(Version clientVersion,
                    String name,
                    String username,
                    String password,
                    boolean xa,
                    boolean autoCommitSends,
                    boolean autoCommitAcks,
                    boolean preAcknowledge,
                    int minLargeMessageSize,
                    int confirmationWindowSize,
                    long sessionChannelID) {
 return new CreateSessionMessage(name, sessionChannelID, clientVersion.getIncrementingVersion(), username, password, minLargeMessageSize, xa, autoCommitSends, autoCommitAcks, preAcknowledge, confirmationWindowSize, null);
}

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

protected Packet newCreateSessionPacket(Version clientVersion,
                    String name,
                    String username,
                    String password,
                    boolean xa,
                    boolean autoCommitSends,
                    boolean autoCommitAcks,
                    boolean preAcknowledge,
                    int minLargeMessageSize,
                    int confirmationWindowSize,
                    long sessionChannelID) {
 return new CreateSessionMessage(name, sessionChannelID, clientVersion.getIncrementingVersion(), username, password, minLargeMessageSize, xa, autoCommitSends, autoCommitAcks, preAcknowledge, confirmationWindowSize, null);
}

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

protected Packet newCreateSessionPacket(Version clientVersion,
                    String name,
                    String username,
                    String password,
                    boolean xa,
                    boolean autoCommitSends,
                    boolean autoCommitAcks,
                    boolean preAcknowledge,
                    int minLargeMessageSize,
                    int confirmationWindowSize,
                    long sessionChannelID) {
 return new CreateSessionMessage(name, sessionChannelID, clientVersion.getIncrementingVersion(), username, password, minLargeMessageSize, xa, autoCommitSends, autoCommitAcks, preAcknowledge, confirmationWindowSize, null);
}

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

protected Packet newCreateSessionPacket(Version clientVersion,
                    String name,
                    String username,
                    String password,
                    boolean xa,
                    boolean autoCommitSends,
                    boolean autoCommitAcks,
                    boolean preAcknowledge,
                    int minLargeMessageSize,
                    int confirmationWindowSize,
                    long sessionChannelID) {
 return new CreateSessionMessage(name, sessionChannelID, clientVersion.getIncrementingVersion(), username, password, minLargeMessageSize, xa, autoCommitSends, autoCommitAcks, preAcknowledge, confirmationWindowSize, null);
}

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

@Override
public void sendSubscribeTopology(final boolean isServer) {
 getChannel0().send(new SubscribeClusterTopologyUpdatesMessageV2(isServer, VersionLoader.getVersion().getIncrementingVersion()));
}

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

@Override
public void sendSubscribeTopology(final boolean isServer) {
 getChannel0().send(new SubscribeClusterTopologyUpdatesMessageV2(isServer, VersionLoader.getVersion().getIncrementingVersion()));
}

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

@Override
public void sendSubscribeTopology(final boolean isServer) {
 getChannel0().send(new SubscribeClusterTopologyUpdatesMessageV2(isServer, VersionLoader.getVersion().getIncrementingVersion()));
}

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

@Override
public void sendSubscribeTopology(final boolean isServer) {
 getChannel0().send(new SubscribeClusterTopologyUpdatesMessageV2(isServer, VersionLoader.getVersion().getIncrementingVersion()));
}

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

@Override
public void sendSubscribeTopology(final boolean isServer) {
 getChannel0().send(new SubscribeClusterTopologyUpdatesMessageV2(isServer, VersionLoader.getVersion().getIncrementingVersion()));
}

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

@Test
public void testLoadVersion() throws Exception {
 Version version = VersionLoader.getVersion();
 Properties props = new Properties();
 props.load(ClassLoader.getSystemResourceAsStream(VersionLoader.DEFAULT_PROP_FILE_NAME));
 Assert.assertEquals(props.get("activemq.version.versionName"), version.getVersionName());
 Assert.assertEquals(Integer.parseInt(props.getProperty("activemq.version.majorVersion")), version.getMajorVersion());
 Assert.assertEquals(Integer.parseInt(props.getProperty("activemq.version.minorVersion")), version.getMinorVersion());
 Assert.assertEquals(Integer.parseInt(props.getProperty("activemq.version.microVersion")), version.getMicroVersion());
 Assert.assertEquals(Integer.parseInt(new StringTokenizer(props.getProperty("activemq.version.incrementingVersion"), ",").nextToken()), version.getIncrementingVersion());
}

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

@Test
public void testGetVersion() throws Exception {
 cf = createSessionFactory(locator);
 ClientSession clientSession = cf.createSession(false, true, true);
 Assert.assertEquals(server.getVersion().getIncrementingVersion(), clientSession.getVersion());
 clientSession.close();
}

相关文章