本文整理了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
暂无
代码示例来源: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();
}
内容来源于网络,如有侵权,请联系作者删除!